Java：MultiDataSource 中 SQLAuto: 解决非 UPDATE/DELETE SQL 报错 can't commit after auto commit

Author: TommyLemon

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

@@ -2570,6 +2570,7 @@ public String execute(@RequestBody String request, HttpSession session) {
                 long rsDuration = 0;
                 long executeStartTime = System.currentTimeMillis();
 
+                boolean isAutoCommit = true;
                 try {
                     if (DemoSQLConfig.DATABASE_INFLUXDB.equals(database) || DemoSQLConfig.DATABASE_CASSANDRA.equals(database)) {
                         JSONObject result = executor.execute(config, false);
@@ -2593,6 +2594,7 @@ public String execute(@RequestBody String request, HttpSession session) {
                             if (EXECUTE_STRICTLY) {
                                 if (isWrite) {
                                     try {
+                                        isAutoCommit = false;
                                         connection.setAutoCommit(false);
                                         // connection.beginRequest();
                                         int rows = ((PreparedStatement) statement).executeUpdate();
@@ -2617,6 +2619,7 @@ public String execute(@RequestBody String request, HttpSession session) {
                             if (EXECUTE_STRICTLY) {
                                 if (isWrite) {
                                     try {
+                                        isAutoCommit = false;
                                         connection.setAutoCommit(false);
                                         // connection.beginRequest();
                                         int rows = statement.executeUpdate(sql);
@@ -2673,7 +2676,9 @@ public String execute(@RequestBody String request, HttpSession session) {
                         }
 
                         try {
-                            connection.commit();
+                            if (! (isAutoCommit || connection.getAutoCommit())) {
+                                connection.commit();
+                            }
                         } finally {
                             try {
                                 statement.close();