Package com.ibm.fhir.database.utils.postgres

Class PostgresAdapter

java.lang.Object

com.ibm.fhir.database.utils.common.CommonDatabaseAdapter

com.ibm.fhir.database.utils.postgres.PostgresAdapter

All Implemented Interfaces:

IDatabaseAdapter, IDatabaseTypeAdapter

public class PostgresAdapter
extends CommonDatabaseAdapter

A PostgreSql database target

Field Summary

Fields inherited from class com.ibm.fhir.database.utils.common.CommonDatabaseAdapter

connectionProvider, target

Constructor Summary

Constructors

Constructor	Description
PostgresAdapter()
PostgresAdapter(IConnectionProvider cp)
PostgresAdapter(IDatabaseTarget tgt)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	activateRowAccessControl(String schemaName, String tableName)	ALTER TABLE ACTIVATE ROW ACCESS CONTROL
void	alterTableColumnIdentityCache(String schemaName, String tableName, String columnName, int cache)	Change the CACHE value of the named identity generated always column
String	blobClause(long size, int inlineSize)	Generate a clause for BLOB (with an inline size if supported)
boolean	checkCompatibility(String adminSchema)	checks connectivity to the database and that it is compatible
String	clobClause()
void	createArrType(String schemaName, String typeName, String valueType, int arraySize)	Create ARRAY type used for passing values to stored procedures e.g.: CREATE OR REPLACE TYPE .t_str_values_arr AS .t_str_values ARRAY[256]
void	createForeignKeyConstraint(String constraintName, String schemaName, String name, String targetSchema, String targetTable, String targetColumnName, String tenantColumnName, List<String> columns, boolean enforced)
void	createIndex(String schemaName, String tableName, String indexName, String tenantColumnName, List<OrderedColumnDef> indexColumns)
void	createIntVariable(String schemaName, String variableName)	CREATE VARIABLE ptng.session_tenant INT DEFAULT NULL;
void	createOrReplacePermission(String schemaName, String permissionName, String tableName, String predicate)	CREATE OR REPLACE PERMISSION ROW_ACCESS ON ptng.patients FOR ROWS WHERE patients.mt_id = ptng.session_tenant ENFORCED FOR ALL ACCESS ENABLE;
void	createOrReplaceProcedure(String schemaName, String procedureName, Supplier<String> supplier)	Create the stored procedure using the DDL text provided by the supplier
void	createRowType(String schemaName, String typeName, List<ColumnBase> columns)	Create ROW type used for passing values to stored procedures e.g.:
void	createSchema(String schemaName)	Create a database schema
void	createSequence(String schemaName, String sequenceName, long startWith, int cache, int incrementBy)
void	createTable(String schemaName, String name, String tenantColumnName, List<ColumnBase> columns, PrimaryKeyDef primaryKey, IdentityDef identity, String tablespaceName)	Build the create table DDL
void	createTablespace(String tablespaceName)	Create a new tablespace with the given name
void	createTablespace(String tablespaceName, int extentSizeKB)	Create a new tablespace using the given extent size
void	createTenantPartitions(Collection<Table> tables, String schemaName, int newTenantId, int extentSizeKB)	Create the partitions on each of these tables
void	createUniqueIndex(String schemaName, String tableName, String indexName, String tenantColumnName, List<OrderedColumnDef> indexColumns)
void	createUniqueIndex(String schemaName, String tableName, String indexName, String tenantColumnName, List<OrderedColumnDef> indexColumns, List<String> includeColumns)
void	deactivateRowAccessControl(String schemaName, String tableName)	Deactivate row access control on a table ALTER TABLE DEACTIVATE ROW ACCESS CONTROL
void	detachPartition(String schemaName, String tableName, String partitionName, String newTableName)	Detach the partition
void	disableForeignKey(String schemaName, String tableName, String constraintName)	Disable the FK with the given constraint name
boolean	doesTableExist(String schemaName, String tableName)	Check if the table currently exists
String	doubleClause()	Generate a clause for double data type
void	dropDetachedPartitions(Collection<Table> tables, String schemaName, int tenantId)	Drop the tables which were created by the detach partition operation (as part of tenant deprovisioning).
void	dropPermission(String schemaName, String permissionName)	Drop permission object from the schema
void	dropProcedure(String schemaName, String procedureName)	Drop the given procedure
void	dropSequence(String schemaName, String sequenceName)
void	dropTablespace(String tablespaceName)	Drop an existing tablespace, including all of its contents
void	dropTenantTablespace(int tenantId)	Drop the tablespace associated with the given tenantId
void	dropType(String schemaName, String typeName)	Drop the type object from the schema
void	enableForeignKey(String schemaName, String tableName, String constraintName)	Enable the FK with the given constraint name
void	grantProcedurePrivileges(String schemaName, String procedureName, Collection<Privilege> privileges, String toUser)	Grant the collection of privileges on the named procedure to the user
protected List<OrderedColumnDef>	prefixTenantColumn(String tenantColumnName, List<OrderedColumnDef> columns)	Prefix the tenantColumnName to the list of columns, or do nothing if tenantColumnName is null
void	removeTenantPartitions(Collection<Table> tables, String schemaName, int tenantId)	Detach the partition associated with the tenantId from each of the given tables
void	runStatement(IDatabaseStatement stmt)	Run the statement using the connectionProvider to obtain a new connection.
void	setIntegrityOff(String schemaName, String tableName)
void	setIntegrityUnchecked(String schemaName, String tableName)
void	setIntVariable(String schemaName, String variableName, int value)	Build the DML statement for setting a session variable
String	timestampClause(Integer precision)	Generate a clause for TIMESTAMP
String	varbinaryClause(int size)	Generate a clause for binary data type
String	varcharClause(int size)	Generate a clause for VARCHAR
void	warnOnce(com.ibm.fhir.database.utils.postgres.PostgresAdapter.MessageKey messageKey, String msg)	Once write each warning message once

