Package io.quarkus.agroal.runtime

Class OpenTelemetryAgroalDataSource

java.lang.Object

io.quarkus.agroal.runtime.OpenTelemetryAgroalDataSource

All Implemented Interfaces:

io.agroal.api.AgroalDataSource, Serializable, AutoCloseable, Wrapper, CommonDataSource, DataSource

public class OpenTelemetryAgroalDataSource
extends Object
implements io.agroal.api.AgroalDataSource

The AgroalDataSource wrapper that activates OpenTelemetry JDBC instrumentation.

Uses composition to wrap an OpenTelemetryDataSource (for instrumented connections) while delegating AgroalDataSource-specific operations to the original data source.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface io.agroal.api.AgroalDataSource

io.agroal.api.AgroalDataSource.FlushMode

Constructor Summary

Constructors

Constructor	Description
OpenTelemetryAgroalDataSource(io.agroal.api.AgroalDataSource delegate, io.opentelemetry.instrumentation.jdbc.datasource.OpenTelemetryDataSource otelDataSource)

Method Summary

Modifier and Type	Method	Description
void	close()
ShardingKeyBuilder	createShardingKeyBuilder()
void	flush(io.agroal.api.AgroalDataSource.FlushMode mode)
io.agroal.api.configuration.AgroalDataSourceConfiguration	getConfiguration()
Connection	getConnection()
Connection	getConnection(String username, String password)
int	getLoginTimeout()
PrintWriter	getLogWriter()
io.agroal.api.AgroalDataSourceMetrics	getMetrics()
Logger	getParentLogger()
List<io.agroal.api.AgroalPoolInterceptor>	getPoolInterceptors()
Connection	getReadOnlyConnection()
boolean	isHealthy(boolean newConnection)
boolean	isWrapperFor(Class<?> iface)
void	setLoginTimeout(int seconds)
void	setLogWriter(PrintWriter out)
void	setPoolInterceptors(Collection<? extends io.agroal.api.AgroalPoolInterceptor> interceptors)
<T> T	unwrap(Class<T> iface)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder

Constructor Details

OpenTelemetryAgroalDataSource

public OpenTelemetryAgroalDataSource(io.agroal.api.AgroalDataSource delegate,
 io.opentelemetry.instrumentation.jdbc.datasource.OpenTelemetryDataSource otelDataSource)

Method Details

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getConnection

public Connection getConnection(String username,
 String password)
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getLogWriter

public PrintWriter getLogWriter()
                         throws SQLException

Specified by:

getLogWriter in interface CommonDataSource

Specified by:

getLogWriter in interface DataSource

Throws:

SQLException

setLogWriter

public void setLogWriter(PrintWriter out)
                  throws SQLException

Specified by:

setLogWriter in interface CommonDataSource

Specified by:

setLogWriter in interface DataSource

Throws:

SQLException

getLoginTimeout

public int getLoginTimeout()
                    throws SQLException

Specified by:

getLoginTimeout in interface CommonDataSource

Specified by:

getLoginTimeout in interface DataSource

Throws:

SQLException

setLoginTimeout

public void setLoginTimeout(int seconds)
                     throws SQLException

Specified by:

setLoginTimeout in interface CommonDataSource

Specified by:

setLoginTimeout in interface DataSource

Throws:

SQLException

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

unwrap

public <T> T unwrap(Class<T> iface)
             throws SQLException

Specified by:

unwrap in interface Wrapper

Throws:

SQLException

isWrapperFor

public boolean isWrapperFor(Class<?> iface)
                     throws SQLException

Specified by:

isWrapperFor in interface Wrapper

Throws:

SQLException

isHealthy

public boolean isHealthy(boolean newConnection)
                  throws SQLException

Specified by:

isHealthy in interface io.agroal.api.AgroalDataSource

Throws:

SQLException

getReadOnlyConnection

public Connection getReadOnlyConnection()
                                 throws SQLException

Specified by:

getReadOnlyConnection in interface io.agroal.api.AgroalDataSource

Throws:

SQLException

getConfiguration

public io.agroal.api.configuration.AgroalDataSourceConfiguration getConfiguration()

Specified by:

getConfiguration in interface io.agroal.api.AgroalDataSource

getMetrics

public io.agroal.api.AgroalDataSourceMetrics getMetrics()

Specified by:

getMetrics in interface io.agroal.api.AgroalDataSource

flush

public void flush(io.agroal.api.AgroalDataSource.FlushMode mode)

Specified by:

flush in interface io.agroal.api.AgroalDataSource

setPoolInterceptors

public void setPoolInterceptors(Collection<? extends io.agroal.api.AgroalPoolInterceptor> interceptors)

Specified by:

setPoolInterceptors in interface io.agroal.api.AgroalDataSource

getPoolInterceptors

public List<io.agroal.api.AgroalPoolInterceptor> getPoolInterceptors()

Specified by:

getPoolInterceptors in interface io.agroal.api.AgroalDataSource

createShardingKeyBuilder

public ShardingKeyBuilder createShardingKeyBuilder()
                                            throws SQLException

Specified by:

createShardingKeyBuilder in interface CommonDataSource

Throws:

SQLException

close

public void close()

Specified by:

close in interface io.agroal.api.AgroalDataSource

Specified by:

close in interface AutoCloseable