[dbconn替换]

todd5167 · todd5167 · commit 491c3c35801c · 2019-09-18T16:42:41.000+08:00
diff --git a/rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/RetractJDBCOutputFormat.java b/rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/format/RetractJDBCOutputFormat.java
@@ -329,6 +329,7 @@ private void checkConnectionOpen(Connection dbConn) {
                 LOG.info("db connection reconnect..");
                 dbConn= establishConnection();
                 upload = dbConn.prepareStatement(insertQuery);
+                this.dbConn = dbConn;
             }
         } catch (SQLException e) {
             LOG.error("check connection open failed..", e);

Original file line number	Diff line number	Diff line change
`@@ -329,6 +329,7 @@ private void checkConnectionOpen(Connection dbConn) {`
`329`	`329`	`LOG.info("db connection reconnect..");`
`330`	`330`	`dbConn= establishConnection();`
`331`	`331`	`upload = dbConn.prepareStatement(insertQuery);`
	`332`	`+ this.dbConn = dbConn;`
`332`	`333`	`}`
`333`	`334`	`} catch (SQLException e) {`
`334`	`335`	`LOG.error("check connection open failed..", e);`