From 7ca8038318e2bde17bc0e7e273520852a4107b22 Mon Sep 17 00:00:00 2001 From: ShiChao <13263325202@163.com> Date: Wed, 23 Mar 2022 19:23:11 +0800 Subject: [PATCH 1/2] [TS-1358]: fix affected row incorrect --- .../plugin/writer/tdenginewriter/DefaultDataHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java index f2d86509..30ba7e23 100644 --- a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java +++ b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java @@ -90,10 +90,10 @@ public class DefaultDataHandler implements DataHandler { } else { try { recordBatch.add(record); - affectedRows = writeBatch(conn, recordBatch); + affectedRows += writeBatch(conn, recordBatch); } catch (SQLException e) { LOG.warn("use one row insert. because:" + e.getMessage()); - affectedRows = writeEachRow(conn, recordBatch); + affectedRows += writeEachRow(conn, recordBatch); } recordBatch.clear(); } @@ -102,10 +102,10 @@ public class DefaultDataHandler implements DataHandler { if (!recordBatch.isEmpty()) { try { - affectedRows = writeBatch(conn, recordBatch); + affectedRows += writeBatch(conn, recordBatch); } catch (SQLException e) { LOG.warn("use one row insert. because:" + e.getMessage()); - affectedRows = writeEachRow(conn, recordBatch); + affectedRows += writeEachRow(conn, recordBatch); } recordBatch.clear(); } From 81391b60730cc5b030581d3eb9434f4e7a39216b Mon Sep 17 00:00:00 2001 From: ShiChao <13263325202@163.com> Date: Wed, 23 Mar 2022 19:26:13 +0800 Subject: [PATCH 2/2] [TS-1358]: fix affected row incorrect --- .../plugin/writer/tdenginewriter/DefaultDataHandler.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java index f2d86509..30ba7e23 100644 --- a/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java +++ b/tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java @@ -90,10 +90,10 @@ public class DefaultDataHandler implements DataHandler { } else { try { recordBatch.add(record); - affectedRows = writeBatch(conn, recordBatch); + affectedRows += writeBatch(conn, recordBatch); } catch (SQLException e) { LOG.warn("use one row insert. because:" + e.getMessage()); - affectedRows = writeEachRow(conn, recordBatch); + affectedRows += writeEachRow(conn, recordBatch); } recordBatch.clear(); } @@ -102,10 +102,10 @@ public class DefaultDataHandler implements DataHandler { if (!recordBatch.isEmpty()) { try { - affectedRows = writeBatch(conn, recordBatch); + affectedRows += writeBatch(conn, recordBatch); } catch (SQLException e) { LOG.warn("use one row insert. because:" + e.getMessage()); - affectedRows = writeEachRow(conn, recordBatch); + affectedRows += writeEachRow(conn, recordBatch); } recordBatch.clear(); }