zs

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

@@ -142,7 +142,11 @@ public class DBMigrateServiceImpl implements DBMigrateService {
                                 if(s.contains(";")){
                                     if(Regular.lowerAndUpper(s,"CREATE") && Regular.lowerAndUpper(s,"TABLE")){
                                         String tableName = s.substring(s.indexOf("\"") + 1,s.lastIndexOf("\""));
-                                        WebSocketServer.sendIn(uuid,tableName + "表创建");
+                                        try {
+                                            WebSocketServer.sendIn(uuid,tableName + "表创建");
+                                        }catch (Exception e){
+                                            e.printStackTrace();
+                                        }
                                     }
                                     preparedStatement1 = connection1.prepareStatement(sql);
                                     preparedStatement1.execute();
@@ -151,8 +155,22 @@ public class DBMigrateServiceImpl implements DBMigrateService {
                             }
                             if(insertList != null && insertList.size() != 0){
                                 for(String insert:insertList){
-                                    String tableName = s.substring(s.indexOf("\"") + 1,s.lastIndexOf("\""));
-                                    WebSocketServer.sendIn(uuid,tableName + "表中正在插入");
+                                    int insertIndex = insert.indexOf("\"") + 1;
+                                    String tableName = "";
+                                    for(int j = insertIndex;j < insert.length();j++){
+                                        if(insert.charAt(j) == '"'){
+                                            break;
+                                        }else {
+                                            tableName += insert.charAt(j);
+                                        }
+                                    }
+                                    //String tableName = insert.substring(insert.indexOf("\"") + 1,insert.indexOf("("));
+                                    //tableName = tableName.replace("\"","");
+                                    try {
+                                        WebSocketServer.sendIn(uuid,tableName + "表中正在插入");
+                                    }catch (Exception e){
+                                        e.printStackTrace();
+                                    }
                                     SQLExecuteTask sqlExecuteTask = new SQLExecuteTask(connection1);
                                     sqlExecuteTask.setSql(insert);
                                     pool.submit(sqlExecuteTask);