fix: deadlock when binding a wrong type in efficient writing (#252)

Author: sheyanjie-qq

src/main/java/com/taosdata/jdbc/ws/WSEWPreparedStatement.java

@@ -418,12 +418,9 @@ private void writeBlockWithRetry() throws SQLException {
                             toBeBindTagCount,
                             toBeBindColCount,
                             precision);
-                } catch (SQLException e) {
+                } catch (Exception e) {
                     lastError = e;
-                    log.error("Error in serialize data to block, stmt id: {}, req id: {}" +
-                                    "code: {}, msg: {}",
-                            stmtId, reqId,
-                            e.getErrorCode(), e.getMessage());
+                    log.error("Error in serialize data to block, stmt id: {}, req id: {}", stmtId, reqId, e);
                     break;
                 }
 

src/test/java/com/taosdata/jdbc/ws/stmt/WsEfficientWritingTest.java

@@ -17,6 +17,7 @@ public class WsEfficientWritingTest {
     private final String tableName = "wpt";
     private final String tableNameCopyData = "wpt_cp";
     private final String tableReconnect = "wpt_rc";
+    private final String tableNcharTag = "wpt_nchar";
     private final String asyncSqlTable = tableReconnect;
     private Connection connection;
     private TaosAdapterMock taosAdapterMock;
@@ -70,7 +71,7 @@ public void testStmt2InsertStdApiNoTag() throws SQLException {
         }
 
         Assert.assertEquals(numOfSubTable * numOfRow, Utils.getSqlRows(connection, db_name + "." + tableName));
-}
+    }
 
     @Test
     public void testCopyData() throws SQLException {
@@ -347,6 +348,24 @@ public void testColumnDataCloseBatchThrowsSQLException() throws SQLException {
         }
     }
 
+    @Test(expected = SQLException.class)
+    public void testNcharTagThrowsSQLException() throws SQLException {
+        String sql = "INSERT INTO " + db_name + "." + tableNcharTag + "(tbname, ts, i, tag_nchar) VALUES (?,?,?,?)";
+        try (Connection con = getConnection(false);
+             PreparedStatement pstmt = con.prepareStatement(sql)) {
+            long current = System.currentTimeMillis();
+            for (int i = 0; i < 1000; i++) {
+                pstmt.setString(1, "ncahr_bind_1");
+                pstmt.setTimestamp(2, new Timestamp(current + i));
+                pstmt.setInt(3, 100);
+                pstmt.setString(4, "中国人");
+                pstmt.addBatch();
+                pstmt.executeBatch();
+            }
+            pstmt.executeUpdate();
+        }
+    }
+
     @Before
     public void before() throws SQLException {
         connection = getConnection(false);
@@ -357,6 +376,8 @@ public void before() throws SQLException {
         statement.execute("create stable if not exists " + db_name + "." + tableName + " (ts TIMESTAMP, current FLOAT, voltage INT, phase FLOAT) TAGS (groupId INT, location BINARY(24))");
         statement.execute("create stable if not exists " + db_name + "." + tableNameCopyData + " (ts TIMESTAMP, b varbinary(10)) TAGS (groupId INT)");
         statement.execute("create stable if not exists " + db_name + "." + tableReconnect + " (ts TIMESTAMP, i INT) TAGS (groupId INT)");
+        statement.execute("create stable if not exists " + db_name + "." + tableNcharTag + " (ts TIMESTAMP, i INT) TAGS (tag_nchar nchar(100))");
+
         statement.close();
 
         createSubTable();