Package org.jumpmind.symmetric.db.postgresql

Class PostgreSqlSymmetricDialect

java.lang.Object

org.jumpmind.symmetric.db.AbstractSymmetricDialect

org.jumpmind.symmetric.db.postgresql.PostgreSqlSymmetricDialect

All Implemented Interfaces:

ISymmetricDialect

Direct Known Subclasses:

GreenplumSymmetricDialect

public class PostgreSqlSymmetricDialect
extends AbstractSymmetricDialect
implements ISymmetricDialect

Field Summary

Fields inherited from class org.jumpmind.symmetric.db.AbstractSymmetricDialect

databaseMajorVersion, databaseMinorVersion, databaseName, databaseProductVersion, driverName, driverVersion, extensionService, isSpatialTypesEnabled, log, MAX_SYMMETRIC_SUPPORTED_TRIGGER_SIZE, parameterService, platform, sqlKeywords, sqlReplacementTokens, supportsDdlTriggers, supportsGetGeneratedKeys, supportsSubselectsInDelete, supportsSubselectsInUpdate, supportsTransactionViews, tablePrefixLowerCase, targetDialect, triggerTemplate

Constructor Summary

Constructors

Constructor	Description
PostgreSqlSymmetricDialect(IParameterService parameterService, IDatabasePlatform platform)

Method Summary

Modifier and Type	Method	Description
void	cleanDatabase()
void	createRequiredDatabaseObjectsImpl(StringBuilder ddl)
void	disableSyncTriggers(ISqlTransaction transaction, String nodeId)
boolean	doesDdlTriggerExist(String catalogName, String schema, String triggerName)
protected boolean	doesTriggerExistOnPlatform(StringBuilder sqlBuffer, String catalogName, String schema, String tableName, String triggerName)
void	dropRequiredDatabaseObjects()
void	enableSyncTriggers(ISqlTransaction transaction)
BinaryEncoding	getBinaryEncoding()
long	getCurrentSequenceValue(SequenceIdentifier identifier)
protected String	getDbSpecificDataHasChangedCondition(Trigger trigger)
final Date	getEarliestTransactionStartTime()
int	getSqlTypeForIds()
String	getSyncTriggersExpression()
String	getSyncTriggersOnIncomingExpression()
String	getTransactionId(ISqlTransaction transaction)
String	getTransactionTriggerExpression(String defaultCatalog, String defaultSchema, Trigger trigger)
void	removeDdlTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName)
void	removeTrigger(StringBuilder sqlBuffer, String catalogName, String schemaName, String triggerName, String tableName, ISqlTransaction transaction)
boolean	requiresAutoCommitFalseToSetFetchSize()
boolean	supportsTransactionId()
boolean	supportsTransactionViews()

Methods inherited from class org.jumpmind.symmetric.db.AbstractSymmetricDialect

areDatabaseTransactionsPendingSince, buildSqlReplacementTokens, canGapsOccurInCapturedDataIds, cleanupTriggers, close, createCsvDataSql, createCsvPrimaryKeySql, createDdlTrigger, createInitialLoadSqlFor, createOrAlterTablesIfNecessary, createPostDdlTriggerDDL, createPostTriggerDDL, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createTrigger, createTrigger, disableSyncTriggers, doesTriggerExist, dropTablesAndDatabaseObjects, escapesTemplatesForDatabaseInserts, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDriverName, getDriverVersion, getDropTriggerSql, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobLengthSql, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSymmetricDdlChanges, getSymTablePermissions, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, install, installed, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, isTransactionIdOverrideSupported, logSql, massageDataExtractionSql, massageForLob, merge, needsToSelectLobData, orderColumns, postCreateDdlTrigger, postCreateTrigger, prefixConfigDatabase, preProcessTriggerSqlClause, readDatabaseFromXml, readSymmetricSchemaFromDatabase, readSymmetricSchemaFromXml, removeTrigger, replaceTokens, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, switchCatalogForTriggerInstall, truncateTable, uninstall, uninstall, verifyDatabaseIsCompatible

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.db.ISymmetricDialect

areDatabaseTransactionsPendingSince, canGapsOccurInCapturedDataIds, cleanupTriggers, createCsvDataSql, createCsvPrimaryKeySql, createDdlTrigger, createInitialLoadSqlFor, createOrAlterTablesIfNecessary, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlFor, createPurgeSqlForMultipleTables, createRequiredDatabaseObjects, createTrigger, createTrigger, disableSyncTriggers, doesTriggerExist, dropTablesAndDatabaseObjects, escapesTemplatesForDatabaseInserts, getColumnPositionUsingTemplate, getCreateRequiredDatabaseObjectsDDL, getCreateSymmetricDDL, getDatabaseTime, getDatabaseTimeSQL, getDataHasChangedCondition, getDriverName, getDriverVersion, getEngineName, getInitialLoadTableAlias, getInitialLoadTwoPassLobSql, getMajorVersion, getMasterCollation, getMaxTriggerNameLength, getMinorVersion, getName, getParameterService, getPlatform, getProductVersion, getSequenceKeyName, getSequenceName, getSourceNodeExpression, getSqlKeywords, getSqlReplacementTokens, getSymmetricDdlChanges, getSymTablePermissions, getTablePrefix, getTargetDialect, getTargetDialect, getTargetPlatform, getTargetPlatform, getTemplateNumberPrecisionSpec, getTriggerTemplate, getVersion, initTablesAndDatabaseObjects, insertWithGeneratedKey, insertWithGeneratedKey, isBlobSyncSupported, isClobSyncSupported, isInitialLoadTwoPassLob, isTransactionIdOverrideSupported, massageDataExtractionSql, massageForLob, needsToSelectLobData, orderColumns, preProcessTriggerSqlClause, readSymmetricSchemaFromXml, removeTrigger, setExtensionService, setTargetDialect, supportsBatchUpdates, supportsDdlTriggers, supportsOpenCursorsAcrossCommit, supportsSubselectsInDelete, supportsSubselectsInUpdate, truncateTable, verifyDatabaseIsCompatible

