Przeglądaj źródła

fix 数据迁移 导出脚本文件 特殊字符处理

lvxianyun 3 lat temu
rodzic
commit
21dcd63be3

+ 5 - 7
adm-business/adm-middleware/src/main/java/com/persagy/proxy/migration/service/Impl/ObjectDigitalMigration.java

@@ -138,7 +138,6 @@ public class ObjectDigitalMigration extends MigrationAbstractServiceImpl<ObjectD
         sql = sql.substring(0, sql.lastIndexOf(","));
         sql += ";";
         sql = sql.replaceAll("\"","\\\\\"");
-        sql = sql.replaceAll("\\\\n","\\\\\\\\n");
         sql = sql.replaceAll("\\\\r","\\\\\\\\\\r");
         StringBuffer sqls = new StringBuffer("\r");
         sqls.append(MigrationConstant.DT_OBJECT_SQL_PRE);
@@ -146,8 +145,9 @@ public class ObjectDigitalMigration extends MigrationAbstractServiceImpl<ObjectD
         return  sqls.toString();
     }
     private StringBuffer appendValues(List<ObjectNode> admData){
-        StringBuffer sqls = new StringBuffer();
+        StringBuffer sqlsAll = new StringBuffer();
         admData.forEach(obj -> {
+            StringBuffer sqls = new StringBuffer();
             ObjectDigital objectDigital = JsonNodeUtils.toEntity(obj, ObjectDigital.class, "infos");
             sqls.append("(");
             sqls.append("'").append(objectDigital.getId()).append("',");
@@ -177,9 +177,6 @@ public class ObjectDigitalMigration extends MigrationAbstractServiceImpl<ObjectD
             }else{
                 sqls.append("'").append(objectDigital.getInfos()).append("',");
             }
-
-
-
             if (objectDigital.getVirtualCodes() == null) {
                 sqls.append(objectDigital.getVirtualCodes()).append(",");
             } else {
@@ -202,9 +199,10 @@ public class ObjectDigitalMigration extends MigrationAbstractServiceImpl<ObjectD
             sqls.append("'").append(objectDigital.getModifier()).append("',");
             sqls.append("'").append(objectDigital.getModifiedTime()).append("',");
             sqls.append(objectDigital.getValid());
-            sqls.append(") ,");
+            String sql = sqls.toString().replaceAll("\\\\n","\\\\\\\\n");
+            sqlsAll.append(sql).append(")\n ,");
         });
-        return sqls;
+        return sqlsAll;
     }
     private QueryCriteria getQueryCriteria(String typeCode){
         QueryCriteria queryCriteria = new QueryCriteria();