[v0.3.0] 添加测试项目，并对新内容进行测试

- [A] 添加 TableAlertBuilder 用于快捷修改表的相关设定
- [A] 为 TableCreateBuilder 添加数个方法，包含创建索引、自增主键与外键。
- [R] 修改部分Builder的参数值，为泛型添加限定。

.github/gpg_public.key

@@ -0,0 +1,41 @@
+-----BEGIN PGP PUBLIC KEY BLOCK-----
+
+mQGNBGHwDt0BDAC+2u7hHXIp+C3tvUc5w7Ga5gDVNN3xTQEurGXgYSnGnNPb89h/
+tk6MBQ2AHdsj61yK/mH65RbDZe725+0zBvumxfrPbgqYBy9veE1Cjpl3wJwsGYa+
+gidq3tU2WBpUpaFOcyfxzvoDjKv6BClX+m7RijRM4tTSxmzrUTfwrClSdSV2HlBu
+AuKvY5W+cDwlKtuXEBtgCpdlOGsp8YZsqe4QD9xMI6GOOnXnHisYnmsMzn2RU8mW
+GUS3ob1J1vAfIinixwB8tHlxB/G3jaOXtQEwFmI2dfYOdkbxOiIgcSfbRI8PGiHA
+KiluZpn+Ww05GwUch2HdX8dw1hsbWM4G/X8Aqy3HdJB28p73dE4I9FRrJ1uxsmMe
+iON8QevhSBC0qwSxb+16vKt58ErQnqXrJI6+HzPldn22OQIF7bMZGwYkZiOjS5LU
+xAoRT4Jomks0ccOZGe7wMIUp2Ch22vmv4O78Pd2GEzAcTUvM8mrS+zJBMogjx27C
+r86HOWEjmi2R32EAEQEAAbQeQ2FybSBKb3MgPEthcm11bkpAb3V0bG9vay5jb20+
+iQHUBBMBCAA+FiEEL6NL2WG27xbAlAIkh337tzeYbfcFAmHwDt0CGwMFCQPCZwAF
+CwkIBwIGFQoJCAsCBBYCAwECHgECF4AACgkQh337tzeYbffNvQwAscXykUimCOli
+lRK52P6+w5n/arl7UxCh7TZiRjf9feiCp3OivETKCeqnbtNTgv67aNbxjO9asCTK
+dU6J6Zh6wO8CqDhg+EA8qn+Nu4ESPGvgyWyeck9otMy16To5/I9eQRYTOos1crOA
+DRUH1MWLeIkZabM6wSPad/CcRAzFNf5+8JNuQqCgQ3Rngst1Z6Gyb1hixWnjxc4P
+7dFquwbR0D0ojwj0Etqd0c5p0iwyRl2I2QQ1bS3aGqdW0LzM9ixh25HAReg2QH7G
+FBQ5PLLXr4UqYQygzwhUtxl2jra0+3ia+D7OBwlgm3QPnlo82Z7nExQUYmemD7jV
+3Gc1ELXKSRHKbVjSoGiHWpnSiw4ptLo+tnzhRCHlV+pTS3IbQoPdb/glBOVIkA/j
+ksCfbrmC8aXpk1YycAXY2my7BpXsImWAOwPHVsvcB2IpEA2s3VfsZ/IB9z+yih3n
+z8mL0BFjKWUV23IOoeRqmt7l8nB7u55Nbjasu0LdTcl2R6swE3fTuQGNBGHwDt0B
+DAChLPfZ1njctL8BijLO//Hgvw9E6STJGYgqglNetfdoir+YAwCPQ32K4MsaQKl8
+xQelmcOU+5jO2C8wEyNAjmvyKGB2J/IjLEtAlbOn1UltKQ/GhxgMjg0EheY81ZMa
+7FDq1TDwYRCN5SMKhl5GF0JJ4OWfg1i7HbpEfkw4mW1pl0/eNdeQaC6qV6EWTsqz
+WRbi8DeH1WarSgq/00Za6zxNntLNLoq7jsTbDwTc6pgOp1Z8EcGfI/mcn3moqTxc
+o/PLYg+6impCKXVeRUlgGBpJ5YVvR5ACTLS9Tztwho9MpKJ9obXAfwXKyoToHCII
++pTnuzweOfOsrjLsFySnXq8WO2PY9JbNWjveKfk35fGfsrbwU0Vg+m67UahXqA4i
+KNvZeA8bG8AXrxUirKLWIj/8AuW8NAKu7ui4YmexldraYUgaoBrqhXZCVe8dNQv+
+erzNbmJUCPDauNddnDsCqOoZ8fWyBenDs3NS0TWuvua4/ND+AyVxPeatI4qfS2TD
+gnUAEQEAAYkBvAQYAQgAJhYhBC+jS9lhtu8WwJQCJId9+7c3mG33BQJh8A7dAhsM
+BQkDwmcAAAoJEId9+7c3mG33znkL/01lWSQOzFd+omzrz0RPqFUksxqQS+CUty0m
+/4n9H/K3BLcut+nUNbosNuqPqISoiaV7BGigv0bT+Pu+EQQtyjYOSeibeBadB48w
+cYp8k3YJbfinuKApw1Zp9IfAd3eXXWi30OY4FmlsKy6LGnusZ6KS+FzTjU94yN/0
+LK05fmBtLN/MQJQyqYIkquzk//diwpsxnv34+10igYaQBAEpPIsmsYwWg+ecCtyx
+lJGvmQggBrKvo5EdOGhO9DJAu1WQcFqnUCj5qvL+YKIsMyIwujQH8554P8xfCLFU
+a351qs30yWXX4HGMn3o7RuVQAACs1buxlMen/JEdQOLOaUtFcu2iYzCFhuzDsetc
+geNinFyo0bV9dXiahG95oTL45OA0w+E9Y0B5VXc9Yf08Yyj8ayMChASfVG5lZU6l
+KhiaKHV9t4xmwP43lRjs8HTC5rtXc31kPtOAT61HG9vPA49ZdXybUqoHru15PFmc
+OK7d0W/LdJ3iFeselROADHgPQn14sg==
+=rRA5
+-----END PGP PUBLIC KEY BLOCK-----

.github/workflows/deploy.yml

@@ -11,7 +11,8 @@ on:
     types: [ published ]
 
 jobs:
-  deploy:
+  gh-deploy:
+    name: "Publish Project (GitHub)"
     runs-on: ubuntu-latest
 
     steps:
@@ -25,12 +26,15 @@ jobs:
           server-id: github
           server-username: MAVEN_USERNAME
           server-password: MAVEN_TOKEN
+          gpg-private-key: ${{ secrets.MAVEN_GPG_PRIVATE_KEY }} # Value of the GPG private key to import
+          gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase
 
       - name: "Maven Deploy With Javadoc"
-        run: mvn -B deploy --file pom.xml -DskipTests
+        run: mvn -B -Pgithub deploy --file pom.xml -DskipTests
         env:
           MAVEN_USERNAME: ${{ github.repository_owner }}
           MAVEN_TOKEN: ${{secrets.GITHUB_TOKEN}}
+          MAVEN_GPG_PASSPHRASE: ${{ secrets.MAVEN_GPG_PASSPHRASE }}
 
       - name: "Copy Javadoc to Location"
         run: |
@@ -77,3 +81,28 @@ jobs:
         run: |
           cd docs
           git push origin HEAD:gh-pages --force
+
+  central-deploy:
+    name: "Deploy Project (Central Repository)"
+    runs-on: ubuntu-latest
+
+    steps:
+      - uses: actions/checkout@v2
+      - name: "Set up JDK"
+        uses: actions/setup-java@v2
+        with:
+          java-version: '11'
+          distribution: 'adopt'
+          cache: maven
+          server-id: ossrh
+          server-username: MAVEN_USERNAME
+          server-password: MAVEN_PASSWORD
+          gpg-private-key: ${{ secrets.MAVEN_GPG_PRIVATE_KEY }} # Value of the GPG private key to import
+          gpg-passphrase: MAVEN_GPG_PASSPHRASE # env variable for GPG private key passphrase
+
+      - name: "Central Deploy"
+        run: mvn -B -Possrh deploy --file pom.xml -DskipTests
+        env:
+          MAVEN_USERNAME: ${{ secrets.OSSRH_USER }}
+          MAVEN_PASSWORD: ${{ secrets.OSSRH_PASS }}
+          MAVEN_GPG_PASSPHRASE: ${{ secrets.MAVEN_GPG_PASSPHRASE }}

.github/workflows/sonar-analyze.yml

@@ -1,36 +0,0 @@
-name: "Sonar Analyze"
-on:
-  push:
-    branches:
-      - master
-  pull_request:
-    types: [ opened, synchronize, reopened ]
-jobs:
-  build:
-    name: Build
-    runs-on: ubuntu-latest
-    steps:
-      - uses: actions/checkout@v2
-        with:
-          fetch-depth: 0  # Shallow clones should be disabled for a better relevancy of analysis
-      - name: Set up JDK 11
-        uses: actions/setup-java@v1
-        with:
-          java-version: 11
-      - name: Cache SonarCloud packages
-        uses: actions/cache@v1
-        with:
-          path: ~/.sonar/cache
-          key: ${{ runner.os }}-sonar
-          restore-keys: ${{ runner.os }}-sonar
-      - name: Cache Maven packages
-        uses: actions/cache@v1
-        with:
-          path: ~/.m2
-          key: ${{ runner.os }}-m2-${{ hashFiles('**/pom.xml') }}
-          restore-keys: ${{ runner.os }}-m2
-      - name: Build and analyze
-        env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}  # Needed to get PR information, if any
-          SONAR_TOKEN: ${{ secrets.SONAR_TOKEN }}
-        run: mvn -B verify org.sonarsource.scanner.maven:sonar-maven-plugin:sonar -Dsonar.projectKey=CarmJos_EasySQL

README.md

@@ -35,7 +35,7 @@
 
 ### 示例代码
 
-您可以 [点击这里](easysql-demo/src/main/java/EasySQLDemo.java) 查看部分代码演示，更多演示详见 [开发介绍](.documentation/README.md) 。
+您可以 [点击这里](example/easysql-demo/src/main/java/EasySQLDemo.java) 查看部分代码演示，更多演示详见 [开发介绍](.documentation/README.md) 。
 
 ### 依赖方式
 

easysql-api/pom.xml

@@ -5,10 +5,17 @@
     <parent>
         <groupId>cc.carm.lib</groupId>
         <artifactId>easysql-parent</artifactId>
-        <version>0.2.8</version>
+        <version>0.3.0</version>
     </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>
+    </properties>
+
     <artifactId>easysql-api</artifactId>
     <packaging>jar</packaging>
 
@@ -45,13 +52,6 @@
         <url>${project.url}/actions/workflows/maven.yml</url>
     </ciManagement>
 
-    <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>
-    </properties>
-
     <build>
         <plugins>
             <plugin>

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

@@ -3,11 +3,14 @@ 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 java.sql.SQLException;
 import java.util.UUID;
+import java.util.logging.Logger;
 
 /**
  * SQLAction 是用于承载SQL语句并进行处理、返回的基本类。
@@ -20,7 +23,8 @@ import java.util.UUID;
  *     <li>异步执行 {@link #executeAsync(SQLHandler, SQLExceptionHandler)}
  *     <br>异步执行时将提供成功与异常两种处理方式
  *     <br>可自行选择是否对数据或异常进行处理
- *     <br>默认的异常处理器为 {@link #defaultExceptionHandler()}</li>
+ *     <br>默认的异常处理器为 {@link #defaultExceptionHandler()}
+ *     <br>若有特殊需要，可通过{@link #setExceptionHandler(SQLExceptionHandler)} 方法修改默认的处理器</li>
  * </ul>
  *
  * @param <T> 需要返回的类型
@@ -84,24 +88,6 @@ public interface SQLAction<T> {
 		return execute(t -> t, exceptionHandler);
 	}
 
-	/**
-	 * 执行语句并处理返回值
-	 *
-	 * @param function 处理方法
-	 * @param <R>      需要返回的内容
-	 * @return 指定类型数据
-	 * @throws SQLException 当SQL操作出现问题时抛出
-	 */
-	@Nullable
-	default <R> R executeFunction(@NotNull SQLFunction<T, R> function) throws SQLException {
-		try {
-			T value = execute();
-			return function.apply(value);
-		} catch (SQLException exception) {
-			throw new SQLException(exception);
-		}
-	}
-
 	/**
 	 * 执行语句并处理返回值
 	 *
@@ -113,14 +99,66 @@ public interface SQLAction<T> {
 	@Nullable
 	default <R> R execute(@NotNull SQLFunction<T, R> function,
 						  @Nullable SQLExceptionHandler exceptionHandler) {
+		return execute(function, null, exceptionHandler);
+	}
+
+	/**
+	 * 执行语句并处理返回值
+	 *
+	 * @param function         处理方法
+	 * @param defaultResult    默认结果，若处理后的结果为null，则返回该值
+	 * @param exceptionHandler 异常处理器 默认为 {@link #defaultExceptionHandler()}
+	 * @param <R>              需要返回的内容
+	 * @return 指定类型数据
+	 */
+	@Nullable
+	@Contract("_,!null,_ -> !null")
+	default <R> R execute(@NotNull SQLFunction<T, R> function,
+						  @Nullable R defaultResult,
+						  @Nullable SQLExceptionHandler exceptionHandler) {
 		try {
-			return executeFunction(function);
+			return executeFunction(function, defaultResult);
 		} catch (SQLException exception) {
 			handleException(exceptionHandler, exception);
 			return null;
 		}
 	}
 
+	/**
+	 * 执行语句并处理返回值
+	 *
+	 * @param function 处理方法
+	 * @param <R>      需要返回的内容
+	 * @return 指定类型数据
+	 * @throws SQLException 当SQL操作出现问题时抛出
+	 */
+	@Nullable
+	default <R> R executeFunction(@NotNull SQLFunction<T, R> function) throws SQLException {
+		return executeFunction(function, null);
+	}
+
+	/**
+	 * 执行语句并处理返回值
+	 *
+	 * @param function      处理方法
+	 * @param defaultResult 默认结果，若处理后的结果为null，则返回该值
+	 * @param <R>           需要返回的内容
+	 * @return 指定类型数据
+	 * @throws SQLException 当SQL操作出现问题时抛出
+	 */
+	@Nullable
+	@Contract("_,!null -> !null")
+	default <R> R executeFunction(@NotNull SQLFunction<T, R> function,
+								  @Nullable R defaultResult) throws SQLException {
+		try {
+			T value = execute();
+			R result = function.apply(value);
+			return result == null ? defaultResult : result;
+		} catch (SQLException exception) {
+			throw new SQLException(exception);
+		}
+	}
+
 	/**
 	 * 异步执行SQL语句，采用默认异常处理，无需返回值。
 	 */
