穿云 5 months ago
parent
commit
12b1568232

+ 6 - 2
dbsyncer-connector/dbsyncer-connector-sqlserver/src/main/java/org/dbsyncer/connector/sqlserver/SqlServerConnector.java

@@ -130,7 +130,12 @@ public final class SqlServerConnector extends AbstractDatabaseConnector {
     @Override
     public Map<String, String> getTargetCommand(CommandConfig commandConfig) {
         Map<String, String> targetCommand = super.getTargetCommand(commandConfig);
-        targetCommand.put(ConnectorConstant.OPERTION_INSERT, "SET IDENTITY_INSERT " + commandConfig.getTable().getName() + " ON;" + targetCommand.get("INSERT"));
+        String insert = new StringBuilder("SET IDENTITY_INSERT ")
+                .append(commandConfig.getTable().getName())
+                .append(" ON;")
+                .append(targetCommand.get(ConnectorConstant.OPERTION_INSERT))
+                .toString();
+        targetCommand.put(ConnectorConstant.OPERTION_INSERT, insert);
         return targetCommand;
     }
 
@@ -138,5 +143,4 @@ public final class SqlServerConnector extends AbstractDatabaseConnector {
         return new StringBuilder("[").append(key).append("]").toString();
     }
 
-
 }