diff --git a/nop-batch/nop-batch-jdbc/src/main/java/io/nop/batch/jdbc/consumer/JdbcUpdateBatchConsumer.java b/nop-batch/nop-batch-jdbc/src/main/java/io/nop/batch/jdbc/consumer/JdbcUpdateBatchConsumer.java index beb015db6537e8c5646a3793cc5265632274277a..e9c44d73b47fff3463eb8a2e1f6b54eb89601762 100644 --- a/nop-batch/nop-batch-jdbc/src/main/java/io/nop/batch/jdbc/consumer/JdbcUpdateBatchConsumer.java +++ b/nop-batch/nop-batch-jdbc/src/main/java/io/nop/batch/jdbc/consumer/JdbcUpdateBatchConsumer.java @@ -88,13 +88,13 @@ public class JdbcUpdateBatchConsumer implements IBatchConsumerProvider, IB if (first) { first = false; } else { - sb.append(','); + sb.append(" AND "); } + sb.append(keyField).append("="); IDataParameterBinder binder = this.colBinders.get(keyField); appendParam(sb, binder, BeanTool.getProperty(record, keyField)); } - sb.append(')'); return sb.end(); }