Package org.pgcodekeeper.core.database.pg.schema

Class GpExternalTable

java.lang.Object

org.pgcodekeeper.core.database.base.schema.AbstractStatement

org.pgcodekeeper.core.database.pg.schema.PgAbstractStatement

org.pgcodekeeper.core.database.pg.schema.PgAbstractStatementContainer

org.pgcodekeeper.core.database.pg.schema.PgAbstractTable

org.pgcodekeeper.core.database.pg.schema.GpExternalTable

All Implemented Interfaces:

IForeignTable, IOptionContainer, IRelation, ISearchPath, IStatement, IStatementContainer, ITable, PgForeignOptionContainer, IHashable

public class GpExternalTable
extends PgAbstractTable
implements IForeignTable, PgForeignOptionContainer

Greenplum external table implementation. External tables allow access to data stored outside the database, such as flat files, web services, or other external data sources.

Field Summary

Fields inherited from interface org.pgcodekeeper.core.database.pg.schema.PgForeignOptionContainer

ALTER_FOREIGN_OPTION, DELIM

Constructor Summary

Constructors

Constructor	Description
GpExternalTable(String name)	Creates a new Greenplum external table.

Method Summary

Modifier and Type	Method	Description
void	addUrLocation(String location)	Adds a URI location for the external table.
void	addUrLocations(List<String> urlLocation)
void	appendMoveDataSql(IStatement newCondition, SQLScript script, String tblTmpBareName, List<String> identityCols)	Adds commands to the script for move data from the temporary table to the new table, given the identity columns, and a command to delete the temporary table.
void	appendOptions(StringBuilder sbSQL)	Appends SQL OPTIONS clause to StringBuilder.
boolean	compare(IStatement obj)	This method does not account for nested child PgStatements.
void	compareOptions(IOptionContainer newContainer, SQLScript script)	Compares options between this container and a new container, generating SQL to update differences.
void	computeHash(Hasher hasher)	Computes the hash of the implementing object using the provided hasher.
String	getAlterHeader()	Returns the ALTER statement header for this object.
String	getTypeName()	Gets the type name of this statement for SQL generation.
void	setCommand(String command)
void	setDistribution(String distribution)
void	setEncoding(String encoding)
void	setExLocation(String exLocation)
void	setFormatOptions(String formatOptions)
void	setFormatType(String formatType)
void	setIsLogErrors(boolean isLogErrors)
void	setRejectLimit(int rejectLimit)
void	setRowReject(boolean isRowReject)
void	setWeb(boolean isWeb)
void	setWritable(boolean isWritable)

Methods inherited from class org.pgcodekeeper.core.database.pg.schema.PgAbstractTable

addChild, addColumn, addInherits, addOption, appendAlterSQL, appendComments, compareChildren, compareIgnoringColumnOrder, computeChildrenHash, fillChildrenList, getChild, getChildrenByType, getColumn, getColumns, getConstraint, getConstraints, getCreationSQL, getInherits, getOptions, getRelationColumns, hasInherits, isClustered, isRecreated, putTriggerState, setHasOids, sortColumns

Methods inherited from class org.pgcodekeeper.core.database.pg.schema.PgAbstractStatementContainer

getIndex, getIndexes, getPolicies, getPolicy, getRule, getTrigger, getTriggers

Methods inherited from class org.pgcodekeeper.core.database.pg.schema.PgAbstractStatement

addPrivilege, appendDefaultPrivileges, appendOwnerSQL, formatSql, getQuoter, getRenameCommand, isOwned

Methods inherited from class org.pgcodekeeper.core.database.base.schema.AbstractStatement

addDependency, appendAlterComments, appendPrivileges, canDrop, canDropBeforeCreate, checkComments, clearPrivileges, deepCopy, equals, fillDescendantsList, getAuthor, getBareName, getChildren, getComment, getDependencies, getDescendants, getDropSQL, getDropSQL, getLibName, getLocation, getName, getObjectState, getObjectState, getOwner, getParent, getPrivileges, getQualifiedName, getSeparator, getSQL, getTwin, hasChildren, hashCode, isLib, setAuthor, setComment, setLibName, setLocation, setOwner, setParent, shallowCopy, toString

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.IOptionContainer

