github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 03:40:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #29 from taosdata/dev/shichao1

Browse Source 
[TS-1358]<fix>: fix affected row incorrect
This commit is contained in:
Minglei Jin 2022-03-24 11:08:42 +08:00 committed by GitHub
commit 03465162ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java
View File

@ -90,10 +90,10 @@ public class DefaultDataHandler implements DataHandler {
} else { } else {
try { try {
recordBatch.add(record); recordBatch.add(record);
affectedRows = writeBatch(conn, recordBatch); affectedRows += writeBatch(conn, recordBatch);
} catch (SQLException e) { } catch (SQLException e) {
LOG.warn("use one row insert. because:" + e.getMessage()); LOG.warn("use one row insert. because:" + e.getMessage());
affectedRows = writeEachRow(conn, recordBatch); affectedRows += writeEachRow(conn, recordBatch);
} }
recordBatch.clear(); recordBatch.clear();
} }
@ -102,10 +102,10 @@ public class DefaultDataHandler implements DataHandler {
if (!recordBatch.isEmpty()) { if (!recordBatch.isEmpty()) {
try { try {
affectedRows = writeBatch(conn, recordBatch); affectedRows += writeBatch(conn, recordBatch);
} catch (SQLException e) { } catch (SQLException e) {
LOG.warn("use one row insert. because:" + e.getMessage()); LOG.warn("use one row insert. because:" + e.getMessage());
affectedRows = writeEachRow(conn, recordBatch); affectedRows += writeEachRow(conn, recordBatch);
} }
recordBatch.clear(); recordBatch.clear();
} }