@@ -152,15 +190,24 @@ public interface SQLAction<T> {
 	}
 
 	/**
-	 * @return 默认的异常处理器
+	 * 默认的异常处理器
+	 *
+	 * @return {@link DefaultSQLExceptionHandler#get(Logger)}
+	 * @see DefaultSQLExceptionHandler
 	 */
 	default SQLExceptionHandler defaultExceptionHandler() {
-		return (exception, action) -> {
-			getManager().getLogger().severe("Error when execute [" + action.getSQLContent() + "]");
-			getManager().getLogger().severe(exception.getLocalizedMessage());
-			exception.printStackTrace();
-		};
+		return DefaultSQLExceptionHandler.get(getManager().getLogger());
 	}
 
+	/**
+	 * 设定通用的异常处理器。
+	 * <br> 在使用 {@link #execute(SQLExceptionHandler)} 等相关方法时，若传入的处理器为null，则会采用此处理器。
+	 * <br> 若该方法传入参数为 null，则会使用 {@link #defaultExceptionHandler()} 。
+	 *
+	 * @param handler 异常处理器
+	 */
+	default void setExceptionHandler(@Nullable SQLExceptionHandler handler) {
+		DefaultSQLExceptionHandler.setCustomHandler(handler);
+	}
 
 }

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

@@ -28,7 +28,7 @@ public interface SQLManager {
 	default void setDebugMode(boolean enable) {
 		setDebugMode(() -> enable);
 	}
-	
+
 	/**
 	 * 得到连接池源
 	 *
@@ -109,6 +109,14 @@ public interface SQLManager {
 	 */
 	TableCreateBuilder createTable(@NotNull String tableName);
 
+	/**
+	 * 对库中的某个表执行更改
+	 *
+	 * @param tableName 表名
+	 * @return {@link TableAlterBuilder}
+	 */
+	TableAlterBuilder alterTable(@NotNull String tableName);
+
 	/**
 	 * 新建一个查询
 	 *

easysql-api/src/main/java/cc/carm/lib/easysql/api/SQLQuery.java

@@ -1,6 +1,5 @@
 package cc.carm.lib.easysql.api;
 
-import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.action.query.PreparedQueryAction;
 import cc.carm.lib.easysql.api.action.query.QueryAction;
 
@@ -10,43 +9,44 @@ import java.sql.Statement;
 
 public interface SQLQuery extends AutoCloseable {
 
-    /**
-     * 获取该查询创建的时间
-     *
-     * @return 创建时间
-     */
-    long getExecuteTime();
+	/**
+	 * 获取该查询创建的时间
+	 *
+	 * @return 创建时间
+	 */
+	long getExecuteTime();
 
-    /**
-     * 得到承载该SQLQuery的对应{@link SQLManager}
-     *
-     * @return {@link SQLManager}
-     */
-    SQLManager getManager();
+	/**
+	 * 得到承载该SQLQuery的对应{@link SQLManager}
+	 *
+	 * @return {@link SQLManager}
+	 */
+	SQLManager getManager();
 
-    /**
-     * 得到承载该SQLQuery的对应{@link QueryAction}
-     *
-     * @return {@link QueryAction} 或 {@link PreparedQueryAction}
-     */
-    QueryAction getAction();
+	/**
+	 * 得到承载该SQLQuery的对应{@link QueryAction}
+	 *
+	 * @return {@link QueryAction} 或 {@link PreparedQueryAction}
+	 */
+	QueryAction getAction();
 
-    ResultSet getResultSet();
+	ResultSet getResultSet();
 
-    /**
-     * 得到设定的SQL语句
-     *
-     * @return SQL语句
-     */
-    String getSQLContent();
+	/**
+	 * 得到设定的SQL语句
+	 *
+	 * @return SQL语句
+	 */
+	String getSQLContent();
 
-    /**
-     * 关闭所有内容
-     */
-    void close();
+	/**
+	 * 关闭所有内容
+	 */
+	@Override
+	void close();
 
-    Statement getStatement();
+	Statement getStatement();
 
-    Connection getConnection();
+	Connection getConnection();
 
 }

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

@@ -1,7 +1,6 @@
 package cc.carm.lib.easysql.api.action;
 
 import cc.carm.lib.easysql.api.SQLAction;
-import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import org.jetbrains.annotations.NotNull;
 
 import java.util.List;
