Class 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';"
     
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      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