Skip to content

Commit 95ebbd3

Browse files
committed
Added query result debug
1 parent 160ab43 commit 95ebbd3

1 file changed

Lines changed: 9 additions & 1 deletion

File tree

core/src/main/java/me/zort/sqllib/SQLDatabaseConnectionImpl.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -415,7 +415,7 @@ QueryRowsResult<Row> query(final @NotNull Query query, boolean isRetry) {
415415
}
416416

417417
cacheManager.set(query, result);
418-
418+
debug(result);
419419
return result;
420420
} catch (SQLException e) {
421421
if (!isRetry && e.getMessage().contains("database connection closed")) {
@@ -460,6 +460,7 @@ public QueryResult exec(final @NotNull String query) {
460460
stmt.execute();
461461
QueryResultImpl result = new QueryResultImpl(true);
462462
cacheManager.set(query, result);
463+
debug(result);
463464
return result;
464465
} catch (SQLException e) {
465466
if (!isRetry && e.getMessage().contains("database connection closed")) {
@@ -565,6 +566,13 @@ public void debug(String message) {
565566
if(options.isDebug()) logger.info(message);
566567
}
567568

569+
private void debug(QueryResult result) {
570+
debug("Query result: " + result);
571+
if (result instanceof QueryRowsResult) {
572+
debug("Rows: " + ((QueryRowsResult<?>) result).size());
573+
}
574+
}
575+
568576
@Override
569577
public void close() {
570578
if (errorCount > 0 && getAssignedPool() != null) {

0 commit comments

Comments
 (0)