Package org.linuxforhealth.fhir.database.utils.citus

Class ConfigureConnectionDAO

java.lang.Object

org.linuxforhealth.fhir.database.utils.citus.ConfigureConnectionDAO

All Implemented Interfaces:

IDatabaseStatement

public class ConfigureConnectionDAO
extends java.lang.Object
implements IDatabaseStatement

DAO to configure the Citus database connection when performing schema build activities. This must be performed before any of the following UDFs are called:

• create_distributed_table
• create_reference_table

to avoid the following error:

 org.postgresql.util.PSQLException: ERROR: cannot modify table "common_token_values" because there was a parallel operation on a distributed table in the transaction
 Detail: When there is a foreign key to a reference table, Citus needs to perform all operations over a single connection per node to ensure consistency.
 Hint: Try re-running the transaction with "SET LOCAL citus.multi_shard_modify_mode TO 'sequential';"
 

Constructor Summary

Constructors

Constructor	Description
ConfigureConnectionDAO()	Public constructor

Method Summary

Modifier and Type	Method	Description
void	run(IDatabaseTranslator translator, java.sql.Connection c)	Execute the statement using the connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConfigureConnectionDAO

public ConfigureConnectionDAO()

Public constructor

Method Detail

run

public void run(IDatabaseTranslator translator,
                java.sql.Connection c)

Description copied from interface: IDatabaseStatement

Execute the statement using the connection.

Specified by:

run in interface IDatabaseStatement

Parameters:

translator - to translate any exceptions