@@ -16,20 +15,10 @@ public interface SQLUpdateBatchAction extends SQLAction<List<Integer>> {
 	 */
 	SQLUpdateBatchAction addBatch(@NotNull String sql);
 
-	List<String> getSQLContents();
-
-	@Override
-	default SQLExceptionHandler defaultExceptionHandler() {
-		return (exception, action) -> {
-			getManager().getLogger().severe("Error when execute SQLs : ");
-			int i = 1;
-			for (String content : getSQLContents()) {
-				getManager().getLogger().severe("#" + i + " [" + content + "]");
-				i++;
-			}
-			getManager().getLogger().severe(exception.getLocalizedMessage());
-			exception.printStackTrace();
-		};
+	default @NotNull String getSQLContent() {
+		return getSQLContents().get(0);
 	}
 
+	List<String> getSQLContents();
+
 }

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

@@ -5,6 +5,7 @@ import cc.carm.lib.easysql.api.SQLQuery;
 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 org.jetbrains.annotations.Contract;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
@@ -34,16 +35,20 @@ public interface QueryAction extends SQLAction<SQLQuery> {
 	/**
 	 * 执行语句并处理返回值
 	 *
-	 * @param function 处理方法
-	 * @param <R>      需要返回的内容
+	 * @param defaultResult 默认结果，若处理后的结果为null，则返回该值
+	 * @param function      处理方法
+	 * @param <R>           需要返回的内容
 	 * @return 指定类型数据
 	 * @throws SQLException 当SQL操作出现问题时抛出
 	 */
 	@Nullable
-	default <R> R executeFunction(@NotNull SQLFunction<SQLQuery, R> function)
-			throws SQLException {
+	@Contract("!null, _ -> !null")
+	default <R> R executeFunction(@Nullable R defaultResult,
+								  @NotNull SQLFunction<SQLQuery, R> function) throws SQLException {
+
 		try (SQLQuery value = execute()) {
-			return function.apply(value);
+			R result = function.apply(value);
+			return result == null ? defaultResult : result;
 		} catch (SQLException exception) {
 			throw new SQLException(exception);
 		}

easysql-api/src/main/java/cc/carm/lib/easysql/api/builder/ConditionalBuilder.java

@@ -1,5 +1,6 @@
 package cc.carm.lib.easysql.api.builder;
 
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.SQLBuilder;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
@@ -7,36 +8,47 @@ import org.jetbrains.annotations.Nullable;
 import java.util.Date;
 import java.util.LinkedHashMap;
 
-public interface ConditionalBuilder<B extends ConditionalBuilder<B, T>, T> extends SQLBuilder {
+public interface ConditionalBuilder<B extends ConditionalBuilder<B, T>, T extends SQLAction<?>> extends SQLBuilder {
 
-    T build();
+	/**
+	 * 将现有条件构建完整的SQL语句用于执行。
+	 *
+	 * @return {@link cc.carm.lib.easysql.api.SQLAction}
+	 */
+	T build();
 
-    B setLimit(int limit);
+	/**
+	 * 设定取出的条数
+	 *
+	 * @param limit 条数限制
+	 * @return {@link B}
+	 */
+	B setLimit(int limit);
 
-    B setConditions(@Nullable String condition);
+	B setConditions(@Nullable String condition);
 
-    B setConditions(LinkedHashMap<@NotNull String, @Nullable Object> conditionSQLs);
+	B setConditions(LinkedHashMap<@NotNull String, @Nullable Object> conditionSQLs);
 
-    B addCondition(@Nullable String condition);
+	B addCondition(@Nullable String condition);
 
-    B addCondition(@NotNull String queryName, @NotNull String operator, @Nullable Object queryValue);
+	B addCondition(@NotNull String queryName, @NotNull String operator, @Nullable Object queryValue);
 
-    default B addCondition(@NotNull String queryName, @Nullable Object queryValue) {
-        return addCondition(queryName, "=", queryValue);
-    }
+	default B addCondition(@NotNull String queryName, @Nullable Object queryValue) {
+		return addCondition(queryName, "=", queryValue);
+	}
 
-    B addCondition(@NotNull String[] queryNames, @Nullable Object[] queryValues);
+	B addCondition(@NotNull String[] queryNames, @Nullable Object[] queryValues);
 
-    B addNotNullCondition(@NotNull String queryName);
+	B addNotNullCondition(@NotNull String queryName);
 
-    default B addTimeCondition(@NotNull String queryName, long startMillis, long endMillis) {
-        return addTimeCondition(queryName,
-                startMillis > 0 ? new Date(startMillis) : null,
-                endMillis > 0 ? new Date(endMillis) : null
-        );
-    }
+	default B addTimeCondition(@NotNull String queryName, long startMillis, long endMillis) {
+		return addTimeCondition(queryName,
+				startMillis > 0 ? new Date(startMillis) : null,
+				endMillis > 0 ? new Date(endMillis) : null
+		);
+	}
 
-    B addTimeCondition(@NotNull String queryName, @Nullable java.util.Date startDate, @Nullable java.util.Date endDate);
+	B addTimeCondition(@NotNull String queryName, @Nullable java.util.Date startDate, @Nullable java.util.Date endDate);
 
 
 }

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

@@ -1,9 +1,9 @@
 package cc.carm.lib.easysql.api.builder;
 
-import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
+import cc.carm.lib.easysql.api.SQLAction;
 
-public interface DeleteBuilder extends ConditionalBuilder<DeleteBuilder, PreparedSQLUpdateAction> {
+public interface DeleteBuilder extends ConditionalBuilder<DeleteBuilder, SQLAction<Integer>> {
 
-    String getTableName();
+	String getTableName();
 
 }

easysql-api/src/main/java/cc/carm/lib/easysql/api/builder/InsertBuilder.java

@@ -1,9 +1,11 @@
 package cc.carm.lib.easysql.api.builder;
 
+import cc.carm.lib.easysql.api.SQLAction;
+
 import java.util.Arrays;
 import java.util.List;
 
-public interface InsertBuilder<T> {
+public interface InsertBuilder<T extends SQLAction<?>> {
 
     String getTableName();
 

easysql-api/src/main/java/cc/carm/lib/easysql/api/builder/ReplaceBuilder.java

@@ -1,17 +1,25 @@
 package cc.carm.lib.easysql.api.builder;
 
+import cc.carm.lib.easysql.api.SQLAction;
+
 import java.util.Arrays;
 import java.util.List;
 
-public interface ReplaceBuilder<T> {
+/**
+ * REPLACE 语句用于将一组值更新进数据表中。
+ * <br> 执行后，将通过表中键判断该数据是否存在，若存在则用新数据替换原来的值，若不存在则会插入该数据。
+ * <br> 在使用REPLACE时，表与所给行列数据中必须包含唯一索引(或主键)，且索引不得为空值，否则将等同于插入语句。
+ *
+ * @param <T> 最终构建出的 {@link SQLAction} 类型
+ */
+public interface ReplaceBuilder<T extends SQLAction<?>> {
 
-    String getTableName();
+	String getTableName();
 
-    T setColumnNames(List<String> columnNames);
-
-    default T setColumnNames(String... columnNames) {
-        return setColumnNames(columnNames == null ? null : Arrays.asList(columnNames));
-    }
+	T setColumnNames(List<String> columnNames);
 
+	default T setColumnNames(String... columnNames) {
+		return setColumnNames(columnNames == null ? null : Arrays.asList(columnNames));
+	}
 
 }

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

@@ -0,0 +1,129 @@
+package cc.carm.lib.easysql.api.builder;
+
+import cc.carm.lib.easysql.api.SQLAction;
+import cc.carm.lib.easysql.api.SQLBuilder;
+import cc.carm.lib.easysql.api.action.SQLUpdateAction;
+import cc.carm.lib.easysql.api.enums.IndexType;
+import cc.carm.lib.easysql.api.enums.NumberType;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+public interface TableAlterBuilder extends SQLBuilder {
+
+	SQLAction<Integer> renameTo(@NotNull String newTableName);
+
+	SQLAction<Integer> changeComment(@NotNull String newTableComment);
+
+	SQLAction<Integer> setAutoIncrementIndex(int index);
+
+	SQLAction<Integer> addIndex(@NotNull IndexType indexType, @NotNull String indexName,
+								@NotNull String columnName, @NotNull String... moreColumns);
+
+	/**
+	 * 为该表移除一个索引
+	 *
+	 * @param indexName 索引名
+	 * @return {@link SQLUpdateAction}
+	 */
+	SQLAction<Integer> dropIndex(@NotNull String indexName);
+
+	/**
+	 * 为该表移除一个外键
+	 *
+	 * @param keySymbol 外键名
+	 * @return {@link SQLUpdateAction}
+	 */
+	SQLAction<Integer> dropForeignKey(@NotNull String keySymbol);
+
+	/**
+	 * 为该表移除主键(须添加新主键)
+	 *
+	 * @return {@link SQLUpdateAction}
+	 */
+	SQLAction<Integer> dropPrimaryKey();
+
+	/**
+	 * 为表添加一列
+	 *
+	 * @param columnName 列名
+	 * @param settings   列的相关设定
+	 * @return {@link SQLUpdateAction}
+	 */
+	default SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings) {
+		return addColumn(columnName, settings, null);
+	}
+
+	/**
+	 * 为表添加一列
+	 *
+	 * @param columnName  列名
+	 * @param settings    列的相关设定
+	 * @param afterColumn 该列增添到哪个列的后面，
+	 *                    <p> 该参数若省缺则放于最后一行
+	 *                    <p> 若为 "" 则置于首行。
+	 * @return {@link SQLUpdateAction}
+	 */
+	SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn);
+
+	SQLAction<Integer> renameColumn(@NotNull String columnName, @NotNull String newName);
+
+	SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String settings);
+
+	default SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String columnSettings, @NotNull String afterColumn) {
+		return modifyColumn(columnName, columnSettings + " AFTER `" + afterColumn + "`");
+	}
+
+	SQLAction<Integer> removeColumn(@NotNull String columnName);
+
+	SQLAction<Integer> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue);
+
+	SQLAction<Integer> removeColumnDefault(@NotNull String columnName);
+
+	/**
+	 * 为该表添加一个自增列
+	 * <p> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName 列名
+	 * @param numberType 数字类型，若省缺则为 {@link NumberType#INT}
+	 * @param primary    是否为主键，若否则只为唯一键
+	 * @param unsigned   是否采用 UNSIGNED (即无负数，可以增加自增键的最高数，建议为true)
+	 * @return {@link TableCreateBuilder}
+	 */
+	default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName, @Nullable NumberType numberType,
+													  boolean primary, boolean unsigned) {
+		return addColumn(columnName,
+				(numberType == null ? NumberType.INT : numberType).name()
+						+ (unsigned ? " UNSIGNED " : " ")
+						+ "NOT NULL AUTO_INCREMENT " + (primary ? "PRIMARY KEY" : "UNIQUE KEY"),
+				""
+		);
+	}
+
+	/**
+	 * 为该表添加一个自增列
+	 * <br> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName 列名
+	 * @param numberType 数字类型，若省缺则为 {@link NumberType#INT}
+	 * @return {@link TableAlterBuilder}
+	 */
+	default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName, @NotNull NumberType numberType) {
+		return addAutoIncrementColumn(columnName, numberType, false, true);
+	}
+
+
+	/**
+	 * 为该表添加一个自增列
+	 * <br> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName 列名
+	 * @return {@link TableAlterBuilder}
+	 */
+	default SQLAction<Integer> addAutoIncrementColumn(@NotNull String columnName) {
+		return addAutoIncrementColumn(columnName, NumberType.INT);
+	}
+
+}

easysql-api/src/main/java/cc/carm/lib/easysql/api/builder/TableCreateBuilder.java

@@ -2,29 +2,248 @@ package cc.carm.lib.easysql.api.builder;
 
 import cc.carm.lib.easysql.api.SQLBuilder;
 import cc.carm.lib.easysql.api.action.SQLUpdateAction;
+import cc.carm.lib.easysql.api.enums.ForeignKeyRule;
+import cc.carm.lib.easysql.api.enums.IndexType;
+import cc.carm.lib.easysql.api.enums.NumberType;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
 public interface TableCreateBuilder extends SQLBuilder {
 
-    @NotNull String getTableName();
+	/**
+	 * 将现有条件构建完整的SQL语句用于执行。
+	 *
+	 * @return {@link SQLUpdateAction}
+	 */
+	SQLUpdateAction build();
 
-    @NotNull String getTableSettings();
+	@NotNull String getTableName();
 
-    TableCreateBuilder setTableSettings(@NotNull String settings);
+	/**
+	 * 得到表的设定。
+	 * <p> 若未使用 {@link #setTableSettings(String)} 方法则会采用 {@link #defaultTablesSettings()} 。
+	 *
+	 * @return TableSettings
+	 */
+	@NotNull String getTableSettings();
 
-    SQLUpdateAction build();
+	TableCreateBuilder setTableSettings(@NotNull String settings);
 
-    default TableCreateBuilder addColumn(@NotNull String columnName, @NotNull String settings) {
-        return addColumn("`" + columnName + "` " + settings);
-    }
+	/**
+	 * 设定表的标注，一般用于解释该表的作用。
+	 *
+	 * @param comment 表标注
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder setTableComment(@Nullable String comment);
 
-    TableCreateBuilder addColumn(@NotNull String column);
+	/**
+	 * 直接设定表的所有列信息
+	 *
+	 * @param columns 列的相关信息 (包括列设定)
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder setColumns(@NotNull String... columns);
 
-    TableCreateBuilder setColumns(@NotNull String... columns);
+	/**
+	 * 为该表添加一个列
+	 *
+	 * @param column 列的相关信息
+	 *               <br>如 `uuid` VARCHAR(36) NOT NULL UNIQUE KEY
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder addColumn(@NotNull String column);
 
-    default TableCreateBuilder defaultTablesSettings() {
-        return setTableSettings("ENGINE=InnoDB DEFAULT CHARSET=utf8");
-    }
+	/**
+	 * 为该表添加一个列
+	 *
+	 * @param columnName 列名
+	 * @param settings   列的设定
+	 *                   <br>如 VARCHAR(36) NOT NULL UNIQUE KEY
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addColumn(@NotNull String columnName, @NotNull String settings) {
+		return addColumn("`" + columnName + "` " + settings);
+	}
 
+	/**
+	 * 为该表添加一个列
+	 *
+	 * @param columnName 列名
+	 * @param settings   列的设定
+	 *                   <br>如 VARCHAR(36) NOT NULL UNIQUE KEY
+	 * @param comments   列的注解，用于解释该列数据的作用
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addColumn(@NotNull String columnName, @NotNull String settings, @NotNull String comments) {
+		return addColumn(columnName, settings + " COMMENT '" + comments + "'");
+	}
+
+	/**
+	 * 为该表添加一个自增列
+	 * <p> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName   列名
+	 * @param numberType   数字类型，若省缺则为 {@link NumberType#INT}
+	 * @param asPrimaryKey 是否为主键，若为false则设定为唯一键
+	 * @param unsigned     是否采用 UNSIGNED (即无负数，可以增加自增键的最高数，建议为true)
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder addAutoIncrementColumn(@NotNull String columnName, @Nullable NumberType numberType,
+											  boolean asPrimaryKey, boolean unsigned);
+
+	/**
+	 * 为该表添加一个INT类型的自增主键列
+	 * <p> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName   列名
+	 * @param asPrimaryKey 是否为主键，若为false则设定为唯一键
+	 * @param unsigned     是否采用 UNSIGNED (即无负数，可以增加自增键的最高数，建议为true)
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addAutoIncrementColumn(@NotNull String columnName,
+													  boolean asPrimaryKey, boolean unsigned) {
+		return addAutoIncrementColumn(columnName, NumberType.INT, asPrimaryKey, unsigned);
+	}
+
+
+	/**
+	 * 为该表添加一个INT类型的自增列
+	 * <p> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName   列名
+	 * @param asPrimaryKey 是否为主键，若为false则设定为唯一键
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addAutoIncrementColumn(@NotNull String columnName, boolean asPrimaryKey) {
+		return addAutoIncrementColumn(columnName, asPrimaryKey, true);
+	}
+
+	/**
+	 * 为该表添加一个INT类型的自增主键列
+	 * <p> 自增列强制要求为数字类型，非空，且为UNIQUE。
+	 * <p> 注意：一个表只允许有一个自增列！
+	 *
+	 * @param columnName 列名
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addAutoIncrementColumn(@NotNull String columnName) {
+		return addAutoIncrementColumn(columnName, true);
+	}
+
+	/**
+	 * 设定表中的某列为索引或键。
+	 *
+	 * <p>创建索引时，你需要确保该索引是应用在 SQL 查询语句的条件(一般作为 WHERE 子句的条件)。
+	 * <br>虽然索引大大提高了查询速度，同时却会降低更新表的速度，如对表进行INSERT、UPDATE 和DELETE。
+	 * <br>因此，请合理的设计索引。
+	 *
+	 * @param type       索引类型
+	 * @param columnName 索引包含的列
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder setIndex(@NotNull String columnName,
+										@NotNull IndexType type) {
+		return setIndex(type, null, columnName);
+	}
+
+	/**
+	 * 设定表中的某列为索引或键。
+	 *
+	 * <p>创建索引时，你需要确保该索引是应用在 SQL 查询语句的条件(一般作为 WHERE 子句的条件)。
+	 * <br>虽然索引大大提高了查询速度，同时却会降低更新表的速度，如对表进行INSERT、UPDATE 和DELETE。
+	 * <br>因此，请合理的设计索引。
+	 *
+	 * @param type        索引类型
+	 * @param indexName   索引名称，缺省时将根据第一个索引列赋一个名称
+	 * @param columnName  索引包含的列
+	 * @param moreColumns 联合索引需要包含的列
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder setIndex(@NotNull IndexType type, @Nullable String indexName,
+								@NotNull String columnName, @NotNull String... moreColumns);
+
+
+	/**
+	 * 以本表位从表，为表中某列设定自参照外键(即自参照完整性)。
+	 *
+	 * <p>外键约束（FOREIGN KEY）是表的一个特殊字段，经常与主键约束一起使用。
+	 * <br>外键用来建立主表与从表的关联关系，为两个表的数据建立连接，约束两个表中数据的一致性和完整性。
+	 * <br>主表删除某条记录时，从表中与之对应的记录也必须有相应的改变。
+	 *
+	 * @param tableColumn   本表中的列
+	 * @param foreignColumn 外键关联表中对应的关联列，必须为目标表的主键，即 {@link IndexType#PRIMARY_KEY}
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addForeignKey(@NotNull String tableColumn, @NotNull String foreignColumn) {
+		return addForeignKey(tableColumn, getTableName(), foreignColumn);
+	}
+
+	/**
+	 * 以本表位从表，为表中某列设定外键。
+	 *
+	 * <p>外键约束（FOREIGN KEY）是表的一个特殊字段，经常与主键约束一起使用。
+	 * <br>外键用来建立主表与从表的关联关系，为两个表的数据建立连接，约束两个表中数据的一致性和完整性。
+	 * <br>主表删除某条记录时，从表中与之对应的记录也必须有相应的改变。
+	 *
+	 * @param tableColumn   本表中的列
+	 * @param foreignTable  外键关联主表，必须为已存在的表或本表，且必须有主键。
+	 * @param foreignColumn 外键关联主表中对应的关联列，须满足
+	 *                      <p> 1. 为主表的主键，即 {@link IndexType#PRIMARY_KEY}
+	 *                      <p> 2. 数据类型必须和所要建立主键的列的数据类型相同。
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addForeignKey(@NotNull String tableColumn,
+											 @NotNull String foreignTable, @NotNull String foreignColumn) {
+		return addForeignKey(tableColumn, null, foreignTable, foreignColumn);
+	}
+
+	/**
+	 * 以本表位从表，为表中某列设定外键。
+	 *
+	 * <p>外键约束（FOREIGN KEY）是表的一个特殊字段，经常与主键约束一起使用。
+	 * <br>外键用来建立主表与从表的关联关系，为两个表的数据建立连接，约束两个表中数据的一致性和完整性。
+	 * <br>主表删除某条记录时，从表中与之对应的记录也必须有相应的改变。
+	 *
+	 * @param tableColumn    本表中的列
+	 * @param constraintName 约束名，缺省时将使用参数自动生成，如 <i>fk_[tableColumn]_[foreignTable]</i>
+	 * @param foreignTable   外键关联主表，必须为已存在的表或本表，且必须有主键。
+	 * @param foreignColumn  外键关联主表中对应的关联列，须满足
+	 *                       <p> 1. 为主表的主键，即 {@link IndexType#PRIMARY_KEY}
+	 *                       <p> 2. 数据类型必须和所要建立主键的列的数据类型相同。
+	 * @return {@link TableCreateBuilder}
+	 */
+	default TableCreateBuilder addForeignKey(@NotNull String tableColumn, @Nullable String constraintName,
+											 @NotNull String foreignTable, @NotNull String foreignColumn) {
+		return addForeignKey(tableColumn, constraintName, foreignTable, foreignColumn, null, null);
+	}
+
+	/**
+	 * 以本表位从表，为表中某列设定外键。
+	 *
+	 * <p>外键约束（FOREIGN KEY）是表的一个特殊字段，经常与主键约束一起使用。
+	 * <br>外键用来建立主表与从表的关联关系，为两个表的数据建立连接，约束两个表中数据的一致性和完整性。
+	 * <br>主表删除某条记录时，从表中与之对应的记录也必须有相应的改变。
+	 *
+	 * @param tableColumn    本表中的列
+	 * @param constraintName 约束名，缺省时将使用参数自动生成，如 <i>fk_[tableColumn]_[foreignTable]</i>
+	 * @param foreignTable   外键关联主表，必须为已存在的表或本表，且必须有主键。
+	 * @param foreignColumn  外键关联主表中对应的关联列，须满足
+	 *                       <p> 1. 为主表的主键，即 {@link IndexType#PRIMARY_KEY}
+	 *                       <p> 2. 数据类型必须和所要建立主键的列的数据类型相同。
+	 * @param updateRule     在外键被更新时采用的规则，缺省时默认为{@link ForeignKeyRule#RESTRICT}
+	 * @param deleteRule     在外键被删除时采用的规则，缺省时默认为{@link ForeignKeyRule#RESTRICT}
+	 * @return {@link TableCreateBuilder}
+	 */
+	TableCreateBuilder addForeignKey(@NotNull String tableColumn, @Nullable String constraintName,
+									 @NotNull String foreignTable, @NotNull String foreignColumn,
+									 @Nullable ForeignKeyRule updateRule, @Nullable ForeignKeyRule deleteRule);
+
+	default String defaultTablesSettings() {
+		return "ENGINE=InnoDB DEFAULT CHARSET=utf8";
+	}
 
 }

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

@@ -1,20 +1,20 @@
 package cc.carm.lib.easysql.api.builder;
 
-import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
+import cc.carm.lib.easysql.api.SQLAction;
 
 import java.util.LinkedHashMap;
 
-public interface UpdateBuilder extends ConditionalBuilder<UpdateBuilder, PreparedSQLUpdateAction> {
+public interface UpdateBuilder extends ConditionalBuilder<UpdateBuilder, SQLAction<Integer>> {
 
-    String getTableName();
+	String getTableName();
 
-    UpdateBuilder setColumnValues(LinkedHashMap<String, Object> columnData);
+	UpdateBuilder setColumnValues(LinkedHashMap<String, Object> columnData);
 
-    UpdateBuilder setColumnValues(String[] columnNames, Object[] columnValues);
+	UpdateBuilder setColumnValues(String[] columnNames, Object[] columnValues);
 
-    default UpdateBuilder setColumnValues(String columnName, Object columnValue) {
-        return setColumnValues(new String[]{columnName}, new Object[]{columnValue});
-    }
+	default UpdateBuilder setColumnValues(String columnName, Object columnValue) {
+		return setColumnValues(new String[]{columnName}, new Object[]{columnValue});
+	}
 
 
 }

easysql-api/src/main/java/cc/carm/lib/easysql/api/builder/UpsertBuilder.java

@@ -1,9 +1,15 @@
 package cc.carm.lib.easysql.api.builder;
 
+/**
+ * 存在则更新，不存在则插入。
+ *
+ * @see ReplaceBuilder
+ */
+@Deprecated
 public interface UpsertBuilder {
 
-    String getTableName();
+	String getTableName();
 
-    UpsertBuilder setColumnNames(String[] columnNames, String updateColumn);
+	UpsertBuilder setColumnNames(String[] columnNames, String updateColumn);
 
 }

easysql-api/src/main/java/cc/carm/lib/easysql/api/enums/ForeignKeyRule.java

@@ -0,0 +1,41 @@
+package cc.carm.lib.easysql.api.enums;
+
+public enum ForeignKeyRule {
+
+	/**
+	 * 啥也不做
+	 * <p>注意： 在Mysql中该选项实际上等同于采用默认的 {@link #RESTRICT} 设定！
+	 */
+	NO_ACTION("NO ACTION"),
+
+	/**
+	 * 拒绝删除要求，直到使用删除键值的辅助表被手工删除，并且没有参照时(这是默认设置，也是最安全的设置)
+	 */
+	RESTRICT("RESTRICT"),
+
+	/**
+	 * 修改包含与已删除键值有参照关系的所有记录，使用NULL值替换（只能用于已标记为NOT NULL的字段）
+	 */
+	SET_NULL("SET NULL"),
+
+	/**
+	 * 修改包含与已删除键值有参照关系的所有记录，使用默认值替换（只能用于设定了DEFAULT的字段）
+	 */
+	SET_DEFAULT("SET DEFAULT"),
+
+	/**
+	 * <b>级联删除</b>，删除包含与已删除键值有参照关系的所有记录
+	 */
+	CASCADE("CASCADE");
+
+	String ruleName;
+
+	ForeignKeyRule(String ruleName) {
+		this.ruleName = ruleName;
+	}
+
+	public String getRuleName() {
+		return ruleName;
+	}
+
+}

easysql-api/src/main/java/cc/carm/lib/easysql/api/enums/IndexType.java

@@ -0,0 +1,41 @@
+package cc.carm.lib.easysql.api.enums;
+
+public enum IndexType {
+
+
+	/**
+	 * <b>普通索引</b>（由关键字KEY或INDEX定义的索引）的唯一任务是加快对数据的访问速度。
+	 * <br> 因此，应该只为那些最经常出现在查询条件（WHERE column=）或排序条件（ORDER BY column）中的数据列创建索引。
+	 * <br> 只要有可能，就应该选择一个数据最整齐、最紧凑的数据列（如一个整数类型的数据列）来创建索引。
+	 */
+	INDEX("INDEX"),
+
+
+	/**
+	 * <b>唯一索引</b> 是在表上一个或者多个字段组合建立的索引，这个或者这些字段的值组合起来在表中不可以重复，用于保证数据的唯一性。
+	 */
+	UNIQUE_KEY("UNIQUE KEY"),
+
+	/**
+	 * <b>主键索引</b> 是唯一索引的特定类型。表中创建主键时自动创建的索引 。一个表只能建立一个主索引。
+	 */
+	PRIMARY_KEY("PRIMARY KEY"),
+
+	/**
+	 * <b>全文索引</b> 主要用来查找文本中的关键字，而不是直接与索引中的值相比较。
+	 * <br> 请搭配 MATCH 等语句使用，而不是使用 WHERE - LIKE 。
+	 * <br> 全文索引只可用于 CHAR、 VARCHAR 与 TEXT 系列类型。
+	 */
+	FULLTEXT_INDEX("FULLTEXT");
+
+
+	String name;
+
+	IndexType(String name) {
+		this.name = name;
+	}
+
+	public String getName() {
+		return name;
+	}
+}

easysql-api/src/main/java/cc/carm/lib/easysql/api/enums/NumberType.java

@@ -0,0 +1,11 @@
+package cc.carm.lib.easysql.api.enums;
+
+public enum NumberType {
+
+	TINYINT,
+	SMALLINT,
+	MEDIUMINT,
+	INT,
+	BIGINT
+
+}

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

@@ -7,5 +7,6 @@ import java.util.function.BiConsumer;
 
 @FunctionalInterface
 public interface SQLExceptionHandler extends BiConsumer<SQLException, SQLAction<?>> {
+	
 
 }

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

@@ -9,6 +9,6 @@ import java.sql.SQLException;
 public interface SQLFunction<T, R> {
 
 	@Nullable
-	R apply(T t) throws SQLException;
+	R apply(@NotNull T t) throws SQLException;
 
 }

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

@@ -0,0 +1,57 @@
+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;
+
+	public static void setCustomHandler(@Nullable SQLExceptionHandler handler) {
+		DefaultSQLExceptionHandler.customDefaultHandler = handler;
+	}
+
+	public static @Nullable SQLExceptionHandler getCustomHandler() {
+		return customDefaultHandler;
+	}
+
+	public static @NotNull SQLExceptionHandler get(Logger logger) {
+		if (getCustomHandler() != null) return getCustomHandler();
+		else return new DefaultSQLExceptionHandler(logger);
+	}
+
+	private final Logger logger;
+
+	public DefaultSQLExceptionHandler(Logger logger) {
+		this.logger = 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("#" + i + " {" + content + "}");
+				i++;
+			}
+
+		} else {
+			getLogger().severe("Error when execute { " + sqlAction.getSQLContent() + " }");
+		}
+		exception.printStackTrace();
+	}
+
+
+}

