[0.3.13] 版本修复

- `[R]` 修复上一版本中 SQLDebugHandler 的处理出现空指针异常。

.github/workflows/deploy.yml

@@ -40,7 +40,7 @@ jobs:
         run: |
           rm -rf docs
           mkdir -vp docs
-          cp -vrf easysql-api/target/apidocs/* docs/
+          cp -vrf api/target/apidocs/* docs/
           cp -vrf .documentation/JAVADOC-README.md docs/README.md
 
       - name: "Generate the Javadoc sitemap"

.github/workflows/maven.yml

@@ -6,6 +6,7 @@ name: Project Build & Tests
 on:
   # 支持手动触发构建
   workflow_dispatch:
+  pull_request:
   push:
 
 jobs:

.gitignore

@@ -1,4 +1,3 @@
 /.idea/
-/target/
-/*/target/
+**/target/
 **.iml

api/pom.xml

@@ -5,13 +5,13 @@
     <parent>
         <groupId>cc.carm.lib</groupId>
         <artifactId>easysql-parent</artifactId>
-        <version>0.3.8</version>
+        <version>0.3.13</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
     </properties>
@@ -52,6 +52,14 @@
         <url>https://github.com/CarmJos/EasySQL/actions/workflows/maven.yml</url>
     </ciManagement>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.36</version>
+        </dependency>
+    </dependencies>
+
     <build>
         <plugins>
             <plugin>

api/src/main/java/cc/carm/lib/easysql/api/SQLAction.java

@@ -3,14 +3,15 @@ package cc.carm.lib.easysql.api;
 import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import cc.carm.lib.easysql.api.function.SQLFunction;
 import cc.carm.lib.easysql.api.function.SQLHandler;
-import cc.carm.lib.easysql.api.function.defaults.DefaultSQLExceptionHandler;
 import org.jetbrains.annotations.Contract;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
 
 import java.sql.SQLException;
+import java.util.Collections;
+import java.util.List;
 import java.util.UUID;
-import java.util.logging.Logger;
 
 /**
  * SQLAction 是用于承载SQL语句并进行处理、返回的基本类。
@@ -61,6 +62,15 @@ public interface SQLAction<T> {
      */
     @NotNull String getSQLContent();
 
+    /**
+     * 得到该Action所要执行的源SQL语句列表。
+     *
+     * @return 源SQL语句列表
+     */
+    default @NotNull List<String> getSQLContents() {
+        return Collections.singletonList(getSQLContent());
+    }
+
     /**
      * 得到承载该Action的对应{@link SQLManager}
      *
@@ -189,13 +199,14 @@ public interface SQLAction<T> {
     }
 
     /**
-     * 默认的异常处理器
+     * 获取管理器提供的默认异常处理器。
+     * 若未使用过 {@link #setExceptionHandler(SQLExceptionHandler)} 方法，
+     * 则默认返回 {@link SQLExceptionHandler#detailed(Logger)} 。
      *
-     * @return {@link DefaultSQLExceptionHandler#get(Logger)}
-     * @see DefaultSQLExceptionHandler
+     * @return {@link SQLExceptionHandler}
      */
     default SQLExceptionHandler defaultExceptionHandler() {
-        return DefaultSQLExceptionHandler.get(getManager().getLogger());
+        return getManager().getExceptionHandler();
     }
 
     /**
@@ -206,7 +217,7 @@ public interface SQLAction<T> {
      * @param handler 异常处理器
      */
     default void setExceptionHandler(@Nullable SQLExceptionHandler handler) {
-        DefaultSQLExceptionHandler.setCustomHandler(handler);
+        getManager().setExceptionHandler(handler);
     }
 
 }

api/src/main/java/cc/carm/lib/easysql/api/SQLManager.java

@@ -5,8 +5,11 @@ import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.action.SQLUpdateAction;
 import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.builder.*;
+import cc.carm.lib.easysql.api.function.SQLDebugHandler;
+import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
 
 import javax.sql.DataSource;
 import java.sql.Connection;
@@ -15,7 +18,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.UUID;
 import java.util.function.Supplier;
-import java.util.logging.Logger;
 
 /**
  * SQLManager 是EasySQL的核心类，用于管理数据库连接，提供数据库操作的方法。
@@ -28,12 +30,38 @@ public interface SQLManager {
 
     boolean isDebugMode();
 
+    /**
+     * 设定是否启用调试模式。
+     * 启用调试模式后，会在每次执行SQL语句时，调用 {@link #getDebugHandler()} 来输出调试信息。
+     *
+     * @param debugMode 是否启用调试模式
+     */
     void setDebugMode(@NotNull Supplier<@NotNull Boolean> debugMode);
 
+    /**
+     * 设定是否启用调试模式。
+     * 启用调试模式后，会在每次执行SQL语句时，调用 {@link #getDebugHandler()} 来输出调试信息。
+     *
+     * @param enable 是否启用调试模式
+     */
     default void setDebugMode(boolean enable) {
         setDebugMode(() -> enable);
     }
 
+    /**
+     * 获取调试处理器，用于处理调试信息。
+     *
+     * @return {@link SQLDebugHandler}
+     */
+    @NotNull SQLDebugHandler getDebugHandler();
+
+    /**
+     * 设定调试处理器，默认为 {@link SQLDebugHandler#defaultHandler(Logger)} 。
+     *
+     * @param debugHandler {@link SQLDebugHandler}
+     */
+    void setDebugHandler(@NotNull SQLDebugHandler debugHandler);
+
     /**
      * 得到连接池源
      *
@@ -56,6 +84,24 @@ public interface SQLManager {
      */
     @NotNull Map<UUID, SQLQuery> getActiveQuery();
 
+    /**
+     * 获取改管理器提供的默认异常处理器。
+     * 若未使用过 {@link #setExceptionHandler(SQLExceptionHandler)} 方法，
+     * 则默认返回 {@link SQLExceptionHandler#detailed(Logger)} 。
+     *
+     * @return {@link SQLExceptionHandler}
+     */
+    @NotNull SQLExceptionHandler getExceptionHandler();
+
+    /**
+     * 设定通用的异常处理器。
+     * <br> 在使用 {@link SQLAction#execute(SQLExceptionHandler)} 等相关方法时，若传入的处理器为null，则会采用此处理器。
+     * <br> 若该方法传入参数为 null，则会使用 {@link SQLExceptionHandler#detailed(Logger)} 。
+     *
+     * @param handler 异常处理器
+     */
+    void setExceptionHandler(@Nullable SQLExceptionHandler handler);
+
     /**
      * 执行一条不需要返回结果的SQL语句(多用于UPDATE、REPLACE、DELETE方法)
      * 该方法使用 Statement 实现，请注意SQL注入风险！
@@ -64,7 +110,7 @@ public interface SQLManager {
      * @return 更新的行数
      * @see SQLUpdateAction
      */
-    @Nullable Integer executeSQL(String sql);
+    @Nullable Long executeSQL(String sql);
 
     /**
      * 执行一条不需要返回结果的预处理SQL更改(UPDATE、REPLACE、DELETE)
@@ -74,7 +120,7 @@ public interface SQLManager {
      * @return 更新的行数
      * @see PreparedSQLUpdateAction
      */
-    @Nullable Integer executeSQL(String sql, Object[] params);
+    @Nullable Long executeSQL(String sql, Object[] params);
 
     /**
      * 执行多条不需要返回结果的SQL更改(UPDATE、REPLACE、DELETE)
@@ -84,7 +130,7 @@ public interface SQLManager {
      * @return 对应参数返回的行数
      * @see PreparedSQLUpdateBatchAction
      */
