`

如何停止超时的DB查询

阅读更多

一.问题:有时我们执行的DB查询(例如一些查询的存储过程)会时间太长,当我们的代码逻辑上不想等待这么长时间时,怎么删除呢?

 

二.思考:首先想到使用"select connectionId()",然后通过"kill query id"语句来删除掉对应的DB进程.后来发现JdbcTemplate里面CallableStatement的cancel()可以关掉存储过程的调用.那么我们可以结合Timer来计时,当超过N分钟后,就执行cancel()即可.

 

三.代码:

1.定义一个task:(可以配合connectionId来做追踪,虽然逻辑上没有使用上)

public class CustomTimeTask extends TimerTask {
	private static final Logger logger = LoggerFactory.getLogger(CustomTimeTask.class);
	
	CallableStatement cs ;
	int id;
	
	public CustomTimeTask(CallableStatement cs, int id) {
		super();
		this.cs = cs;
		this.id = id;
	}

	@Override
	public void run() {
		try {
			logger.info("[Timeout]TimeTask try to cancel the long time procedure query. Connection ID is [{}]", id);
			cs.cancel();
		} catch (Exception e) {
			logger.error("[Timeout]TimeTask fail to cancel the long time procedure query. Please check the if the query has been stopped in database. "
					+ "The connection ID is [{}]", id);
		}
	}

}

 

2.执行:

logger.debug("-----------Start to call CSV store procedure------------");
		Connection conn = null;
		CallableStatement cs = null;
		ResultSet rs = null;
		
		Timer timer = null;
		boolean isQuery = false;
		
	......
		try{
			conn = jdbcTemplate.getDataSource().getConnection();
			cs = conn.prepareCall(foo);
			....
			
			isQuery = true;
			int queryTimeoutMins = SystemConfig.getQueryTimeout();
			if(queryTimeoutMins>0) {
				logger.debug("Execute the statemnet to call procedure  to connection ID [{}]. "
					+ "And start the timer to cancel the timeout query. Timeout setting [{} minutes]"
						,conID,queryTimeoutMins);
				CustomTimeTask customTimeTask = new CustomTimeTask(cs, conID);
				timer = new Timer();
				timer.schedule(customTimeTask, queryTimeoutMins * 60 * 1000);
			}else {
				logger.debug("Execute the statemnet to call procedure to gen CSV record to connection ID [{}]. "
						+ "But not start the timer to cancel the timeout query because timeout setting is [{} minutes]"
						,conID,queryTimeoutMins);
			}
			
			cs.execute();
			if(timer != null) {
				logger.debug("The query for connection ID [{}] is completed. "
					+ "Cancel the timer and begin to get the resultSet. ",conID);
				timer.cancel();
				timer.purge();
			}else {
				logger.debug("The query for connection ID [{}] is completed. Begin to get the resultSet.",conID);
			}
			isQuery = false;
			
			rs = cs.getResultSet();
			
			.........
			
			...........
			
			rs.close();
		}catch (DataAccessException e) {
			dbLogger.error("DB is down. Exception is [{}]", e.getMessage());
			try {
				if(isQuery && cs!=null && !cs.isClosed()) {
					logger.info("Program has begun the query. Try to cancel the procedure query for connection ID [{}]"
							, conID);
					cs.cancel();
				}
				
			} catch (MySQLStatementCancelledException e1) {
				logger.info("Successfully cancel the procedure query for connection ID [{}]"
						, conID);
				if(timer != null) {
					timer.cancel();
					timer.purge();
				}
				isQuery = false;
			} catch (Exception e1) {
				logger.error("-- Error occur when try to cancel the query for connection ID[{}]. "
						+ "Exception is [{}].",conID, e.getMessage());
			}
			throw e;
			
		} catch (MySQLStatementCancelledException e) {
			logger.info("Successfully cancel the procedure query for connection ID [{}]"
					, conID);
			if(timer != null) {
				timer.cancel();
				timer.purge();
			}
			isQuery = false;
			return null;
		}catch (Exception e) {
			logger.error("-- Error occur, exception is [{}]", e.getMessage());
			logger.error("DB: error:", e);
			try {
				if(isQuery && cs!=null && !cs.isClosed()) {
					logger.info("Program has begun the query. Try to cancel the procedure query for connection ID [{}]"
							, conID);
					cs.cancel();
				}
				
			} catch (MySQLStatementCancelledException e1) {
				logger.info("Successfully cancel the procedure query for connection ID [{}]"
						, conID);
				if(timer != null) {
					timer.cancel();
					timer.purge();
				}
				isQuery = false;
			} catch (Exception e1) {
				logger.error("-- Error occur when try to cancel the query for connection ID[{}]. "
						+ "Exception is [{}].",conID, e.getMessage());
			}
			
			return null;
		}finally {
			try {
				if (rs != null)
					rs.close();
				if (cs != null)
					cs.close();
				if (conn != null) {
					conn.close();
				}
			} catch (Exception e) {
				logger.error("Error occurs when close the connection to database. Error:", e);
				return null;
			}
			
		}
		logger.debug("-----------End to call store procedure------------");
		return resultMap;
	}

 

有几个地方值得注意,省略号的地方就正常cs执行存储过程的处理.但是对于timer要做判断:

1.如果查询结束了,那就没必要等待schedule了,要把timer取消掉

2.如果DB错误,判断是否在查询并且确定cs是否close,否则要调用cs.cancel()来结束

3.同时,注意cs.cancel()后,timer有没有结束

分享到:
评论

相关推荐

    DB2 9.5 中的锁定超时分析新方法

    通过这些信息,DBA可以清晰地了解到发生锁定超时的具体情况,进而采取相应的措施进行优化,比如调整锁超时值、修改应用逻辑、优化查询等。这样不仅可以减少锁定超时的发生,还能显著提升数据库的整体性能。

    db2数据库性能优化小技巧

    - **查询优化**:简化查询条件,减少不必要的JOIN操作,避免使用SELECT *等全字段查询方式。 - **统计信息更新**:定期更新统计信息,帮助数据库优化器做出更好的执行计划决策。 #### 三、锁管理优化 锁机制是...

    SQL数据库超时过期问题的解决方案

    症状:Microsoft OLE DB Provider for SQL Server 错误 '80040e31' ([ODBC SQL Server Driver]超时已过期);服务器上看 CPU、内存占用率很低;事件日志中提示:数据库 '*' 中文件 '*' 的自动增长在 453 毫秒后已取消...

    DB2常用命令集

    - **注意事项**: 如果实例中有未完成的事务或连接,`db2stop`会等待这些事务完成或超时后自动停止实例。 - **示例**: `db2stop` - **增强选项**: - **命令**: `db2stop force` - **描述**: 强制停止DB2实例,不会...

    BerkleyDB 内存数据库

    通过DatabaseEntry类表示键和值,使用Database.put()和Database.get()方法进行数据的插入和查询。此外,事务处理可以通过Transaction对象进行控制。 **使用示例:** ```java import com.sleepycat.db.*; public ...

    polardb-jdbc18.zip

    PolarDB-JDBC18支持动态配置数据库连接参数,如自动重连、超时设置等,适应各种复杂的网络环境。 2.4 安全性 通过SSL加密传输,保证了数据在传输过程中的安全性,防止数据被窃取或篡改。 三、使用PolarDB-JDBC18 ...

    jdbc连接db2

    5. **执行 SQL 查询**:创建 `Statement` 对象并通过其 `executeQuery()` 方法执行 SQL 查询。 6. **处理结果集**:遍历 `ResultSet` 对象来获取查询结果。 7. **关闭资源**:为避免资源泄露,必须在完成操作后关闭...

    DB2日常维护手册

    对特定查询进行索引建议。 2. **执行计划优化** - 使用`db2batch`收集执行信息:`#db2batch <bad_query.sql>` 通过批处理方式收集执行信息,帮助优化执行计划。 3. **统计信息收集及表维护** - 收集统计信息:`...

    DB2 SQL性能调优秘笈

    2. **锁等待超时配置**:适当配置锁等待超时时间,可以有效避免长时间的锁等待,减少死锁的可能性。 3. **手动锁定管理**:在某些情况下,通过手动控制锁定行为,可以更精细地控制并发访问,提高系统的整体吞吐量。 ...

    DB2解决表死锁

    3. **超时和重试**:为事务设置合理的超时时间,并在发生超时时,让事务自动回滚或重试操作。 4. **锁级别和类型**:根据业务需求,合理选择行级锁、页级锁或表级锁,以减少锁定资源的数量。 5. **监控与分析**:...

    db2jcc4的使用

    可以通过配置JDBC驱动参数(如批处理大小、超时时间等)进行性能调优。此外,对SQL查询进行优化,如使用索引、避免全表扫描等,也是提升性能的关键。 总之,db2jcc4是连接Java应用和DB2数据库的桥梁,理解和掌握其...

    DB2数据库SQL语句错误代码查询

    ### DB2数据库SQL语句错误代码查询:深入解析与应对策略 #### 引言 在进行数据库操作时,遇到SQL语句错误是常有的事,尤其是对于DB2这样的大型关系型数据库管理系统而言,其丰富的功能和复杂的架构可能导致各种...

    十大DB2优化技巧

    4. **锁超时设置**:默认的`LOCKTIMEOUT`值为-1,表示无锁超时,对于OLTP系统可能引发问题。建议设置一个较短的超时值(如15秒),以防止锁等待导致的阻塞。检查当前设置使用`db2 "get db cfg for DBNAME"`,如果`...

    DB2网上资源汇总

    "SQL0911N"错误通常表示一个事务因为死锁或超时而无法继续执行。死锁是指两个或多个事务互相等待对方释放资源,从而导致它们都无法继续的情况。理解DB2的锁类型(如共享锁、独占锁、意向锁等)以及如何避免和解决...

    db的 jar包 包括 db2jcc.jar、 db2jcc_license_cu.jar

    DB2数据库驱动是Java应用程序与IBM DB2数据库交互的关键组件,它使得开发者能够在Java环境中执行SQL语句,处理数据库查询和事务。标题提到的"db2jcc.jar"和"db2jcc_license_cu.jar"是IBM DB2 JDBC驱动程序的主要组成...

    DB2错误代码(DB2错误代码大全)

    10. SQLSTATE 58030:连接超时。当客户端与数据库之间的连接尝试超过预设的时间限制时,会出现此错误。 解决这些问题的关键在于准确解读错误代码和SQLSTATE,理解其背后的含义,然后针对性地检查代码、配置或数据。...

    db2 驱动包 jar

    总之,DB2驱动包JAR是Java应用与DB2数据库之间的桥梁,它提供了连接、查询和操作数据库的接口。正确配置和使用这个驱动包,对于构建高效、可靠的Java DB2应用至关重要。在实际开发中,开发者应了解其工作原理,并...

    DB2性能调整的10个技巧

    - **优化建议**:设置一个较小的锁超时时间,如10或15秒,并确保应用程序能够处理锁超时的情况。可以通过以下命令设置: ```sql db2 "update db cfg for DBNAME using LOCKTIMEOUT 15" ``` - **监控命令**: ``...

    db2死锁问题分析及解决方案

    - **68**: 由于锁定超时而导致事务已回滚。 ##### 2. 查找原因码 - **步骤**: 1. 检查错误信息以确定是否为死锁。 2. 若未获得原因码,可使用系统自带的死锁监视器进行确认。 3. 如果没有发生死锁,则可能是由...

    IBM DB2 jdbc 驱动 for v10.5(官方版)

    在实际应用中,为了确保最佳性能和稳定性,需要配置合适的连接参数,如最大连接数、超时设置等。此外,定期更新驱动到最新版本以获取安全更新和新特性也是十分重要的。 总结起来,IBM DB2 JDBC驱动v10.5是Java...

Global site tag (gtag.js) - Google Analytics