zs

src/main/java/com/zjty/adaptationmaster/adaptor/entity/Project.java

@@ -31,6 +31,8 @@ public class Project {
     private String sourceDB;//原数据库
     private String createTypeDB;//目标数据库
     private String createMiddleware;//目标中间件
+    private String operatingSystem;//操作系统
+    private String cpu;//cpu
 
     private String codeUrl;//当前源码源码路径
 

src/main/java/com/zjty/adaptationmaster/adaptor/entity/db/DBName.java

+package com.zjty.adaptationmaster.adaptor.entity.db;
+
+public class DBName {
+
+    public static String highgoName = "highgo";
+
+}

src/main/java/com/zjty/adaptationmaster/adaptor/entity/db/SQLExecuteTask.java

@@ -22,12 +22,12 @@ public class SQLExecuteTask implements Runnable{
     public void run() {
         Connection connection = null;
         PreparedStatement preparedStatement = null;
-        //String unRecordSql = "SET LOCAL fsync TO OFF;";
+        String unRecordSql = "SET LOCAL synchronous_commit TO OFF;";
         try {
             connection = Regular.databaseConnection(dbManage);
-            //不记录日志,加快insert速度
-            //preparedStatement = connection.prepareStatement(unRecordSql);
-            //preparedStatement.execute();
+            //将数据库临时设置为异步提交，不等待wal日志完成就返回成功响应
+            preparedStatement = connection.prepareStatement(unRecordSql);
+            preparedStatement.execute();
             preparedStatement = connection.prepareStatement(sql);
             preparedStatement.setQueryTimeout(10);
             preparedStatement.execute();

src/main/java/com/zjty/adaptationmaster/adaptor/service/Impl/DBManageServiceImpl.java

@@ -3,6 +3,7 @@ package com.zjty.adaptationmaster.adaptor.service.Impl;
 
 import com.zjty.adaptationmaster.adaptor.entity.db.DBDeleteResponse;
 import com.zjty.adaptationmaster.adaptor.entity.db.DBManage;
+import com.zjty.adaptationmaster.adaptor.entity.db.DBName;
 import com.zjty.adaptationmaster.adaptor.entity.db.DBRecord;
 import com.zjty.adaptationmaster.adaptor.repository.DBManageDao;
 import com.zjty.adaptationmaster.adaptor.repository.DBRecordDao;
@@ -78,7 +79,7 @@ public class DBManageServiceImpl implements DBManageService {
     @Transactional
     public ServerResponse deleteDB(DBDeleteResponse dbDeleteResponse) {
         DBManage dbManage = databaseDao.findDBManageByIdAndStatus(dbDeleteResponse.getId(),1);
-        if(dbDeleteResponse.getDbType().equals("highgo")){
+        if(dbDeleteResponse.getDbType().equals(DBName.highgoName)){
             dbManage.setDatabaseName(highgoDBName);
             dbManage.setDriver(highgoDriver);
             dbManage.setConnectionType(highgoConnnectionType);

src/main/java/com/zjty/adaptationmaster/adaptor/service/Impl/DBMigrateServiceImpl.java

@@ -75,8 +75,8 @@ public class DBMigrateServiceImpl implements DBMigrateService {
             String path = "";
             //根据传入的生成数据库类型，查找未被删除的配置文件
             DBManage databaseManagement = dbManageDao.findDBManageByIdAndStatus(databaseResponse.getId(),1);
-            //mysql数据库
-            if(databaseResponse.getCreateType().equals("highgo") && databaseResponse.getSourceType().equals("mysql")){
+            //源数据库：mysql数据库  目标数据库：highgo
+            if(databaseResponse.getCreateType().equals(DBName.highgoName) && databaseResponse.getSourceType().equals("mysql")){
                 //生成数据库的名称
                 //连接系统数据库，建立新数据库
                 databaseManagement.setDatabaseName(highgoDBName);
@@ -159,7 +159,7 @@ public class DBMigrateServiceImpl implements DBMigrateService {
                             }
                             preparedStatement1 = connection1.prepareStatement(createTableSql);
                             preparedStatement1.execute();
-                            //插入
+                            //数据插入
                             if(insertList != null && insertList.size() != 0){
                                 for(String insert:insertList){
                                     int insertIndex = insert.indexOf("\"") + 1;
@@ -250,7 +250,7 @@ public class DBMigrateServiceImpl implements DBMigrateService {
         DBNameReturn dbNameReturn = new DBNameReturn();
         DBManage databaseManagement = dbManageDao.findDBManageByIdAndStatus(id, 1);
         //highgo查询所有数据库
-        if(databaseManagement.getDatabaseType().equals("highgo")){
+        if(databaseManagement.getDatabaseType().equals(DBName.highgoName)){
             databaseManagement.setDatabaseName(highgoDBName);
             databaseManagement.setDriver(highgoDriver);
             databaseManagement.setConnectionType(highgoConnnectionType);