commit

src/main/java/com/cxzx/db/Tidb.java

@@ -11,7 +11,7 @@ import java.util.List;
 
 public class Tidb {
 
-    private static final Connection connection ;
+    private static final Connection connection;
 
     static {
         try {
@@ -29,15 +29,15 @@ public class Tidb {
         if (CollUtil.isEmpty(kafkaDataList)) {
             return;
         }
-        @Cleanup
         var preparedStatement = connection.prepareStatement("insert ignore into article (offset,create_time,data) values (?,?,?)");
-        for (KafkaData kafkaData : kafkaDataList) {
-            preparedStatement.setLong(1, kafkaData.getOffset());
-            preparedStatement.setTimestamp(2, kafkaData.getCreateTime());
-            preparedStatement.setString(3, kafkaData.getData());
-            preparedStatement.addBatch();
+        try (preparedStatement) {
+            for (KafkaData kafkaData : kafkaDataList) {
+                preparedStatement.setLong(1, kafkaData.getOffset());
+                preparedStatement.setTimestamp(2, kafkaData.getCreateTime());
+                preparedStatement.setString(3, kafkaData.getData());
+                preparedStatement.addBatch();
+            }
+            preparedStatement.executeBatch();
         }
-        preparedStatement.executeBatch();
-
     }
 }