public final class PostgresAdaptor extends OpenSourceDbAdaptor
Constructor and Description |
---|
PostgresAdaptor(ConnectionPool connectionPool,
DdlConsumer ddlConsumer) |
Modifier and Type | Method and Description |
---|---|
void |
createSysObjects(Connection conn,
String sysSchemaName)
Creates or recreates other system objects (stored procedures, functions)
needed for Celesta functioning on current RDBMS.
|
DbColumnInfo |
getColumnInfo(Connection conn,
Column<?> c)
Returns information on a column.
|
int |
getCurrentIdent(Connection conn,
BasicTable t)
Returns current identity value for the table.
|
int |
getDBPid(Connection conn)
Returns process id of current database connection.
|
List<DbFkInfo> |
getFKInfo(Connection conn,
Grain g)
Returns information on the foreign keys from grain.
|
Map<String,DbIndexInfo> |
getIndices(Connection conn,
Grain g)
Returns a set of indices referring to tables specified in the indicated grain.
|
String |
getInFilterClause(DataGrainElement dge,
DataGrainElement otherDge,
List<String> fields,
List<String> otherFields,
String otherWhere) |
PreparedStatement |
getInsertRecordStatement(Connection conn,
BasicTable t,
boolean[] nullsMask,
List<ParameterSetter> program)
Creates a PreparedStatement object for an INSERT statement to insert a record into a table.
|
List<String> |
getParameterizedViewList(Connection conn,
Grain g)
Get names of existing parameterized views.
|
DbPkInfo |
getPKInfo(Connection conn,
TableElement t)
Returns information on the primary key of a table.
|
DbSequenceInfo |
getSequenceInfo(Connection conn,
SequenceElement s)
Returns information on a sequence.
|
DBType |
getType()
Returns current database type.
|
ZonedDateTime |
prepareZonedDateTimeForParameterSetter(Connection conn,
ZonedDateTime z) |
boolean |
supportsCortegeComparing()
Whether DB supports cortege comparing.
|
boolean |
triggerExists(Connection conn,
TriggerQuery query)
Checks if trigger exists in the DB.
|
deleteRecordSetStatement, getColumns, getDeleteRecordStatement, getNavigationStatement, getOneFieldStatement, getOneRecordStatement, nextSequenceValue, nullsFirst, sequenceExists, tableExists
alterSequence, compareStrings, createColumn, createFK, createIndex, createParameterizedView, createPK, createSchemaIfNotExists, createSequence, createTable, createTableTriggersForMaterializedViews, createView, dropFK, dropIndex, dropParameterizedView, dropPk, dropSequence, dropTable, dropTableTriggersForMaterializedViews, dropTrigger, dropView, executeNative, getCallFunctionSql, getRecordSetStatement, getSetCountStatement, getTriggerBody, getUpdateRecordStatement, getViewList, getViewSQLGenerator, initDataForMaterializedView, isValidConnection, pkConstraintString, selectStaticStrings, sequenceString, tableString, translateDate, updateColumn, updateVersioningTrigger, userTablesExist
public PostgresAdaptor(ConnectionPool connectionPool, DdlConsumer ddlConsumer)
public int getCurrentIdent(Connection conn, BasicTable t)
DBAdaptor
getCurrentIdent
in class DBAdaptor
conn
- DB connectiont
- tablepublic PreparedStatement getInsertRecordStatement(Connection conn, BasicTable t, boolean[] nullsMask, List<ParameterSetter> program)
DBAdaptor
getInsertRecordStatement
in class DBAdaptor
conn
- DB connectiont
- tablenullsMask
- null-flags (if set the corresponding field at n-th position becomes null
)program
- collects parameters that can be set with the querypublic DbColumnInfo getColumnInfo(Connection conn, Column<?> c)
DBAdaptor
getColumnInfo
in class DBAdaptor
conn
- DB connectionc
- columnpublic String getInFilterClause(DataGrainElement dge, DataGrainElement otherDge, List<String> fields, List<String> otherFields, String otherWhere)
public List<String> getParameterizedViewList(Connection conn, Grain g)
DBAdaptor
getParameterizedViewList
in class DBAdaptor
conn
- connectiong
- current grainpublic DbPkInfo getPKInfo(Connection conn, TableElement t)
DBAdaptor
public List<DbFkInfo> getFKInfo(Connection conn, Grain g)
DBAdaptor
public Map<String,DbIndexInfo> getIndices(Connection conn, Grain g)
DBAdaptor
getIndices
in class DBAdaptor
conn
- DB connectiong
- Grain the tables of which have to be traversed for the indices.public void createSysObjects(Connection conn, String sysSchemaName)
DBAdaptor
createSysObjects
in class DBAdaptor
conn
- DB connectionsysSchemaName
- system schema namepublic boolean triggerExists(Connection conn, TriggerQuery query) throws SQLException
DBAdaptor
triggerExists
in class DBAdaptor
conn
- DB connection.query
- trigger query parametersSQLException
- thrown if resulting query failspublic int getDBPid(Connection conn)
DBAdaptor
public ZonedDateTime prepareZonedDateTimeForParameterSetter(Connection conn, ZonedDateTime z)
prepareZonedDateTimeForParameterSetter
in interface QueryBuildingHelper
prepareZonedDateTimeForParameterSetter
in class DBAdaptor
public DBType getType()
DBAdaptor
public boolean supportsCortegeComparing()
DBAdaptor
supportsCortegeComparing
in interface QueryBuildingHelper
supportsCortegeComparing
in class DBAdaptor
public DbSequenceInfo getSequenceInfo(Connection conn, SequenceElement s)
DBAdaptor
getSequenceInfo
in class DBAdaptor
conn
- DB connections
- sequenceCopyright © 2023 CURS. All rights reserved.