-    @Nullable List<Integer> executeSQLBatch(String sql, Iterable<Object[]> paramsBatch);
+    @Nullable List<Long> executeSQLBatch(String sql, Iterable<Object[]> paramsBatch);
 
 
     /**

api/src/main/java/cc/carm/lib/easysql/api/SQLTable.java

@@ -0,0 +1,135 @@
+package cc.carm.lib.easysql.api;
+
+import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
+import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
+import cc.carm.lib.easysql.api.builder.*;
+import cc.carm.lib.easysql.api.function.SQLHandler;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+import java.sql.SQLException;
+
+/**
+ * SQLTable 基于 {@link TableCreateBuilder} 构建表，用于快速创建与该表相关的操作。
+ * <ul>
+ *  <li>1. 调用 {@link SQLTable#of(String, String[])} 方法创建一个 SQLTable 对象;</li>
+ *  <li>2. 在应用初始化阶段调用 {@link SQLTable#create(SQLManager)} 方法初始化 SQLTable 对象;</li>
+ *  <li>3. 获取已创建的{@link SQLTable} 实例，直接调用对应方法进行关于表的相关操作。</li>
+ * </ul>
+ *
+ * @author CarmJos
+ * @since 0.3.10
+ */
+public abstract class SQLTable {
+
+    public static @NotNull SQLTable of(@NotNull String tableName, @Nullable SQLHandler<TableCreateBuilder> table) {
+        return new SQLTable(tableName) {
+            @Override
+            public boolean create(SQLManager sqlManager) throws SQLException {
+                if (this.manager == null) this.manager = sqlManager;
+                TableCreateBuilder tableBuilder = sqlManager.createTable(getTableName());
+                if (table != null) table.accept(tableBuilder);
+                return tableBuilder.build().executeFunction(l -> l > 0, false);
+            }
+        };
+    }
+
+    public static @NotNull SQLTable of(@NotNull String tableName, @NotNull String[] columns) {
+        return of(tableName, columns, null);
+    }
+
+    public static @NotNull SQLTable of(@NotNull String tableName,
+                                       @NotNull String[] columns, @Nullable String tableSettings) {
+        return of(tableName, builder -> {
+            builder.setColumns(columns);
+            if (tableSettings != null) builder.setTableSettings(tableSettings);
+        });
+    }
+
+    private final @NotNull String tableName;
+
+    protected SQLManager manager;
+
+    /**
+     * 请调用 {@link SQLTable} 下的静态方法进行对象的初始化。
+     *
+     * @param tableName 该表的名称
+     */
+    private SQLTable(@NotNull String tableName) {
+        this.tableName = tableName;
+    }
+
+    public @NotNull String getTableName() {
+        return tableName;
+    }
+
+    /**
+     * 使用指定 SQLManager 进行本示例的初始化。
+     *
+     * @param sqlManager {@link SQLManager}
+     * @return 本表是否为首次创建
+     * @throws SQLException 出现任何错误时抛出
+     */
+    public abstract boolean create(SQLManager sqlManager) throws SQLException;
+
+    public @NotNull TableQueryBuilder createQuery(@NotNull SQLManager sqlManager) {
+        return sqlManager.createQuery().inTable(getTableName());
+    }
+
+    public @NotNull TableQueryBuilder createQuery() {
+        return createQuery(this.manager);
+    }
+
+    public @NotNull DeleteBuilder createDelete() {
+        return createDelete(this.manager);
+    }
+
+    public @NotNull DeleteBuilder createDelete(@NotNull SQLManager sqlManager) {
+        return sqlManager.createDelete(getTableName());
+    }
+
+    public @NotNull UpdateBuilder createUpdate() {
+        return createUpdate(this.manager);
+    }
+
+    public @NotNull UpdateBuilder createUpdate(@NotNull SQLManager sqlManager) {
+        return sqlManager.createUpdate(getTableName());
+    }
+
+
+    public @NotNull InsertBuilder<PreparedSQLUpdateAction> createInsert() {
+        return createInsert(this.manager);
+    }
+
+    public @NotNull InsertBuilder<PreparedSQLUpdateAction> createInsert(@NotNull SQLManager sqlManager) {
+        return sqlManager.createInsert(getTableName());
+    }
+
+
+    public @NotNull InsertBuilder<PreparedSQLUpdateBatchAction> createInsertBatch() {
+        return createInsertBatch(this.manager);
+    }
+
+    public @NotNull InsertBuilder<PreparedSQLUpdateBatchAction> createInsertBatch(@NotNull SQLManager sqlManager) {
+        return sqlManager.createInsertBatch(getTableName());
+    }
+
+
+    public @NotNull ReplaceBuilder<PreparedSQLUpdateAction> createReplace() {
+        return createReplace(this.manager);
+    }
+
+    public @NotNull ReplaceBuilder<PreparedSQLUpdateAction> createReplace(@NotNull SQLManager sqlManager) {
+        return sqlManager.createReplace(getTableName());
+    }
+
+
+    public @NotNull ReplaceBuilder<PreparedSQLUpdateBatchAction> createReplaceBatch() {
+        return createReplaceBatch(this.manager);
+    }
+
+    public @NotNull ReplaceBuilder<PreparedSQLUpdateBatchAction> createReplaceBatch(@NotNull SQLManager sqlManager) {
+        return sqlManager.createReplaceBatch(getTableName());
+    }
+
+}

api/src/main/java/cc/carm/lib/easysql/api/action/PreparedSQLUpdateBatchAction.java

@@ -4,7 +4,7 @@ import cc.carm.lib.easysql.api.SQLAction;
 
 import java.util.List;
 
-public interface PreparedSQLUpdateBatchAction extends SQLAction<List<Integer>> {
+public interface PreparedSQLUpdateBatchAction extends SQLAction<List<Long>> {
 
     /**
      * 设定多组SQL语句中所有 ? 对应的参数

api/src/main/java/cc/carm/lib/easysql/api/action/SQLUpdateAction.java

@@ -2,7 +2,7 @@ package cc.carm.lib.easysql.api.action;
 
 import cc.carm.lib.easysql.api.SQLAction;
 
-public interface SQLUpdateAction extends SQLAction<Integer> {
+public interface SQLUpdateAction extends SQLAction<Long> {
 
     /**
      * 设定自增主键的序列

api/src/main/java/cc/carm/lib/easysql/api/action/SQLUpdateBatchAction.java

@@ -21,6 +21,7 @@ public interface SQLUpdateBatchAction extends SQLAction<List<Integer>> {
         return getSQLContents().get(0);
     }
 
-    List<String> getSQLContents();
+    @Override
+    @NotNull List<String> getSQLContents();
 
 }

api/src/main/java/cc/carm/lib/easysql/api/action/query/QueryAction.java

@@ -39,8 +39,6 @@ public interface QueryAction extends SQLAction<SQLQuery> {
         try (SQLQuery value = execute()) {
             R result = function.apply(value);
             return result == null ? defaultResult : result;
-        } catch (SQLException exception) {
-            throw new SQLException(exception);
         }
     }
 

api/src/main/java/cc/carm/lib/easysql/api/builder/DeleteBuilder.java

@@ -2,7 +2,7 @@ package cc.carm.lib.easysql.api.builder;
 
 import cc.carm.lib.easysql.api.SQLAction;
 
-public interface DeleteBuilder extends ConditionalBuilder<DeleteBuilder, SQLAction<Integer>> {
+public interface DeleteBuilder extends ConditionalBuilder<DeleteBuilder, SQLAction<Long>> {
 
     String getTableName();
 

api/src/main/java/cc/carm/lib/easysql/api/builder/TableAlterBuilder.java

@@ -10,13 +10,13 @@ import org.jetbrains.annotations.Nullable;
 
 public interface TableAlterBuilder extends SQLBuilder {
 
-    SQLAction<Integer> renameTo(@NotNull String newTableName);
+    SQLAction<Long> renameTo(@NotNull String newTableName);
 
-    SQLAction<Integer> changeComment(@NotNull String newTableComment);
+    SQLAction<Long> changeComment(@NotNull String newTableComment);
 
-    SQLAction<Integer> setAutoIncrementIndex(int index);
+    SQLAction<Long> setAutoIncrementIndex(int index);
 
-    SQLAction<Integer> addIndex(@NotNull IndexType indexType, @Nullable String indexName,
+    SQLAction<Long> addIndex(@NotNull IndexType indexType, @Nullable String indexName,
                                 @NotNull String columnName, @NotNull String... moreColumns);
 
     /**
@@ -25,7 +25,7 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param indexName 索引名
      * @return {@link SQLUpdateAction}
      */
-    SQLAction<Integer> dropIndex(@NotNull String indexName);
+    SQLAction<Long> dropIndex(@NotNull String indexName);
 
     /**
      * 为该表移除一个外键
@@ -33,14 +33,14 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param keySymbol 外键名
      * @return {@link SQLUpdateAction}
      */
-    SQLAction<Integer> dropForeignKey(@NotNull String keySymbol);
+    SQLAction<Long> dropForeignKey(@NotNull String keySymbol);
 
     /**
      * 为该表移除主键(须添加新主键)
      *
      * @return {@link SQLUpdateAction}
      */
-    SQLAction<Integer> dropPrimaryKey();
+    SQLAction<Long> dropPrimaryKey();
 
     /**
      * 为表添加一列
@@ -49,7 +49,7 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param settings   列的相关设定
      * @return {@link SQLUpdateAction}
      */
-    default SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings) {
+    default SQLAction<Long> addColumn(@NotNull String columnName, @NotNull String settings) {
         return addColumn(columnName, settings, null);
     }
 
@@ -63,21 +63,21 @@ public interface TableAlterBuilder extends SQLBuilder {
      *                    <p> 若为 "" 则置于首行。
      * @return {@link SQLUpdateAction}
      */
-    SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn);
+    SQLAction<Long> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn);
 
-    SQLAction<Integer> renameColumn(@NotNull String columnName, @NotNull String newName);
+    SQLAction<Long> renameColumn(@NotNull String columnName, @NotNull String newName);
 
-    SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String settings);
+    SQLAction<Long> modifyColumn(@NotNull String columnName, @NotNull String settings);
 
-    default SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String columnSettings, @NotNull String afterColumn) {
+    default SQLAction<Long> modifyColumn(@NotNull String columnName, @NotNull String columnSettings, @NotNull String afterColumn) {
         return modifyColumn(columnName, columnSettings + " AFTER `" + afterColumn + "`");
     }
 
-    SQLAction<Integer> removeColumn(@NotNull String columnName);
+    SQLAction<Long> removeColumn(@NotNull String columnName);
 
-    SQLAction<Integer> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue);
+    SQLAction<Long> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue);
 
