We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 05ea936 commit 467f48dCopy full SHA for 467f48d
src/main/java/org/javawebstack/orm/connection/pool/SQLPool.java
@@ -15,6 +15,7 @@ public class SQLPool {
15
private final Queue<SQL> connectionQueue = new LinkedBlockingQueue<>();
16
private final Set<QueryLogger> loggers = new HashSet<>();
17
private boolean closing;
18
+ private PoolQueryLogger queryLogger = new PoolQueryLogger();
19
20
public SQLPool(PoolScaling scaling, Supplier<SQL> supplier) {
21
this.scaling = scaling;
@@ -64,6 +65,7 @@ public void scale() {
64
65
return;
66
while (newScale > connections.size()) {
67
SQL sql = supplier.get();
68
+ sql.addQueryLogger(queryLogger);
69
connections.add(sql);
70
connectionQueue.add(sql);
71
}
0 commit comments