Methods inherited from class com.ibm.fhir.database.utils.common.CommonDatabaseAdapter

addNewTenantPartitions, allocateTenant, alterSequenceRestartWith, alterTableAddColumn, buildColumns, buildCreateTableStatement, createOrReplaceFunction, createOrReplaceView, createUniqueConstraint, createView, deleteTenantMeta, dropFunction, dropIndex, dropTable, dropVariable, dropView, findTenantId, getQualifiedName, getTranslator, grantFunctionPrivileges, grantObjectPrivileges, grantSequencePrivileges, grantVariablePrivileges, reorgTable, runStatement, runStatement, updateTenantStatus

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.ibm.fhir.database.utils.api.IDatabaseAdapter

useSessionVariable

Constructor Detail

PostgresAdapter

public PostgresAdapter(IDatabaseTarget tgt)

Public constructor

Parameters:

tgt - the target database we want to manage

PostgresAdapter

public PostgresAdapter(IConnectionProvider cp)

PostgresAdapter

public PostgresAdapter()

Method Detail

warnOnce

public void warnOnce(com.ibm.fhir.database.utils.postgres.PostgresAdapter.MessageKey messageKey,
                     String msg)

Once write each warning message once

Parameters:

msg -

createTable

public void createTable(String schemaName,
                        String name,
                        String tenantColumnName,
                        List<ColumnBase> columns,
                        PrimaryKeyDef primaryKey,
                        IdentityDef identity,
                        String tablespaceName)

Description copied from interface: IDatabaseAdapter

Build the create table DDL

tenantColumnName - optional column name to enable multi-tenancy

createUniqueIndex

public void createUniqueIndex(String schemaName,
                              String tableName,
                              String indexName,
                              String tenantColumnName,
                              List<OrderedColumnDef> indexColumns,
                              List<String> includeColumns)

Specified by:

createUniqueIndex in interface IDatabaseAdapter

Overrides:

createUniqueIndex in class CommonDatabaseAdapter

createIntVariable

public void createIntVariable(String schemaName,
                              String variableName)

Description copied from interface: IDatabaseAdapter

 CREATE VARIABLE ptng.session_tenant INT DEFAULT NULL;
 

createOrReplacePermission

public void createOrReplacePermission(String schemaName,
                                      String permissionName,
                                      String tableName,
                                      String predicate)

Description copied from interface: IDatabaseAdapter

 CREATE OR REPLACE PERMISSION ROW_ACCESS ON ptng.patients FOR ROWS WHERE patients.mt_id =
 ptng.session_tenant ENFORCED FOR ALL ACCESS ENABLE;
 

activateRowAccessControl

public void activateRowAccessControl(String schemaName,
                                     String tableName)

Description copied from interface: IDatabaseAdapter

 ALTER TABLE  ACTIVATE ROW ACCESS CONTROL
 

setIntVariable

public void setIntVariable(String schemaName,
                           String variableName,
                           int value)

