Java：MultiDataSource 还原流量录制/回放配置、默认端口，更新 APIAuto

Author: TommyLemon

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

@@ -100,7 +100,7 @@ public static void main(String[] args) throws Exception {
     // SpringBoot 2.x 自定义端口方式
     @Override
     public void customize(ConfigurableServletWebServerFactory server) {
-        server.setPort(9090);
+        server.setPort(8080);
     }
 
     // 支持 APIAuto 中 JavaScript 代码跨域请求

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

@@ -1178,7 +1178,7 @@ public void remove(String key) {
     public static final int REQUEST_RECORD_TYPE_UNIT = 2;
     public static final int REQUEST_RECORD_TYPE_SQL = 3;
 
-    public static Integer REQUEST_RECORD_TYPE = - REQUEST_RECORD_TYPE_API;
+    public static Integer REQUEST_RECORD_TYPE = 0;
 
     @Autowired
     HttpServletRequest httpServletRequest;

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/java/apijson/demo/DemoSQLExecutor.java

@@ -130,8 +130,6 @@ public synchronized void removeCache(String sql, SQLConfig config) {
     // Redis 缓存 >>>>>>>>>>>>>>>>>>>>>>>>>>>>>>
 
     public static final String DATABASE_NEBULA = "NEBULA";
-    public static final String DATABASE_SNOWFLAKE = "SNOWFLAKE";
-    public static final String DATABASE_CASSANDRA = "CASSANDRA";
 
     // 适配连接池，如果这里能拿到连接池的有效 Connection，则 SQLConfig 不需要配置 dbVersion, dbUri, dbAccount, dbPassword
     @Override
@@ -204,7 +202,8 @@ public Connection getConnection(SQLConfig config) throws Exception {
 
     @Override
     public JSONObject execute(@NotNull SQLConfig config, boolean unknownType) throws Exception {
-        if (DATABASE_CASSANDRA.equals(config.getDatabase()) || DemoSQLConfig.DATABASE_INFLUXDB.equals(config.getDatabase())) {
+        String db = config.getDatabase();
+        if (DemoSQLConfig.DATABASE_CASSANDRA.equals(db) || DemoSQLConfig.DATABASE_INFLUXDB.equals(db)) {
 
             String sql = config.getSQL(config.isPrepared());
 
@@ -217,7 +216,7 @@ public JSONObject execute(@NotNull SQLConfig config, boolean unknownType) throws
             }
 
 
-            if (DATABASE_CASSANDRA.equals(config.getDatabase())) {
+            if (DemoSQLConfig.DATABASE_CASSANDRA.equals(db)) {
                 CqlSession session = CqlSession.builder()
 //                        .withCloudSecureConnectBundle(Paths.get("/path/to/secure-connect-database_name.zip"))
                         .withCloudSecureConnectBundle(new URL(config.getDBUri()))
@@ -253,7 +252,7 @@ public JSONObject execute(@NotNull SQLConfig config, boolean unknownType) throws
             }
 
 
-            if (DemoSQLConfig.DATABASE_INFLUXDB.equals(config.getDatabase())) {
+            if (DemoSQLConfig.DATABASE_INFLUXDB.equals(db)) {
                 InfluxDB influxDB = InfluxDBFactory.connect(config.getDBUri(), config.getDBAccount(), config.getDBPassword());
                 influxDB.setDatabase(config.getSchema());
 

APIJSON-Java-Server/APIJSONBoot-MultiDataSource/src/main/resources/static/js/main.js

@@ -5000,25 +5000,13 @@ https://github.com/Tencent/APIJSON/issues
         var evalPostScript = function () {}
 
         var sendRequest = function (isAdminOperation, type, url, req, header, callback) {
-          var hs = ""
-          if (isDelegate && header != null) {
-            for (var k in header) {
-                var v = k == null ? null : header[k]
-                if (k == null || k.toLowerCase() == 'apijson-delegate-id') {
-                    continue
-                }
-                hs += '\n' + k + ': ' + (v instanceof Object ? JSON.stringify(v) : v)
-            }
-          }
-
           // axios.defaults.withcredentials = true
           axios({
             method: (type == REQUEST_TYPE_PARAM ? 'get' : 'post'),
-            url: (isDelegate ? (
+            url: (isDelegate
+                ? (
                   App.server + '/delegate?' + (type == REQUEST_TYPE_GRPC ? '$_type=GRPC&' : '')
-                  + (StringUtil.isEmpty(App.delegateId, true) ? '' : '$_delegate_id=' + App.delegateId + '&')
-                  + '$_delegate_url=' + encodeURIComponent(url)
-                  + (StringUtil.isEmpty(hs, true) ? '' : '&$_headers=' + encodeURIComponent(hs.trim()))
+                  + (StringUtil.isEmpty(App.delegateId, true) ? '' : '$_delegate_id=' + App.delegateId + '&') + '$_delegate_url=' + encodeURIComponent(url)
                 ) : (
                   App.isEncodeEnabled ? encodeURI(url) : url
                 )