org.apache.activemq.artemis.jdbc.store.drivers

Class AbstractJDBCDriver

java.lang.Object

org.apache.activemq.artemis.jdbc.store.drivers.AbstractJDBCDriver

Direct Known Subclasses:

JDBCJournalImpl, JDBCSequentialFileFactoryDriver

public abstract class AbstractJDBCDriver
extends Object

Class to hold common database functionality such as drivers and connections

Field Summary

Fields

Modifier and Type	Field and Description
protected Connection	connection
protected SQLProvider	sqlProvider

Constructor Summary

Constructors

Constructor and Description
AbstractJDBCDriver()
AbstractJDBCDriver(Connection connection, SQLProvider sqlProvider)
AbstractJDBCDriver(DataSource dataSource, SQLProvider provider)
AbstractJDBCDriver(SQLProvider sqlProvider, String jdbcConnectionUrl, String user, String password, String jdbcDriverClass)

Method Summary

Modifier and Type	Method and Description
protected abstract void	createSchema()
protected void	createTable(String... schemaSqls)
void	destroy()
Connection	getConnection()
String	getPassword()
String	getUser()
protected abstract void	prepareStatements()
void	setConnection(Connection connection)
void	setDataSource(DataSource dataSource)
void	setJdbcConnectionUrl(String jdbcConnectionUrl)
void	setJdbcDriverClass(String jdbcDriverClass)
void	setNetworkTimeout(Executor executor, int milliseconds)
void	setPassword(String password)
void	setSqlProvider(SQLProvider sqlProvider)
void	setUser(String user)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected Connection connection

sqlProvider

protected SQLProvider sqlProvider

Constructor Detail

AbstractJDBCDriver

public AbstractJDBCDriver()

AbstractJDBCDriver

public AbstractJDBCDriver(SQLProvider sqlProvider,
                          String jdbcConnectionUrl,
                          String user,
                          String password,
                          String jdbcDriverClass)

AbstractJDBCDriver

public AbstractJDBCDriver(DataSource dataSource,
                          SQLProvider provider)

AbstractJDBCDriver

public AbstractJDBCDriver(Connection connection,
                          SQLProvider sqlProvider)

Method Detail

start

public void start()
           throws SQLException

Throws:

SQLException

stop

public void stop()
          throws SQLException

Throws:

SQLException

prepareStatements

protected abstract void prepareStatements()
                                   throws SQLException

Throws:

SQLException

createSchema

protected abstract void createSchema()
                              throws SQLException

Throws:

SQLException

createTable

protected final void createTable(String... schemaSqls)
                          throws SQLException

Throws:

SQLException

destroy

public void destroy()
             throws Exception

Throws:

Exception

getConnection

public Connection getConnection()

setConnection

public final void setConnection(Connection connection)

setSqlProvider

public void setSqlProvider(SQLProvider sqlProvider)

setJdbcConnectionUrl

public void setJdbcConnectionUrl(String jdbcConnectionUrl)

getUser

public String getUser()

setUser

public void setUser(String user)

getPassword

public String getPassword()

setPassword

public void setPassword(String password)

setJdbcDriverClass

public void setJdbcDriverClass(String jdbcDriverClass)

setDataSource

public void setDataSource(DataSource dataSource)

setNetworkTimeout

public void setNetworkTimeout(Executor executor,
                              int milliseconds)