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 |
ColumnIndexAutoGeneratedKeyStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
ColumnNameAutoGeneratedKeyStrategy.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 |
class |
OracleDbConnection
Custom
DbConnection for Oracle databases |
Modifier and Type | Method and Description |
---|---|
DbConnection |
TransactionalDbConnectionFactory.createConnection(TransactionalAction transactionalAction) |
DbConnection |
DbConnectionFactory.createConnection(TransactionalAction transactionalAction)
Creates a connection with a given
TransactionalAction |
protected DbConnection |
TransactionalDbConnectionFactory.doCreateDbConnection(Connection connection,
TransactionalAction transactionalAction) |
protected DbConnection |
OracleTransactionalDbConnectionFactory.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 |
TransactionalDbConnectionFactory.releaseConnection(DbConnection connection) |
void |
DbConnectionFactory.releaseConnection(DbConnection connection)
Indicates that the connection is not used anymore
|
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
AbstractSingleQueryExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query) |
protected Object |
StoredProcedureExecutor.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 abstract Object |
AbstractSingleQueryExecutor.doExecuteQuery(DbConnection dbConnection,
Statement statement,
Query query,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected Object |
StoredProcedureExecutor.doExecuteQuery(DbConnection connection,
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) |
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 |
StaticDbTypeManager.lookup(DbConnection connection,
int id,
String name) |
DbType |
CompositeDbTypeManager.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 |
StaticDbTypeManager.lookup(DbConnection connection,
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 |
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 |
AbstractDbFunction.createValue(DbConnection connection,
String typeName,
Object[] values)
Creates the structured type value
|
protected Object |
DbCreateArrayFunction.createValue(DbConnection connection,
String typeName,
Object[] values) |
protected Object |
DbCreateStructFunction.createValue(DbConnection connection,
String typeName,
Object[] values) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
AbstractSingleQueryDbMessageProcessor.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 |
ExecuteDdlMessageProcessor.doExecuteQuery(DbConnection connection,
Query query) |
protected Object |
BulkExecuteMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected abstract Object |
AbstractDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
AbstractSingleQueryDbMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
PreparedBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected Object |
DynamicBulkUpdateMessageProcessor.executeQuery(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
BulkExecuteMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected abstract List<FieldDebugInfo<?>> |
AbstractDbMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
AbstractSingleQueryDbMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
PreparedBulkUpdateMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
protected List<FieldDebugInfo<?>> |
DynamicBulkUpdateMessageProcessor.getMessageProcessorDebugInfo(DbConnection connection,
MuleEvent muleEvent) |
Modifier and Type | Method and Description |
---|---|
Map<Integer,DbType> |
DefaultParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
ParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate)
Resolves actual parameter types
|
Map<Integer,DbType> |
QueryParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
StoredProcedureParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
protected Map<Integer,DbType> |
DefaultParamTypeResolver.getParamTypesUsingMetadata(DbConnection connection,
QueryTemplate queryTemplate) |
Modifier and Type | Method and Description |
---|---|
Query |
DynamicQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
StaticQueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent) |
Query |
QueryResolver.resolve(DbConnection connection,
MuleEvent muleEvent)
Resolves a query in the context of a given Mule event.
|
Query |
ParametrizedQueryResolver.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 |
ResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
ResultSetIterator |
IteratorResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
List<Map<String,Object>> |
ListResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
ResultSet |
NullResultSetHandler.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) |
void |
StatementStreamingResultSetCloser.closeResultSets(DbConnection connection)
Closes all tracked
ResultSet s for the passed connection . |
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) |
Map<String,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
|
Map<String,Object> |
EagerStatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGeneratedKeyStrategy autoGeneratedKeyStrategy) |
protected void |
StatementStreamingResultSetCloser.releaseResources(DbConnection connection) |
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–2018 MuleSoft, Inc.. All rights reserved.