easysql-impl/pom.xml

@@ -5,10 +5,17 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.2.8</version>
+        <version>0.3.0</version>
     </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>
+    </properties>
+
     <artifactId>easysql-impl</artifactId>
     <packaging>jar</packaging>
 
@@ -45,14 +52,6 @@
         <url>${project.url}/actions/workflows/maven.yml</url>
     </ciManagement>
 
-    <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>
-    </properties>
-
     <dependencies>
 
         <dependency>

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

@@ -5,11 +5,9 @@ import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import cc.carm.lib.easysql.api.function.SQLHandler;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
-import org.jetbrains.annotations.Nullable;
 
 import java.sql.SQLException;
 import java.util.UUID;
-import java.util.function.BiConsumer;
 
 public abstract class AbstractSQLAction<T> implements SQLAction<T> {
 
@@ -20,8 +18,6 @@ public abstract class AbstractSQLAction<T> implements SQLAction<T> {
 
 	protected @NotNull String sqlContent;
 
-	protected @Nullable BiConsumer<SQLException, SQLAction<T>> exceptionHandler = null;
-
 	public AbstractSQLAction(@NotNull SQLManagerImpl manager, @NotNull String sql) {
 		this(manager, sql, System.currentTimeMillis());
 	}
@@ -69,10 +65,11 @@ public abstract class AbstractSQLAction<T> implements SQLAction<T> {
 	}
 
 	protected void outputDebugMessage() {
-		getManager().debug("#" + getShortID() + " ->" + getSQLContent());
+		getManager().debug("#" + getShortID() + " -> { " + getSQLContent() + " }");
 	}
 
 	@Override
+	@SuppressWarnings("FutureReturnValueIgnored")
 	public void executeAsync(SQLHandler<T> success, SQLExceptionHandler failure) {
 		getManager().getExecutorPool().submit(() -> {
 			try {

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

@@ -16,43 +16,48 @@ public class SQLUpdateBatchActionImpl
 		extends AbstractSQLAction<List<Integer>>
 		implements SQLUpdateBatchAction {
 
-    List<String> sqlContents = new ArrayList<>();
+	List<String> sqlContents = new ArrayList<>();
 
-    public SQLUpdateBatchActionImpl(@NotNull SQLManagerImpl manager, @NotNull String sql) {
-        super(manager, sql);
-        this.sqlContents.add(sql);
-    }
+	public SQLUpdateBatchActionImpl(@NotNull SQLManagerImpl manager, @NotNull String sql) {
+		super(manager, sql);
+		this.sqlContents.add(sql);
+	}
 
-    @Override
-    public @NotNull String getSQLContent() {
-        return this.sqlContents.get(0);
-    }
+	@Override
+	public @NotNull List<String> getSQLContents() {
+		return this.sqlContents;
+	}
 
-    @Override
-    public @NotNull List<String> getSQLContents() {
-        return this.sqlContents;
-    }
+	@Override
+	public SQLUpdateBatchAction addBatch(@NotNull String sql) {
+		this.sqlContents.add(sql);
+		return this;
+	}
 
-    @Override
-    public SQLUpdateBatchAction addBatch(@NotNull String sql) {
-        this.sqlContents.add(sql);
-        return this;
-    }
+	@Override
+	public @NotNull List<Integer> execute() throws SQLException {
+		Connection connection = getManager().getConnection();
+		Statement statement = connection.createStatement();
+		outputDebugMessage();
 
-    @Override
-    public @NotNull List<Integer> execute() throws SQLException {
-        Connection connection = getManager().getConnection();
-        Statement statement = connection.createStatement();
-        outputDebugMessage();
-        for (String content : this.sqlContents) {
-            statement.addBatch(content);
-        }
-        int[] executed = statement.executeBatch();
-        List<Integer> returnedValues = Arrays.stream(executed).boxed().collect(Collectors.toList());
+		for (String content : this.sqlContents) {
+			statement.addBatch(content);
+		}
+		int[] executed = statement.executeBatch();
+		List<Integer> returnedValues = Arrays.stream(executed).boxed().collect(Collectors.toList());
 
-        statement.close();
-        connection.close();
+		statement.close();
+		connection.close();
+
+		return returnedValues;
+	}
+
+	@Override
+	protected void outputDebugMessage() {
+		getManager().debug("#" + getShortID() + " -> {");
+		for (String content : getSQLContents()) getManager().debug("  " + content);
+		getManager().debug("}");
+
+	}
 
-        return returnedValues;
-    }
 }

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

@@ -50,8 +50,9 @@ public class PreparedQueryActionImpl extends QueryActionImpl implements Prepared
 
 	@Override
 	public @NotNull SQLQueryImpl execute() throws SQLException {
+		outputDebugMessage();
+
 		Connection connection = getManager().getConnection();
-		getManager().debug("#" + getShortID() + " ->" + getSQLContent());
 		PreparedStatement preparedStatement;
 		if (handler == null) {
 			preparedStatement = StatementUtil.createPrepareStatement(connection, getSQLContent(), this.params);
@@ -60,8 +61,14 @@ public class PreparedQueryActionImpl extends QueryActionImpl implements Prepared
 			handler.accept(preparedStatement);
 		}
 
+		long executeTime = System.currentTimeMillis();
 		ResultSet resultSet = preparedStatement.executeQuery();
 
-		return new SQLQueryImpl(getManager(), this, connection, preparedStatement, resultSet);
+		return new SQLQueryImpl(
+				getManager(), this,
+				connection, preparedStatement, resultSet,
+				executeTime
+		);
+
 	}
 }

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

@@ -1,8 +1,8 @@
 package cc.carm.lib.easysql.action.query;
 
 import cc.carm.lib.easysql.action.AbstractSQLAction;
-import cc.carm.lib.easysql.api.action.query.QueryAction;
 import cc.carm.lib.easysql.api.SQLQuery;
+import cc.carm.lib.easysql.api.action.query.QueryAction;
 import cc.carm.lib.easysql.api.function.SQLExceptionHandler;
 import cc.carm.lib.easysql.api.function.SQLHandler;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -22,13 +22,20 @@ public class QueryActionImpl extends AbstractSQLAction<SQLQuery> implements Quer
 
 	@Override
 	public @NotNull SQLQueryImpl execute() throws SQLException {
+
 		Connection connection = getManager().getConnection();
 		Statement statement = connection.createStatement();
 
 		outputDebugMessage();
 
+		long executeTime = System.currentTimeMillis();
 		ResultSet resultSet = statement.executeQuery(getSQLContent());
-		SQLQueryImpl query = new SQLQueryImpl(getManager(), this, connection, statement, resultSet);
+		SQLQueryImpl query = new SQLQueryImpl(
+				getManager(), this,
+				connection, statement, resultSet,
+				executeTime
+		);
+
 		getManager().getActiveQuery().put(getActionUUID(), query);
 
 		return query;

easysql-impl/src/main/java/cc/carm/lib/easysql/builder/impl/AbstractConditionalBuilder.java

@@ -1,5 +1,6 @@
 package cc.carm.lib.easysql.builder.impl;
 
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.builder.ConditionalBuilder;
 import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -13,132 +14,132 @@ import java.util.Date;
 import java.util.Iterator;
 import java.util.LinkedHashMap;
 
-public abstract class AbstractConditionalBuilder<B extends ConditionalBuilder<B, T>, T>
-        extends AbstractSQLBuilder implements ConditionalBuilder<B, T> {
+public abstract class AbstractConditionalBuilder<B extends ConditionalBuilder<B, T>, T extends SQLAction<?>>
+		extends AbstractSQLBuilder implements ConditionalBuilder<B, T> {
 
-    ArrayList<String> conditionSQLs = new ArrayList<>();
-    ArrayList<Object> conditionParams = new ArrayList<>();
-    int limit = -1;
+	ArrayList<String> conditionSQLs = new ArrayList<>();
+	ArrayList<Object> conditionParams = new ArrayList<>();
+	int limit = -1;
 
-    public AbstractConditionalBuilder(@NotNull SQLManagerImpl manager) {
-        super(manager);
-    }
+	public AbstractConditionalBuilder(@NotNull SQLManagerImpl manager) {
+		super(manager);
+	}
 
-    protected abstract B getThis();
+	protected abstract B getThis();
 
-    @Override
-    public B setConditions(@Nullable String condition) {
-        this.conditionSQLs = new ArrayList<>();
-        this.conditionParams = new ArrayList<>();
-        if (condition != null) this.conditionSQLs.add(condition);
-        return getThis();
-    }
+	@Override
+	public B setConditions(@Nullable String condition) {
+		this.conditionSQLs = new ArrayList<>();
+		this.conditionParams = new ArrayList<>();
+		if (condition != null) this.conditionSQLs.add(condition);
+		return getThis();
+	}
 
-    @Override
-    public B setConditions(
-            LinkedHashMap<@NotNull String, @Nullable Object> conditions
-    ) {
-        conditions.forEach(this::addCondition);
-        return getThis();
-    }
+	@Override
+	public B setConditions(
+			LinkedHashMap<@NotNull String, @Nullable Object> conditions
+	) {
+		conditions.forEach(this::addCondition);
+		return getThis();
+	}
 
-    @Override
-    public B addCondition(@Nullable String condition) {
-        this.conditionSQLs.add(condition);
-        return getThis();
-    }
+	@Override
+	public B addCondition(@Nullable String condition) {
+		this.conditionSQLs.add(condition);
+		return getThis();
+	}
 
-    @Override
-    public B addCondition(
-            @NotNull String queryName, @NotNull String operator, @Nullable Object queryValue
-    ) {
-        addCondition("`" + queryName + "` " + operator + " ?");
-        this.conditionParams.add(queryValue);
-        return getThis();
-    }
+	@Override
+	public B addCondition(
+			@NotNull String queryName, @NotNull String operator, @Nullable Object queryValue
+	) {
+		addCondition("`" + queryName + "` " + operator + " ?");
+		this.conditionParams.add(queryValue);
+		return getThis();
+	}
 
-    @Override
-    public B addCondition(
-            @NotNull String[] queryNames, @Nullable Object[] queryValues
-    ) {
-        if (queryNames.length != queryValues.length) {
-            throw new RuntimeException("queryNames are not match with queryValues");
-        }
-        for (int i = 0; i < queryNames.length; i++) {
-            addCondition(queryNames[i], queryValues[i]);
-        }
-        return getThis();
-    }
+	@Override
+	public B addCondition(
+			@NotNull String[] queryNames, @Nullable Object[] queryValues
+	) {
+		if (queryNames.length != queryValues.length) {
+			throw new RuntimeException("queryNames are not match with queryValues");
+		}
+		for (int i = 0; i < queryNames.length; i++) {
+			addCondition(queryNames[i], queryValues[i]);
+		}
+		return getThis();
+	}
 
 
-    @Override
-    public B addNotNullCondition(@NotNull String queryName) {
-        return addCondition("`" + queryName + "` IS NOT NULL");
-    }
+	@Override
+	public B addNotNullCondition(@NotNull String queryName) {
+		return addCondition("`" + queryName + "` IS NOT NULL");
+	}
 
 
-    @Override
-    public B addTimeCondition(
-            @NotNull String queryName, @Nullable Date startDate, @Nullable Date endDate
-    ) {
-        if (startDate == null && endDate == null) return getThis(); // 都不限定时间，不用判断了
-        if (startDate != null) {
-            addCondition("`" + queryName + "` BETWEEN ? AND ?");
-            this.conditionParams.add(startDate);
-            if (endDate != null) {
-                this.conditionParams.add(endDate);
-            } else {
-                if (startDate instanceof java.sql.Date) {
-                    this.conditionParams.add(new java.sql.Date(System.currentTimeMillis()));
-                } else if (startDate instanceof Time) {
-                    this.conditionParams.add(new Time(System.currentTimeMillis()));
-                } else {
-                    this.conditionParams.add(new Timestamp(System.currentTimeMillis()));
-                }
-            }
-        } else {
-            addCondition(queryName, "<=", endDate);
-        }
-        return getThis();
-    }
+	@Override
+	public B addTimeCondition(
+			@NotNull String queryName, @Nullable Date startDate, @Nullable Date endDate
+	) {
+		if (startDate == null && endDate == null) return getThis(); // 都不限定时间，不用判断了
+		if (startDate != null) {
+			addCondition("`" + queryName + "` BETWEEN ? AND ?");
+			this.conditionParams.add(startDate);
+			if (endDate != null) {
+				this.conditionParams.add(endDate);
+			} else {
+				if (startDate instanceof java.sql.Date) {
+					this.conditionParams.add(new java.sql.Date(System.currentTimeMillis()));
+				} else if (startDate instanceof Time) {
+					this.conditionParams.add(new Time(System.currentTimeMillis()));
+				} else {
+					this.conditionParams.add(new Timestamp(System.currentTimeMillis()));
+				}
+			}
+		} else {
+			addCondition(queryName, "<=", endDate);
+		}
+		return getThis();
+	}
 
 
-    @Override
-    public B setLimit(int limit) {
-        this.limit = limit;
-        return getThis();
-    }
+	@Override
+	public B setLimit(int limit) {
+		this.limit = limit;
+		return getThis();
+	}
 
-    protected String buildConditionSQL() {
+	protected String buildConditionSQL() {
 
-        if (!conditionSQLs.isEmpty()) {
-            StringBuilder conditionBuilder = new StringBuilder();
-            conditionBuilder.append("WHERE").append(" ");
-            Iterator<String> iterator = conditionSQLs.iterator();
-            while (iterator.hasNext()) {
-                conditionBuilder.append(iterator.next());
-                if (iterator.hasNext()) conditionBuilder.append(" ");
-            }
-            return conditionBuilder.toString();
-        } else {
-            return null;
-        }
+		if (!conditionSQLs.isEmpty()) {
+			StringBuilder conditionBuilder = new StringBuilder();
+			conditionBuilder.append("WHERE").append(" ");
+			Iterator<String> iterator = conditionSQLs.iterator();
+			while (iterator.hasNext()) {
+				conditionBuilder.append(iterator.next());
+				if (iterator.hasNext()) conditionBuilder.append(" ");
+			}
+			return conditionBuilder.toString();
+		} else {
+			return null;
+		}
 
-    }
+	}
 
-    protected String buildLimitSQL() {
-        return limit > 0 ? "LIMIT " + limit : "";
-    }
+	protected String buildLimitSQL() {
+		return limit > 0 ? "LIMIT " + limit : "";
+	}
 
-    protected ArrayList<Object> getConditionParams() {
-        return conditionParams;
-    }
+	protected ArrayList<Object> getConditionParams() {
+		return conditionParams;
+	}
 
-    protected boolean hasConditions() {
-        return this.conditionSQLs != null && !this.conditionSQLs.isEmpty();
-    }
+	protected boolean hasConditions() {
+		return this.conditionSQLs != null && !this.conditionSQLs.isEmpty();
+	}
 
-    protected boolean hasConditionParams() {
-        return hasConditions() && getConditionParams() != null && !getConditionParams().isEmpty();
-    }
+	protected boolean hasConditionParams() {
+		return hasConditions() && getConditionParams() != null && !getConditionParams().isEmpty();
+	}
 }

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

@@ -1,47 +1,48 @@
 package cc.carm.lib.easysql.builder.impl;
 
 import cc.carm.lib.easysql.action.PreparedSQLUpdateActionImpl;
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
 import cc.carm.lib.easysql.api.builder.DeleteBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
 
 public class DeleteBuilderImpl
-        extends AbstractConditionalBuilder<DeleteBuilder, PreparedSQLUpdateAction>
-        implements DeleteBuilder {
+		extends AbstractConditionalBuilder<DeleteBuilder, SQLAction<Integer>>
+		implements DeleteBuilder {
 
-    String tableName;
+	String tableName;
 
-    public DeleteBuilderImpl(@NotNull SQLManagerImpl manager, @NotNull String tableName) {
-        super(manager);
-        this.tableName = tableName;
-    }
+	public DeleteBuilderImpl(@NotNull SQLManagerImpl manager, @NotNull String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
 
-    @Override
-    public PreparedSQLUpdateAction build() {
+	@Override
+	public PreparedSQLUpdateAction build() {
 
-        StringBuilder sqlBuilder = new StringBuilder();
+		StringBuilder sqlBuilder = new StringBuilder();
 
-        sqlBuilder.append("DELETE FROM `").append(getTableName()).append("`");
+		sqlBuilder.append("DELETE FROM `").append(getTableName()).append("`");
 
-        if (hasConditions()) sqlBuilder.append(" ").append(buildConditionSQL());
-        if (limit > 0) sqlBuilder.append(" ").append(buildLimitSQL());
+		if (hasConditions()) sqlBuilder.append(" ").append(buildConditionSQL());
+		if (limit > 0) sqlBuilder.append(" ").append(buildLimitSQL());
 
-        return new PreparedSQLUpdateActionImpl(
-                getManager(), sqlBuilder.toString(),
-                hasConditionParams() ? getConditionParams() : null
-        );
-    }
+		return new PreparedSQLUpdateActionImpl(
+				getManager(), sqlBuilder.toString(),
+				hasConditionParams() ? getConditionParams() : null
+		);
+	}
 
-    @Override
-    public String getTableName() {
-        return tableName;
-    }
+	@Override
+	public String getTableName() {
+		return tableName;
+	}
 
 
-    @Override
-    protected DeleteBuilderImpl getThis() {
-        return this;
-    }
+	@Override
+	protected DeleteBuilderImpl getThis() {
+		return this;
+	}
 
 }

easysql-impl/src/main/java/cc/carm/lib/easysql/builder/impl/InsertBuilderImpl.java

@@ -1,5 +1,6 @@
 package cc.carm.lib.easysql.builder.impl;
 
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.builder.InsertBuilder;
 import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -8,39 +9,41 @@ import org.jetbrains.annotations.NotNull;
 import java.util.Iterator;
 import java.util.List;
 
-public abstract class InsertBuilderImpl<T> extends AbstractSQLBuilder implements InsertBuilder<T> {
+public abstract class InsertBuilderImpl<T extends SQLAction<?>>
+		extends AbstractSQLBuilder implements InsertBuilder<T> {
 
-    String tableName;
+	String tableName;
 
-    public InsertBuilderImpl(@NotNull SQLManagerImpl manager, String tableName) {
-        super(manager);
-        this.tableName = tableName;
-    }
+	public InsertBuilderImpl(@NotNull SQLManagerImpl manager, String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
 
-    protected static String buildSQL(String tableName, List<String> columnNames) {
-        int valueLength = columnNames.size();
-        StringBuilder sqlBuilder = new StringBuilder();
+	protected static String buildSQL(String tableName, List<String> columnNames) {
+		int valueLength = columnNames.size();
+		StringBuilder sqlBuilder = new StringBuilder();
 
-        sqlBuilder.append("INSERT IGNORE INTO `").append(tableName).append("`(");
-        Iterator<String> iterator = columnNames.iterator();
-        while (iterator.hasNext()) {
-            sqlBuilder.append("`").append(iterator.next()).append("`");
-            if (iterator.hasNext()) sqlBuilder.append(", ");
-        }
+		sqlBuilder.append("INSERT IGNORE INTO `").append(tableName).append("`(");
+		Iterator<String> iterator = columnNames.iterator();
+		while (iterator.hasNext()) {
+			sqlBuilder.append("`").append(iterator.next()).append("`");
+			if (iterator.hasNext()) sqlBuilder.append(", ");
+		}
 
-        sqlBuilder.append(") VALUES (");
+		sqlBuilder.append(") VALUES (");
 
-        for (int i = 0; i < valueLength; i++) {
-            sqlBuilder.append("?");
-            if (i != valueLength - 1) {
-                sqlBuilder.append(", ");
-            }
-        }
-        sqlBuilder.append(")");
-        return sqlBuilder.toString();
-    }
+		for (int i = 0; i < valueLength; i++) {
+			sqlBuilder.append("?");
+			if (i != valueLength - 1) {
+				sqlBuilder.append(", ");
+			}
+		}
+		sqlBuilder.append(")");
+		return sqlBuilder.toString();
+	}
 
-    public String getTableName() {
-        return tableName;
-    }
+	@Override
+	public String getTableName() {
+		return tableName;
+	}
 }

easysql-impl/src/main/java/cc/carm/lib/easysql/builder/impl/ReplaceBuilderImpl.java

@@ -1,5 +1,6 @@
 package cc.carm.lib.easysql.builder.impl;
 
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.builder.ReplaceBuilder;
 import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -8,39 +9,41 @@ import org.jetbrains.annotations.NotNull;
 import java.util.Iterator;
 import java.util.List;
 
-public abstract class ReplaceBuilderImpl<T> extends AbstractSQLBuilder implements ReplaceBuilder<T> {
+public abstract class ReplaceBuilderImpl<T extends SQLAction<?>>
+		extends AbstractSQLBuilder implements ReplaceBuilder<T> {
 
-    String tableName;
+	String tableName;
 
-    public ReplaceBuilderImpl(@NotNull SQLManagerImpl manager, String tableName) {
-        super(manager);
-        this.tableName = tableName;
-    }
+	public ReplaceBuilderImpl(@NotNull SQLManagerImpl manager, String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
 
-    protected static String buildSQL(String tableName, List<String> columnNames) {
-        int valueLength = columnNames.size();
-        StringBuilder sqlBuilder = new StringBuilder();
+	protected static String buildSQL(String tableName, List<String> columnNames) {
+		int valueLength = columnNames.size();
+		StringBuilder sqlBuilder = new StringBuilder();
 
-        sqlBuilder.append("REPLACE INTO `").append(tableName).append("`(");
-        Iterator<String> iterator = columnNames.iterator();
-        while (iterator.hasNext()) {
-            sqlBuilder.append("`").append(iterator.next()).append("`");
-            if (iterator.hasNext()) sqlBuilder.append(", ");
-        }
+		sqlBuilder.append("REPLACE INTO `").append(tableName).append("`(");
+		Iterator<String> iterator = columnNames.iterator();
+		while (iterator.hasNext()) {
+			sqlBuilder.append("`").append(iterator.next()).append("`");
+			if (iterator.hasNext()) sqlBuilder.append(", ");
+		}
 
-        sqlBuilder.append(") VALUES (");
+		sqlBuilder.append(") VALUES (");
 
-        for (int i = 0; i < valueLength; i++) {
-            sqlBuilder.append("?");
-            if (i != valueLength - 1) {
-                sqlBuilder.append(", ");
-            }
-        }
-        sqlBuilder.append(")");
-        return sqlBuilder.toString();
-    }
+		for (int i = 0; i < valueLength; i++) {
+			sqlBuilder.append("?");
+			if (i != valueLength - 1) {
+				sqlBuilder.append(", ");
+			}
+		}
+		sqlBuilder.append(")");
+		return sqlBuilder.toString();
+	}
 
-    public String getTableName() {
-        return tableName;
-    }
+	@Override
+	public String getTableName() {
+		return tableName;
+	}
 }

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

@@ -0,0 +1,130 @@
+package cc.carm.lib.easysql.builder.impl;
+
+import cc.carm.lib.easysql.action.SQLUpdateActionImpl;
+import cc.carm.lib.easysql.api.SQLAction;
+import cc.carm.lib.easysql.api.builder.TableAlterBuilder;
+import cc.carm.lib.easysql.api.enums.IndexType;
+import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
+import cc.carm.lib.easysql.manager.SQLManagerImpl;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+public class TableAlterBuilderImpl extends AbstractSQLBuilder implements TableAlterBuilder {
+
+	protected final @NotNull String tableName;
+
+	public TableAlterBuilderImpl(@NotNull SQLManagerImpl manager, @NotNull String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
+
+	public @NotNull String getTableName() {
+		return tableName;
+	}
+
+	@Override
+	public SQLAction<Integer> renameTo(@NotNull String newTableName) {
+		return new SQLUpdateActionImpl(getManager(),
+				"ALTER TABLE `" + getTableName() + "` RENAME TO `" + newTableName + "`"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> changeComment(@NotNull String newTableComment) {
+		return new SQLUpdateActionImpl(getManager(),
+				"ALTER TABLE `" + getTableName() + "` COMMENT '" + newTableComment + "'"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> setAutoIncrementIndex(int index) {
+		return new SQLUpdateActionImpl(getManager(),
+				"ALTER TABLE `" + getTableName() + "` AUTO_INCREMENT=" + index
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> addIndex(@NotNull IndexType indexType, @NotNull String indexName, @NotNull String columnName, @NotNull String... moreColumns) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` ADD "
+						+ TableCreateBuilderImpl.buildIndexSettings(indexType, indexName, columnName, moreColumns)
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> dropIndex(@NotNull String indexName) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` DROP INDEX `" + indexName + "`"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> dropForeignKey(@NotNull String keySymbol) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` DROP FOREIGN KEY `" + keySymbol + "`"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> dropPrimaryKey() {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` DROP PRIMARY KEY"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> addColumn(@NotNull String columnName, @NotNull String settings, @Nullable String afterColumn) {
+		String orderSettings = null;
+		if (afterColumn != null) {
+			if (afterColumn.length() > 0) {
+				orderSettings = "AFTER `" + afterColumn + "`";
+			} else {
+				orderSettings = "FIRST";
+			}
+		}
+
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` ADD `" + columnName + "` " + settings
+						+ (orderSettings != null ? " " + orderSettings : "")
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> renameColumn(@NotNull String columnName, @NotNull String newName) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` RENAME COLUMN `" + columnName + "` TO `" + newName + "`"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> modifyColumn(@NotNull String columnName, @NotNull String settings) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` MODIFY COLUMN `" + columnName + "` " + settings
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> removeColumn(@NotNull String columnName) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` DROP `" + columnName + "`"
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> setColumnDefault(@NotNull String columnName, @NotNull String defaultValue) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` ALTER `" + columnName + "` SET DEFAULT " + defaultValue
+		);
+	}
+
+	@Override
+	public SQLAction<Integer> removeColumnDefault(@NotNull String columnName) {
+		return createAction(
+				"ALTER TABLE `" + getTableName() + "` ALTER `" + columnName + "` DROP DEFAULT"
+		);
+	}
+
+	private SQLUpdateActionImpl createAction(@NotNull String sql) {
+		return new SQLUpdateActionImpl(getManager(), sql);
+	}
+}

easysql-impl/src/main/java/cc/carm/lib/easysql/builder/impl/TableCreateBuilderImpl.java

@@ -3,9 +3,13 @@ package cc.carm.lib.easysql.builder.impl;
 import cc.carm.lib.easysql.action.SQLUpdateActionImpl;
 import cc.carm.lib.easysql.api.action.SQLUpdateAction;
 import cc.carm.lib.easysql.api.builder.TableCreateBuilder;
+import cc.carm.lib.easysql.api.enums.ForeignKeyRule;
+import cc.carm.lib.easysql.api.enums.IndexType;
+import cc.carm.lib.easysql.api.enums.NumberType;
 import cc.carm.lib.easysql.builder.AbstractSQLBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
 import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
 
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -13,59 +17,142 @@ import java.util.List;
 
 public class TableCreateBuilderImpl extends AbstractSQLBuilder implements TableCreateBuilder {
 
-    String tableName;
+	protected final @NotNull String tableName;
 
-    List<String> columns;
+	@NotNull List<String> columns = new ArrayList<>();
+	@NotNull List<String> indexes = new ArrayList<>();
+	@NotNull List<String> foreignKeys = new ArrayList<>();
 
-    String tableSettings;
+	@NotNull String tableSettings = defaultTablesSettings();
+	@Nullable String tableComment;
 
-    public TableCreateBuilderImpl(SQLManagerImpl manager, String tableName) {
-        super(manager);
-        this.tableName = tableName;
-        this.columns = new ArrayList<>();
-        defaultTablesSettings();
-    }
+	public TableCreateBuilderImpl(SQLManagerImpl manager, @NotNull String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
 
-    @Override
-    public @NotNull String getTableName() {
-        return this.tableName;
-    }
+	@Override
+	public @NotNull String getTableName() {
+		return this.tableName;
+	}
 
-    @Override
-    public @NotNull String getTableSettings() {
-        return this.tableSettings;
-    }
+	@Override
+	public @NotNull String getTableSettings() {
+		return this.tableSettings;
+	}
 
-    @Override
-    public SQLUpdateAction build() {
-        StringBuilder createSQL = new StringBuilder();
-        createSQL.append("CREATE TABLE IF NOT EXISTS `").append(tableName).append("`");
-        createSQL.append("(");
-        for (int i = 0; i < columns.size(); i++) {
-            createSQL.append(columns.get(i));
-            if (i != columns.size() - 1) createSQL.append(", ");
-        }
-        createSQL.append(") ").append(tableSettings);
+	@Override
+	public SQLUpdateAction build() {
+		StringBuilder createSQL = new StringBuilder();
+		createSQL.append("CREATE TABLE IF NOT EXISTS `").append(tableName).append("`");
+		createSQL.append("(");
+		createSQL.append(String.join(", ", columns));
+		if (indexes.size() > 0) {
+			createSQL.append(", ");
+			createSQL.append(String.join(", ", indexes));
+		}
+		if (foreignKeys.size() > 0) {
+			createSQL.append(", ");
+			createSQL.append(String.join(", ", foreignKeys));
+		}
+		createSQL.append(") ").append(getTableSettings());
 
-        return new SQLUpdateActionImpl(getManager(), createSQL.toString());
-    }
+		if (tableComment != null) {
+			createSQL.append(" COMMENT '").append(tableComment).append("'");
+		}
 
-    @Override
-    public TableCreateBuilder addColumn(@NotNull String column) {
-        this.columns.add(column);
-        return this;
-    }
+		return new SQLUpdateActionImpl(getManager(), createSQL.toString());
+	}
 
-    @Override
-    public TableCreateBuilder setColumns(@NotNull String[] columns) {
-        this.columns = Arrays.asList(columns);
-        return this;
-    }
+	@Override
+	public TableCreateBuilder addColumn(@NotNull String column) {
+		this.columns.add(column);
+		return this;
+	}
 
-    @Override
-    public TableCreateBuilder setTableSettings(@NotNull String settings) {
-        this.tableSettings = settings;
-        return this;
-    }
+	@Override
+	public TableCreateBuilder addAutoIncrementColumn(@NotNull String columnName, @Nullable NumberType numberType,
+													 boolean asPrimaryKey, boolean unsigned) {
+		return addColumn(columnName,
+				(numberType == null ? NumberType.INT : numberType).name()
+						+ (unsigned ? " UNSIGNED " : " ")
+						+ "NOT NULL AUTO_INCREMENT " + (asPrimaryKey ? "PRIMARY KEY" : "UNIQUE KEY")
+		);
+	}
+
+	@Override
+	public TableCreateBuilder setIndex(@NotNull IndexType type, @Nullable String indexName,
+									   @NotNull String columnName, @NotNull String... moreColumns) {
+		this.indexes.add(buildIndexSettings(type, indexName, columnName, moreColumns));
+		return this;
+	}
+
+	@Override
+	public TableCreateBuilder addForeignKey(@NotNull String tableColumn, @Nullable String constraintName,
+											@NotNull String foreignTable, @NotNull String foreignColumn,
+											@Nullable ForeignKeyRule updateRule, @Nullable ForeignKeyRule deleteRule) {
+		StringBuilder keyBuilder = new StringBuilder();
+
+		keyBuilder.append("CONSTRAINT ");
+		if (constraintName == null) {
+			keyBuilder.append("`").append("fk_").append(tableColumn).append("_").append(foreignTable).append("`");
+		} else {
+			keyBuilder.append("`").append(constraintName).append("`");
+		}
+		keyBuilder.append(" ");
+		keyBuilder.append("FOREIGN KEY (`").append(tableColumn).append("`) ");
+		keyBuilder.append("REFERENCES `").append(foreignTable).append("`(`").append(foreignColumn).append("`)");
+
+		if (updateRule != null) keyBuilder.append(" ON UPDATE ").append(updateRule.getRuleName());
+		if (deleteRule != null) keyBuilder.append(" ON DELETE ").append(deleteRule.getRuleName());
+
+		this.foreignKeys.add(keyBuilder.toString());
+		return this;
+	}
+
+	@Override
+	public TableCreateBuilder setColumns(@NotNull String[] columns) {
+		this.columns = Arrays.asList(columns);
+		return this;
+	}
+
+	@Override
+	public TableCreateBuilder setTableSettings(@NotNull String settings) {
+		this.tableSettings = settings;
+		return this;
+	}
+
+	@Override
+	public TableCreateBuilder setTableComment(@Nullable String comment) {
+		this.tableComment = comment;
+		return this;
+	}
+
+	protected static String buildIndexSettings(@NotNull IndexType indexType, @Nullable String indexName,
+											   @NotNull String columnName, @NotNull String... moreColumns) {
+
+		StringBuilder indexBuilder = new StringBuilder();
+
+		indexBuilder.append(indexType.getName()).append(" ");
+		if (indexName != null) {
+			indexBuilder.append("`").append(indexName).append("`");
+		}
+		indexBuilder.append("(");
+		indexBuilder.append("`").append(columnName).append("`");
+
+		if (moreColumns.length > 0) {
+			indexBuilder.append(", ");
+
+			for (int i = 0; i < moreColumns.length; i++) {
+				indexBuilder.append(moreColumns[i]);
+				if (i != moreColumns.length - 1) indexBuilder.append(", ");
+			}
+
+		}
+
+		indexBuilder.append(")");
+
+		return indexBuilder.toString();
+	}
 
 }

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

@@ -1,6 +1,7 @@
 package cc.carm.lib.easysql.builder.impl;
 
 import cc.carm.lib.easysql.action.PreparedSQLUpdateActionImpl;
+import cc.carm.lib.easysql.api.SQLAction;
 import cc.carm.lib.easysql.api.action.PreparedSQLUpdateAction;
 import cc.carm.lib.easysql.api.builder.UpdateBuilder;
 import cc.carm.lib.easysql.manager.SQLManagerImpl;
@@ -9,72 +10,72 @@ import org.jetbrains.annotations.NotNull;
 import java.util.*;
 
 public class UpdateBuilderImpl
-        extends AbstractConditionalBuilder<UpdateBuilder, PreparedSQLUpdateAction>
-        implements UpdateBuilder {
+		extends AbstractConditionalBuilder<UpdateBuilder, SQLAction<Integer>>
+		implements UpdateBuilder {
 
-    String tableName;
+	String tableName;
 
-    List<String> columnNames;
-    List<Object> columnValues;
+	List<String> columnNames;
+	List<Object> columnValues;
 
-    public UpdateBuilderImpl(@NotNull SQLManagerImpl manager, @NotNull String tableName) {
-        super(manager);
-        this.tableName = tableName;
-    }
+	public UpdateBuilderImpl(@NotNull SQLManagerImpl manager, @NotNull String tableName) {
+		super(manager);
+		this.tableName = tableName;
+	}
 
-    @Override
-    public PreparedSQLUpdateAction build() {
+	@Override
+	public PreparedSQLUpdateAction build() {
 
-        StringBuilder sqlBuilder = new StringBuilder();
+		StringBuilder sqlBuilder = new StringBuilder();
 
-        sqlBuilder.append("UPDATE `").append(getTableName()).append("` SET ");
+		sqlBuilder.append("UPDATE `").append(getTableName()).append("` SET ");
 
-        Iterator<String> iterator = this.columnNames.iterator();
-        while (iterator.hasNext()) {
-            sqlBuilder.append("`").append(iterator.next()).append("` = ?");
-            if (iterator.hasNext()) sqlBuilder.append(" , ");
-        }
-        List<Object> allParams = new ArrayList<>(this.columnValues);
+		Iterator<String> iterator = this.columnNames.iterator();
+		while (iterator.hasNext()) {
+			sqlBuilder.append("`").append(iterator.next()).append("` = ?");
+			if (iterator.hasNext()) sqlBuilder.append(" , ");
+		}
+		List<Object> allParams = new ArrayList<>(this.columnValues);
 
-        if (hasConditions()) {
-            sqlBuilder.append(" ").append(buildConditionSQL());
-            allParams.addAll(getConditionParams());
-        }
+		if (hasConditions()) {
+			sqlBuilder.append(" ").append(buildConditionSQL());
+			allParams.addAll(getConditionParams());
+		}
 
-        if (limit > 0) sqlBuilder.append(" ").append(buildLimitSQL());
+		if (limit > 0) sqlBuilder.append(" ").append(buildLimitSQL());
 
-        return new PreparedSQLUpdateActionImpl(getManager(), sqlBuilder.toString(), allParams);
-    }
+		return new PreparedSQLUpdateActionImpl(getManager(), sqlBuilder.toString(), allParams);
+	}
 
-    @Override
-    public String getTableName() {
-        return tableName;
-    }
+	@Override
+	public String getTableName() {
+		return tableName;
+	}
 
-    @Override
-    public UpdateBuilder setColumnValues(LinkedHashMap<String, Object> columnData) {
-        this.columnNames = new ArrayList<>();
-        this.columnValues = new ArrayList<>();
-        columnData.forEach((name, value) -> {
-            this.columnNames.add(name);
-            this.columnValues.add(value);
-        });
-        return this;
-    }
+	@Override
+	public UpdateBuilder setColumnValues(LinkedHashMap<String, Object> columnData) {
+		this.columnNames = new ArrayList<>();
+		this.columnValues = new ArrayList<>();
+		columnData.forEach((name, value) -> {
+			this.columnNames.add(name);
+			this.columnValues.add(value);
+		});
+		return this;
+	}
 
-    @Override
-    public UpdateBuilder setColumnValues(String[] columnNames, Object[] columnValues) {
-        if (columnNames.length != columnValues.length) {
-            throw new RuntimeException("columnNames are not match with columnValues");
-        }
-        this.columnNames = Arrays.asList(columnNames);
-        this.columnValues = Arrays.asList(columnValues);
-        return this;
-    }
+	@Override
+	public UpdateBuilder setColumnValues(String[] columnNames, Object[] columnValues) {
+		if (columnNames.length != columnValues.length) {
+			throw new RuntimeException("columnNames are not match with columnValues");
+		}
+		this.columnNames = Arrays.asList(columnNames);
+		this.columnValues = Arrays.asList(columnValues);
+		return this;
+	}
 
 
-    @Override
-    protected UpdateBuilder getThis() {
-        return this;
-    }
+	@Override
+	protected UpdateBuilder getThis() {
+		return this;
+	}
 }

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

@@ -129,6 +129,11 @@ public class SQLManagerImpl implements SQLManager {
 		return new TableCreateBuilderImpl(this, tableName);
 	}
 
+	@Override
+	public TableAlterBuilder alterTable(@NotNull String tableName) {
+		return new TableAlterBuilderImpl(this, tableName);
+	}
+
 	@Override
 	public QueryBuilder createQuery() {
 		return new QueryBuilderImpl(this);

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

@@ -25,7 +25,15 @@ public class SQLQueryImpl implements SQLQuery {
 			SQLManagerImpl sqlManager, QueryActionImpl queryAction,
 			Connection connection, Statement statement, ResultSet resultSet
 	) {
-		this.executeTime = System.currentTimeMillis();
+		this(sqlManager, queryAction, connection, statement, resultSet, System.currentTimeMillis());
+	}
+
+	public SQLQueryImpl(
+			SQLManagerImpl sqlManager, QueryActionImpl queryAction,
+			Connection connection, Statement statement, ResultSet resultSet,
+			long executeTime
+	) {
+		this.executeTime = executeTime;
 		this.sqlManager = sqlManager;
 		this.queryAction = queryAction;
 		this.connection = connection;

easysql-impl/src/main/java/cc/carm/lib/easysql/util/StatementUtil.java

@@ -10,195 +10,199 @@ import java.util.UUID;
 
 public class StatementUtil {
 
-    /**
-     * 创建一个 {@link PreparedStatement} 。
-     *
-     * @param connection 数据库连接
-     * @param sql        SQL语句，使用"?"做为占位符
-     * @param params     "?"所代表的对应参数列表
-     * @return 完成参数填充的 {@link PreparedStatement}
-     */
-    public static PreparedStatement createPrepareStatement(
-            Connection connection, String sql, Object[] params
-    ) throws SQLException {
-        return createPrepareStatement(connection, sql, params, false);
-    }
+	/**
+	 * 创建一个 {@link PreparedStatement} 。
+	 *
+	 * @param connection 数据库连接
+	 * @param sql        SQL语句，使用"?"做为占位符
+	 * @param params     "?"所代表的对应参数列表
+	 * @return 完成参数填充的 {@link PreparedStatement}
+	 */
+	public static PreparedStatement createPrepareStatement(
+			Connection connection, String sql, Object[] params
+	) throws SQLException {
+		return createPrepareStatement(connection, sql, params, false);
+	}
 
-    /**
-     * 创建一个 {@link PreparedStatement} 。
-     *
-     * @param connection         数据库连接
-     * @param sql                SQL语句，使用"?"做为占位符
-     * @param params             "?"所代表的对应参数列表
-     * @param returnGeneratedKey 是否会返回自增主键
-     * @return 完成参数填充的 {@link PreparedStatement}
-     */
-    public static PreparedStatement createPrepareStatement(
-            Connection connection, String sql, Object[] params, boolean returnGeneratedKey
-    ) throws SQLException {
-        sql = sql.trim();
-        PreparedStatement statement = connection.prepareStatement(sql, returnGeneratedKey ? Statement.RETURN_GENERATED_KEYS : Statement.NO_GENERATED_KEYS);
-        Map<Integer, Integer> nullTypeMap = new HashMap<>();
-        if (params != null) fillParams(statement, Arrays.asList(params), nullTypeMap);
-        statement.addBatch();
-        return statement;
-    }
+	/**
+	 * 创建一个 {@link PreparedStatement} 。
+	 *
+	 * @param connection         数据库连接
+	 * @param sql                SQL语句，使用"?"做为占位符
+	 * @param params             "?"所代表的对应参数列表
+	 * @param returnGeneratedKey 是否会返回自增主键
+	 * @return 完成参数填充的 {@link PreparedStatement}
+	 */
+	public static PreparedStatement createPrepareStatement(
+			Connection connection, String sql, Object[] params, boolean returnGeneratedKey
+	) throws SQLException {
+		sql = sql.trim();
+		PreparedStatement statement = connection.prepareStatement(sql, returnGeneratedKey ? Statement.RETURN_GENERATED_KEYS : Statement.NO_GENERATED_KEYS);
+		Map<Integer, Integer> nullTypeMap = new HashMap<>();
+		if (params != null) fillParams(statement, Arrays.asList(params), nullTypeMap);
+		statement.addBatch();
+		return statement;
+	}
 
-    /**
-     * 创建批量操作的一个 {@link PreparedStatement} 。
-     *
-     * @param connection  数据库连接
-     * @param sql         SQL语句，使用"?"做为占位符
-     * @param paramsBatch "?"所代表的对应参数列表
-     * @return 完成参数填充的 {@link PreparedStatement}
-     */
-    public static PreparedStatement createPrepareStatementBatch(
-            Connection connection, String sql, Iterable<Object[]> paramsBatch
-    ) throws SQLException {
-        return createPrepareStatementBatch(connection, sql, paramsBatch, false);
-    }
+	/**
+	 * 创建批量操作的一个 {@link PreparedStatement} 。
+	 *
+	 * @param connection  数据库连接
+	 * @param sql         SQL语句，使用"?"做为占位符
+	 * @param paramsBatch "?"所代表的对应参数列表
+	 * @return 完成参数填充的 {@link PreparedStatement}
+	 */
+	public static PreparedStatement createPrepareStatementBatch(
+			Connection connection, String sql, Iterable<Object[]> paramsBatch
+	) throws SQLException {
+		return createPrepareStatementBatch(connection, sql, paramsBatch, false);
+	}
 
-    /**
-     * 创建批量操作的一个 {@link PreparedStatement} 。
-     *
-     * @param connection         数据库连接
-     * @param sql                SQL语句，使用"?"做为占位符
-     * @param paramsBatch        "?"所代表的对应参数列表
-     * @param returnGeneratedKey 是否会返回自增主键
-     * @return 完成参数填充的 {@link PreparedStatement}
-     */
-    public static PreparedStatement createPrepareStatementBatch(
-            Connection connection, String sql, Iterable<Object[]> paramsBatch, boolean returnGeneratedKey
-    ) throws SQLException {
+	/**
+	 * 创建批量操作的一个 {@link PreparedStatement} 。
+	 *
+	 * @param connection         数据库连接
+	 * @param sql                SQL语句，使用"?"做为占位符
+	 * @param paramsBatch        "?"所代表的对应参数列表
+	 * @param returnGeneratedKey 是否会返回自增主键
+	 * @return 完成参数填充的 {@link PreparedStatement}
+	 */
+	public static PreparedStatement createPrepareStatementBatch(
+			Connection connection, String sql, Iterable<Object[]> paramsBatch, boolean returnGeneratedKey
+	) throws SQLException {
 
-        sql = sql.trim();
-        PreparedStatement statement = connection.prepareStatement(sql, returnGeneratedKey ? Statement.RETURN_GENERATED_KEYS : Statement.NO_GENERATED_KEYS);
-        Map<Integer, Integer> nullTypeMap = new HashMap<>();
-        for (Object[] params : paramsBatch) {
-            fillParams(statement, Arrays.asList(params), nullTypeMap);
-            statement.addBatch();
-        }
+		sql = sql.trim();
+		PreparedStatement statement = connection.prepareStatement(sql, returnGeneratedKey ? Statement.RETURN_GENERATED_KEYS : Statement.NO_GENERATED_KEYS);
+		Map<Integer, Integer> nullTypeMap = new HashMap<>();
+		for (Object[] params : paramsBatch) {
+			fillParams(statement, Arrays.asList(params), nullTypeMap);
+			statement.addBatch();
+		}
 
-        return statement;
-    }
+		return statement;
+	}
 
 
-    /**
-     * 填充PreparedStatement的参数。
-     *
-     * @param statement PreparedStatement
-     * @param params    SQL参数
-     * @return {@link PreparedStatement} 填充参数后的PreparedStatement
-     * @throws SQLException SQL执行异常
-     */
-    public static PreparedStatement fillParams(
-            PreparedStatement statement, Iterable<?> params
-    ) throws SQLException {
-        return fillParams(statement, params, null);
-    }
+	/**
+	 * 填充PreparedStatement的参数。
+	 *
+	 * @param statement PreparedStatement
+	 * @param params    SQL参数
+	 * @return {@link PreparedStatement} 填充参数后的PreparedStatement
+	 * @throws SQLException SQL执行异常
+	 */
+	public static PreparedStatement fillParams(
+			PreparedStatement statement, Iterable<?> params
+	) throws SQLException {
+		return fillParams(statement, params, null);
+	}
 
-    /**
-     * 填充PreparedStatement的参数。
-     *
-     * @param statement PreparedStatement
-     * @param params    SQL参数
-     * @param nullCache null参数的类型缓存，避免循环中重复获取类型
-     * @return 完成参数填充的 {@link PreparedStatement}
-     */
-    public static PreparedStatement fillParams(
-            PreparedStatement statement, Iterable<?> params, Map<Integer, Integer> nullCache
-    ) throws SQLException {
-        if (null == params) {
-            return statement;// 无参数
-        }
+	/**
+	 * 填充PreparedStatement的参数。
+	 *
+	 * @param statement PreparedStatement
+	 * @param params    SQL参数
+	 * @param nullCache null参数的类型缓存，避免循环中重复获取类型
+	 * @return 完成参数填充的 {@link PreparedStatement}
+	 */
+	public static PreparedStatement fillParams(
+			PreparedStatement statement, Iterable<?> params, Map<Integer, Integer> nullCache
+	) throws SQLException {
+		if (null == params) {
+			return statement;// 无参数
+		}
 
-        int paramIndex = 1;//第一个参数从1计数
-        for (Object param : params) {
-            setParam(statement, paramIndex++, param, nullCache);
-        }
-        return statement;
-    }
+		int paramIndex = 1;//第一个参数从1计数
+		for (Object param : params) {
+			setParam(statement, paramIndex++, param, nullCache);
+		}
+		return statement;
+	}
 
-    /**
-     * 获取null字段对应位置的数据类型
-     * 如果类型获取失败将使用默认的 {@link Types#VARCHAR}
-     *
-     * @param statement  {@link PreparedStatement}
-     * @param paramIndex 参数序列，第一位从1开始
-     * @return 数据类型，默认为 {@link Types#VARCHAR}
-     */
-    public static int getNullType(PreparedStatement statement, int paramIndex) {
-        int sqlType = Types.VARCHAR;
+	/**
+	 * 获取null字段对应位置的数据类型
+	 * 如果类型获取失败将使用默认的 {@link Types#VARCHAR}
+	 *
+	 * @param statement  {@link PreparedStatement}
+	 * @param paramIndex 参数序列，第一位从1开始
+	 * @return 数据类型，默认为 {@link Types#VARCHAR}
+	 */
+	public static int getNullType(PreparedStatement statement, int paramIndex) {
+		int sqlType = Types.VARCHAR;
 
-        final ParameterMetaData pmd;
-        try {
-            pmd = statement.getParameterMetaData();
-            sqlType = pmd.getParameterType(paramIndex);
-        } catch (SQLException ignore) {
-        }
+		final ParameterMetaData pmd;
+		try {
+			pmd = statement.getParameterMetaData();
+			sqlType = pmd.getParameterType(paramIndex);
+		} catch (SQLException ignore) {
+		}
 
-        return sqlType;
-    }
+		return sqlType;
+	}
 
-    /**
-     * 为 {@link PreparedStatement} 设置单个参数
-     *
-     * @param preparedStatement {@link PreparedStatement}
-     * @param paramIndex        参数序列，从1开始
-     * @param param             参数，不能为{@code null}
-     * @param nullCache         用于缓存参数为null位置的类型，避免重复获取
-     */
-    private static void setParam(
-            PreparedStatement preparedStatement, int paramIndex, Object param,
-            Map<Integer, Integer> nullCache
-    ) throws SQLException {
+	/**
+	 * 为 {@link PreparedStatement} 设置单个参数
+	 *
+	 * @param preparedStatement {@link PreparedStatement}
+	 * @param paramIndex        参数序列，从1开始
+	 * @param param             参数，不能为{@code null}
+	 * @param nullCache         用于缓存参数为null位置的类型，避免重复获取
+	 */
+	private static void setParam(
+			PreparedStatement preparedStatement, int paramIndex, Object param,
+			Map<Integer, Integer> nullCache
+	) throws SQLException {
 
-        if (param == null) {
-            Integer type = (null == nullCache) ? null : nullCache.get(paramIndex);
-            if (null == type) {
-                type = getNullType(preparedStatement, paramIndex);
-                if (null != nullCache) {
-                    nullCache.put(paramIndex, type);
-                }
-            }
-            preparedStatement.setNull(paramIndex, type);
-        }
+		if (param == null) {
+			Integer type = (null == nullCache) ? null : nullCache.get(paramIndex);
+			if (null == type) {
+				type = getNullType(preparedStatement, paramIndex);
+				if (null != nullCache) {
+					nullCache.put(paramIndex, type);
+				}
+			}
+			preparedStatement.setNull(paramIndex, type);
+		}
 
-        // 针对UUID特殊处理，避免元数据直接插入
-        if (param instanceof UUID) {
-            preparedStatement.setString(paramIndex, param.toString());
-            return;
-        }
+		// 针对UUID特殊处理，避免元数据直接传入
+		if (param instanceof UUID) {
+			preparedStatement.setString(paramIndex, param.toString());
+			return;
+		}
 
-        // 日期特殊处理，默认按照时间戳传入，避免毫秒丢失
-        if (param instanceof java.util.Date) {
-            if (param instanceof Date) {
-                preparedStatement.setDate(paramIndex, (Date) param);
-            } else if (param instanceof Time) {
-                preparedStatement.setTime(paramIndex, (Time) param);
-            } else {
-                preparedStatement.setTimestamp(paramIndex, new Timestamp(((java.util.Date) param).getTime()));
-            }
-            return;
-        }
+		// 针对StringBuilder或StringBuffer进行处理，避免元数据传入
+		if (param instanceof StringBuilder || param instanceof StringBuffer) {
+			preparedStatement.setString(paramIndex, param.toString());
+			return;
+		}
 
-        // 针对大数字类型的特殊处理
-        if (param instanceof Number) {
-            if (param instanceof BigDecimal) {
-                // BigDecimal的转换交给JDBC驱动处理
-                preparedStatement.setBigDecimal(paramIndex, (BigDecimal) param);
-                return;
-            }
-            if (param instanceof BigInteger) {
-                // BigInteger转为BigDecimal
-                preparedStatement.setBigDecimal(paramIndex, new BigDecimal((BigInteger) param));
-                return;
-            }
-            // 忽略其它数字类型，按照默认类型传入
-        }
+		// 日期特殊处理，默认按照时间戳传入，避免精度丢失
+		if (param instanceof java.util.Date) {
+			if (param instanceof Date) {
+				preparedStatement.setDate(paramIndex, (Date) param);
+			} else if (param instanceof Time) {
+				preparedStatement.setTime(paramIndex, (Time) param);
+			} else {
+				preparedStatement.setTimestamp(paramIndex, new Timestamp(((java.util.Date) param).getTime()));
+			}
+			return;
+		}
 
-        // 其它参数类型直接插入
-        preparedStatement.setObject(paramIndex, param);
-    }
+		// 针对大数字类型的特殊处理
+		if (param instanceof Number) {
+			if (param instanceof BigDecimal) {
+				// BigDecimal的转换交给JDBC驱动处理
+				preparedStatement.setBigDecimal(paramIndex, (BigDecimal) param);
+				return;
+			} else if (param instanceof BigInteger) {
+				preparedStatement.setBigDecimal(paramIndex, new BigDecimal((BigInteger) param));
+				return;
+			}
+			// 其它数字类型按照默认类型传入
+		}
+
+		// 其它参数类型直接传入
+		preparedStatement.setObject(paramIndex, param);
+	}
 
 }

example/easysql-demo/pom.xml

@@ -5,9 +5,19 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.2.8</version>
+        <version>0.3.0</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-demo</artifactId>
     <packaging>jar</packaging>
@@ -45,15 +55,6 @@
         <url>${project.url}/actions/workflows/maven.yml</url>
     </ciManagement>
 
-    <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>
-
     <dependencies>
 
         <dependency>

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

@@ -1,27 +1,56 @@
 import cc.carm.lib.easysql.api.SQLManager;
 import cc.carm.lib.easysql.api.SQLQuery;
+import cc.carm.lib.easysql.api.enums.ForeignKeyRule;
+import cc.carm.lib.easysql.api.enums.IndexType;
+import cc.carm.lib.easysql.api.enums.NumberType;
 import cc.carm.lib.easysql.api.util.TimeDateUtils;
 import cc.carm.lib.easysql.api.util.UUIDUtil;
+import org.jetbrains.annotations.TestOnly;
 
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.UUID;
 
+@TestOnly
+@SuppressWarnings("all")
 public class EasySQLDemo {
 
 	public void createTable(SQLManager sqlManager) {
 		// 同步创建表
 		sqlManager.createTable("users")
-				.addColumn("id", "INT(11) AUTO_INCREMENT NOT NULL PRIMARY KEY")
+//				.addColumn("id", "INT(11) AUTO_INCREMENT NOT NULL PRIMARY KEY")
+				.addAutoIncrementColumn("id", NumberType.INT, true, true)
 				.addColumn("uuid", "VARCHAR(32) NOT NULL UNIQUE KEY")
-				.addColumn("username", "VARCHAR(16) NOT NULL UNIQUE KEY")
-				.addColumn("age", "INT(3) NOT NULL DEFAULT 1")
+				.addColumn("username", "VARCHAR(16) NOT NULL")
+				.addColumn("age", "TINYINT NOT NULL DEFAULT 1")
 				.addColumn("email", "VARCHAR(32)")
 				.addColumn("phone", "VARCHAR(16)")
 				.addColumn("registerTime", "DATETIME NOT NULL")
+//				.addColumn("INDEX `phone`") // 原始方法添加索引
+				.setIndex("username", IndexType.UNIQUE_KEY) // 添加唯一索引
+				.setIndex(IndexType.INDEX, "contact", "email", "phone") //添加联合索引 (示例)
+				.build().execute(null /* 不处理错误 */);
+
+		sqlManager.createTable("user_ipaddr")
+				.addAutoIncrementColumn("id", NumberType.INT, true, true)
+				.addColumn("uuid", "VARCHAR(32) NOT NULL")
+				.addColumn("ip", "VARCHAR(16)")
+				.addColumn("time", "DATETIME NOT NULL")
+				.addForeignKey("uuid", null,
+						"users", "uuid",
+						ForeignKeyRule.CASCADE, ForeignKeyRule.CASCADE
+				)
 				.build().execute(null /* 不处理错误 */);
 	}
 
+	public void alertTable(SQLManager sqlManager) {
+		// 同步更新表
+		sqlManager.alterTable("users")
+				.modifyColumn("age", "TINYINT NOT NULL DEFAULT 0")
+				.execute(null /* 不处理错误 */);
+	}
+
+
 	public void sqlQuery(SQLManager sqlManager) {
 		// 同步SQL查询
 		try (SQLQuery query = sqlManager.createQuery()

example/easysql-test/pom.xml

@@ -0,0 +1,130 @@
+<?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.0</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-test</artifactId>
+    <dependencies>
+        <dependency>
+            <groupId>${project.parent.groupId}</groupId>
+            <artifactId>easysql-hikaricp</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.25</version>
+            <scope>compile</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-api</artifactId>
+            <version>1.7.29</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.3</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.testrunner.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-test/src/main/java/cc/carm/lib/easysql/testrunner/EasySQLTest.java

@@ -0,0 +1,36 @@
+package cc.carm.lib.easysql.testrunner;
+
+import cc.carm.lib.easysql.api.SQLManager;
+import org.jetbrains.annotations.ApiStatus;
+import org.jetbrains.annotations.NotNull;
+
+import java.sql.SQLException;
+
+public abstract class EasySQLTest {
+
+	@ApiStatus.OverrideOnly
+	public abstract void onTest(SQLManager sqlManager) throws SQLException;
+
+	public boolean executeTest(int index, SQLManager sqlManager) {
+		String testName = getClass().getSimpleName();
+
+		print("  #%s 测试 @%s 开始", index, testName);
+		long start = System.currentTimeMillis();
+
+		try {
+			onTest(sqlManager);
+			print("  #%s 测试 @%s 成功，耗时 %s ms。", index, testName, (System.currentTimeMillis() - start));
+			return true;
+		} catch (Exception exception) {
+			print("  #%s 测试 @%s 失败，耗时 %s ms。", index, testName, (System.currentTimeMillis() - start));
+			exception.printStackTrace();
+			return false;
+		}
+	}
+
+	protected static void print(@NotNull String format, Object... params) {
+		Main.print(format, params);
+	}
+
+
+}

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

@@ -0,0 +1,93 @@
+package cc.carm.lib.easysql.testrunner;
+
+import cc.carm.lib.easysql.EasySQL;
+import cc.carm.lib.easysql.api.SQLManager;
+import cc.carm.lib.easysql.testrunner.tests.TableAlterTest;
+import cc.carm.lib.easysql.testrunner.tests.TableCreateTest;
+import cc.carm.lib.easysql.testrunner.tests.TableRenameTest;
+import org.jetbrains.annotations.NotNull;
+import org.jetbrains.annotations.Nullable;
+
+import java.util.Iterator;
+import java.util.LinkedHashSet;
+import java.util.Scanner;
+import java.util.Set;
+
+public class Main {
+
+	public static void main(String[] args) {
+		if (args.length < 4) {
+			print("请提供以下参数： 数据库地址 数据库用户名 数据库密码");
+			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());
+
+		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)
+		);
+
+	}
+
+
+	public static void print(@NotNull String format, Object... params) {
+		System.out.printf((format) + "%n", params);
+	}
+
+	public static @Nullable EasySQLTest cast(@NotNull Class<?> value) {
+		if (!EasySQLTest.class.isAssignableFrom(value)) return null;
+		try {
+			return (EasySQLTest) value.newInstance();
+		} catch (InstantiationException | IllegalAccessException e) {
+			return null;
+		}
+
+	}
+
+}

example/easysql-test/src/main/java/cc/carm/lib/easysql/testrunner/tests/TableAlterTest.java

@@ -0,0 +1,35 @@
+package cc.carm.lib.easysql.testrunner.tests;
+
+import cc.carm.lib.easysql.api.SQLManager;
+import cc.carm.lib.easysql.api.enums.NumberType;
+import cc.carm.lib.easysql.testrunner.EasySQLTest;
+
+import java.sql.SQLException;
+
+public class TableAlterTest extends EasySQLTest {
+
+	@Override
+	public void onTest(SQLManager sqlManager) throws SQLException {
+
+		print("	修改 test_user_table");
+		sqlManager.alterTable("test_user_table")
+				.addColumn("test", "VARCHAR(16) NOT NULL")
+				.execute();
+
+		sqlManager.alterTable("test_user_table")
+				.addColumn("test2", "VARCHAR(16) NOT NULL", "username")
+				.execute();
+
+
+		print("	修改 test_user_info");
+		sqlManager.alterTable("test_user_info")
+				.addAutoIncrementColumn("num", NumberType.BIGINT, false, true)
+				.execute();
+
+		sqlManager.alterTable("test_user_info")
+				.addColumn("a", "VARCHAR(16) NOT NULL", "")
+				.execute();
+
+	}
+
+}

example/easysql-test/src/main/java/cc/carm/lib/easysql/testrunner/tests/TableCreateTest.java

@@ -0,0 +1,38 @@
+package cc.carm.lib.easysql.testrunner.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.testrunner.EasySQLTest;
+
+import java.sql.SQLException;
+
+public class TableCreateTest extends EasySQLTest {
+
+	@Override
+	public void onTest(SQLManager sqlManager) throws SQLException {
+
+		print("	创建 test_user_table");
+		sqlManager.createTable("test_user_table")
+				.addAutoIncrementColumn("id")
+				.addColumn("uuid", "VARCHAR(36) NOT NULL", "用户UUID")
+				.addColumn("username", "VARCHAR(16) NOT NULL", "用户名")
+				.addColumn("age", "TINYINT DEFAULT 0 NOT NULL", "年龄")
+
+				.setIndex("uuid", IndexType.UNIQUE_KEY)
+				.build().execute();
+
+		print("	创建 test_user_info");
+		sqlManager.createTable("test_user_info")
+				.addColumn("uid", "INT UNSIGNED NOT NULL")
+				.addColumn("info", "TEXT", "相关信息")
+				.addForeignKey("uid", "user",
+						"test_user_table", "id",
+						ForeignKeyRule.CASCADE, ForeignKeyRule.CASCADE
+				)
+				.setIndex(IndexType.FULLTEXT_INDEX, "sign", "info")
+				.build().execute();
+
+	}
+
+}

example/easysql-test/src/main/java/cc/carm/lib/easysql/testrunner/tests/TableRenameTest.java

@@ -0,0 +1,16 @@
+package cc.carm.lib.easysql.testrunner.tests;
+
+import cc.carm.lib.easysql.api.SQLManager;
+import cc.carm.lib.easysql.testrunner.EasySQLTest;
+
+import java.sql.SQLException;
+
+public class TableRenameTest extends EasySQLTest {
+	@Override
+	public void onTest(SQLManager sqlManager) throws SQLException {
+		print("	重命名 test_user_table");
+		sqlManager.alterTable("test_user_table")
+				.renameTo("test_user_table2")
+				.execute();
+	}
+}

pom.xml

@@ -16,15 +16,16 @@
     <groupId>cc.carm.lib</groupId>
     <artifactId>easysql-parent</artifactId>
     <packaging>pom</packaging>
-    <version>0.2.8</version>
+    <version>0.3.0</version>
 
     <modules>
         <module>easysql-api</module>
         <module>easysql-impl</module>
 
-        <module>easysql-beecp</module>
-        <module>easysql-hikaricp</module>
-        <module>easysql-demo</module>
+        <module>with-pool/easysql-beecp</module>
+        <module>with-pool/easysql-hikaricp</module>
+        <module>example/easysql-demo</module>
+        <module>example/easysql-test</module>
 
     </modules>
 
@@ -38,6 +39,7 @@
             <name>Carm Jos</name>
             <email>carm@carm.cc</email>
             <url>https://www.carm.cc</url>
+            <timezone>Asia/Shanghai</timezone>
         </developer>
     </developers>
 
@@ -45,6 +47,7 @@
         <connection>scm:git:git@github.com:CarmJos/EasySQL.git</connection>
         <developerConnection>scm:git:git@github.com:CarmJos/EasySQL.git</developerConnection>
         <url>https://github.com/CarmJos/EasySQL</url>
+        <tag>HEAD</tag>
     </scm>
 
     <licenses>
@@ -93,12 +96,11 @@
     <distributionManagement>
 
         <downloadUrl>${project.url}/releases</downloadUrl>
-
-        <repository>
-            <id>github</id>
-            <name>GitHub Packages</name>
-            <url>https://maven.pkg.github.com/CarmJos/EasySQL</url>
-        </repository>
+        <site>
+            <id>easysql-javadoc</id>
+            <name>EasySQL JavaDoc (on Github Pages)</name>
+            <url>https://carmjos.github.io/EasySQL</url>
+        </site>
 
     </distributionManagement>
 
@@ -128,20 +130,37 @@
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-surefire-plugin</artifactId>
             </plugin>
-            <!--            <plugin>-->
-            <!--                <groupId>org.apache.maven.plugins</groupId>-->
-            <!--                <artifactId>maven-gpg-plugin</artifactId>-->
-            <!--                <version>1.5</version>-->
-            <!--                <executions>-->
-            <!--                    <execution>-->
-            <!--                        <id>sign-artifacts</id>-->
-            <!--                        <phase>verify</phase>-->
-            <!--                        <goals>-->
-            <!--                            <goal>sign</goal>-->
-            <!--                        </goals>-->
-            <!--                    </execution>-->
-            <!--                </executions>-->
-            <!--            </plugin>-->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-gpg-plugin</artifactId>
+                <version>1.6</version>
+                <executions>
+                    <execution>
+                        <id>sign-artifacts</id>
+                        <phase>verify</phase>
+                        <goals>
+                            <goal>sign</goal>
+                        </goals>
+                    </execution>
+                </executions>
+                <configuration>
+                    <gpgArguments>
+                        <arg>--pinentry-mode</arg>
+                        <arg>loopback</arg>
+                    </gpgArguments>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-release-plugin</artifactId>
+                <version>2.5.1</version>
+                <configuration>
+                    <autoVersionSubmodules>true</autoVersionSubmodules>
+                    <useReleaseProfile>false</useReleaseProfile>
+                    <releaseProfiles>release</releaseProfiles>
+                    <goals>deploy</goals>
+                </configuration>
+            </plugin>
         </plugins>
 
         <pluginManagement>
@@ -253,5 +272,34 @@
 
     </build>
 
+    <profiles>
+
+        <profile>
+            <id>ossrh</id>
+            <distributionManagement>
+                <snapshotRepository>
+                    <id>ossrh</id>
+                    <url>https://s01.oss.sonatype.org/content/repositories/snapshots</url>
+                </snapshotRepository>
+
+                <repository>
+                    <id>ossrh</id>
+                    <url>https://s01.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+                </repository>
+            </distributionManagement>
+        </profile>
+
+        <profile>
+            <id>github</id>
+            <distributionManagement>
+                <repository>
+                    <id>github</id>
+                    <name>GitHub Packages</name>
+                    <url>https://maven.pkg.github.com/CarmJos/EasySQL</url>
+                </repository>
+            </distributionManagement>
+        </profile>
+
+    </profiles>
 
 </project>

with-pool/easysql-beecp/pom.xml

@@ -5,10 +5,18 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.2.8</version>
+        <version>0.3.0</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>
+    </properties>
+
     <artifactId>easysql-beecp</artifactId>
     <packaging>jar</packaging>
 
@@ -45,14 +53,6 @@
         <url>${project.url}/actions/workflows/maven.yml</url>
     </ciManagement>
 
-    <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>
-    </properties>
-
     <dependencies>
 
         <dependency>

with-pool/easysql-hikaricp/pom.xml

@@ -5,10 +5,18 @@
     <parent>
         <artifactId>easysql-parent</artifactId>
         <groupId>cc.carm.lib</groupId>
-        <version>0.2.8</version>
+        <version>0.3.0</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>
+    </properties>
+
     <artifactId>easysql-hikaricp</artifactId>
 
     <name>11-EasySQL-HikariCP</name>
@@ -44,14 +52,6 @@
         <url>${project.url}/actions/workflows/maven.yml</url>
     </ciManagement>
 
-    <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>
-    </properties>
-
     <dependencies>
 
         <dependency>