Package org.pgcodekeeper.core.loader.jdbc

Class JdbcLoaderBase

java.lang.Object

org.pgcodekeeper.core.loader.DatabaseLoader

org.pgcodekeeper.core.loader.jdbc.JdbcLoaderBase

Direct Known Subclasses:

JdbcChLoader, JdbcMsLoader, JdbcPgLoader, JdbcSystemLoader

public abstract class JdbcLoaderBase
extends DatabaseLoader

Abstract base class for JDBC-based database loaders. Contains shared state and functionality for loading database schemas from JDBC connections including schema mapping, type caching, version detection, and progress monitoring.

Author:

levsha_aa

Method Summary

Modifier and Type	Method	Description
void	addError(String message)
JdbcType	getCachedTypeByOid(Long oid)
Connection	getConnection()
String	getCurrentLocation()
String	getExtensionSchema()
long	getLastSysOid()
IMonitor	getMonitor()
static String	getMsType(PgStatement statement, String schema, String dataType, boolean isUserDefined, int size, int precision, int scale)
static String	getMsType(PgStatement statement, String schema, String dataType, boolean isUserDefined, int size, int precision, int scale, boolean quoteSysTypes)
String	getRoleByOid(long oid)
JdbcRunner	getRunner()
String	getSchemas()	Returns a string representation of loaded schemas.
ISettings	getSettings()
Statement	getStatement()
int	getVersion()
boolean	isGreenplumDb()
boolean	isIgnoredSchema(String schemaName)
void	putSchema(Object schemaId, AbstractSchema schema)	Associates a schema ID with a schema object.
void	setAuthor(PgStatement st, ResultSet res)
final void	setComment(PgStatement f, ResultSet res)
void	setCurrentObject(GenericColumn currentObject)
void	setCurrentOperation(String operation)
void	setOwner(PgStatement statement, long ownerOid)
void	setOwner(PgStatement st, String owner)
void	setPrivileges(AbstractColumn column, AbstractTable t, String aclItemsArrayAsString, String schemaName)
void	setPrivileges(PgStatement st, String aclItemsArrayAsString, String schemaName)
void	setPrivileges(PgStatement st, String aclItemsArrayAsString, String columnName, String schemaName)
void	setPrivileges(PgStatement st, List<XmlReader> privs)
<T> void	submitAntlrTask(String sql, Function<SQLParser,T> parserCtxReader, Consumer<T> finalizer)
<T> void	submitChAntlrTask(String sql, Function<CHParser,T> parserCtxReader, Consumer<T> finalizer)
<T> void	submitMsAntlrTask(String sql, Function<TSQLParser,T> parserCtxReader, Consumer<T> finalizer)
<T> void	submitPlpgsqlTask(String sql, Function<SQLParser,T> parserCtxReader, Consumer<T> finalizer)

Methods inherited from class org.pgcodekeeper.core.loader.DatabaseLoader

createDb, getErrors, load, loadAndAnalyze

Methods inherited from class java.lang.Object

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

Method Details

getVersion

public int getVersion()

getSettings

public ISettings getSettings()

getLastSysOid

public long getLastSysOid()

getConnection

public Connection getConnection()

getRunner

public JdbcRunner getRunner()

getStatement

public Statement getStatement()

getMonitor

public IMonitor getMonitor()

getExtensionSchema

public String getExtensionSchema()

putSchema

public void putSchema(Object schemaId,
 AbstractSchema schema)

Associates a schema ID with a schema object.

Parameters:

schemaId - the schema identifier

schema - the schema object to associate

getSchemas

public String getSchemas()

Returns a string representation of loaded schemas.

Returns:

string containing schema information

setCurrentObject

public void setCurrentObject(GenericColumn currentObject)

setCurrentOperation

public void setCurrentOperation(String operation)

isIgnoredSchema

public boolean isIgnoredSchema(String schemaName)

getCachedTypeByOid

public JdbcType getCachedTypeByOid(Long oid)

getCurrentLocation

public String getCurrentLocation()

isGreenplumDb

public boolean isGreenplumDb()

addError

public void addError(String message)

getRoleByOid

public String getRoleByOid(long oid)

setComment

public final void setComment(PgStatement f,
 ResultSet res)
                      throws SQLException

Throws:

SQLException

setOwner

public void setOwner(PgStatement statement,
 long ownerOid)

setOwner

public void setOwner(PgStatement st,
 String owner)

setAuthor

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

Throws:

SQLException

setPrivileges

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

setPrivileges

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

setPrivileges

public void setPrivileges(AbstractColumn column,
 AbstractTable t,
 String aclItemsArrayAsString,
 String schemaName)

setPrivileges

public void setPrivileges(PgStatement st,
 List<XmlReader> privs)

getMsType

public static String getMsType(PgStatement statement,
 String schema,
 String dataType,
 boolean isUserDefined,
 int size,
 int precision,
 int scale)

getMsType

public static String getMsType(PgStatement statement,
 String schema,
 String dataType,
 boolean isUserDefined,
 int size,
 int precision,
 int scale,
 boolean quoteSysTypes)

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)

submitMsAntlrTask

public <T> void submitMsAntlrTask(String sql,
 Function<TSQLParser,T> parserCtxReader,
 Consumer<T> finalizer)

submitChAntlrTask

public <T> void submitChAntlrTask(String sql,
 Function<CHParser,T> parserCtxReader,
 Consumer<T> finalizer)