0

我在尝试从对 sqlserver 的 java 调用执行 sql 查询时遇到一个奇怪的问题。

对 java 函数的一次调用运行良好,但是当我在循环中执行相同操作(从 2 到 30 次迭代)时,有时(并非总是)会出现这样的错误:

引起:com.microsoft.sqlserver.jdbc.SQLServerException: Le délai Giveti à la requête a expiré。在 com.microsoft.sqlserver.jdbc.TDSCommand.checkForInterrupt(IOBuffer.java:5918)

我注意到的几件事:

  • 它总是在循环的同一步骤失败,只要迭代的项目保持不变(例如,如果它在 15 步中的第 7 步失败,它总是在第 7 步失败!)
  • 如果我跳过或更改任何迭代项目,包括先前失败的项目,它将在另一个步骤失败......并且它不会在下一步失败,但是 - 看起来像 - 随机一个
  • 如果我将失败的查询(来自调试)复制/粘贴到 SqlQueryBrowser 并执行它:它可以工作
  • 如果我从 Sql Server Profiler 复制/粘贴失败的查询:它可以工作!
  • 如果我从 sql server 查询浏览器中执行循环(迭代输入参数):它可以工作!
  • 如果我从 JUnit 测试中执行循环,只迭代参数:它也有效!
  • 从 Sql Server Profiler,我可以看到成功的请求需要 200 到 600 毫秒才能完成,而失败的请求恰好需要 15000 毫秒(= 当前配置的超时)
  • 当我更改超时时,查询会一直超时。

这是我尝试执行的操作,但没有成功:

  • 每个步骤/查询使用一个事务
  • 通过sp_serveroption更新服务器 'connect timeout' et 'query timeout' ( EXEC sp_serveroption 'myServer\SQLEXPRESS', 'connect timeout', 45; )
  • 从java更改queryTimeout
  • 从 Sql Query Browser {Server} >“properties”>“advanced”>“parallelism”更改“query wait”选项
  • 不要删除临时表 #MATCHINGDAYS
  • 将随机令牌添加到#MATCHINGDAYS 以防止并发冲突
  • 在查询周围添加 BEGIN / END
  • 使用WAITFOR DELAY t延迟请求
  • 使用存储过程而不是保存请求的字符串
  • 从“finally”语句中执行刷新 + 清除会话。
  • 重启SqlServer+tomcat
  • 将驱动程序更新到 mssql-jdbc 6.1.0.jre7
  • 使用实际表而不是临时表

java调用

它嵌入在单个事务中

final SessionImpl sess = (SessionImpl) this.getSessionFactory().openSession();
try (Connection conn = sess.connection(); Statement st = conn.createStatement();) {
    final NamedParameterPreparedStatement ps = NamedParameterPreparedStatement.createNamedParameterPreparedStatement(conn, aStringWithTheRequestBelow);
        // ... set parameters here ...
    ps.setQueryTimeout(15);
    final ResultSet rs = ps.executeQuery();
} catch (final SQLException ex) {
    LOG.error("parameter 1 :" + parameter1 + "etc.");
} finally {
    sess.close();
}

TSQL 查询

(我让它对大脑和眼睛友好,但它看起来有点棘手;但基本上,你有它的想法)

--DECLARE @date as DATE = '2017-09-03'; -- one of the input parameter set up from java.


IF OBJECT_ID('tempdb.dbo.#MATCHINGDAYS718567154','U') is not null 
DROP TABLE #MATCHINGDAYS718567154; -- RANDOM TOKEN HERE TO AVOID CONCURRENCY

WITH startDateTable AS ( 
    SELECT TOP 1 a.dateStart 
    FROM   someSelection
), 
endDateTable AS ( 
    SELECT TOP 1 endDate
    FROM   anotherSelection
), 
AllDays  AS ( 
    SELECT myFunc_getMaxDate(DATEADD(DAY,1,startDateTable.dateStart), DATEADD(dd, -30,@date))AS [Date] 
    FROM startDateTable 
    UNION ALL 
    SELECT    
    DATEADD(DAY, 1, [Date]) 
    from  AllDays 
    join endDateTable on 1=1 
     WHERE    [Date] < myFunc_getMinDate(DATEADD(dd, +7, @date),endDateTable.endDate)) 


-- build a temporary table with all days from startDate to endDate the recursive way
-- with a min -30 days before input date and 7 days after output date    
SELECT [Date] 
     INTO #MATCHINGDAYS718567154 
         FROM    AllDays 
     OPTION (MAXRECURSION 37) 

SELECT   
    manyFields

from MainTable
-- various joins
join #MATCHINGDAYS718567154 as MD on 1 = 1 
where 1 = 1
and -- etc... many clauses including some computed over MATCHINGDAYS718567154

order by someField

DROP TABLE #MATCHINGDAYS718567154 

其他一些信息

  • 爪哇 1.7_071
  • 休眠 4.3.4.Final
  • SqlServer Express 2014
  • 雄猫 7
  • sqljdbc4 4.0

编辑 28/11:原因

在我的循环中的某处,不时插入来自查询项的同一个表的对象。它在一个单独的事务中执行(尽管我也尝试在同一个事务中执行它)。插入对象时迭代不会出现问题,但是在接下来的迭代中......现在,我有原因......我仍然不明白为什么这会导致下一次迭代失败......虽然我怀疑一旦我理解它就会非常明显!

someIterationOver(List<SomeObject> manyObjects){
    from(SomeObject mo : manyObjects){
        List<MyTableObject> myTableObjects = performMyBigQueryOver(mo.getSomeId());
        for(MyTableObject myTableSingleObject : myTableObjects){
            if(myTableSingleObject.matchesSomeCondition()){
                TableSingleObject aNewTableSingleObject = new TableSingleObject("newTableObject");
                // this will cause the problem in the next iteration
                saveTableObject(aNewTableSingleObject);
            }
        }

    }
}

@Transactional(propagation = Propagation.REQUIRES_NEW)
private void saveTableObject(ableSingleObject aNewTableSingleObject){
    this.sessionFactory.getCurrentSession.save(aNewTableSingleObject); // works fine
}

...这里欢迎任何提示!

4

1 回答 1

0

最终,我设法让它工作:将“saveTableObject”方法从循环内移动到循环外就可以了......但是虽然我找到了解决方案,但我仍然不明白为什么以前的插入嵌入到它自己的专门的事务,导致这个锁被维护到下一次迭代和另一个事务中!......所以如果你有提示:他们仍然欢迎!

顺便说一句,这篇文章帮助我找出了哪个对象被锁定了!

@Jean:非常感谢您提出的许多问题,这些问题帮助我专注于核心事业!

于 2017-11-29T08:20:24.170 回答