diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java index 67750cd70be2..000202a4e7d6 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java @@ -143,7 +143,7 @@ protected PreparedStatement createPreparedStatement(String sql) throws SQLExcept if (connection.getAutoCommit() != autoCommit) { connection.setAutoCommit(autoCommit); } - log.debug("Prepared statement: {}", sql); + log.info("Prepared statement: {}", sql); return jdbcDialect.creatPreparedStatement(connection, sql, fetchSize); } diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java index a6c10b8a5e9a..bafe042ae7de 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java @@ -903,16 +903,31 @@ private static void prepareDynamicSplitStatement( statement.setObject(i + 1, splitEnd[i]); statement.setObject(i + 1 + splitKeyNumbers, splitEnd[i]); } + log.info( + "Dynamic split (first) - params: [{}={}, {}={}]", + 1, + splitEnd[0], + 2, + splitEnd[0]); } else if (isLastSplit) { for (int i = 0; i < splitKeyNumbers; i++) { statement.setObject(i + 1, splitStart[i]); } + log.info("Dynamic split (last) - params: [{}={}]", 1, splitStart[0]); } else { for (int i = 0; i < splitKeyNumbers; i++) { statement.setObject(i + 1, splitStart[i]); statement.setObject(i + 1 + splitKeyNumbers, splitEnd[i]); statement.setObject(i + 1 + 2 * splitKeyNumbers, splitEnd[i]); } + log.info( + "Dynamic split (middle) - params: [{}={}, {}={}, {}={}]", + 1, + splitStart[0], + 2, + splitEnd[0], + 3, + splitEnd[0]); } } diff --git a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java index 309b6c82bd67..5ad48e8554be 100644 --- a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java +++ b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java @@ -341,6 +341,7 @@ private PreparedStatement createStringColumnSplitStatement(JdbcSourceSplit split throws SQLException { PreparedStatement statement = createPreparedStatement(split.getSplitQuery()); statement.setInt(1, (Integer) split.getSplitStart()); + log.info("String column split - param[1]: {}", split.getSplitStart()); return statement; } @@ -410,6 +411,12 @@ private Collection createNumberColumnSplits( jdbcNumericBetweenParametersProvider.getParameterValues(); List splits = new ArrayList<>(table.getPartitionNumber()); for (int i = 0; i < parameterValues.length; i++) { + log.info( + "Number column split - params: [{}={}, {}={}]", + 1, + parameterValues[i][0], + 2, + parameterValues[i][1]); JdbcSourceSplit split = new JdbcSourceSplit( table.getTablePath(),