Class SqlServerEngine
- java.lang.Object
-
- com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine
-
- com.feedzai.commons.sql.abstraction.engine.impl.SqlServerEngine
-
- All Implemented Interfaces:
DatabaseEngine,AutoCloseable
public class SqlServerEngine extends AbstractDatabaseEngine
SQLServer specific database implementation.- Since:
- 2.0.0
- Author:
- Rui Vilao (rui.vilao@feedzai.com)
-
-
Field Summary
Fields Modifier and Type Field Description static intINDEX_ALREADY_EXISTSSequence does not exist.static intMAXIMUM_VARBINARY_SIZEThe maximum size for the VARBINARY type.static intNAME_ALREADY_EXISTSName is already used by an existing object.protected static StringSQLSERVER_DRIVERThe SQLServer JDBC driver.static intTABLE_CAN_ONLY_HAVE_ONE_PRIMARY_KEYTable can have only one primary key.static intTABLE_OR_VIEW_DOES_NOT_EXISTTable or view does not exist.-
Fields inherited from class com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine
conn, currentSchema, DEFAULT_QUERY_EXCEPTION_HANDLER, dev, dialect, eh, entities, injector, logger, notificationLogger, properties, socketTimeoutExecutor, stmts, translator
-
-
Constructor Summary
Constructors Constructor Description SqlServerEngine(PdbProperties properties)Creates a new SQL Server connection.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidaddColumn(DbEntity entity, DbColumn... columns)Adds the column to an existent table.protected voidaddFks(DbEntity entity, Set<DbFk> fks)Adds foreign key constraints to the table in the database that the provided entity represents.protected voidaddIndexes(DbEntity entity)Add the desired indexes.protected voidaddPrimaryKey(DbEntity entity)Add a primary key to the entity.protected voidaddSequences(DbEntity entity)Adds the necessary sequences.protected MappedEntitycreatePreparedStatementForInserts(DbEntity entity)Creates and gets the prepared statement that will be used for insertions.protected ResultIteratorcreateResultIterator(PreparedStatement ps)Creates a specificResultIteratorfor the engine in place given a prepared statement.protected ResultIteratorcreateResultIterator(Statement statement, String sql)Creates a specificResultIteratorgiven the engine implementation.protected voidcreateTable(DbEntity entity)Creates the table.protected longdoPersist(PreparedStatement ps, MappedEntity me, boolean useAutoInc, int lastBindPosition)DB engine specific auxiliary method forAbstractDatabaseEngine.persist(String, EntityEntry, boolean)to effectively perform the persist action.protected voiddropColumn(DbEntity entity, String... columns)Drops the column.protected voiddropReferringFks(DbEntity entity)protected voiddropSequences(DbEntity entity)Drops the sequences of the entity.protected voiddropTable(DbEntity entity)Drops the table.protected intentityToPreparedStatement(DbEntity entity, PreparedStatement ps, EntityEntry entry, boolean useAutoInc)Translates the given entry entity to the prepared statement.intexecuteUpdate(Expression query)Executes the given update.protected PropertiesgetDBProperties()Get the properties to be passed to the database connection that will be created.Class<? extends AbstractTranslator>getTranslatorClass()Gets the class that translates SQL bound to this engine.booleanisStringAggDistinctCapable()Checks if the engine supports using DISTINCT inside a string aggregation.protected voidsetSchema(String schema)Sets the schema for the currentconnection.-
Methods inherited from class com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine
addBatch, addEntity, addFks, beginTransaction, checkConnection, checkConnection, checkConnection, clearParameters, close, commentCharacter, commit, connect, containsEntity, createBatch, createBatch, createBatch, createBatch, createPreparedStatement, createPreparedStatement, createPreparedStatement, createPreparedStatement, createSelectStatement, dropEntity, dropEntity, dropFkQuery, dropFks, dropFks, dropView, duplicate, entityToPreparedStatementForBatch, escapeCharacter, executePS, executePSUpdate, executeUpdate, executeUpdateSilently, flush, getConnection, getDialect, getEntities, getEntities, getFinalJdbcConnection, getImportedKeys, getMetadata, getMetadata, getPreparedStatementForPersist, getPrivateKey, getProperties, getPSIterator, getPSIterator, getPSResultSet, getQueryExceptionHandler, getQueryMetadata, getQueryMetadata, getSchema, handleOperation, hasIdentityColumn, inject, isTransactionActive, iterator, iterator, iterator, iterator, iterator, iterator, loadEntity, objectToArray, persist, persist, preparedStatementExists, processResultIterator, query, query, query, query, reconnectExceptionally, removeEntity, removePreparedStatement, rollback, setExceptionHandler, setParameter, setParameter, setParameters, setParameterValues, setTransactionIsolation, toPdbType, translate, translateType, updateEntity
-
-
-
-
Field Detail
-
SQLSERVER_DRIVER
protected static final String SQLSERVER_DRIVER
The SQLServer JDBC driver.
-
NAME_ALREADY_EXISTS
public static final int NAME_ALREADY_EXISTS
Name is already used by an existing object.- See Also:
- Constant Field Values
-
TABLE_CAN_ONLY_HAVE_ONE_PRIMARY_KEY
public static final int TABLE_CAN_ONLY_HAVE_ONE_PRIMARY_KEY
Table can have only one primary key.- See Also:
- Constant Field Values
-
INDEX_ALREADY_EXISTS
public static final int INDEX_ALREADY_EXISTS
Sequence does not exist.- See Also:
- Constant Field Values
-
TABLE_OR_VIEW_DOES_NOT_EXIST
public static final int TABLE_OR_VIEW_DOES_NOT_EXIST
Table or view does not exist.- See Also:
- Constant Field Values
-
MAXIMUM_VARBINARY_SIZE
public static final int MAXIMUM_VARBINARY_SIZE
The maximum size for the VARBINARY type.- See Also:
- Constant Field Values
-
-
Constructor Detail
-
SqlServerEngine
public SqlServerEngine(PdbProperties properties) throws DatabaseEngineException
Creates a new SQL Server connection.- Parameters:
properties- The properties for the database connection.- Throws:
DatabaseEngineException- When the connection fails.
-
-
Method Detail
-
getDBProperties
protected Properties getDBProperties()
Description copied from class:AbstractDatabaseEngineGet the properties to be passed to the database connection that will be created. Since these properties are specific to the database engine, it is up to theAbstractDatabaseEngineimplementation to specify them. This is used, for instance, to set the database connection timeout.- Overrides:
getDBPropertiesin classAbstractDatabaseEngine- Returns:
- the properties of the connection to the database.
-
entityToPreparedStatement
protected int entityToPreparedStatement(DbEntity entity, PreparedStatement ps, EntityEntry entry, boolean useAutoInc) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineTranslates the given entry entity to the prepared statement.- Specified by:
entityToPreparedStatementin classAbstractDatabaseEngine- Parameters:
entity- The entity.ps- The prepared statement.entry- The entry.- Returns:
- The position (1-based) of the last bind parameter that was filled in a prepared statement.
- Throws:
DatabaseEngineException- if something occurs during the translation.
-
createTable
protected void createTable(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineCreates the table.- Specified by:
createTablein classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong while creating the table.
-
addPrimaryKey
protected void addPrimaryKey(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineAdd a primary key to the entity.- Specified by:
addPrimaryKeyin classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong while creating the table.
-
addIndexes
protected void addIndexes(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineAdd the desired indexes.- Specified by:
addIndexesin classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong while creating the table.
-
addSequences
protected void addSequences(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineAdds the necessary sequences.- Specified by:
addSequencesin classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong while creating the table.
-
createPreparedStatementForInserts
protected MappedEntity createPreparedStatementForInserts(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineCreates and gets the prepared statement that will be used for insertions.- Specified by:
createPreparedStatementForInsertsin classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong while creating the table.
-
dropSequences
protected void dropSequences(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineDrops the sequences of the entity.- Specified by:
dropSequencesin classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong dropping the sequences.
-
dropTable
protected void dropTable(DbEntity entity) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineDrops the table.- Specified by:
dropTablein classAbstractDatabaseEngine- Parameters:
entity- The entity.- Throws:
DatabaseEngineException- If something goes wrong dropping the sequences.
-
dropColumn
protected void dropColumn(DbEntity entity, String... columns) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineDrops the column.- Specified by:
dropColumnin classAbstractDatabaseEngine- Parameters:
entity- The entity.columns- The column name to drop.- Throws:
DatabaseEngineException- If something goes wrong dropping the sequences.
-
addColumn
protected void addColumn(DbEntity entity, DbColumn... columns) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineAdds the column to an existent table.- Specified by:
addColumnin classAbstractDatabaseEngine- Parameters:
entity- The entity that represents the table.columns- The db column to add.- Throws:
DatabaseEngineException- If something goes wrong adding columns.
-
getTranslatorClass
public Class<? extends AbstractTranslator> getTranslatorClass()
Description copied from class:AbstractDatabaseEngineGets the class that translates SQL bound to this engine.- Specified by:
getTranslatorClassin classAbstractDatabaseEngine- Returns:
- The class that translates SQL bound to this engine.
-
doPersist
protected long doPersist(PreparedStatement ps, MappedEntity me, boolean useAutoInc, int lastBindPosition) throws Exception
Description copied from class:AbstractDatabaseEngineDB engine specific auxiliary method forAbstractDatabaseEngine.persist(String, EntityEntry, boolean)to effectively perform the persist action.- Specified by:
doPersistin classAbstractDatabaseEngine- Parameters:
ps- ThePreparedStatementto use in the persist operationme- The mapped entity on which to persist.useAutoInc- Whether to use autoInc.lastBindPosition- The position (1-based) of the last bind parameter that was filled in the prepared statement.- Returns:
- The ID of the auto generated value (
0if there's no auto generated value). If the table has more than 1 column with auto generated values, then it will return the first column found. - Throws:
Exception- if any problem occurs while persisting.
-
addFks
protected void addFks(DbEntity entity, Set<DbFk> fks) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineAdds foreign key constraints to the table in the database that the provided entity represents.- Overrides:
addFksin classAbstractDatabaseEngine- Parameters:
entity- The entity.fks- The foreign keys to be added.- Throws:
DatabaseEngineException- If something goes wrong creating the FKs.
-
dropReferringFks
protected void dropReferringFks(DbEntity entity) throws DatabaseEngineException
- Throws:
DatabaseEngineException
-
executeUpdate
public int executeUpdate(Expression query) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineExecutes the given update.- Specified by:
executeUpdatein interfaceDatabaseEngine- Overrides:
executeUpdatein classAbstractDatabaseEngine- Parameters:
query- The update to execute.- Throws:
DatabaseEngineException- If something goes wrong executing the update.
-
isStringAggDistinctCapable
public boolean isStringAggDistinctCapable()
Description copied from interface:DatabaseEngineChecks if the engine supports using DISTINCT inside a string aggregation.- Returns:
- true if the engine supports using DISTINCT inside a string aggregation, false otherwise.
-
setSchema
protected void setSchema(String schema) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineSets the schema for the currentconnection.- Overrides:
setSchemain classAbstractDatabaseEngine- Throws:
DatabaseEngineException- If schema doesn't exist, a database access error occurs or this method is called on a closed connection.
-
createResultIterator
protected ResultIterator createResultIterator(Statement statement, String sql) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineCreates a specificResultIteratorgiven the engine implementation.- Specified by:
createResultIteratorin classAbstractDatabaseEngine- Parameters:
statement- The statement.sql- The SQL sentence.- Returns:
- An iterator for the specific engine.
- Throws:
DatabaseEngineException- If a database access error occurs.
-
createResultIterator
protected ResultIterator createResultIterator(PreparedStatement ps) throws DatabaseEngineException
Description copied from class:AbstractDatabaseEngineCreates a specificResultIteratorfor the engine in place given a prepared statement.- Specified by:
createResultIteratorin classAbstractDatabaseEngine- Parameters:
ps- The prepared statement.- Returns:
- The result iterator.
- Throws:
DatabaseEngineException- If a database access error occurs.
-
-