Package org.pjdbc.drivers

Class ChaosDriver

java.lang.Object

org.pjdbc.sql.AbstractDriver

org.pjdbc.sql.AbstractProxyDriver

org.pjdbc.drivers.ChaosDriver

All Implemented Interfaces:

Driver

@DriverCapability(prefix="chaos",
                  description="Injects configurable failures and latency for resilience testing",
                  capabilities={"testing","resilience"})
@DriverParameter(name="failureRate",type=FLOAT,description="Probability of throwing SQLException per query",defaultValue="0.0") @DriverParameter(name="latency",type=INTEGER,description="Fixed delay in milliseconds before each query",defaultValue="0",min=0L) @DriverParameter(name="latencyVariance",type=INTEGER,description="Random additional delay up to this value in ms",defaultValue="0",min=0L) @DriverParameter(name="connectionDropRate",type=FLOAT,description="Probability of closing connection unexpectedly",defaultValue="0.0") @DriverParameter(name="resultSetLatency",type=INTEGER,description="Delay in ms for each ResultSet.next() call",defaultValue="0",min=0L) @DriverParameter(name="exceptionMessage",type=STRING,description="Custom exception message",defaultValue="ChaosDriver: Induced failure")
public class ChaosDriver
extends AbstractProxyDriver

ChaosDriver injects configurable failures and latency for resilience testing.

URL format: jdbc:chaos[param=value,...]:jdbc:target:...

Example URLs:

 jdbc:chaos[failureRate=0.1]:jdbc:postgresql://localhost/mydb
 jdbc:chaos[latency=100,latencyVariance=50]:jdbc:h2:mem:test
 jdbc:chaos[failureRate=0.05,connectionDropRate=0.01]:jdbc:mysql://localhost/db
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChaosDriver.ChaosConfig	Configuration holder for chaos parameters, parsed once at connection time.

Driver Parameters

URL format: jdbc:chaos[param=value,...]:<target-url>

Parameter	Type	Default	Constraints	Description
failureRate	float	0.0	-	Probability of throwing SQLException per query
latency	integer	0	≥ 0	Fixed delay in milliseconds before each query
latencyVariance	integer	0	≥ 0	Random additional delay up to this value in ms
connectionDropRate	float	0.0	-	Probability of closing connection unexpectedly
resultSetLatency	integer	0	≥ 0	Delay in ms for each ResultSet.next() call
exceptionMessage	string	ChaosDriver: Induced failure	-	Custom exception message

Constructor Summary

Constructors

Constructor	Description
ChaosDriver()

Method Summary

Modifier and Type	Method	Description
protected boolean	acceptsSubName(String subname)
protected boolean	acceptsSubProtocol(String subprotocol)
Connection	connect(String url, Properties info)
protected CallableStatement	proxyCallableStatement(CallableStatement delegate, Connection conn)
protected Connection	proxyConnection(Connection delegate, String url, Properties info, Driver driver)
protected PreparedStatement	proxyPreparedStatement(PreparedStatement delegate, Connection conn)
ResultSet	proxyResultSet(Statement stmt, ResultSet delegate)
protected Statement	proxyStatement(Statement delegate, Connection conn)

Methods inherited from class org.pjdbc.sql.AbstractProxyDriver

getPropertyInfo, isCompositionValidationEnabled, isValidateParametersEnabled, proxyCallableStatement, proxyConnection, proxyConnection, proxyPreparedStatement

Methods inherited from class org.pjdbc.sql.AbstractDriver

acceptsProtocol, acceptsURL, getMajorVersion, getMinorVersion, getParentLogger, getUrlParameter, getUrlParameter, getUrlParameters, jdbcCompliant, parseUrl, protocol, subname, subprotocol, validateParameters

Methods inherited from class java.lang.Object

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

Constructor Details

ChaosDriver

public ChaosDriver()

Method Details

acceptsSubProtocol

protected boolean acceptsSubProtocol(String subprotocol)

Specified by:

acceptsSubProtocol in class AbstractDriver

acceptsSubName

protected boolean acceptsSubName(String subname)

Overrides:

acceptsSubName in class AbstractProxyDriver

connect

public Connection connect(String url,
 Properties info)
                   throws SQLException

Specified by:

connect in interface Driver

Overrides:

connect in class AbstractProxyDriver

Throws:

SQLException

proxyConnection

protected Connection proxyConnection(Connection delegate,
 String url,
 Properties info,
 Driver driver)
                              throws SQLException

Overrides:

proxyConnection in class AbstractProxyDriver

Throws:

SQLException

proxyStatement

protected Statement proxyStatement(Statement delegate,
 Connection conn)
                            throws SQLException

Overrides:

proxyStatement in class AbstractProxyDriver

Throws:

SQLException

proxyPreparedStatement

protected PreparedStatement proxyPreparedStatement(PreparedStatement delegate,
 Connection conn)
                                            throws SQLException

Overrides:

proxyPreparedStatement in class AbstractProxyDriver

Throws:

SQLException

proxyCallableStatement

protected CallableStatement proxyCallableStatement(CallableStatement delegate,
 Connection conn)
                                            throws SQLException

Overrides:

proxyCallableStatement in class AbstractProxyDriver

Throws:

SQLException

proxyResultSet

public ResultSet proxyResultSet(Statement stmt,
 ResultSet delegate)
                         throws SQLException

Overrides:

proxyResultSet in class AbstractProxyDriver

Throws:

SQLException