jOOQ’s R2DBC LoggingConnection to log all SQL statements

jOOQ already has a LoggingConnection (see also the manual), which acts as a JDBC proxy Connection to log all SQL statements that are executed by any JDBC client (including Hibernate, MyBatis, JdbcTemplate, native JDBC, etc.). Starting from jOOQ 3.18.0, 3.17.7, and 3.16.13, a LoggingConnection is now also available for R2DBC clients to log all reactive … Continue reading jOOQ’s R2DBC LoggingConnection to log all SQL statements →

jOOQ’s R2DBC LoggingConnection to log all SQL statements

Posted on January 17, 2023January 17, 2023 by lukaseder

jOOQ already has a LoggingConnection (see also the manual), which acts as a JDBC proxy Connection to log all SQL statements that are executed by any JDBC client (including Hibernate, MyBatis, JdbcTemplate, native JDBC, etc.).

Starting from jOOQ 3.18.0, 3.17.7, and 3.16.13, a LoggingConnection is now also available for R2DBC clients to log all reactive queries. While some R2DBC drivers already do their own DEBUG logging, some of them don’t, so this utility will be very useful to jOOQ users or anyone else working with R2DBC.

If you don’t want to add the jOOQ dependency, you can simply use the LoggingConnection code available from github. To give you an idea of what it does:

// The jOOQ DefaultConnection just delegates all calls
// to a delegate Connection
public class LoggingConnection extends DefaultConnection {

// Use your own logger, alternatively
private static final JooqLogger log =
JooqLogger.getLogger(LoggingConnection.class);

public LoggingConnection(Connection delegate) {
super(delegate);

@Override
public Publisher<Void> close() {
return s -> {
if (log.isDebugEnabled())
log.debug("Connection::close");

getDelegate().close().subscribe(s);

@Override
public Statement createStatement(String sql) {
if (log.isDebugEnabled())
log.debug("Connection::createStatement", sql);

return new LoggingStatement(getDelegate().createStatement(sql));

// [...]

And the same thing is done with a wrapper for Statement or Batch:

// The jOOQ DefaultStatement just delegates all calls
// to a delegate Statement
public class LoggingStatement extends DefaultStatement {

// Use your own logger, alternatively
private static final JooqLogger log =
JooqLogger.getLogger(LoggingStatement.class);

public LoggingStatement(Statement delegate) {
super(delegate);

@Override
public Statement add() {
if (log.isDebugEnabled())
log.debug("Statement::add");

getDelegate().add();
return this;

@Override
public Publisher<? extends Result> execute() {
return s -> {
if (log.isDebugEnabled())
log.debug("Statement::execute");

getDelegate().execute().subscribe(s);

That’s it!

• Facebook
• LinkedIn
• X
• Reddit
• More

Like this:

Like Loading...

###
Published by lukaseder

I made jOOQ View all posts by lukaseder

Original source