升级新版本

yzg-util-base/src/main/java/com/yanzuoguang/util/helper/YzgTimeout.java

@@ -4,6 +4,8 @@ import com.yanzuoguang.util.log.Log;
 import com.yanzuoguang.util.thread.ThreadHelper;
 import com.yanzuoguang.util.vo.Ref;
 
+import java.util.function.Consumer;
+
 /**
  * 超时监控
  *
@@ -23,8 +25,20 @@ public class YzgTimeout {
      * @param runnable 运行函数
      */
     public static void timeOut(Class<?> cls, String message, Runnable runnable) {
+        timeOut(cls, message, runnable, null);
+    }
+
+    /**
+     * 超时监控
+     *
+     * @param cls      日志类
+     * @param message  消息
+     * @param runnable 运行函数
+     */
+    public static void timeOut(Class<?> cls, String message, Runnable runnable, Consumer<Long> consumer) {
         timeHeart(TIME_OUT_DEFAULT, TIME_OUT_UNIT, TIME_OUT_TIP, runnable, (time) -> {
             Log.error(cls, "%s超时,已经执行%d豪秒,正在等待执行完成", message, time);
+            consumer.accept(time);
         });
     }
 

yzg-util-db/src/main/java/com/yanzuoguang/db/impl/DbExecuteImpl.java

@@ -158,9 +158,10 @@ public class DbExecuteImpl implements DbExecute {
 
         boolean isError = false;
         try {
-            YzgTimeout.timeOut(sqlInfo.getTargetClass(), sqlInfo.getSqlName(), () ->
-                    sqlFunction.accept(row, start)
-            );
+            YzgTimeout.timeOut(sqlInfo.getTargetClass(), sqlInfo.getSqlName()
+                    , () -> sqlFunction.accept(row, start)
+                    // 打印超时的SQL语句
+                    , (time) -> printSql.print(sqlInfo, time, row.value));
         } catch (Exception ex) {
             isError = true;
             throw ex;