com.feedzai.commons.sql.abstraction.engine.impl

Class CockroachDBEngine

java.lang.Object

com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine

com.feedzai.commons.sql.abstraction.engine.impl.PostgreSqlEngine

com.feedzai.commons.sql.abstraction.engine.impl.CockroachDBEngine

All Implemented Interfaces:

DatabaseEngine, java.lang.AutoCloseable

public class CockroachDBEngine
extends PostgreSqlEngine

CockroachDB specific database implementation.

Since:

2.5.0

Author:

Mário Pereira (mario.arzileiro@feedzai.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.lang.String	COCKROACHDB_DRIVER The Cockroach JDBC (PostgreSQL) driver.
static java.lang.String	CONSTRAINT_NAME_ALREADY_EXISTS_COCKROACH Constraint name already exists.

Fields inherited from class com.feedzai.commons.sql.abstraction.engine.impl.PostgreSqlEngine

CONSTRAINT_NAME_ALREADY_EXISTS, NAME_ALREADY_EXISTS, POSTGRESQL_DRIVER, SQL_STATE_DEADLOCK_TRANSACTION_FAILURE, TABLE_CAN_ONLY_HAVE_ONE_PRIMARY_KEY, TABLE_OR_VIEW_DOES_NOT_EXIST

Fields inherited from class com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine

conn, currentSchema, dev, dialect, eh, entities, injector, logger, notificationLogger, properties, stmts, translator

Constructor Summary

Constructors

Constructor and Description
CockroachDBEngine(PdbProperties properties) Creates a new CockroachDB connection.

Method Summary

Modifier and Type	Method and Description
protected void	addFks(DbEntity entity) Adds the FKs.
protected void	addPrimaryKey(DbEntity entity) Add a primary key to the entity.
protected void	addSequences(DbEntity entity) Adds the necessary sequences.
protected void	createTable(DbEntity entity) Creates the table.
protected void	dropSequences(DbEntity entity) Drops the sequences of the entity.
java.util.Map<java.lang.String,DbColumnType>	getMetadata(java.lang.String schemaPattern, java.lang.String tableNamePattern) Gets the table metadata (table must be in the current schema).
java.lang.Class<? extends AbstractTranslator>	getTranslatorClass() Gets the class that translates SQL bound to this engine.
java.lang.Long	persist(java.lang.String name, EntityEntry entry, boolean useAutoInc) Persists a given entry.

Methods inherited from class com.feedzai.commons.sql.abstraction.engine.impl.PostgreSqlEngine

addColumn, addIndexes, checkConnection, createPreparedStatementForInserts, createResultIterator, createResultIterator, dropColumn, dropTable, entityToPreparedStatement, getDBProperties, isRetryableException, isStringAggDistinctCapable, persist, setParameter, setSchema, toPdbType, translateType

Methods inherited from class com.feedzai.commons.sql.abstraction.engine.AbstractDatabaseEngine

addBatch, addEntity, beginTransaction, checkConnection, checkConnection, clearParameters, close, commentCharacter, commit, connect, containsEntity, createBatch, createBatch, createBatch, createPreparedStatement, createPreparedStatement, createPreparedStatement, createPreparedStatement, createSelectStatement, dropEntity, dropEntity, dropFks, duplicate, entityToPreparedStatementForBatch, escapeCharacter, executePS, executePSUpdate, executeUpdate, executeUpdate, executeUpdateSilently, flush, getConnection, getDialect, getEntities, getEntities, getFinalJdbcConnection, getMetadata, getPrivateKey, getProperties, getPSIterator, getPSIterator, getPSResultSet, getQueryMetadata, getQueryMetadata, getSchema, handleOperation, hasIdentityColumn, inject, isTransactionActive, iterator, iterator, iterator, iterator, iterator, iterator, loadEntity, objectToArray, preparedStatementExists, processResultIterator, query, query, query, query, removeEntity, removePreparedStatement, rollback, setExceptionHandler, setParameter, setParameters, setParameterValues, setTransactionIsolation, translate, updateEntity

Methods inherited from class java.lang.Object

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

Field Detail

COCKROACHDB_DRIVER

protected static final java.lang.String COCKROACHDB_DRIVER

The Cockroach JDBC (PostgreSQL) driver.

CONSTRAINT_NAME_ALREADY_EXISTS_COCKROACH

public static final java.lang.String CONSTRAINT_NAME_ALREADY_EXISTS_COCKROACH

Constraint name already exists. Note: CockroachDB v19.2.x returns this SQL state when trying to add a foreign key relation that already exists. This constant is needed because PosgtgreSQL uses code 42710 - ERRCODE_DUPLICATE_OBJECT instead. In this situation CockroachDB v19.2.x uses code 23503 - ERRCODE_FOREIGN_KEY_VIOLATION (a column in a table has a value that is not present in the column of other table in the foreign key relation); in the same situation CockroachDB v19.1.x returns state 42830 - ERRCODE_INVALID_FOREIGN_KEY (which can occur for example when the types of columns in the relation have incompatible types).

See Also:

CockroachDB issue #42858, Constant Field Values

Constructor Detail

CockroachDBEngine

public CockroachDBEngine(PdbProperties properties)
                  throws DatabaseEngineException

Creates a new CockroachDB connection.

Parameters:

properties - The properties for the database connection.

Throws:

DatabaseEngineException - When the connection fails.

Method Detail

createTable

protected void createTable(DbEntity entity)
                    throws DatabaseEngineException

Description copied from class: AbstractDatabaseEngine

Creates the table.

Overrides:

createTable in class PostgreSqlEngine

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: AbstractDatabaseEngine

Add a primary key to the entity.

Overrides:

addPrimaryKey in class PostgreSqlEngine

Parameters:

entity - The entity.

Throws:

DatabaseEngineException - If something goes wrong while creating the table.

getTranslatorClass

public java.lang.Class<? extends AbstractTranslator> getTranslatorClass()

Description copied from class: AbstractDatabaseEngine

Gets the class that translates SQL bound to this engine.

Overrides:

getTranslatorClass in class PostgreSqlEngine

Returns:

The class that translates SQL bound to this engine.

persist

public java.lang.Long persist(java.lang.String name,
                              EntityEntry entry,
                              boolean useAutoInc)
                       throws DatabaseEngineException

Description copied from class: AbstractDatabaseEngine

Persists a given entry. Persisting a query implies executing the statement. If define useAutoInc as false, PDB will disable the auto increments for the current insert and advance the sequences if needed.

If you are inside of an explicit transaction, changes will only be visible upon explicit commit, otherwise a commit will immediately take place.

Specified by:

persist in interface DatabaseEngine

Overrides:

persist in class PostgreSqlEngine

Parameters:

name - The entity name.

entry - The entry to persist.

useAutoInc - Use or not the autoinc.

Returns:

The ID of the auto generated value, null if there's no auto generated value.

Throws:

DatabaseEngineException - If something goes wrong while persisting data.

addFks

protected void addFks(DbEntity entity)
               throws DatabaseEngineException

Description copied from class: AbstractDatabaseEngine

Adds the FKs.

Overrides:

addFks in class PostgreSqlEngine

Parameters:

entity - The entity.

Throws:

DatabaseEngineException - If something goes wrong creating the FKs.

addSequences

protected void addSequences(DbEntity entity)
                     throws DatabaseEngineException

Description copied from class: AbstractDatabaseEngine

Adds the necessary sequences.

Overrides:

addSequences in class PostgreSqlEngine

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: AbstractDatabaseEngine

Drops the sequences of the entity.

Overrides:

dropSequences in class PostgreSqlEngine

Parameters:

entity - The entity.

Throws:

DatabaseEngineException - If something goes wrong dropping the sequences.

getMetadata

public java.util.Map<java.lang.String,DbColumnType> getMetadata(java.lang.String schemaPattern,
                                                                java.lang.String tableNamePattern)
                                                         throws DatabaseEngineException

Description copied from interface: DatabaseEngine

Gets the table metadata (table must be in the current schema).

Specified by:

getMetadata in interface DatabaseEngine

Overrides:

getMetadata in class AbstractDatabaseEngine

Parameters:

schemaPattern - A schema name pattern; must match the schema name as it is stored in the database; "" retrieves those without a schema; null means that the schema name should not be used to narrow the search.

tableNamePattern - A table name pattern; must match the table name as it is stored in the database.

Returns:

A representation of the table columns and types.

Throws:

DatabaseEngineException - If something occurs getting the metadata.