springboot mybatis-plus数据库超时设置

mybatis-plus全局控制

1. mybatis-plus:
2.   configuration:
3.     # 单个SQL执行超时时间(含insert,delete,select)，一般应用不宜过长，单位秒
4.     default-statement-timeout: 30

复制代码

• 超时非常
  

1. ### Cause: com.mysql.cj.jdbc.exceptions.MySQLTimeoutException: Statement cancelled due to timeout or client request
2. ; Statement cancelled due to timeout or client request; nested exception is com.mysql.cj.jdbc.exceptions.MySQLTimeoutException: Statement cancelled due to timeout or client request
3.         at org.springframework.jdbc.support.SQLExceptionSubclassTranslator.doTranslate(SQLExceptionSubclassTranslator.java:76)
4.         at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:72)
5.         at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:81)
6.         at org.mybatis.spring.MyBatisExceptionTranslator.translateExceptionIfPossible(MyBatisExceptionTranslator.java:91)
7.         at org.mybatis.spring.SqlSessionTemplate$SqlSessionInterceptor.invoke(SqlSessionTemplate.java:441)
8.         at com.sun.proxy.$Proxy133.selectList(Unknown Source)
9.         at org.mybatis.spring.SqlSessionTemplate.selectList(SqlSessionTemplate.java:224)

复制代码

mybatis单个SQL控制

• 写XML 写法，单元秒
  

2. <insert  
3.   id="insert"  
4.   parameterType="com.test.abc.Person"  
5.   ...
7.   timeout="30">
8. ...
9. </insert>

复制代码

• Mapper类写法，单元秒
  

1. @Mapper
2. public interface DemoMapper extends BaseMapper<Demo> {
4.     @Select("SELECT * FROM DEMO")
5.     @Options(timeout = 30) // 设置超时时间为 30 秒
6.     List<Demo> select();
7. }

复制代码

• 超时非常
  

1. 同上(略)

复制代码

spring事务超时控制

• 整个事务的超时时间，单元是秒。
  
• 它的原理大抵是事务启动时，事务上下文会计算一个到期时间deadLine（当前时间+超时时间），当mybatis -> prepareStatement时，会调用 SpringManagedTransaction 的getTimeOut，该方法会计算事务剩余时间timeToLiveInSeconds（deadLine-System.currentTimeMillis()），如果timeToLiveInSeconds小于0则报错TransactionTimedOutException，大于0根据情况设置为statement 的queryTimeOut （参照下文的源码分析）
  

情况1：事务剩余时间 timeToLiveInSeconds小于 statement 本身的 queryTimeOut，则 statement 的 setQueryTimeout 设置为 timeToLiveInSeconds
情况2: 事务剩余时间 timeToLiveInSeconds大于 statement 本身的 queryTimeOut，则 statement 的 setQueryTimeout 设置为 queryTimeOut

1. @Transactional(timeout = 15)
2. public int test(){
3.         demoMapper.select();
5.         demoMapper.insert(...);
6.        
7.         // 其他数据库操作
8. }

复制代码

根据它的原理及测试，大概会出现以下两种非常。

• 事务超时非常： TransactionTimedOutException
  

1. org.springframework.transaction.TransactionTimedOutException: Transaction timed out: deadline was Thu Dec 14 16:06:47 CST 2023
2.         at org.springframework.transaction.support.ResourceHolderSupport.checkTransactionTimeout(ResourceHolderSupport.java:155)
3.         at org.springframework.transaction.support.ResourceHolderSupport.getTimeToLiveInMillis(ResourceHolderSupport.java:144)
4.         at org.springframework.transaction.support.ResourceHolderSupport.getTimeToLiveInSeconds(ResourceHolderSupport.java:128)
5.         at org.mybatis.spring.transaction.SpringManagedTransaction.getTimeout(SpringManagedTransaction.java:125)
6.         at org.apache.ibatis.executor.SimpleExecutor.prepareStatement(SimpleExecutor.java:87)
7.         at org.apache.ibatis.executor.SimpleExecutor.doQuery(SimpleExecutor.java:62)

复制代码

• statement实行超时非常： MySQLTimeoutException
  