addOption, getOptions

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.IRelation

getRelationColumns

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.ISearchPath

getContainingSchema, getDatabase, getSchemaName, toObjectReference

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.IStatement

addDependency, appendAlterSQL, appendOwnerSQL, canDrop, canDropBeforeCreate, clearPrivileges, deepCopy, formatSql, getAuthor, getBareName, getChildren, getComment, getCreationSQL, getDependencies, getDescendants, getDropSQL, getLibName, getLocation, getName, getOwner, getParent, getPrivileges, getQualifiedName, getQuotedName, getQuoter, getRenameCommand, getSeparator, getSQL, getTwin, hasChildren, isLib, isOwned, quote, setComment, setLibName, setLocation, setOwner, shallowCopy

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.IStatementContainer

addChild, getChild, getChildrenByType

Methods inherited from interface org.pgcodekeeper.core.database.api.schema.ITable

compareIgnoringColumnOrder, getColumn, getColumns, getConstraints, getStatementType, isRecreated

Constructor Details

GpExternalTable

public GpExternalTable(String name)

Creates a new Greenplum external table.

Parameters:

name - table name

Method Details

getTypeName

public String getTypeName()

Description copied from interface: IStatement

Gets the type name of this statement for SQL generation.

Specified by:

getTypeName in interface IStatement

Returns:

the type name

appendOptions

public void appendOptions(StringBuilder sbSQL)

Description copied from interface: PgForeignOptionContainer

Appends SQL OPTIONS clause to StringBuilder.

Specified by:

appendOptions in interface PgForeignOptionContainer

Parameters:

sbSQL - the StringBuilder to append to

appendMoveDataSql

public void appendMoveDataSql(IStatement newCondition,
 SQLScript script,
 String tblTmpBareName,
 List<String> identityCols)

Description copied from interface: ITable

Adds commands to the script for move data from the temporary table to the new table, given the identity columns, and a command to delete the temporary table.

Specified by:

appendMoveDataSql in interface ITable

Overrides:

appendMoveDataSql in class PgAbstractTable

compareOptions

public void compareOptions(IOptionContainer newContainer,
 SQLScript script)

Description copied from interface: IOptionContainer

Compares options between this container and a new container, generating SQL to update differences.

Specified by:

compareOptions in interface IOptionContainer

Specified by:

compareOptions in interface PgForeignOptionContainer

Parameters:

newContainer - the new container to compare against

script - the script to append changes to

getAlterHeader

public String getAlterHeader()

Description copied from interface: PgForeignOptionContainer

Returns the ALTER statement header for this object.

Specified by:

getAlterHeader in interface PgForeignOptionContainer

Returns:

ALTER statement prefix (e.g., "ALTER FOREIGN TABLE table_name")

setWritable

public void setWritable(boolean isWritable)

setWeb

public void setWeb(boolean isWeb)

setRejectLimit

public void setRejectLimit(int rejectLimit)

setDistribution

public void setDistribution(String distribution)

addUrLocations

public void addUrLocations(List<String> urlLocation)

addUrLocation

public void addUrLocation(String location)

Adds a URI location for the external table.

Parameters:

location - URI location to add

setExLocation

public void setExLocation(String exLocation)

setCommand

public void setCommand(String command)

setFormatType

public void setFormatType(String formatType)

setFormatOptions

public void setFormatOptions(String formatOptions)

setRowReject

public void setRowReject(boolean isRowReject)

setEncoding

public void setEncoding(String encoding)

setIsLogErrors

public void setIsLogErrors(boolean isLogErrors)

computeHash

public void computeHash(Hasher hasher)

Description copied from interface: IHashable

Computes the hash of the implementing object using the provided hasher. The implementation should call appropriate put methods on the hasher for all fields that should contribute to the hash value.

Specified by:

computeHash in interface IHashable

Overrides:

computeHash in class PgAbstractTable

Parameters:

hasher - the hasher instance to use for hash computation

compare

public boolean compare(IStatement obj)

Description copied from class: AbstractStatement

This method does not account for nested child PgStatements. Shallow version of AbstractStatement.equals(Object)

Specified by:

compare in interface IStatement

Overrides:

compare in class PgAbstractTable