Java：APIJSONBoot 适配连接池；APIJSONBoot 提供 MariaDB, OceanBase 等对接说明；APIJSONBoot 升级 apijson-orm 和 apijson-framework 版本分别为 4.3.0 和 4.4.5，并针对新版特性来调整代码

Author: TommyLemon

APIJSON-Java-Server/APIJSONBoot/libs/apijson-framework-4.4.2.jar APIJSON-Java-Server/APIJSONBoot/libs/apijson-framework-4.4.5.jar

@@ -5,7 +5,7 @@
 
 	<groupId>apijson.boot</groupId>
 	<artifactId>apijson-boot</artifactId>
-	<version>4.4.0</version>
+	<version>4.4.5</version>
 	<packaging>jar</packaging>
 
 	<name>APIJSONBoot</name>
@@ -41,12 +41,12 @@
 	 	<dependency>
 			<groupId>com.github.Tencent</groupId>
 			<artifactId>APIJSON</artifactId>
-			<version>4.2.5</version>
+			<version>4.3.0</version>
 		</dependency>
 		<dependency>
 			<groupId>com.github.APIJSON</groupId>
 			<artifactId>apijson-framework</artifactId>
-			<version>4.4.3</version>
+			<version>4.4.5</version>
 		</dependency>
 		<!-- 可使用 libs 目录的 apijson-orm.jar 和 apijson-framework.jar 来替代，两种方式二选一 >>>>>>>>>> -->
 

APIJSON-Java-Server/APIJSONBoot/libs/apijson-orm-4.2.5.jar APIJSON-Java-Server/APIJSONBoot/libs/apijson-orm-4.3.0.jar

@@ -47,11 +47,11 @@
 import apijson.demo.DemoVerifier;
 import apijson.framework.APIJSONApplication;
 import apijson.framework.APIJSONCreator;
+import apijson.orm.AbstractVerifier;
 import apijson.orm.FunctionParser;
 import apijson.orm.Parser;
 import apijson.orm.SQLConfig;
 import apijson.orm.SQLExecutor;
-import apijson.orm.Structure;
 import apijson.orm.Verifier;
 import unitauto.MethodUtil;
 import unitauto.MethodUtil.Argument;
