| Modifier and Type | Method and Description |
|---|---|
protected void |
StatementStreamingResultSetCloser.checkValidConnectionLock(DbConnection connection,
Object connectionLock) |
void |
StatementStreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
void |
StatementStreamingResultSetCloser.closeResultSets(DbConnection connection)
Closes all tracked
ResultSets for the passed connection. |
protected Object |
StatementStreamingResultSetCloser.getConnectionLock(DbConnection connection) |
protected Set<ResultSet> |
StatementStreamingResultSetCloser.getConnectionResultSets(DbConnection connection,
ResultSet resultSet) |
protected Optional<Object> |
StatementStreamingResultSetCloser.getTrackedConnectionLock(DbConnection connection) |
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
|
| Modifier and Type | Method and Description |
|---|---|
PreparedStatement |
NoAutoGenerateKeysStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
ColumnNameAutoGenerateKeysStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
ColumnIndexAutoGenerateKeysStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
DefaultAutoGenerateKeysStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate) |
PreparedStatement |
AutoGenerateKeysStrategy.prepareStatement(DbConnection connection,
QueryTemplate queryTemplate)
Prepares a statement in order to return auto generated keys
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultDbConnection |
| Modifier and Type | Method and Description |
|---|---|
DbConnection |
DbConnectionProvider.connect() |
protected DbConnection |
DbConnectionProvider.createDbConnection(Connection connection) |
| Modifier and Type | Method and Description |
|---|---|
void |
DbConnectionProvider.disconnect(DbConnection connection) |
org.mule.runtime.api.connection.ConnectionValidationResult |
DbConnectionProvider.validate(DbConnection connection) |
| Modifier and Type | Class and Description |
|---|---|
class |
OracleDbConnection
DefaultDbConnection implementation for Oracle databases |
| Modifier and Type | Method and Description |
|---|---|
protected DbConnection |
OracleDbConnectionProvider.createDbConnection(Connection connection) |
| 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,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
protected Object |
StoredProcedureExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
protected Object |
SelectExecutor.doExecuteQuery(DbConnection connection,
Statement statement,
Query query,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
protected Object |
UpdateExecutor.doExecuteQuery(DbConnection dbConnection,
Statement statement,
Query query,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
Object |
BulkUpdateExecutor.execute(DbConnection connection,
BulkQuery bulkQuery) |
Object |
BulkExecutor.execute(DbConnection connection,
BulkQuery bulkQuery)
Executes a bulk query
|
Object |
AbstractSingleQueryExecutor.execute(DbConnection connection,
Query query) |
Object |
QueryExecutor.execute(DbConnection connection,
Query query)
Executes a query
|
Object |
AbstractSingleQueryExecutor.execute(DbConnection connection,
Query query,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
Object |
QueryExecutor.execute(DbConnection connection,
Query query,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
Object |
BulkUpdateExecutor.execute(DbConnection connection,
Query query,
List<List<QueryParamValue>> paramValues) |
Object |
BulkExecutor.execute(DbConnection connection,
Query query,
List<List<QueryParamValue>> paramValues)
Executes a parameterized query using a bulk of parameter sets
|
| 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,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
Statement |
StatementFactory.create(DbConnection connection,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy)
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 |
MetadataDbTypeManager.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 |
StaticDbTypeManager.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 |
MetadataDbTypeManager.lookup(DbConnection connection,
String name) |
DbType |
DbTypeManager.lookup(DbConnection connection,
String name)
Finds a mapping for a given type name
|
DbType |
StaticDbTypeManager.lookup(DbConnection connection,
String name) |
| Modifier and Type | Class and Description |
|---|---|
class |
XADbConnection |
| Constructor and Description |
|---|
XADbConnection(DbConnection connection,
XAConnection xaConnection) |
| Modifier and Type | Method and Description |
|---|---|
int[] |
BulkOperations.bulkDelete(List<Map<String,Object>> parameterValues,
BulkQueryDefinition query,
DbConnector connector,
DbConnection connection)
Allows executing one delete statement various times using different parameter bindings.
|
int[] |
BulkOperations.bulkInsert(List<Map<String,Object>> parameterValues,
BulkQueryDefinition query,
DbConnector connector,
DbConnection connection)
Allows executing one insert statement various times using different parameter bindings.
|
int[] |
BulkOperations.bulkUpdate(List<Map<String,Object>> parameterValues,
BulkQueryDefinition query,
DbConnector connector,
DbConnection connection)
Allows executing one update statement various times using different parameter bindings.
|
int |
DmlOperations.delete(QueryDefinition query,
DbConnector connector,
DbConnection connection)
Deletes data in a database.
|
int |
DdlOperations.executeDdl(String sql,
QuerySettings settings,
DbConnector connector,
DbConnection connection)
Enables execution of DDL queries against a database.
|
int[] |
BulkOperations.executeScript(BulkScript script,
QuerySettings settings,
DbConnection connection)
Executes a SQL script in one single Database statement.
|
StatementResult |
DmlOperations.insert(QueryDefinition query,
AutoGenerateKeysAttributes autoGenerateKeysAttributes,
DbConnector connector,
DbConnection connection)
Inserts data into a Database
|
protected Query |
DmlOperations.resolveQuery(StoredProcedureCall call,
DbConnector connector,
DbConnection connection,
QueryType... validTypes) |
org.mule.runtime.extension.api.runtime.operation.InterceptingCallback<Object> |
DmlOperations.select(QueryDefinition query,
boolean streaming,
DbConnector connector,
DbConnection connection)
Selects data from a database
|
org.mule.runtime.extension.api.runtime.operation.InterceptingCallback<Map<String,Object>> |
DmlOperations.storedProcedure(StoredProcedureCall call,
boolean streaming,
AutoGenerateKeysAttributes autoGenerateKeysAttributes,
DbConnector connector,
DbConnection connection)
Invokes a Stored Procedure on the database.
|
StatementResult |
DmlOperations.update(QueryDefinition query,
AutoGenerateKeysAttributes autoGenerateKeysAttributes,
DbConnector connector,
DbConnection connection)
Updates data in a database.
|
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,DbType> |
QueryParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
DefaultParamTypeResolver.getParameterTypes(DbConnection connection,
QueryTemplate queryTemplate) |
Map<Integer,DbType> |
StoredProcedureParamTypeResolver.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 |
|---|---|
protected QueryTemplate |
StoredProcedureQueryResolver.createQueryTemplate(StoredProcedureCall call,
DbConnector connector,
DbConnection connection) |
Query |
BulkQueryResolver.resolve(BulkQueryDefinition definition,
DbConnector connector,
DbConnection connection) |
Query |
QueryResolver.resolve(T statementDefinition,
DbConnector connector,
DbConnection connection)
Resolves a query
|
| Modifier and Type | Method and Description |
|---|---|
void |
SingleResultResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
void |
StreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet)
Closes the given
resultset. |
ResultSet |
NullResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
Object |
ResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
List<Map<String,Object>> |
ListResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
ResultSetIterator |
IteratorResultSetHandler.processResultSet(DbConnection connection,
ResultSet resultSet) |
| Constructor and Description |
|---|
ResultSetIterator(DbConnection connection,
ResultSet resultSet,
RowHandler rowHandler,
StreamingResultSetCloser streamingResultSetCloser) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractStreamingResultSetCloser.close(DbConnection connection,
ResultSet resultSet) |
StatementResultIterator |
StatementResultIteratorFactory.create(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
StatementResultIterator |
GenericStatementResultIteratorFactory.create(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
protected StatementResultIterator |
GenericStatementResultIteratorFactory.doCreateStatementResultIterator(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy,
ResultSetHandler resultSetHandler) |
Object |
StatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy)
Processes the results from a statement execution
|
Map<String,Object> |
AbstractMapStatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
Map<String,Object> |
EagerStatementResultHandler.processStatement(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy) |
| Constructor and Description |
|---|
StatementResultIterator(DbConnection connection,
Statement statement,
QueryTemplate queryTemplate,
AutoGenerateKeysStrategy autoGenerateKeysStrategy,
ResultSetHandler resultSetHandler) |
Copyright © 2003–2017 MuleSoft, Inc.. All rights reserved.