Constructor Details

PostgreSqlSymmetricDialect

public PostgreSqlSymmetricDialect(IParameterService parameterService,
 IDatabasePlatform platform)

Method Details

createRequiredDatabaseObjectsImpl

public void createRequiredDatabaseObjectsImpl(StringBuilder ddl)

Overrides:

createRequiredDatabaseObjectsImpl in class AbstractSymmetricDialect

dropRequiredDatabaseObjects

public void dropRequiredDatabaseObjects()

Specified by:

dropRequiredDatabaseObjects in interface ISymmetricDialect

Specified by:

dropRequiredDatabaseObjects in class AbstractSymmetricDialect

requiresAutoCommitFalseToSetFetchSize

public boolean requiresAutoCommitFalseToSetFetchSize()

Overrides:

requiresAutoCommitFalseToSetFetchSize in class AbstractSymmetricDialect

doesTriggerExistOnPlatform

protected boolean doesTriggerExistOnPlatform(StringBuilder sqlBuffer,
 String catalogName,
 String schema,
 String tableName,
 String triggerName)

Specified by:

doesTriggerExistOnPlatform in class AbstractSymmetricDialect

removeTrigger

public void removeTrigger(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName,
 String tableName,
 ISqlTransaction transaction)

Specified by:

removeTrigger in interface ISymmetricDialect

Overrides:

removeTrigger in class AbstractSymmetricDialect

doesDdlTriggerExist

public boolean doesDdlTriggerExist(String catalogName,
 String schema,
 String triggerName)

Specified by:

doesDdlTriggerExist in interface ISymmetricDialect

Overrides:

doesDdlTriggerExist in class AbstractSymmetricDialect

removeDdlTrigger

public void removeDdlTrigger(StringBuilder sqlBuffer,
 String catalogName,
 String schemaName,
 String triggerName)

Specified by:

removeDdlTrigger in interface ISymmetricDialect

Overrides:

removeDdlTrigger in class AbstractSymmetricDialect

disableSyncTriggers

public void disableSyncTriggers(ISqlTransaction transaction,
 String nodeId)

Specified by:

disableSyncTriggers in interface ISymmetricDialect

enableSyncTriggers

public void enableSyncTriggers(ISqlTransaction transaction)

Specified by:

enableSyncTriggers in interface ISymmetricDialect

getSyncTriggersExpression

public String getSyncTriggersExpression()

Specified by:

getSyncTriggersExpression in interface ISymmetricDialect

getSyncTriggersOnIncomingExpression

public String getSyncTriggersOnIncomingExpression()

Specified by:

getSyncTriggersOnIncomingExpression in interface ISymmetricDialect

Overrides:

getSyncTriggersOnIncomingExpression in class AbstractSymmetricDialect

getTransactionTriggerExpression

public String getTransactionTriggerExpression(String defaultCatalog,
 String defaultSchema,
 Trigger trigger)

Specified by:

getTransactionTriggerExpression in interface ISymmetricDialect

Overrides:

getTransactionTriggerExpression in class AbstractSymmetricDialect

getTransactionId

public String getTransactionId(ISqlTransaction transaction)

Specified by:

getTransactionId in interface ISymmetricDialect

Overrides:

getTransactionId in class AbstractSymmetricDialect

supportsTransactionId

public boolean supportsTransactionId()

Specified by:

supportsTransactionId in interface ISymmetricDialect

Overrides:

supportsTransactionId in class AbstractSymmetricDialect

getEarliestTransactionStartTime

public final Date getEarliestTransactionStartTime()

Specified by:

getEarliestTransactionStartTime in interface ISymmetricDialect

Overrides:

getEarliestTransactionStartTime in class AbstractSymmetricDialect

supportsTransactionViews

public boolean supportsTransactionViews()

Specified by:

supportsTransactionViews in interface ISymmetricDialect

Overrides:

supportsTransactionViews in class AbstractSymmetricDialect

cleanDatabase

public void cleanDatabase()

Specified by:

cleanDatabase in interface ISymmetricDialect

getBinaryEncoding

public BinaryEncoding getBinaryEncoding()

Specified by:

getBinaryEncoding in interface ISymmetricDialect

Specified by:

getBinaryEncoding in class AbstractSymmetricDialect

getSqlTypeForIds

public int getSqlTypeForIds()

Specified by:

getSqlTypeForIds in interface ISymmetricDialect

Overrides:

getSqlTypeForIds in class AbstractSymmetricDialect

getDbSpecificDataHasChangedCondition

protected String getDbSpecificDataHasChangedCondition(Trigger trigger)

Overrides:

getDbSpecificDataHasChangedCondition in class AbstractSymmetricDialect

getCurrentSequenceValue

public long getCurrentSequenceValue(SequenceIdentifier identifier)

Specified by:

getCurrentSequenceValue in interface ISymmetricDialect

Overrides:

getCurrentSequenceValue in class AbstractSymmetricDialect