@@ -73,7 +73,7 @@ public class DemoApplication implements ApplicationContextAware {
 	static {
 		// APIJSON 配置 <<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<<
 
-		Map<String, Pattern> COMPILE_MAP = Structure.COMPILE_MAP;
+		Map<String, Pattern> COMPILE_MAP = AbstractVerifier.COMPILE_MAP;
 		COMPILE_MAP.put("PHONE", StringUtil.PATTERN_PHONE);
 		COMPILE_MAP.put("EMAIL", StringUtil.PATTERN_EMAIL);
 		COMPILE_MAP.put("ID_CARD", StringUtil.PATTERN_ID_CARD);

APIJSON-Java-Server/APIJSONBoot/pom.xml

@@ -79,7 +79,6 @@
 import apijson.demo.model.Verify;
 import apijson.framework.APIJSONController;
 import apijson.framework.BaseModel;
-import apijson.framework.StructureUtil;
 import apijson.orm.JSONRequest;
 import apijson.orm.exception.ConditionErrorException;
 import apijson.orm.exception.ConflictException;
@@ -299,30 +298,30 @@ public JSONObject reload(@RequestBody String request) {
 
 		boolean reloadAll = StringUtil.isEmpty(type, true) || "ALL".equals(type);
 
-		if (reloadAll || "FUNCTION".equals(type)) {
+		if (reloadAll || "ACCESS".equals(type)) {
 			try {
-				result.put(FUNCTION_, DemoFunctionParser.init());
+				result.put(ACCESS_, DemoVerifier.initAccess());
 			} catch (ServerException e) {
 				e.printStackTrace();
-				result.put(FUNCTION_, DemoParser.newErrorResult(e));
+				result.put(ACCESS_, DemoParser.newErrorResult(e));
 			}
 		}
 
-		if (reloadAll || "REQUEST".equals(type)) {
+		if (reloadAll || "FUNCTION".equals(type)) {
 			try {
-				result.put(REQUEST_, StructureUtil.init());
+				result.put(FUNCTION_, DemoFunctionParser.init());
 			} catch (ServerException e) {
 				e.printStackTrace();
-				result.put(REQUEST_, DemoParser.newErrorResult(e));
+				result.put(FUNCTION_, DemoParser.newErrorResult(e));
 			}
 		}
 
-		if (reloadAll || "ACCESS".equals(type)) {
+		if (reloadAll || "REQUEST".equals(type)) {
 			try {
-				result.put(ACCESS_, DemoVerifier.init());
+				result.put(REQUEST_, DemoVerifier.initRequest());
 			} catch (ServerException e) {
 				e.printStackTrace();
-				result.put(ACCESS_, DemoParser.newErrorResult(e));
+				result.put(REQUEST_, DemoParser.newErrorResult(e));
 			}
 		}
 

APIJSON-Java-Server/APIJSONBoot/src/main/java/apijson/boot/DemoApplication.java

@@ -24,7 +24,7 @@
 import apijson.orm.AbstractSQLConfig;
 
 
-/**SQL配置
+/**SQL 配置
  * TiDB 用法和 MySQL 一致
  * @author Lemon
  */
@@ -38,7 +38,7 @@ public DemoSQLConfig(RequestMethod method, String table) {
 	}
 
 	static {
-		DEFAULT_DATABASE = DATABASE_MYSQL;  //TODO 默认数据库类型，改成你自己的
+		DEFAULT_DATABASE = DATABASE_MYSQL;  //TODO 默认数据库类型，改成你自己的。TiDB, MariaDB, OceanBase 这类兼容 MySQL 的可当做 MySQL 使用
 		DEFAULT_SCHEMA = "sys";  //TODO 默认模式名，改成你自己的，默认情况是 MySQL: sys, PostgreSQL: public, SQL Server: dbo, Oracle: 
 
 		//表名和数据库不一致的，需要配置映射关系。只使用 APIJSONORM 时才需要；
@@ -90,6 +90,8 @@ public String getUserIdKey(String database, String schema, String table) {
 	}
 
 
+	// 如果 DemoSQLExecutor.getConnection 能拿到连接池的有效 Connection，则这里不需要配置 dbVersion, dbUri, dbAccount, dbPassword
+
 	@Override
 	public String getDBVersion() {
 		if (isMySQL()) {
@@ -112,7 +114,9 @@ public String getDBVersion() {
 	@Override
 	public String getDBUri() {
 		if (isMySQL()) {
-			return "jdbc:mysql://localhost:3306"; //TODO 改成你自己的，TiDB 可以当成 MySQL 使用，默认端口为 4000
+			// 这个是 MySQL 8.0 及以上，要加 userSSL=false  return "jdbc:mysql://localhost:3306?userSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8";
+			// 以下是 MySQL 5.7 及以下
+			return "jdbc:mysql://localhost:3306?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8"; //TODO 改成你自己的，TiDB 可以当成 MySQL 使用，默认端口为 4000
 		}
 		if (isPostgreSQL()) {
 			return "jdbc:postgresql://localhost:5432/postgres"; //TODO 改成你自己的

APIJSON-Java-Server/APIJSONBoot/src/main/java/apijson/boot/DemoController.java

@@ -14,10 +14,17 @@
 
 package apijson.demo;
 
+import java.sql.Connection;
+
+import javax.sql.DataSource;
+
+import apijson.Log;
+import apijson.boot.DemoApplication;
 import apijson.framework.APIJSONSQLExecutor;
+import apijson.orm.SQLConfig;
 
 
-/**executor for query(read) or update(write) MySQL database
+/**SQL 执行
  * @author Lemon
  */
 public class DemoSQLExecutor extends APIJSONSQLExecutor {
@@ -37,4 +44,25 @@ public class DemoSQLExecutor extends APIJSONSQLExecutor {
 	//		super.removeCache(sql, type);
 	//	}
 
+	// 适配连接池，如果这里能拿到连接池的有效 Connection，则 SQLConfig 不需要配置 dbVersion, dbUri, dbAccount, dbPassword
+	@Override
+	public Connection getConnection(SQLConfig config) throws Exception {
+		Connection c = connectionMap.get(config.getDatabase());
+		if (c == null || c.isClosed()) {
+			try {
+				DataSource ds = DemoApplication.getApplicationContext().getBean(DataSource.class);
+				// 另一种方式是 DruidConfig 初始化获取到 Datasource 后给静态变量 DATA_SOURCE 赋值： ds = DruidConfig.DATA_SOURCE.getConnection();
+				connectionMap.put(config.getDatabase(), ds == null ? null : ds.getConnection());
+			} catch (Exception e) {
+				Log.e(TAG, "DemoSQLExecutor.getConnection   try { "
+						+ "DataSource ds = DemoApplication.getApplicationContext().getBean(DataSource.class); .."
+						+ "} catch (Exception e) = " + e.getMessage());
+			}
+		}
+
+		// 必须最后执行 super 方法，因为里面还有事务相关处理。
+		// 如果这里是 return c，则会导致 增删改 多个对象时只有第一个会 commit，即只有第一个对象成功插入数据库表
+		return super.getConnection(config);
+	}
+
 }