Description copied from interface: IDatabaseAdapter

Build the DML statement for setting a session variable

deactivateRowAccessControl

public void deactivateRowAccessControl(String schemaName,
                                       String tableName)

Description copied from interface: IDatabaseAdapter

Deactivate row access control on a table ALTER TABLE DEACTIVATE ROW ACCESS CONTROL

createTenantPartitions

public void createTenantPartitions(Collection<Table> tables,
                                   String schemaName,
                                   int newTenantId,
                                   int extentSizeKB)

Description copied from interface: IDatabaseAdapter

Create the partitions on each of these tables

createRowType

public void createRowType(String schemaName,
                          String typeName,
                          List<ColumnBase> columns)

Description copied from interface: IDatabaseAdapter

Create ROW type used for passing values to stored procedures e.g.:

 CREATE OR REPLACE TYPE .t_str_values AS ROW (parameter_name_id INTEGER,
 str_value VARCHAR(511 OCTETS), str_value_lcase VARCHAR(511 OCTETS))
 

createArrType

public void createArrType(String schemaName,
                          String typeName,
                          String valueType,
                          int arraySize)

Description copied from interface: IDatabaseAdapter

Create ARRAY type used for passing values to stored procedures e.g.: CREATE OR REPLACE TYPE .t_str_values_arr AS .t_str_values ARRAY[256]

dropType

public void dropType(String schemaName,
                     String typeName)

Description copied from interface: IDatabaseAdapter

Drop the type object from the schema

createTablespace

public void createTablespace(String tablespaceName)

Description copied from interface: IDatabaseAdapter

Create a new tablespace with the given name

dropTablespace

public void dropTablespace(String tablespaceName)

Description copied from interface: IDatabaseAdapter

Drop an existing tablespace, including all of its contents

detachPartition

public void detachPartition(String schemaName,
                            String tableName,
                            String partitionName,
                            String newTableName)

Description copied from interface: IDatabaseAdapter

Detach the partition

removeTenantPartitions

public void removeTenantPartitions(Collection<Table> tables,
                                   String schemaName,
                                   int tenantId)

Description copied from interface: IDatabaseAdapter

Detach the partition associated with the tenantId from each of the given tables

createTablespace

public void createTablespace(String tablespaceName,
                             int extentSizeKB)

Description copied from interface: IDatabaseAdapter

Create a new tablespace using the given extent size

doesTableExist

public boolean doesTableExist(String schemaName,
                              String tableName)

Description copied from interface: IDatabaseAdapter

Check if the table currently exists

Returns:

createSequence

public void createSequence(String schemaName,
                           String sequenceName,
                           long startWith,
                           int cache,
                           int incrementBy)

Specified by:

createSequence in interface IDatabaseAdapter

Overrides:

createSequence in class CommonDatabaseAdapter

startWith - the START WITH value for the sequence

cache - the sequence CACHE value

varbinaryClause

public String varbinaryClause(int size)

Description copied from interface: IDatabaseTypeAdapter

Generate a clause for binary data type

Returns:

blobClause

public String blobClause(long size,
                         int inlineSize)

Description copied from interface: IDatabaseTypeAdapter

Generate a clause for BLOB (with an inline size if supported)

Returns:

varcharClause

public String varcharClause(int size)

Description copied from interface: IDatabaseTypeAdapter

Generate a clause for VARCHAR

Returns:

timestampClause

public String timestampClause(Integer precision)

Description copied from interface: IDatabaseTypeAdapter

Generate a clause for TIMESTAMP

Returns:

doubleClause

public String doubleClause()

Description copied from interface: IDatabaseTypeAdapter

Generate a clause for double data type

Returns:

clobClause

public String clobClause()

createForeignKeyConstraint

public void createForeignKeyConstraint(String constraintName,
                                       String schemaName,
                                       String name,
                                       String targetSchema,
                                       String targetTable,
                                       String targetColumnName,
                                       String tenantColumnName,
                                       List<String> columns,
                                       boolean enforced)

Specified by:

createForeignKeyConstraint in interface IDatabaseAdapter

Overrides:

createForeignKeyConstraint in class CommonDatabaseAdapter

prefixTenantColumn

protected List<OrderedColumnDef> prefixTenantColumn(String tenantColumnName,
                                                    List<OrderedColumnDef> columns)

Description copied from class: CommonDatabaseAdapter

Prefix the tenantColumnName to the list of columns, or do nothing if tenantColumnName is null

