org.apache.oozie.util.db

Class FailingMySQLDriverWrapper

java.lang.Object

com.mysql.jdbc.NonRegisteringDriver

com.mysql.jdbc.Driver

org.apache.oozie.util.db.FailingMySQLDriverWrapper

All Implemented Interfaces:

Driver

public class FailingMySQLDriverWrapper
extends com.mysql.jdbc.Driver

Used for runtime database error injection on MySQL.

Necessary steps:

• set oozie.service.JPAService.connection.data.source to org.apache.oozie.util.db.BasicDataSourceWrapper within oozie-site.xml
• set oozie.service.JPAService.jdbc.driver to org.apache.oozie.util.db.FailingMySQLDriverWrapper within oozie-site.xml
• restart Oozie server
• submit / start some workflows, coordinators etc.
• see any of those JPAException instances with following message prefix: Deliberately failing to prepare statement.

Field Summary

Fields inherited from class com.mysql.jdbc.NonRegisteringDriver

connectionPhantomRefs, DBNAME_PROPERTY_KEY, DEBUG, HOST_NAME_INDEX, HOST_PROPERTY_KEY, LICENSE, LOADBALANCE_URL_PREFIX, NAME, NUM_HOSTS_PROPERTY_KEY, OS, PASSWORD_PROPERTY_KEY, PATH_PROPERTY_KEY, PLATFORM, PORT_NUMBER_INDEX, PORT_PROPERTY_KEY, PROPERTIES_TRANSFORM_KEY, PROTOCOL_PROPERTY_KEY, refQueue, RUNTIME_VENDOR, RUNTIME_VERSION, TRACE, USE_CONFIG_PROPERTY_KEY, USER_PROPERTY_KEY, VERSION

Constructor Summary

Constructors

Constructor and Description
FailingMySQLDriverWrapper()

Method Summary

Modifier and Type	Method and Description
Connection	connect(String url, Properties info)

Methods inherited from class com.mysql.jdbc.NonRegisteringDriver

acceptsURL, connectReplicationConnection, database, expandHostKeyValues, getMajorVersion, getMinorVersion, getOSName, getPlatform, getPropertyInfo, host, isHostPropertiesList, jdbcCompliant, parseHostPortPair, parseURL, port, property, trackConnection

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Driver

acceptsURL, getMajorVersion, getMinorVersion, getParentLogger, getPropertyInfo, jdbcCompliant

Constructor Detail

FailingMySQLDriverWrapper

public FailingMySQLDriverWrapper()
                          throws SQLException

Throws:

SQLException

Method Detail

connect

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

Specified by:

connect in interface Driver

Overrides:

connect in class com.mysql.jdbc.NonRegisteringDriver

Throws:

SQLException