Package org.pgcodekeeper.core.database.pg.jdbc

Interface IPgJdbcReader

All Known Implementing Classes:
PgAbstractJdbcReader, PgAbstractSearchPathJdbcReader, PgCastsReader, PgCollationsReader, PgConstraintsReader, PgEventTriggersReader, PgExtensionsReader, PgForeignDataWrappersReader, PgFtsConfigurationsReader, PgFtsDictionariesReader, PgFtsParsersReader, PgFtsTemplatesReader, PgFunctionsReader, PgIndicesReader, PgOperatorsReader, PgPoliciesReader, PgRulesReader, PgSchemasReader, PgSequencesReader, PgServersReader, PgStatisticsReader, PgTablesReader, PgTriggersReader, PgTypesReader, PgUserMappingsReader, PgViewsReader
public interface IPgJdbcReader

  • Field Details

  • Method Details

    • setFunctionWithDep

      default <T extends AbstractStatement> void setFunctionWithDep(BiConsumer<T,String> setter, T statement, String function, String signature)
      Sets a function reference on a statement and adds appropriate dependencies. Parses the function name to extract schema information and adds schema and function dependencies.
      Type Parameters:
      T - the statement type
      Parameters:
      setter - the setter to apply the function value
      statement - the statement to add dependencies to
      function - the function name (possibly schema-qualified)
      signature - the function signature, or null if not applicable

    • checkTypeValidity

      static void checkTypeValidity(String type)
      Checks type validity for concurrent modifications. Validates that the type is not null or unknown (???) which can occur when functions process metadata of concurrently modified objects.
      Parameters:
      type - the type string to validate
      Throws:
      ConcurrentModificationException - if the type is invalid

    • checkObjectValidity

      static void checkObjectValidity(Object object, DbObjType type, String name)
      Checks validity of database objects that may be concurrently modified. Functions that accept OID/object name and return metadata are considered unsafe as they can return null if the object was deleted outside the transaction block.
      Parameters:
      object - the object to check for validity
      type - the database object type
      name - the object name
      Throws:
      ConcurrentModificationException - if the object is null (was deleted)

    • appendExtension

      default void appendExtension(QueryBuilder builder, String extensionSchema)

    • getExtensionCte

      default QueryBuilder getExtensionCte()

    • addDescriptionPart

      default void addDescriptionPart(QueryBuilder builder)

    • addDescriptionPart

      default void addDescriptionPart(QueryBuilder builder, boolean checkColumn)

    • addExtensionDepsCte

      default void addExtensionDepsCte(QueryBuilder builder)

    • getClassId

      String getClassId()
      Override for postgres.
      Returns:
      object class's catalog name

    • getFormattedClassId

      String getFormattedClassId()