Modifier and Type | Method and Description |
---|---|
PreparedStatement |
AutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate)
Prepares a statement in order to return auto generated keys
|
PreparedStatement |
DefaultAutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
NoAutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
ColumnNameAutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
ColumnIndexAutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDbConnection
Implements connector side of
DbConnection |
class |
DefaultDbConnection
Delegates
Connection behaviour to a delegate |
Modifier and Type | Method and Description |
---|---|
DbConnection |
DbConnectionFactory.createConnection(TransactionalAction transactionalAction)
Creates a connection with a given
TransactionalAction |
DbConnection |
TransactionalDbConnectionFactory.createConnection(TransactionalAction transactionalAction) |
protected DbConnection |
TransactionalDbConnectionFactory.doCreateDbConnection(Connection connection,
TransactionalAction transactionalAction) |
Modifier and Type | Method and Description |
---|---|
void |
DbConnectionReleaser.release(DbConnection connection)
Releases a given connection
|
void |
DefaultDbConnectionReleaser.release(DbConnection connection) |
void |
DbConnectionFactory.releaseConnection(DbConnection connection)
Indicates that the connection is not used anymore
|
void |
TransactionalDbConnectionFactory.releaseConnection(DbConnection connection) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
AbstractSingleQueryExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query) |
protected Object |
SelectExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query) |
protected Object |
UpdateExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query) |
protected Object |
StoredProcedureExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query) |
protected abstract Object |
AbstractSingleQueryExecutor.doExecuteQuery(DbConnection dbConnection,
Statement statement,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected Object |
SelectExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected Object |
UpdateExecutor.doExecuteQuery(DbConnection dbConnection,
Statement statement,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected Object |
StoredProcedureExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
Object |
BulkExecutor.execute(DbConnection connection,
BulkQuery bulkQuery)
Executes a bulk query
|
Object |
BulkUpdateExecutor.execute(DbConnection connection,
BulkQuery bulkQuery) |
Object |
AbstractSingleQueryExecutor.execute(DbConnection connection,
Query query) |
Object |
QueryExecutor.execute(DbConnection connection,
Query query)
Executes a query
|
Object |
AbstractSingleQueryExecutor.execute(DbConnection connection,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
Object |
QueryExecutor.execute(DbConnection connection,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
Object |
BulkExecutor.execute(DbConnection connection,
Query query,
List<List<QueryParamValue>> paramValues)
Executes a parameterized query using a bulk of parameter sets
|
Object |
BulkUpdateExecutor.execute(DbConnection connection,
Query query,
List<List<QueryParamValue>> paramValues) |
Modifier and Type | Method and Description |
---|---|
Statement |
QueryStatementFactory.create(DbConnection connection,
QueryTemplate queryTemplate) |
Statement |
StatementFactory.create(DbConnection connection,
QueryTemplate queryTemplate)
Creates a JDBC statement
|
Statement |
QueryStatementFactory.create(DbConnection connection,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
Statement |
StatementFactory.create(DbConnection connection,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy)
Creates a JDBC statement with auto generated keys processing
|
Modifier and Type | Method and Description |
---|---|
protected void |
MetadataDbTypeManager.initialise(DbConnection connection) |
DbType |
CompositeDbTypeManager.lookup(DbConnection connection,
int id,
String name) |
DbType |
StaticDbTypeManager.lookup(DbConnection connection,
int id,
String name) |
DbType |
DbTypeManager.lookup(DbConnection connection,
int id,
String name)
Finds a mapping for a given type ID and name
|
DbType |
MetadataDbTypeManager.lookup(DbConnection connection,
int id,
String name) |
DbType |
CompositeDbTypeManager.lookup(DbConnection connection,
String name)
Finds a mapping for a given type name using each composed
DbTypeManager until a type is found or there are no more
managers to use. |
DbType |
StaticDbTypeManager.lookup(DbConnection connection,
String name) |
DbType |
DbTypeManager.lookup(DbConnection connection,
String name)
Finds a mapping for a given type name
|
DbType |
MetadataDbTypeManager.lookup(DbConnection connection,
String name) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
AbstractSingleQueryDbMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
ExecuteDdlMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
StoredProcedureMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
SelectMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
UpdateMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
AbstractSingleQueryDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
DynamicBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
BulkExecuteMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
PreparedBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected abstract Object |
AbstractDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
Map<Integer,DbType> |
StoredProcedureParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
DefaultParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
QueryParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
ParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate)
Resolves actual parameter types
|
protected Map<Integer,DbType> |
DefaultParamTypeResolver.getParamTypesUsingMetadata(DbConnection connection,
QueryTemplate queryTemplate) |
Modifier and Type | Method and Description |
---|---|
Query |
DynamicQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
ParametrizedQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
QueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent)
Resolves a query in the context of a given Mule event.
|
Query |
StaticQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
void |
SingleResultResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
void |
StreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
Object |
IteratorResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
Object |
ListResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
Object |
NullResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
Object |
ResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
Constructor and Description |
---|
ResultSetIterator(DbConnection connection,
ResultSet resultSet,
RowHandler rowHandler,
StreamingResultSetCloser streamingResultSetCloser) |
Modifier and Type | Method and Description |
---|---|
protected void |
StatementStreamingResultSetCloser.checkValidConnectionLock(DbConnection connection,
Object connectionLock) |
void |
AbstractStreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
void |
StatementStreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
StatementResultIterator |
GenericStatementResultIteratorFactory.create(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
StatementResultIterator |
StatementResultIteratorFactory.create(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected StatementResultIterator |
GenericStatementResultIteratorFactory.doCreateStatementResultIterator(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy,
ResultSetHandler resultSetHandler) |
protected Object |
StatementStreamingResultSetCloser.getConnectionLock(DbConnection connection) |
protected Set<ResultSet> |
StatementStreamingResultSetCloser.getConnectionResultSets(DbConnection connection,
ResultSet resultSet) |
protected Object |
StatementStreamingResultSetCloser.getTrackedConnectionLock(DbConnection connection) |
Object |
AbstractMapStatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
Object |
StatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy)
Processes the results from a statement execution
|
Object |
EagerStatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected void |
StatementStreamingResultSetCloser.releaseResources(DbConnection connection,
Object connectionLock) |
void |
StatementStreamingResultSetCloser.trackResultSet(DbConnection connection,
ResultSet resultSet)
Adds a resultSet for tracking in order to be able to close it later
|
Constructor and Description |
---|
StatementResultIterator(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy,
ResultSetHandler resultSetHandler) |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.