1. com.mysql.cj.jdbc.exceptions.MySQLTimeoutException: Statement cancelled due to timeout or client request
2.         at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:113)
3.         at com.mysql.cj.jdbc.ClientPreparedStatement.executeInternal(ClientPreparedStatement.java:955)
4.         at com.mysql.cj.jdbc.ClientPreparedStatement.execute(ClientPreparedStatement.java:372)
5.         at com.zaxxer.hikari.pool.ProxyPreparedStatement.execute(ProxyPreparedStatement.java:44)
6.         at com.zaxxer.hikari.pool.HikariProxyPreparedStatement.execute(HikariProxyPreparedStatement.java)
7.         at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
8.         at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
9.         at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
10.         at java.base/java.lang.reflect.Method.invoke(Method.java:566)
11.         at org.apache.ibatis.logging.jdbc.PreparedStatementLogger.invoke(PreparedStatementLogger.java:59)
12.         at com.sun.proxy.$Proxy197.execute(Unknown Source)
13.         at org.apache.ibatis.executor.statement.PreparedStatementHandler.query(PreparedStatementHandler.java:64)

复制代码

JDBC也可以设置socket超时时间

• 设置socketTimeout 单元毫秒，一般不推荐配这个
  

1. jdbc:mysql://localhost:3066/testdb?useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true&serverTimezone=Asia/Shanghai
2. &socketTimeout=60000

复制代码

总结

mybatis 实行SQL超时，底层也是用了 Jdbc 的 Statment 的 setQueryTimeout
mybatis设置超时源码（spring5.2.15+mybatis3.5.9）

BaseStatementHandler.java

1. public abstract class BaseStatementHandler implements StatementHandler {
2.   protected void setStatementTimeout(Statement stmt, Integer transactionTimeout) throws SQLException {
3.     Integer queryTimeout = null;
4.     if (mappedStatement.getTimeout() != null) {
5.       queryTimeout = mappedStatement.getTimeout();
6.     } else if (configuration.getDefaultStatementTimeout() != null) {
7.       queryTimeout = configuration.getDefaultStatementTimeout();
8.     }
9.     if (queryTimeout != null) {
10.       stmt.setQueryTimeout(queryTimeout);
11.     }
12.     StatementUtil.applyTransactionTimeout(stmt, queryTimeout, transactionTimeout);
13.   }

复制代码

StatementUtil.java

1. public class StatementUtil {
3.   private StatementUtil() {
4.     // NOP
5.   }
7.   /**
8.    * Apply a transaction timeout.
9.    * <p>
10.    * Update a query timeout to apply a transaction timeout.
11.    * </p>
12.    * @param statement a target statement
13.    * @param queryTimeout a query timeout
14.    * @param transactionTimeout a transaction timeout
15.    * @throws SQLException if a database access error occurs, this method is called on a closed <code>Statement</code>
16.    */
17.   public static void applyTransactionTimeout(Statement statement, Integer queryTimeout, Integer transactionTimeout) throws SQLException {
18.     if (transactionTimeout == null) {
19.       return;
20.     }
21.     // 事务剩余时间小于 statement自己的queryTimeout，就用事务的剩余时间，所以在事务里面statement的超时时间是动态的。
22.     if (queryTimeout == null || queryTimeout == 0 || transactionTimeout < queryTimeout) {
23.       statement.setQueryTimeout(transactionTimeout);
24.     }
25.   }
27. }

复制代码

jdbc 测试代码

2. try (Connection connection = dataSource.getConnection()) {
3.             // 创建 Statement 对象
4.             Statement statement = connection.createStatement();
6.             // 设置查询超时时间为 10 秒
7.             int timeoutInSeconds = 10;
8.             statement.setQueryTimeout(timeoutInSeconds);
10.             // 执行查询
11.             String sqlQuery = "SELECT sleep(12)";
12.             ResultSet resultSet = statement.executeQuery(sqlQuery);
14.             // 处理结果集
15.             while (resultSet.next()) {
16.                 // 处理每一行数据
17.             }
19.             resultSet.close();
20.             statement.close();
21.         } catch (SQLException e) {
22.             e.printStackTrace();
23.         }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。