Skip to content

Commit 2c96555

Browse files
committed
added SQL request to log
1 parent bad3fb3 commit 2c96555

File tree

1 file changed

+4
-0
lines changed
  • src/main/java/io/elastic/jdbc/QueryBuilders

1 file changed

+4
-0
lines changed

src/main/java/io/elastic/jdbc/QueryBuilders/Query.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,8 +14,11 @@
1414
import javax.json.JsonObject;
1515
import javax.json.JsonObjectBuilder;
1616
import javax.json.JsonValue;
17+
import org.slf4j.Logger;
18+
import org.slf4j.LoggerFactory;
1719

1820
public abstract class Query {
21+
private static final Logger LOGGER = LoggerFactory.getLogger(Query.class);
1922

2023
protected Integer skipNumber = 0;
2124
protected Integer countNumber = 5000;
@@ -276,6 +279,7 @@ public ArrayList getRowsExecutePolling(Connection connection, String sql) throws
276279
try (PreparedStatement stmt = connection.prepareStatement(sql)) {
277280
stmt.setTimestamp(1, pollingValue);
278281
stmt.setInt(2, countNumber);
282+
LOGGER.info("SQL statement: {} with params: {}, {}", sql, pollingValue, countNumber);
279283
try (ResultSet rs = stmt.executeQuery()) {
280284
ArrayList listResult = new ArrayList();
281285
JsonObjectBuilder row = Json.createObjectBuilder();

0 commit comments

Comments
 (0)