org.mule.extension.db.internal.operation

Class DdlOperations

java.lang.Object

org.mule.extension.db.internal.operation.DdlOperations

public class DdlOperations
extends Object

Operations to manipulate data definitions in a relational Database

Since:

4.0

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_FETCH_SIZE
protected static String	QUERY_GROUP
protected static String	QUERY_SETTINGS
protected QueryResolver<ParameterizedStatementDefinition>	queryResolver

Constructor Summary

Constructors

Constructor and Description
DdlOperations()

Method Summary

Modifier and Type	Method and Description
int	executeDdl(String sql, QuerySettings settings, DbConnector connector, DbConnection connection) Enables execution of DDL queries against a database.
protected StatementResult	executeUpdate(QueryDefinition query, StatementAttributes statementAttributes, AutoGeneratedKeyAttributes autoGeneratedKeyAttributes, DbConnection connection, Query resolvedQuery)
protected AutoGeneratedKeyStrategy	getAutoGeneratedKeysStrategy(AutoGeneratedKeyAttributes keyAttributes)
protected QueryStatementFactory	getStatementFactory(StatementAttributes statementAttributes, boolean streaming, QuerySettings settings)
protected Query	resolveQuery(QueryDefinition query, DbConnector connector, DbConnection connection, QueryType... validTypes)
protected void	validateNoParameterTypeIsUnused(Query query, List<ParameterType> parameterTypes)
protected void	validateQueryType(QueryTemplate queryTemplate, List<QueryType> validTypes)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FETCH_SIZE

protected static final int DEFAULT_FETCH_SIZE

See Also:

Constant Field Values

QUERY_GROUP

protected static final String QUERY_GROUP

See Also:

Constant Field Values

QUERY_SETTINGS

protected static final String QUERY_SETTINGS

See Also:

Constant Field Values

queryResolver

protected final QueryResolver<ParameterizedStatementDefinition> queryResolver

Constructor Detail

DdlOperations

public DdlOperations()

Method Detail

executeDdl

@DisplayName(value="Execute DDL")
public int executeDdl(@DisplayName(value="SQL Query Text") @Text
                                                        String sql,
                                                        @ParameterGroup(value="Query Settings")
                                                        QuerySettings settings,
                                                        @UseConfig
                                                        DbConnector connector,
                                                        @Connection
                                                        DbConnection connection)
                                                 throws SQLException

Enables execution of DDL queries against a database.

Parameters:

sql - The text of the SQL query to be executed

settings - Parameters to configure the query

connector - the acting connector

connection - the acting connection

Returns:

the number of affected rows

Throws:

SQLException

getStatementFactory

protected QueryStatementFactory getStatementFactory(StatementAttributes statementAttributes,
                                                    boolean streaming,
                                                    QuerySettings settings)

executeUpdate

protected StatementResult executeUpdate(QueryDefinition query,
                                        StatementAttributes statementAttributes,
                                        AutoGeneratedKeyAttributes autoGeneratedKeyAttributes,
                                        DbConnection connection,
                                        Query resolvedQuery)
                                 throws SQLException

Throws:

SQLException

resolveQuery

protected Query resolveQuery(QueryDefinition query,
                             DbConnector connector,
                             DbConnection connection,
                             QueryType... validTypes)

validateQueryType

protected void validateQueryType(QueryTemplate queryTemplate,
                                 List<QueryType> validTypes)

validateNoParameterTypeIsUnused

protected void validateNoParameterTypeIsUnused(Query query,
                                               List<ParameterType> parameterTypes)

getAutoGeneratedKeysStrategy

protected AutoGeneratedKeyStrategy getAutoGeneratedKeysStrategy(AutoGeneratedKeyAttributes keyAttributes)