package io.quarkus.agroal.runtime;

import java.sql.Connection;

import org.jboss.logging.Logger;

import io.agroal.api.AgroalDataSourceListener;

final class AgroalEventLoggingListener implements AgroalDataSourceListener {

    private static final Logger log = Logger.getLogger("io.agroal.pool");

    private final String datasourceName;

    public AgroalEventLoggingListener(String name) {
        this.datasourceName = name;
    }

    @Override
    public void beforeConnectionLeak(Connection connection) {
        log.tracev("{0}: Leak test on connection {1}", datasourceName, connection);
    }

    @Override
    public void beforeConnectionReap(Connection connection) {
        log.tracev("{0}: Reap test on connection {1}", datasourceName, connection);
    }

    @Override
    public void beforeConnectionValidation(Connection connection) {
        log.tracev("{0}: Validation test on connection {1}", datasourceName, connection);
    }

    @Override
    public void onConnectionAcquire(Connection connection) {
        log.tracev("{0}: Acquire connection {1}", datasourceName, connection);
    }

    @Override
    public void onConnectionCreation(Connection connection) {
        log.tracev("{0}: Created connection {1}", datasourceName, connection);
    }

    @Override
    public void onConnectionReap(Connection connection) {
        log.tracev("{0}: Closing idle connection {1}", datasourceName, connection);
    }

    @Override
    public void onConnectionReturn(Connection connection) {
        log.tracev("{0}: Returning connection {1}", datasourceName, connection);
    }

    @Override
    public void onConnectionDestroy(Connection connection) {
        log.tracev("{0}: Destroyed connection {1}", datasourceName, connection);
    }

    @Override
    public void onWarning(String warning) {
        log.warnv("{0}: {1}", datasourceName, warning);
    }

    @Override
    public void onInfo(String message) {
        log.infov("{0}: {1}", datasourceName, message);
    }

    @Override
    public void onWarning(Throwable throwable) {
        log.warnv("{0}: {1}", datasourceName, throwable.getMessage());
        log.debug("Cause: ", throwable);
    }
}

@@ -418,20 +418,43 @@
 eName = 
-name
+%22Datasource '%22 + name + %22'%22
 ;%0A    %7D%0A

Clarify error messages by prefixing Datasource label to the datasource names