-    SQLAction<Integer> removeColumnDefault(@NotNull String columnName);
+    SQLAction<Long> removeColumnDefault(@NotNull String columnName);
 
     /**
      * 为该表添加一个自增列
@@ -90,7 +90,7 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param unsigned   是否采用 UNSIGNED (即无负数，可以增加自增键的最高数，建议为true)
      * @return {@link TableCreateBuilder}
      */
-    default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName, @Nullable NumberType numberType,
+    default SQLAction<Long> addAutoIncrementColumn(@NotNull String columnName, @Nullable NumberType numberType,
                                                       boolean primary, boolean unsigned) {
         return addColumn(columnName,
                 (numberType == null ? NumberType.INT : numberType).name()
@@ -109,7 +109,7 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param numberType 数字类型，若省缺则为 {@link NumberType#INT}
      * @return {@link TableAlterBuilder}
      */
-    default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName, @NotNull NumberType numberType) {
+    default SQLAction<Long> addAutoIncrementColumn(@NotNull String columnName, @NotNull NumberType numberType) {
         return addAutoIncrementColumn(columnName, numberType, false, true);
     }
 
@@ -122,7 +122,7 @@ public interface TableAlterBuilder extends SQLBuilder {
      * @param columnName 列名
      * @return {@link TableAlterBuilder}
      */
-    default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName) {
+    default SQLAction<Long> addAutoIncrementColumn(@NotNull String columnName) {
         return addAutoIncrementColumn(columnName, NumberType.INT);
     }
 

api/src/main/java/cc/carm/lib/easysql/api/builder/UpdateBuilder.java

@@ -6,7 +6,7 @@ import org.jetbrains.annotations.Nullable;
 
 import java.util.LinkedHashMap;
 
-public interface UpdateBuilder extends ConditionalBuilder<UpdateBuilder, SQLAction<Integer>> {
+public interface UpdateBuilder extends ConditionalBuilder<UpdateBuilder, SQLAction<Long>> {
 
     String getTableName();
 

api/src/main/java/cc/carm/lib/easysql/api/function/SQLDebugHandler.java

@@ -0,0 +1,87 @@
+package cc.carm.lib.easysql.api.function;
+
+import cc.carm.lib.easysql.api.SQLAction;
+import cc.carm.lib.easysql.api.SQLQuery;
+import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
+import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
+
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * 异常处理器。
+ * <br> 在使用 {@link SQLAction#execute(SQLExceptionHandler)} 等相关方法时，
+ * 如果发生异常，则会调用错误处理器进行错误内容的输出提示。
+ */
+
+public interface SQLDebugHandler {
+    /**
+     * 该方法将在 {@link SQLAction#execute()} 执行前调用。
+     *
+     * @param action {@link SQLAction} 对象
+     * @param params 执行传入的参数列表。
+     *               实际上，仅有 {@link PreparedSQLUpdateAction} 和 {@link PreparedSQLUpdateBatchAction} 才会有传入参数。
+     */
+    void beforeExecute(@NotNull SQLAction<?> action, @NotNull List<@Nullable Object[]> params);
+
+    /**
+     * 该方法将在 {@link SQLQuery#close()} 执行后调用。
+     *
+     * @param query       {@link SQLQuery} 对象
+     * @param executeTime 该次查询开始执行的时间
+     * @param closeTime   该次查询彻底关闭的时间
+     */
+    void afterQuery(@NotNull SQLQuery query, long executeTime, long closeTime);
+
+    @SuppressWarnings("DuplicatedCode")
+    static SQLDebugHandler defaultHandler(Logger logger) {
+        return new SQLDebugHandler() {
+            @Override
+            public void beforeExecute(@NotNull SQLAction<?> action, @NotNull List<@Nullable Object[]> params) {
+                logger.info("┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
+                logger.info("┣# ActionUUID: {}", action.getActionUUID());
+                logger.info("┣# ActionType: {}", action.getClass().getName());
+                if (action.getSQLContents().size() == 1) {
+                    logger.info("┣# SQLContent: {}", action.getSQLContents().get(0));
+                } else {
+                    logger.info("┣# SQLContents: ");
+                    int i = 0;
+                    for (String sqlContent : action.getSQLContents()) {
+                        logger.info("┃ [{}] {}", ++i, sqlContent);
+                    }
+                }
+                if (params.size() == 1) {
+                    Object[] param = params.get(0);
+                    if (param != null) {
+                        logger.info("┣# SQLParams({}): {}", param.length, Arrays.stream(param).map(Object::toString).reduce((a, b) -> a + ", " + b).orElse(""));
+                    }
+                } else if (params.size() > 1) {
+                    logger.info("┣# SQLParams: ");
+                    int i = 0;
+                    for (Object[] param : params) {
+                        if (param != null) {
+                            logger.info("┃ [{}] {}", ++i, Arrays.stream(param).map(Object::toString).reduce((a, b) -> a + ", " + b).orElse(""));
+                        } else {
+                            logger.info("┃ [{}] {}", ++i, "<#NULL>");
+                        }
+                    }
+                }
+                logger.info("┣# createTime: {}", action.getCreateTime());
+                logger.info("┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
+            }
+
+            @Override
+            public void afterQuery(@NotNull SQLQuery query, long executeTime, long closeTime) {
+                logger.info("┏━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
+                logger.info("┣# ActionUUID: {}", query.getAction().getActionUUID());
+                logger.info("┣# SQLContent: {}", query.getSQLContent());
+                logger.info("┣# executeCost: {} ms", (closeTime - executeTime));
+                logger.info("┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
+            }
+        };
+    }
+
+}

api/src/main/java/cc/carm/lib/easysql/api/function/SQLExceptionHandler.java

@@ -0,0 +1,46 @@
+package cc.carm.lib.easysql.api.function;
+
+import cc.carm.lib.easysql.api.SQLAction;
+import org.slf4j.Logger;
+
+import java.sql.SQLException;
+import java.util.function.BiConsumer;
+
+/**
+ * 异常处理器。
+ * <br> 在使用 {@link SQLAction#execute(SQLExceptionHandler)} 等相关方法时，
+ * 如果发生异常，则会调用错误处理器进行错误内容的输出提示。
+ */
+@FunctionalInterface
+public interface SQLExceptionHandler extends BiConsumer<SQLException, SQLAction<?>> {
+
+    /**
+     * 默认的异常处理器，将详细的输出相关错误与错误来源。
+     *
+     * @param logger 用于输出错误信息的Logger。
+     * @return 输出详细信息的错误处理器。
+     */
+    static SQLExceptionHandler detailed(Logger logger) {
+        return (exception, sqlAction) -> {
+            logger.error("Error occurred while executing SQL: ");
+            int i = 1;
+            for (String content : sqlAction.getSQLContents()) {
+                logger.error(String.format("#%d {%s}", i, content));
+                i++;
+            }
+            exception.printStackTrace();
+        };
+    }
+
+    /**
+     * “安静“ 的错误处理器，发生错误什么都不做。
+     * 强烈不建议把此处理器作为默认处理器使用！
+     *
+     * @return 无输出的处理器。
+     */
+    static SQLExceptionHandler silent() {
+        return (exception, sqlAction) -> {
+        };
+    }
+
+}

api/src/main/java/cc/carm/lib/easysql/api/util/UUIDUtil.java

@@ -0,0 +1,28 @@
+package cc.carm.lib.easysql.api.util;
+
+import java.util.UUID;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
+public class UUIDUtil {
+
+    private static final Pattern COMPILE = Pattern.compile("-", Pattern.LITERAL);
+
+    public static UUID random() {
+        return UUID.randomUUID();
+    }
+
+    public static String toString(UUID uuid, boolean withDash) {
+        if (withDash) return uuid.toString();
+        else return COMPILE.matcher(uuid.toString()).replaceAll(Matcher.quoteReplacement(""));
+    }
+
+    public static UUID toUUID(String s) {
+        if (s.length() == 36) {
+            return UUID.fromString(s);
+        } else {
+            return UUID.fromString(s.substring(0, 8) + '-' + s.substring(8, 12) + '-' + s.substring(12, 16) + '-' + s.substring(16, 20) + '-' + s.substring(20));
+        }
+    }
+
+}

easysql-api/src/main/java/cc/carm/lib/easysql/api/function/SQLExceptionHandler.java

@@ -1,12 +0,0 @@
-package cc.carm.lib.easysql.api.function;
-
-import cc.carm.lib.easysql.api.SQLAction;
-
-import java.sql.SQLException;
-import java.util.function.BiConsumer;
-
-@FunctionalInterface
-public interface SQLExceptionHandler extends BiConsumer<SQLException, SQLAction<?>> {
-
-
-}

easysql-api/src/main/java/cc/carm/lib/easysql/api/function/defaults/DefaultSQLExceptionHandler.java

@@ -1,56 +0,0 @@
-package cc.carm.lib.easysql.api.function.defaults;
-
-import cc.carm.lib.easysql.api.SQLAction;
-import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
-import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
-import org.jetbrains.annotations.NotNull;
-import org.jetbrains.annotations.Nullable;
-
-import java.sql.SQLException;
-import java.util.logging.Logger;
-
-public class DefaultSQLExceptionHandler implements SQLExceptionHandler {
-
-    private static @Nullable SQLExceptionHandler customDefaultHandler = null;
-    private final Logger logger;
-
-    public DefaultSQLExceptionHandler(Logger logger) {
-        this.logger = logger;
-    }
-
-    public static @Nullable SQLExceptionHandler getCustomHandler() {
-        return customDefaultHandler;
-    }
-
-    public static void setCustomHandler(@Nullable SQLExceptionHandler handler) {
-        DefaultSQLExceptionHandler.customDefaultHandler = handler;
-    }
-
-    public static @NotNull SQLExceptionHandler get(Logger logger) {
-        if (getCustomHandler() != null) return getCustomHandler();
-        else return new DefaultSQLExceptionHandler(logger);
-    }
-
-    protected Logger getLogger() {
-        return logger;
-    }
-
-    @Override
-    public void accept(SQLException exception, SQLAction<?> sqlAction) {
-        if (sqlAction instanceof SQLUpdateBatchAction) {
-
-            getLogger().severe("Error when execute SQLs : ");
-            int i = 1;
-            for (String content : ((SQLUpdateBatchAction) sqlAction).getSQLContents()) {
-                getLogger().severe(String.format("#%d {%s}", i, content));
-                i++;
-            }
-
-        } else {
-            getLogger().severe("Error when execute { " + sqlAction.getSQLContent() + " }");
-        }
-        exception.printStackTrace();
-    }
-
-
-}

easysql-api/src/main/java/cc/carm/lib/easysql/api/util/UUIDUtil.java

@@ -1,15 +0,0 @@
-package cc.carm.lib.easysql.api.util;
-
-import java.util.UUID;
-
-public class UUIDUtil {
-
-    public static UUID toUUID(String s) {
-        if (s.length() == 36) {
-            return UUID.fromString(s);
-        } else {
-            return UUID.fromString(s.substring(0, 8) + '-' + s.substring(8, 12) + '-' + s.substring(12, 16) + '-' + s.substring(16, 20) + '-' + s.substring(20));
-        }
-    }
-
-}

example/demo/pom.xml

@@ -5,18 +5,20 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.3.8</version>
+        <version>0.3.13</version>
         <relativePath>../../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
-    
+
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
         <maven.javadoc.skip>true</maven.javadoc.skip>
         <maven.deploy.skip>true</maven.deploy.skip>
+
+        <log4j.version>2.17.2</log4j.version>
     </properties>
 
     <artifactId>easysql-demo</artifactId>
@@ -64,6 +66,43 @@
             <scope>compile</scope>
         </dependency>
 
+        <dependency>
+            <!--项目地址 https://github.com/brettwooldridge/HikariCP/  -->
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>4.0.3</version>
+            <scope>test</scope>
+        </dependency>
+
+        <!-- https://mvnrepository.com/artifact/com.h2database/h2 -->
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <version>2.1.212</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-api</artifactId>
+            <version>${log4j.version}</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>${log4j.version}</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-slf4j-impl</artifactId>
+            <version>${log4j.version}</version>
+            <scope>compile</scope>
+        </dependency>
+
     </dependencies>
 
     <build>

example/demo/src/main/java/EasySQLDemo.java

@@ -1,5 +1,6 @@
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.SQLQuery;
+import cc.carm.lib.easysql.api.SQLTable;
 import cc.carm.lib.easysql.api.enums.ForeignKeyRule;
 import cc.carm.lib.easysql.api.enums.IndexType;
 import cc.carm.lib.easysql.api.enums.NumberType;
@@ -43,6 +44,33 @@ public class EasySQLDemo {
                 .build().execute(null /* 不处理错误 */);
     }
 
+    public void useSQLTable(SQLManager sqlManager) {
+        SQLTable tags = SQLTable.of("servers", table -> {
+            table.addAutoIncrementColumn("id", true);
+            table.addColumn("user", "INT UNSIGNED NOT NULL");
+            table.addColumn("content", "TEXT NOT NULL");
+            table.addColumn("time", "DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP");
+
+            table.addForeignKey(
+                    "user", "fk_user_tags",
+                    "users", "id",
+                    ForeignKeyRule.CASCADE, ForeignKeyRule.CASCADE
+            );
+
+        });
+
+        try {
+            tags.create(sqlManager);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+        tags.createQuery().addCondition("id", 5).build()
+                .executeAsync(success -> {
+                    System.out.println("success!");
+                });
+    }
+
     public void alertTable(SQLManager sqlManager) {
         // 同步更新表
         sqlManager.alterTable("users")
@@ -106,7 +134,7 @@ public class EasySQLDemo {
 
     public void sqlInsert(SQLManager sqlManager) {
         // 同步SQL插入 （不使用try-catch的情况下，返回的数值可能为空。）
-        Integer id = sqlManager.createInsert("users")
+        Long id = sqlManager.createInsert("users")
                 .setColumnNames("username", "phone", "email", "registerTime")
                 .setParams("CarmJos", "18888888888", "carm@carm.cc", TimeDateUtils.getCurrentTime())
                 .setReturnGeneratedKey(true)// 设定在后续返回自增主键
@@ -117,11 +145,10 @@ public class EasySQLDemo {
                 });
 
         try {
-            Integer userID = sqlManager.createInsert("users")
+            Long userID = sqlManager.createInsert("users")
                     .setColumnNames("username", "phone", "email", "registerTime")
                     .setParams("CarmJos", "18888888888", "carm@carm.cc", TimeDateUtils.getCurrentTime())
-                    .setReturnGeneratedKey(true)
-                    .execute();
+                    .returnGeneratedKey().execute();
 
             System.out.println("新用户的ID为 " + userID);
 

example/demo/src/test/java/cc/carm/lib/easysql/EasySQLTest.java

@@ -0,0 +1,76 @@
+package cc.carm.lib.easysql;
+
+import cc.carm.lib.easysql.api.SQLManager;
+import cc.carm.lib.easysql.manager.SQLManagerImpl;
+import cc.carm.lib.easysql.tests.*;
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import org.jetbrains.annotations.NotNull;
+import org.junit.Test;
+
+import java.util.LinkedHashSet;
+import java.util.Set;
+
+public class EasySQLTest {
+
+
+    @Test
+    public void onTest() {
+
+        HikariConfig config = new HikariConfig();
+        config.setDriverClassName("org.h2.Driver");
+        config.setJdbcUrl("jdbc:h2:mem:test;DB_CLOSE_DELAY=-1;MODE=MYSQL;");
+
+        SQLManager sqlManager = new SQLManagerImpl(new HikariDataSource(config), "test");
+        sqlManager.setDebugMode(true);
+
+        print("加载测试类...");
+        Set<TestHandler> tests = new LinkedHashSet<>();
+        tests.add(new TableCreateTest());
+//		tests.add(new TableAlterTest());
+//		tests.add(new TableRenameTest());
+//		tests.add(new QueryNotCloseTest());
+        tests.add(new QueryCloseTest());
+        tests.add(new SQLUpdateBatchTests());
+        tests.add(new SQLUpdateReturnKeysTest());
+        tests.add(new QueryFunctionTest());
+        tests.add(new DeleteTest());
+
+        print("准备进行测试...");
+
+        int index = 1;
+        int success = 0;
+
+        for (TestHandler currentTest : tests) {
+            print("-------------------------------------------------");
+            if (currentTest.executeTest(index, sqlManager)) {
+                success++;
+            }
+
+            index++;
+            try {
+                Thread.sleep(1000L);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+
+        }
+
+        print(" ");
+        print("全部测试执行完毕，成功 %s 个，失败 %s 个。",
+                success, (tests.size() - success)
+        );
+
+        if (sqlManager.getDataSource() instanceof HikariDataSource) {
+            //Close bee connection pool
+            ((HikariDataSource) sqlManager.getDataSource()).close();
+        }
+
+    }
+
+
+    public static void print(@NotNull String format, Object... params) {
+        System.out.printf((format) + "%n", params);
+    }
+
+}

example/demo/src/test/java/cc/carm/lib/easysql/TestHandler.java

@@ -1,4 +1,4 @@
-package cc.carm.lib.easysql.tester;
+package cc.carm.lib.easysql;
 
 import cc.carm.lib.easysql.api.SQLManager;
 import org.jetbrains.annotations.ApiStatus;
@@ -6,10 +6,10 @@ import org.jetbrains.annotations.NotNull;
 
 import java.sql.SQLException;
 
-public abstract class EasySQLTest {
+public abstract class TestHandler {
 
     protected static void print(@NotNull String format, Object... params) {
-        Main.print(format, params);
+        EasySQLTest.print(format, params);
     }
 
     @ApiStatus.OverrideOnly

example/demo/src/test/java/cc/carm/lib/easysql/tests/DeleteTest.java

@@ -0,0 +1,21 @@
+package cc.carm.lib.easysql.tests;
+
+import cc.carm.lib.easysql.TestHandler;
+import cc.carm.lib.easysql.api.SQLManager;
+
+import java.sql.SQLException;
+
+public class DeleteTest extends TestHandler {
+
+
+    @Override
+    public void onTest(SQLManager sqlManager) throws SQLException {
+
+
+        System.out.println("change(s): " + sqlManager.createDelete("test_user_table")
+                .addCondition("id", ">", 5)
+                .addNotNullCondition("username")
+                .build().execute());
+
+    }
+}

example/demo/src/test/java/cc/carm/lib/easysql/tests/QueryCloseTest.java

@@ -1,13 +1,13 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.SQLQuery;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
-public class QueryCloseTest extends EasySQLTest {
+public class QueryCloseTest extends TestHandler {
 
 
     @Override

example/demo/src/test/java/cc/carm/lib/easysql/tests/QueryFunctionTest.java

@@ -1,11 +1,11 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
+import cc.carm.lib.easysql.TestHandler;
 import cc.carm.lib.easysql.api.SQLManager;
-import cc.carm.lib.easysql.tester.EasySQLTest;
 
 import java.sql.SQLException;
 
-public class QueryFunctionTest extends EasySQLTest {
+public class QueryFunctionTest extends TestHandler {
 
 
     @Override

example/demo/src/test/java/cc/carm/lib/easysql/tests/QueryNotCloseTest.java

@@ -1,13 +1,13 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.SQLQuery;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
-public class QueryNotCloseTest extends EasySQLTest {
+public class QueryNotCloseTest extends TestHandler {
 
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {

example/demo/src/test/java/cc/carm/lib/easysql/tests/SQLUpdateBatchTests.java

@@ -1,7 +1,7 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.SQLException;
 import java.util.Arrays;
@@ -10,7 +10,7 @@ import java.util.UUID;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
-public class SQLUpdateBatchTests extends EasySQLTest {
+public class SQLUpdateBatchTests extends TestHandler {
 
 
     protected static List<Object[]> generateParams() {
@@ -25,7 +25,7 @@ public class SQLUpdateBatchTests extends EasySQLTest {
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {
 
-        List<Integer> updates = sqlManager.createInsertBatch("test_user_table")
+        List<Long> updates = sqlManager.createInsertBatch("test_user_table")
                 .setColumnNames("uuid", "username", "age")
                 .setAllParams(generateParams())
                 .execute();

example/demo/src/test/java/cc/carm/lib/easysql/tests/SQLUpdateReturnKeysTest.java

@@ -1,4 +1,4 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
 
@@ -11,7 +11,7 @@ public class SQLUpdateReturnKeysTest extends SQLUpdateBatchTests {
 
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {
-        List<Integer> generatedKeys = sqlManager.createInsertBatch("test_user_table")
+        List<Long> generatedKeys = sqlManager.createInsertBatch("test_user_table")
                 .setColumnNames("uuid", "username", "age")
                 .setAllParams(generateParams())
                 .returnGeneratedKeys()

example/demo/src/test/java/cc/carm/lib/easysql/tests/TableAlterTest.java

@@ -1,12 +1,12 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.enums.NumberType;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.SQLException;
 
-public class TableAlterTest extends EasySQLTest {
+public class TableAlterTest extends TestHandler {
 
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {

example/demo/src/test/java/cc/carm/lib/easysql/tests/TableCreateTest.java

@@ -1,13 +1,13 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.enums.ForeignKeyRule;
 import cc.carm.lib.easysql.api.enums.IndexType;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.SQLException;
 
-public class TableCreateTest extends EasySQLTest {
+public class TableCreateTest extends TestHandler {
 
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {
@@ -30,7 +30,6 @@ public class TableCreateTest extends EasySQLTest {
                         "test_user_table", "id",
                         ForeignKeyRule.CASCADE, ForeignKeyRule.CASCADE
                 )
-                .setIndex(IndexType.FULLTEXT_INDEX, "sign", "info")
                 .build().execute();
 
     }

example/demo/src/test/java/cc/carm/lib/easysql/tests/TableRenameTest.java

@@ -1,11 +1,11 @@
-package cc.carm.lib.easysql.tester.tests;
+package cc.carm.lib.easysql.tests;
 
 import cc.carm.lib.easysql.api.SQLManager;
-import cc.carm.lib.easysql.tester.EasySQLTest;
+import cc.carm.lib.easysql.TestHandler;
 
 import java.sql.SQLException;
 
-public class TableRenameTest extends EasySQLTest {
+public class TableRenameTest extends TestHandler {
     @Override
     public void onTest(SQLManager sqlManager) throws SQLException {
         print("	重命名 test_user_table");

example/easysql-tester/pom.xml

@@ -1,135 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <parent>
-        <artifactId>easysql-parent</artifactId>
-        <groupId>cc.carm.lib</groupId>
-        <version>0.3.8</version>
-        <relativePath>../../pom.xml</relativePath>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-
-    <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
-        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
-        <maven.javadoc.skip>true</maven.javadoc.skip>
-        <maven.deploy.skip>true</maven.deploy.skip>
-    </properties>
-
-    <artifactId>easysql-tester</artifactId>
-
-    <name>EasySQL-Test</name>
-    <description>EasySQL的测试代码</description>
-    <url>https://github.com/CarmJos/EasySQL</url>
-
-    <dependencies>
-        <dependency>
-            <groupId>${project.parent.groupId}</groupId>
-            <artifactId>easysql-beecp</artifactId>
-            <version>${project.version}</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
-        <dependency>
-            <groupId>mysql</groupId>
-            <artifactId>mysql-connector-java</artifactId>
-            <version>8.0.28</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.slf4j</groupId>
-            <artifactId>slf4j-api</artifactId>
-            <version>1.7.36</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-api</artifactId>
-            <version>2.17.1</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-core</artifactId>
-            <version>2.17.1</version>
-            <scope>compile</scope>
-        </dependency>
-
-        <dependency>
-            <groupId>org.apache.logging.log4j</groupId>
-            <artifactId>log4j-slf4j-impl</artifactId>
-            <version>2.17.1</version>
-            <scope>compile</scope>
-        </dependency>
-
-    </dependencies>
-
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-            </plugin>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-jar-plugin</artifactId>
-            </plugin>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-shade-plugin</artifactId>
-                <version>3.2.4</version>
-                <executions>
-                    <execution>
-                        <phase>package</phase>
-                        <goals>
-                            <goal>shade</goal>
-                        </goals>
-                    </execution>
-                </executions>
-                <configuration>
-                    <filters>
-                        <filter>
-                            <artifact>*:*</artifact>
-                            <excludes>
-                                <exclude>META-INF/MANIFEST.MF</exclude>
-                            </excludes>
-                        </filter>
-                    </filters>
-                    <!-- when downloading via Maven we can pull depends individually -->
-                    <shadedArtifactAttached>true</shadedArtifactAttached>
-                </configuration>
-            </plugin>
-
-            <plugin>
-                <artifactId>maven-assembly-plugin</artifactId>
-                <configuration>
-                    <descriptorRefs>
-                        <descriptRef>jar-with-dependencies</descriptRef>
-                    </descriptorRefs>
-                    <archive>
-                        <manifest>
-                            <mainClass>cc.carm.lib.easysql.tester.Main</mainClass>
-                        </manifest>
-                    </archive>
-                </configuration>
-                <executions>
-                    <execution>
-                        <id>make-assembly</id>
-                        <phase>package</phase>
-                        <goals>
-                            <goal>assembly</goal>
-                        </goals>
-                    </execution>
-                </executions>
-            </plugin>
-        </plugins>
-    </build>
-
-</project>

example/easysql-tester/src/main/java/cc/carm/lib/easysql/tester/Main.java

@@ -1,93 +0,0 @@
-package cc.carm.lib.easysql.tester;
-
-import cc.carm.lib.easysql.EasySQL;
-import cc.carm.lib.easysql.api.SQLManager;
-import cc.carm.lib.easysql.tester.tests.DeleteTest;
-import cc.carm.lib.easysql.tester.tests.QueryCloseTest;
-import cc.carm.lib.easysql.tester.tests.QueryFunctionTest;
-import cc.carm.lib.easysql.tester.tests.TableCreateTest;
-import org.jetbrains.annotations.NotNull;
-import org.jetbrains.annotations.TestOnly;
-
-import java.util.Iterator;
-import java.util.LinkedHashSet;
-import java.util.Scanner;
-import java.util.Set;
-
-@TestOnly
-@SuppressWarnings("all")
-public class Main {
-
-    public static void main(String[] args) {
-        if (args.length < 4) {
-            print("请提供以下参数：<数据库驱动> <数据库地址(JDBC)> <数据库用户> <数据库密码> [是否采用DEBUG(y/n)]");
-            return;
-        }
-
-        SQLManager sqlManager;
-        try {
-            print("初始化 SQLManager...");
-            print("数据库驱动 %s", args[0]);
-            print("数据库地址 %s", args[1]);
-            print("数据库用户 %s", args[2]);
-            print("数据库密码 %s", args[3]);
-            sqlManager = EasySQL.createManager(args[0], args[1], args[2], args[3]);
-            sqlManager.setDebugMode(args.length > 4);
-            print("SQLManager 初始化完成！");
-        } catch (Exception exception) {
-            print("SQLManager 初始化失败，请检查数据库配置。");
-            exception.printStackTrace();
-            return;
-        }
-
-        print("加载测试类...");
-        Set<EasySQLTest> tests = new LinkedHashSet<>();
-        tests.add(new TableCreateTest());
-//		tests.add(new TableAlterTest());
-//		tests.add(new TableRenameTest());
-//		tests.add(new QueryNotCloseTest());
-        tests.add(new QueryCloseTest());
-//		tests.add(new SQLUpdateBatchTests());
-//		tests.add(new SQLUpdateReturnKeysTest());
-        tests.add(new QueryFunctionTest());
-        tests.add(new DeleteTest());
-
-        print("准备进行测试...");
-
-        int index = 1;
-        int success = 0;
-
-        Iterator<EasySQLTest> testIterator = tests.iterator();
-
-        print("准备完成，请按回车键开始执行测试。");
-
-        while (testIterator.hasNext()) {
-            Scanner scanner = new Scanner(System.in);
-
-            if (scanner.nextLine() != null) {
-
-                EasySQLTest currentTest = testIterator.next();
-
-                if (currentTest.executeTest(index, sqlManager)) {
-                    success++;
-                }
-
-                index++;
-            }
-
-        }
-
-        print(" ");
-        print("全部测试执行完毕，成功 %s 个，失败 %s 个。",
-                success, (tests.size() - success)
-        );
-
-        EasySQL.shutdownManager(sqlManager);
-
-    }
-
-    public static void print(@NotNull String format, Object... params) {
-        System.out.printf((format) + "%n", params);
-    }
-
-}

example/easysql-tester/src/main/java/cc/carm/lib/easysql/tester/tests/DeleteTest.java

@@ -1,22 +0,0 @@
-package cc.carm.lib.easysql.tester.tests;
-
-import cc.carm.lib.easysql.api.SQLManager;
-import cc.carm.lib.easysql.tester.EasySQLTest;
-
-import java.sql.SQLException;
-
-public class DeleteTest extends EasySQLTest {
-
-
-    @Override
-    public void onTest(SQLManager sqlManager) throws SQLException {
-
-        Integer changes = sqlManager.createDelete("test_user_table")
-                .addCondition("id", ">", 5)
-                .addNotNullCondition("username")
-                .build().execute();
-
-        System.out.println("change(s): " + changes);
-
-    }
-}

example/easysql-tester/src/main/resources/log4j2.xml

@@ -1,26 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<Configuration status="WARN" packages="cc.carm.lib.easysql">
-    <Appenders>
-        <console name="Console" target="SYSTEM_OUT">
-            <PatternLayout pattern="[%d{HH:mm:ss} %level]: %msg%n"/>
-        </console>
-        <RollingRandomAccessFile name="File" fileName="logs/latest.log" filePattern="logs/%d{yyyy-MM-dd}-%i.log.gz">
-            <PatternLayout pattern="[%d{HH:mm:ss}] [%t/%level]: %msg%n"/>
-            <Policies>
-                <TimeBasedTriggeringPolicy/>
-                <OnStartupTriggeringPolicy/>
-            </Policies>
-        </RollingRandomAccessFile>
-    </Appenders>
-    <Loggers>
-        <root level="info">
-            <filters>
-                <MarkerFilter marker="NETWORK_PACKETS" onMatch="DENY" onMismatch="NEUTRAL"/>
-            </filters>
-            <!--            <AppenderRef ref="WINDOWS_COMPAT" level="info"/>-->
-            <AppenderRef ref="File"/>
-            <appender-ref ref="Console"/>
-        </root>
-    </Loggers>
-</Configuration>
-

impl/pom.xml

@@ -5,13 +5,13 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.3.8</version>
+        <version>0.3.13</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
     </properties>

impl/src/main/java/cc/carm/lib/easysql/action/AbstractSQLAction.java

@@ -7,6 +7,7 @@ import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
 
 import java.sql.SQLException;
+import java.util.List;
 import java.util.Objects;
 import java.util.UUID;
 
@@ -66,8 +67,10 @@ public abstract class AbstractSQLAction<T> implements SQLAction<T> {
         return this.sqlManager;
     }
 
-    protected void outputDebugMessage() {
-        getManager().debug("# " + getShortID() + " -> { " + getSQLContent() + " }");
+    protected void debugMessage(List<Object[]> params) {
+        if (getManager().isDebugMode()) {
+            getManager().getDebugHandler().beforeExecute(this, params);
+        }
     }
 
     @Override

impl/src/main/java/cc/carm/lib/easysql/action/PreparedSQLBatchUpdateActionImpl.java

@@ -15,11 +15,11 @@ import java.util.List;
 import java.util.stream.Collectors;
 
 public class PreparedSQLBatchUpdateActionImpl
-        extends AbstractSQLAction<List<Integer>>
+        extends AbstractSQLAction<List<Long>>
         implements PreparedSQLUpdateBatchAction {
 
     boolean returnKeys = false;
-    List<Object[]> allParams;
+    @NotNull List<Object[]> allParams;
 
     public PreparedSQLBatchUpdateActionImpl(@NotNull SQLManagerImpl manager, @NotNull String sql) {
         super(manager, sql);
@@ -47,21 +47,23 @@ public class PreparedSQLBatchUpdateActionImpl
     }
 
     @Override
-    public @NotNull List<Integer> execute() throws SQLException {
+    public @NotNull List<Long> execute() throws SQLException {
+        debugMessage(allParams);
+
         try (Connection connection = getManager().getConnection()) {
             try (PreparedStatement statement = StatementUtil.createPrepareStatementBatch(
                     connection, getSQLContent(), allParams, returnKeys
             )) {
 
-                outputDebugMessage();
                 int[] executed = statement.executeBatch();
 
-                if (!returnKeys) return Arrays.stream(executed).boxed().collect(Collectors.toList());
-                else {
+                if (!returnKeys) {
+                    return Arrays.stream(executed).mapToLong(Long::valueOf).boxed().collect(Collectors.toList());
+                } else {
                     try (ResultSet resultSet = statement.getGeneratedKeys()) {
-                        List<Integer> generatedKeys = new ArrayList<>();
+                        List<Long> generatedKeys = new ArrayList<>();
                         while (resultSet.next()) {
-                            generatedKeys.add(resultSet.getInt(1));
+                            generatedKeys.add(resultSet.getLong(1));
                         }
                         return generatedKeys;
                     }

impl/src/main/java/cc/carm/lib/easysql/action/PreparedSQLUpdateActionImpl.java

@@ -11,6 +11,7 @@ import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 
 public class PreparedSQLUpdateActionImpl
@@ -52,20 +53,20 @@ public class PreparedSQLUpdateActionImpl
     }
 
     @Override
-    public @NotNull Integer execute() throws SQLException {
+    public @NotNull Long execute() throws SQLException {
+        debugMessage(Collections.singletonList(params));
+
         try (Connection connection = getManager().getConnection()) {
 
             try (PreparedStatement statement = StatementUtil.createPrepareStatement(
                     connection, getSQLContent(), params, returnGeneratedKeys
             )) {
 
-                outputDebugMessage();
-
                 int changes = statement.executeUpdate();
-                if (!returnGeneratedKeys) return changes;
+                if (!returnGeneratedKeys) return (long) changes;
                 else {
                     try (ResultSet resultSet = statement.getGeneratedKeys()) {
-                        return resultSet.next() ? resultSet.getInt(1) : -1;
+                        return resultSet.next() ? resultSet.getLong(1) : -1;
                     }
                 }
 

impl/src/main/java/cc/carm/lib/easysql/action/SQLUpdateActionImpl.java

@@ -8,9 +8,10 @@ import java.sql.Connection;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.ArrayList;
 
 public class SQLUpdateActionImpl
-        extends AbstractSQLAction<Integer>
+        extends AbstractSQLAction<Long>
         implements SQLUpdateAction {
 
     boolean returnGeneratedKeys = false;
@@ -20,18 +21,19 @@ public class SQLUpdateActionImpl
     }
 
     @Override
-    public @NotNull Integer execute() throws SQLException {
+    public @NotNull Long execute() throws SQLException {
+        debugMessage(new ArrayList<>());
+
         try (Connection connection = getManager().getConnection()) {
             try (Statement statement = connection.createStatement()) {
-                outputDebugMessage();
 
                 if (!returnGeneratedKeys) {
-                    return statement.executeUpdate(getSQLContent());
+                    return (long) statement.executeUpdate(getSQLContent());
                 } else {
                     statement.executeUpdate(getSQLContent(), Statement.RETURN_GENERATED_KEYS);
 
                     try (ResultSet resultSet = statement.getGeneratedKeys()) {
-                        return resultSet.next() ? resultSet.getInt(1) : -1;
+                        return resultSet.next() ? resultSet.getLong(1) : -1;
                     }
                 }
             }

impl/src/main/java/cc/carm/lib/easysql/action/SQLUpdateBatchActionImpl.java

@@ -38,10 +38,11 @@ public class SQLUpdateBatchActionImpl
 
     @Override
     public @NotNull List<Integer> execute() throws SQLException {
+        debugMessage(new ArrayList<>());
+
         try (Connection connection = getManager().getConnection()) {
 
             try (Statement statement = connection.createStatement()) {
-                outputDebugMessage();
 
                 for (String content : this.sqlContents) {
                     statement.addBatch(content);
@@ -55,12 +56,4 @@ public class SQLUpdateBatchActionImpl
         }
     }
 
-    @Override
-    protected void outputDebugMessage() {
-        getManager().debug("# " + getShortID() + " -> [");
-        for (String content : getSQLContents()) getManager().debug(String.format(" { %s }", content));
-        getManager().debug("]");
-
-    }
-
 }

impl/src/main/java/cc/carm/lib/easysql/action/query/PreparedQueryActionImpl.java

@@ -11,6 +11,7 @@ import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.function.Consumer;
 
@@ -49,8 +50,8 @@ public class PreparedQueryActionImpl extends QueryActionImpl implements Prepared
 
     @Override
     public @NotNull SQLQueryImpl execute() throws SQLException {
-        outputDebugMessage();
-
+        debugMessage(Collections.singletonList(params));
+        
         Connection connection = getManager().getConnection();
         PreparedStatement preparedStatement;
         try {
@@ -74,7 +75,6 @@ public class PreparedQueryActionImpl extends QueryActionImpl implements Prepared
                     executeTime
             );
             getManager().getActiveQuery().put(getActionUUID(), query);
-
             return query;
         } catch (SQLException exception) {
             preparedStatement.close();

impl/src/main/java/cc/carm/lib/easysql/action/query/QueryActionImpl.java

@@ -12,6 +12,7 @@ import org.jetbrains.annotations.NotNull;
 import java.sql.Connection;
 import java.sql.SQLException;
 import java.sql.Statement;
+import java.util.ArrayList;
 
 public class QueryActionImpl extends AbstractSQLAction<SQLQuery> implements QueryAction {
 
@@ -21,6 +22,7 @@ public class QueryActionImpl extends AbstractSQLAction<SQLQuery> implements Quer
 
     @Override
     public @NotNull SQLQueryImpl execute() throws SQLException {
+        debugMessage(new ArrayList<>());
 
         Connection connection = getManager().getConnection();
         Statement statement;
@@ -32,7 +34,6 @@ public class QueryActionImpl extends AbstractSQLAction<SQLQuery> implements Quer
             throw ex;
         }
 
-        outputDebugMessage();
         try {
             long executeTime = System.currentTimeMillis();
             SQLQueryImpl query = new SQLQueryImpl(

impl/src/main/java/cc/carm/lib/easysql/builder/impl/DeleteBuilderImpl.java

@@ -12,7 +12,7 @@ import java.util.Objects;
 import static cc.carm.lib.easysql.api.SQLBuilder.withBackQuote;
 
 public class DeleteBuilderImpl
-        extends AbstractConditionalBuilder<DeleteBuilder, SQLAction<Integer>>
+        extends AbstractConditionalBuilder<DeleteBuilder, SQLAction<Long>>
         implements DeleteBuilder {
 
     protected final String tableName;

impl/src/main/java/cc/carm/lib/easysql/builder/impl/QueryBuilderImpl.java

@@ -10,6 +10,8 @@ import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
 
+import java.util.ArrayList;
+import java.util.Collections;
 import java.util.Objects;
 
 public class QueryBuilderImpl extends AbstractSQLBuilder implements QueryBuilder {

impl/src/main/java/cc/carm/lib/easysql/builder/impl/TableAlterBuilderImpl.java

@@ -28,7 +28,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> renameTo(@NotNull String newTableName) {
+    public SQLAction<Long> renameTo(@NotNull String newTableName) {
         Objects.requireNonNull(newTableName, "table name could not be null");
         return new SQLUpdateActionImpl(getManager(),
                 "ALTER TABLE " + withBackQuote(tableName) + " RENAME TO " + withBackQuote(newTableName)
@@ -36,7 +36,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> changeComment(@NotNull String newTableComment) {
+    public SQLAction<Long> changeComment(@NotNull String newTableComment) {
         Objects.requireNonNull(newTableComment, "table comment could not be null");
         return new SQLUpdateActionImpl(getManager(),
                 "ALTER TABLE " + withBackQuote(getTableName()) + " COMMENT " + withQuote(newTableComment)
@@ -44,15 +44,15 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> setAutoIncrementIndex(int index) {
+    public SQLAction<Long> setAutoIncrementIndex(int index) {
         return new SQLUpdateActionImpl(getManager(),
                 "ALTER TABLE " + withBackQuote(getTableName()) + " AUTO_INCREMENT=" + index
         );
     }
 
     @Override
-    public SQLAction<Integer> addIndex(@NotNull IndexType indexType, @Nullable String indexName,
-                                       @NotNull String columnName, @NotNull String... moreColumns) {
+    public SQLAction<Long> addIndex(@NotNull IndexType indexType, @Nullable String indexName,
+                                    @NotNull String columnName, @NotNull String... moreColumns) {
         Objects.requireNonNull(indexType, "indexType could not be null");
         Objects.requireNonNull(columnName, "column names could not be null");
         Objects.requireNonNull(moreColumns, "column names could not be null");
@@ -63,7 +63,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> dropIndex(@NotNull String indexName) {
+    public SQLAction<Long> dropIndex(@NotNull String indexName) {
         Objects.requireNonNull(indexName, "indexName could not be null");
         return createAction(
                 "ALTER TABLE " + withBackQuote(getTableName()) + " DROP INDEX " + withBackQuote(indexName)
@@ -71,7 +71,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> dropForeignKey(@NotNull String keySymbol) {
+    public SQLAction<Long> dropForeignKey(@NotNull String keySymbol) {
         Objects.requireNonNull(keySymbol, "keySymbol could not be null");
         return createAction(
                 "ALTER TABLE " + withBackQuote(getTableName()) + " DROP FOREIGN KEY " + withBackQuote(keySymbol)
@@ -79,14 +79,14 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> dropPrimaryKey() {
+    public SQLAction<Long> dropPrimaryKey() {
         return createAction(
                 "ALTER TABLE " + withBackQuote(getTableName()) + " DROP PRIMARY KEY"
         );
     }
 
     @Override
-    public SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn) {
+    public SQLAction<Long> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         Objects.requireNonNull(settings, "settings could not be null");
         String orderSettings = null;
@@ -105,7 +105,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> renameColumn(@NotNull String columnName, @NotNull String newName) {
+    public SQLAction<Long> renameColumn(@NotNull String columnName, @NotNull String newName) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         Objects.requireNonNull(newName, "please specify new column name");
         return createAction(
@@ -114,7 +114,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String settings) {
+    public SQLAction<Long> modifyColumn(@NotNull String columnName, @NotNull String settings) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         Objects.requireNonNull(settings, "please specify new column settings");
         return createAction(
@@ -123,7 +123,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> removeColumn(@NotNull String columnName) {
+    public SQLAction<Long> removeColumn(@NotNull String columnName) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         return createAction(
                 "ALTER TABLE " + withBackQuote(getTableName()) + " DROP " + withBackQuote(columnName)
@@ -131,7 +131,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue) {
+    public SQLAction<Long> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         Objects.requireNonNull(defaultValue, "defaultValue could not be null, if you need to remove the default value, please use #removeColumnDefault().");
         return createAction(
@@ -140,7 +140,7 @@ public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAl
     }
 
     @Override
-    public SQLAction<Integer> removeColumnDefault(@NotNull String columnName) {
+    public SQLAction<Long> removeColumnDefault(@NotNull String columnName) {
         Objects.requireNonNull(columnName, "columnName could not be null");
         return createAction(
                 "ALTER TABLE " + withBackQuote(getTableName()) + " ALTER " + withBackQuote(columnName) + " DROP DEFAULT"

impl/src/main/java/cc/carm/lib/easysql/builder/impl/UpdateBuilderImpl.java

@@ -13,7 +13,7 @@ import java.util.*;
 import static cc.carm.lib.easysql.api.SQLBuilder.withBackQuote;
 
 public class UpdateBuilderImpl
-        extends AbstractConditionalBuilder<UpdateBuilder, SQLAction<Integer>>
+        extends AbstractConditionalBuilder<UpdateBuilder, SQLAction<Long>>
         implements UpdateBuilder {
 
     protected final @NotNull String tableName;

impl/src/main/java/cc/carm/lib/easysql/manager/SQLManagerImpl.java

@@ -10,9 +10,13 @@ import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
 import cc.carm.lib.easysql.api.action.PreparedSQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.action.SQLUpdateBatchAction;
 import cc.carm.lib.easysql.api.builder.*;
+import cc.carm.lib.easysql.api.function.SQLDebugHandler;
+import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import cc.carm.lib.easysql.builder.impl.*;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import javax.sql.DataSource;
 import java.sql.Connection;
@@ -22,7 +26,6 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.function.Supplier;
-import java.util.logging.Logger;
 
 public class SQLManagerImpl implements SQLManager {
 
@@ -32,19 +35,29 @@ public class SQLManagerImpl implements SQLManager {
     protected ExecutorService executorPool;
     @NotNull Supplier<Boolean> debugMode = () -> Boolean.FALSE;
 
+    @NotNull SQLExceptionHandler exceptionHandler;
+    @NotNull SQLDebugHandler debugHandler;
+
     public SQLManagerImpl(@NotNull DataSource dataSource) {
         this(dataSource, null);
     }
 
     public SQLManagerImpl(@NotNull DataSource dataSource, @Nullable String name) {
+        this(dataSource, LoggerFactory.getLogger(SQLManagerImpl.class), name);
+    }
+
+    public SQLManagerImpl(@NotNull DataSource dataSource, @NotNull Logger logger, @Nullable String name) {
         String managerName = "SQLManager" + (name != null ? "#" + name : "");
-        this.LOGGER = Logger.getLogger(managerName);
+        this.LOGGER = logger;
         this.dataSource = dataSource;
         this.executorPool = Executors.newFixedThreadPool(3, r -> {
             Thread thread = new Thread(r, managerName);
             thread.setDaemon(true);
             return thread;
         });
+
+        this.exceptionHandler = SQLExceptionHandler.detailed(getLogger());
+        this.debugHandler = SQLDebugHandler.defaultHandler(getLogger());
     }
 
     @Override
@@ -57,6 +70,16 @@ public class SQLManagerImpl implements SQLManager {
         this.debugMode = debugMode;
     }
 
+    @Override
+    public @NotNull SQLDebugHandler getDebugHandler() {
+        return this.debugHandler;
+    }
+
+    @Override
+    public void setDebugHandler(@NotNull SQLDebugHandler debugHandler) {
+        this.debugHandler = debugHandler;
+    }
+
     public void debug(String msg) {
         if (isDebugMode()) getLogger().info("[DEBUG] " + msg);
     }
@@ -86,17 +109,28 @@ public class SQLManagerImpl implements SQLManager {
     }
 
     @Override
-    public Integer executeSQL(String sql) {
+    public @NotNull SQLExceptionHandler getExceptionHandler() {
+        return this.exceptionHandler;
+    }
+
+    @Override
+    public void setExceptionHandler(@Nullable SQLExceptionHandler handler) {
+        if (handler == null) this.exceptionHandler = SQLExceptionHandler.detailed(getLogger());
+        else this.exceptionHandler = handler;
+    }
+
+    @Override
+    public Long executeSQL(String sql) {
         return new SQLUpdateActionImpl(this, sql).execute(null);
     }
 
     @Override
-    public Integer executeSQL(String sql, Object[] params) {
+    public Long executeSQL(String sql, Object[] params) {
         return new PreparedSQLUpdateActionImpl(this, sql, params).execute(null);
     }
 
     @Override
-    public List<Integer> executeSQLBatch(String sql, Iterable<Object[]> paramsBatch) {
+    public List<Long> executeSQLBatch(String sql, Iterable<Object[]> paramsBatch) {
         return new PreparedSQLBatchUpdateActionImpl(this, sql)
                 .setAllParams(paramsBatch)
                 .execute(null);

impl/src/main/java/cc/carm/lib/easysql/query/SQLQueryImpl.java

@@ -71,9 +71,9 @@ public class SQLQueryImpl implements SQLQuery {
             if (getStatement() != null && !getStatement().isClosed()) getStatement().close();
             if (getConnection() != null && !getConnection().isClosed()) getConnection().close();
 
-            getManager().debug("#" + getAction().getShortID() +
-                    " -> finished after " + (System.currentTimeMillis() - getExecuteTime()) + " ms."
-            );
+            if (getManager().isDebugMode()) {
+                getManager().getDebugHandler().afterQuery(this, getExecuteTime(), System.currentTimeMillis());
+            }
             getManager().getActiveQuery().remove(getAction().getActionUUID());
         } catch (SQLException e) {
             getAction().handleException(getAction().defaultExceptionHandler(), e);

pom.xml

@@ -17,17 +17,16 @@
     <groupId>cc.carm.lib</groupId>
     <artifactId>easysql-parent</artifactId>
     <packaging>pom</packaging>
-    <version>0.3.8</version>
+    <version>0.3.13</version>
 
     <modules>
-        <module>easysql-api</module>
-        <module>easysql-impl</module>
+        <module>api</module>
+        <module>impl</module>
 
-        <module>with-pool/easysql-beecp</module>
-        <module>with-pool/easysql-hikaricp</module>
+        <module>with-pool/beecp</module>
+        <module>with-pool/hikaricp</module>
 
-        <module>example/easysql-demo</module>
-        <module>example/easysql-tester</module>
+        <module>example/demo</module>
     </modules>
 
     <name>EasySQL</name>
@@ -197,7 +196,7 @@
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-compiler-plugin</artifactId>
-                    <version>3.10.0</version>
+                    <version>3.10.1</version>
                     <configuration>
                         <source>${java.version}</source>
                         <target>${java.version}</target>
@@ -229,7 +228,7 @@
                 <plugin>
                     <groupId>org.apache.maven.plugins</groupId>
                     <artifactId>maven-shade-plugin</artifactId>
-                    <version>3.2.4</version>
+                    <version>3.3.0</version>
                     <executions>
                         <execution>
                             <phase>package</phase>

with-pool/beecp/pom.xml

@@ -5,14 +5,14 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.3.8</version>
+        <version>0.3.13</version>
         <relativePath>../../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
     </properties>
@@ -73,7 +73,7 @@
             <!--项目地址 https://github.com/Chris2018998/BeeCP  -->
             <groupId>com.github.chris2018998</groupId>
             <artifactId>beecp</artifactId>
-            <version>3.3.2</version>
+            <version>3.3.5</version>
             <optional>true</optional>
             <scope>compile</scope>
         </dependency>
@@ -101,7 +101,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-shade-plugin</artifactId>
-                <version>3.2.4</version>
+                <version>3.3.0</version>
                 <executions>
                     <execution>
                         <phase>package</phase>

with-pool/beecp/src/main/java/cc/carm/lib/easysql/EasySQL.java

@@ -24,11 +24,11 @@ public class EasySQL {
 
     public static void shutdownManager(SQLManager manager, boolean forceClose, boolean outputActiveQuery) {
         if (!manager.getActiveQuery().isEmpty()) {
-            manager.getLogger().severe("There are " + manager.getActiveQuery().size() + " connections still running");
+            manager.getLogger().warn("There are " + manager.getActiveQuery().size() + " connections still running");
             for (SQLQuery value : manager.getActiveQuery().values()) {
                 if (outputActiveQuery) {
-                    manager.getLogger().severe("#" + value.getAction().getShortID() + " -> " + value.getSQLContent());
-                    manager.getLogger().severe("- execute at " + TimeDateUtils.getTimeString(value.getExecuteTime()));
+                    manager.getLogger().warn(String.format("#%s -> %s", value.getAction().getShortID(), value.getSQLContent()));
+                    manager.getLogger().warn(String.format("- execute at %s", TimeDateUtils.getTimeString(value.getExecuteTime())));
                 }
                 if (forceClose) value.close();
             }

with-pool/hikaricp/pom.xml

@@ -5,14 +5,14 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.3.8</version>
+        <version>0.3.13</version>
         <relativePath>../../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <properties>
-        <maven.compiler.source>11</maven.compiler.source>
-        <maven.compiler.target>11</maven.compiler.target>
+        <maven.compiler.source>${java.version}</maven.compiler.source>
+        <maven.compiler.target>${java.version}</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
     </properties>
@@ -101,7 +101,7 @@
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-shade-plugin</artifactId>
-                <version>3.2.4</version>
+                <version>3.3.0</version>
                 <executions>
                     <execution>
                         <phase>package</phase>

with-pool/hikaricp/src/main/java/cc/carm/lib/easysql/EasySQL.java

@@ -34,11 +34,11 @@ public class EasySQL {
 
     public static void shutdownManager(SQLManager manager, boolean forceClose, boolean outputActiveQuery) {
         if (!manager.getActiveQuery().isEmpty()) {
-            manager.getLogger().severe("There are " + manager.getActiveQuery().size() + " connections still running");
+            manager.getLogger().warn("There are " + manager.getActiveQuery().size() + " connections still running");
             for (SQLQuery value : manager.getActiveQuery().values()) {
                 if (outputActiveQuery) {
-                    manager.getLogger().severe("#" + value.getAction().getShortID() + " -> " + value.getSQLContent());
-                    manager.getLogger().severe("- execute at " + TimeDateUtils.getTimeString(value.getExecuteTime()));
+                    manager.getLogger().warn(String.format("#%s -> %s", value.getAction().getShortID(), value.getSQLContent()));
+                    manager.getLogger().warn(String.format("- execute at %s", TimeDateUtils.getTimeString(value.getExecuteTime())));
                 }
                 if (forceClose) value.close();
             }