Overrides:

prefixTenantColumn in class CommonDatabaseAdapter

Returns:

runStatement

public void runStatement(IDatabaseStatement stmt)

Description copied from class: CommonDatabaseAdapter

Run the statement using the connectionProvider to obtain a new connection. Also, there should be a transaction open on the current thread at this time

Specified by:

runStatement in interface IDatabaseAdapter

Overrides:

runStatement in class CommonDatabaseAdapter

createUniqueIndex

public void createUniqueIndex(String schemaName,
                              String tableName,
                              String indexName,
                              String tenantColumnName,
                              List<OrderedColumnDef> indexColumns)

Specified by:

createUniqueIndex in interface IDatabaseAdapter

Overrides:

createUniqueIndex in class CommonDatabaseAdapter

createIndex

public void createIndex(String schemaName,
                        String tableName,
                        String indexName,
                        String tenantColumnName,
                        List<OrderedColumnDef> indexColumns)

Specified by:

createIndex in interface IDatabaseAdapter

Overrides:

createIndex in class CommonDatabaseAdapter

checkCompatibility

public boolean checkCompatibility(String adminSchema)

Description copied from interface: IDatabaseAdapter

checks connectivity to the database and that it is compatible

Returns:

createSchema

public void createSchema(String schemaName)

Description copied from interface: IDatabaseAdapter

Create a database schema

createOrReplaceProcedure

public void createOrReplaceProcedure(String schemaName,
                                     String procedureName,
                                     Supplier<String> supplier)

Description copied from interface: IDatabaseAdapter

Create the stored procedure using the DDL text provided by the supplier

Specified by:

createOrReplaceProcedure in interface IDatabaseAdapter

Overrides:

createOrReplaceProcedure in class CommonDatabaseAdapter

grantProcedurePrivileges

public void grantProcedurePrivileges(String schemaName,
                                     String procedureName,
                                     Collection<Privilege> privileges,
                                     String toUser)

Description copied from interface: IDatabaseAdapter

Grant the collection of privileges on the named procedure to the user

Specified by:

grantProcedurePrivileges in interface IDatabaseAdapter

Overrides:

grantProcedurePrivileges in class CommonDatabaseAdapter

dropProcedure

public void dropProcedure(String schemaName,
                          String procedureName)

Description copied from interface: IDatabaseAdapter

Drop the given procedure

Specified by:

dropProcedure in interface IDatabaseAdapter

Overrides:

dropProcedure in class CommonDatabaseAdapter

dropDetachedPartitions

public void dropDetachedPartitions(Collection<Table> tables,
                                   String schemaName,
                                   int tenantId)

Description copied from interface: IDatabaseAdapter

Drop the tables which were created by the detach partition operation (as part of tenant deprovisioning).

dropTenantTablespace

public void dropTenantTablespace(int tenantId)

Description copied from interface: IDatabaseAdapter

Drop the tablespace associated with the given tenantId

disableForeignKey

public void disableForeignKey(String schemaName,
                              String tableName,
                              String constraintName)

Description copied from interface: IDatabaseAdapter

Disable the FK with the given constraint name

enableForeignKey

public void enableForeignKey(String schemaName,
                             String tableName,
                             String constraintName)

Description copied from interface: IDatabaseAdapter

Enable the FK with the given constraint name

setIntegrityOff

public void setIntegrityOff(String schemaName,
                            String tableName)

setIntegrityUnchecked

public void setIntegrityUnchecked(String schemaName,
                                  String tableName)

alterTableColumnIdentityCache

public void alterTableColumnIdentityCache(String schemaName,
                                          String tableName,
                                          String columnName,
                                          int cache)

Description copied from interface: IDatabaseAdapter

Change the CACHE value of the named identity generated always column

Specified by:

alterTableColumnIdentityCache in interface IDatabaseAdapter

Overrides:

alterTableColumnIdentityCache in class CommonDatabaseAdapter

dropPermission

public void dropPermission(String schemaName,
                           String permissionName)

Description copied from interface: IDatabaseAdapter

Drop permission object from the schema

Specified by:

dropPermission in interface IDatabaseAdapter

Overrides:

dropPermission in class CommonDatabaseAdapter

dropSequence

public void dropSequence(String schemaName,
                         String sequenceName)

Specified by:

dropSequence in interface IDatabaseAdapter

Overrides:

dropSequence in class CommonDatabaseAdapter