diff --git a/src/org/redkale/source/DataJdbcSource.java b/src/org/redkale/source/DataJdbcSource.java index 6057ca182..827923c67 100644 --- a/src/org/redkale/source/DataJdbcSource.java +++ b/src/org/redkale/source/DataJdbcSource.java @@ -63,7 +63,12 @@ public class DataJdbcSource extends DataSqlSource { conn.setAutoCommit(true); PreparedStatement prestmt = createInsertPreparedStatement(conn, sql, info, values); try { - prestmt.executeBatch(); + int[] cs = prestmt.executeBatch(); + int c1 = 0; + for (int cc : cs) { + c1 += cc; + } + c = c1; } catch (SQLException se) { if (info.tableStrategy == null || !info.isTableNotExist(se)) throw se; synchronized (info.tables) {