Package org.pgcodekeeper.core.database.pg.loader

Class PgJdbcLoader

java.lang.Object

org.pgcodekeeper.core.database.base.loader.AbstractLoader<T>

org.pgcodekeeper.core.database.base.loader.AbstractJdbcLoader<PgDatabase>

org.pgcodekeeper.core.database.pg.loader.PgJdbcLoader

All Implemented Interfaces:

IJdbcLoader, ILoader

public class PgJdbcLoader
extends AbstractJdbcLoader<PgDatabase>

JDBC-based database schema loader for PostgreSQL databases. Reads database schemas, functions, views, tables, types, sequences, extensions, and other objects from a PostgreSQL database. Supports timezone configuration and Greenplum database detection. Extends JdbcLoaderBase to provide PostgreSQL-specific loading functionality.

Constructor Summary

Constructors

Constructor	Description
PgJdbcLoader(IJdbcConnector connector, String timezone, DiffSettings diffSettings)	Creates a new PostgreSQL JDBC loader with the specified parameters.

Method Summary

Modifier and Type	Method	Description
PgJdbcType	getCachedTypeByOid(Long oid)
String	getExtensionSchema()
long	getLastSysOid()
String	getRoleByOid(long oid)
boolean	isGreenplumDb()
PgDatabase	loadInternal()
void	preLoad()
void	setAuthor(AbstractStatement st, ResultSet res)
void	setOwner(AbstractStatement statement, long ownerOid)
void	setPrivileges(AbstractStatement st, String aclItemsArrayAsString, String schemaName)
void	setPrivileges(AbstractStatement st, String aclItemsArrayAsString, String columnName, String schemaName)
void	setPrivileges(PgColumn column, PgAbstractTable t, String aclItemsArrayAsString, String schemaName)
<T> void	submitAntlrTask(String sql, Function<SQLParser,T> parserCtxReader, Consumer<T> finalizer)
<T> void	submitPlpgsqlTask(String sql, Function<SQLParser,T> parserCtxReader, Consumer<T> finalizer)

Methods inherited from class org.pgcodekeeper.core.database.base.loader.AbstractJdbcLoader

getConnection, getCurrentLocation, getRunner, getSchema, getSchemas, getStatement, getVersion, putSchema, setComment, setCurrentObject, setCurrentOperation, setOwner, setVersion

Methods inherited from class org.pgcodekeeper.core.database.base.loader.AbstractLoader

addError, getDatabase, getDatabaseName, getErrors, getMonitor, getSettings, isAllowedSchema, load, loadAndAnalyze

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.pgcodekeeper.core.database.api.loader.ILoader

getDatabase, getDatabaseName, getErrors, getSettings, load, loadAndAnalyze

Constructor Details

PgJdbcLoader

public PgJdbcLoader(IJdbcConnector connector,
 String timezone,
 DiffSettings diffSettings)

Creates a new PostgreSQL JDBC loader with the specified parameters.

Parameters:

connector - the JDBC connector for establishing database connections

timezone - the timezone to set for the database connection

diffSettings - unified context object containing settings, ignore list, and error accumulator

Method Details

preLoad

public void preLoad()

loadInternal

public PgDatabase loadInternal()
                        throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

submitAntlrTask

public <T> void submitAntlrTask(String sql,
 Function<SQLParser,T> parserCtxReader,
 Consumer<T> finalizer)

submitPlpgsqlTask

public <T> void submitPlpgsqlTask(String sql,
 Function<SQLParser,T> parserCtxReader,
 Consumer<T> finalizer)

setPrivileges

public void setPrivileges(AbstractStatement st,
 String aclItemsArrayAsString,
 String schemaName)

setPrivileges

public void setPrivileges(PgColumn column,
 PgAbstractTable t,
 String aclItemsArrayAsString,
 String schemaName)

setPrivileges

public void setPrivileges(AbstractStatement st,
 String aclItemsArrayAsString,
 String columnName,
 String schemaName)

setOwner

public void setOwner(AbstractStatement statement,
 long ownerOid)

setAuthor

public void setAuthor(AbstractStatement st,
 ResultSet res)
               throws SQLException

Throws:

SQLException

getLastSysOid

public long getLastSysOid()

getExtensionSchema

public String getExtensionSchema()

isGreenplumDb

public boolean isGreenplumDb()

getCachedTypeByOid

public PgJdbcType getCachedTypeByOid(Long oid)

getRoleByOid

public String getRoleByOid(long oid)