Module sqlg.postgres.dialect

Package org.umlg.sqlg.dialect.impl

Class PostgresDialect

java.lang.Object

org.umlg.sqlg.sql.dialect.BaseSqlDialect

org.umlg.sqlg.dialect.impl.PostgresDialect

All Implemented Interfaces:

SqlBulkDialect, SqlDialect, SqlSchemaChangeDialect

public class PostgresDialect
extends BaseSqlDialect
implements SqlBulkDialect

Date: 2014/07/16 Time: 1:42 PM

Field Summary

Fields inherited from class org.umlg.sqlg.sql.dialect.BaseSqlDialect

logger

Fields inherited from interface org.umlg.sqlg.sql.dialect.SqlDialect

INDEX_POSTFIX

Constructor Summary

Constructors

Constructor	Description
PostgresDialect()

Method Summary

Modifier and Type	Method	Description
List<String>	addHashPartitionColumns()
List<String>	addInEdgeDefinitions()
List<String>	addOutEdgeDefinitions()
List<String>	addPartitionSchemaAbstractLabelColumns()
List<String>	addPartitionTables()
List<String>	addPropertyDefinitions()
String	afterCreateTemporaryTableStatement()
String	alterForeignKeyToDeferrable(String schema, String table, String foreignKeyName)
void	alterSequenceCacheSize(SqlgGraph sqlgGraph, SchemaTable schemaTable, String sequence, int batchSize)
void	assertTableName(String tableName)
<L, R> void	bulkAddEdges(SqlgGraph sqlgGraph, SchemaTable out, SchemaTable in, String edgeLabel, org.apache.commons.lang3.tuple.Pair<String,String> idFields, Collection<org.apache.commons.lang3.tuple.Pair<L,R>> uids, Map<String,PropertyDefinition> edgeColumns, Map<String,Object> edgePropertyMap)
String	checkConstraintName(SqlgGraph sqlgGraph, String schema, String table, String column, String constraint)
List<String>	columnsToIgnore()
String	constructCompleteCopyCommandSqlEdge(SqlgGraph sqlgGraph, SqlgEdge sqlgEdge, VertexLabel outVertexLabel, VertexLabel inVertexLabel, SqlgVertex outVertex, SqlgVertex inVertex, Map<String,Object> keyValueMap)
String	constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph, String schema, String table, Set<String> keys)
String	constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph, SqlgVertex vertex, Map<String,Object> keyValueMap)
String	constructCompleteCopyCommandTemporarySqlVertex(SqlgGraph sqlgGraph, SqlgVertex vertex, Map<String,Object> keyValueMap)
Object	convertArray(PropertyType propertyType, Array array)
String	createSchemaStatement(String schemaName)
long	currSequenceVal(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
String	dialectName()
List<SqlgSqlExecutor.DropQuery>	drop(SqlgGraph sqlgGraph, String leafElementsToDelete, String edgesToDelete, LinkedList<SchemaTableTree> distinctQueryStack)
String	drop(EdgeLabel edgeLabel, Collection<RecordId.ID> ids)
String	drop(VertexLabel vertexLabel, Collection<RecordId.ID> ids)
String	dropWithForeignKey(boolean out, EdgeLabel edgeLabel, VertexLabel vertexLabel, Collection<RecordId.ID> ids, boolean mutatingCallbacks)
String	existIndexQuery(SchemaTable schemaTable, String prefix, String indexName)
Map<String,Set<IndexRef>>	extractIndices(Connection conn, String catalog, String schema)
void	flushEdgeCache(SqlgGraph sqlgGraph, Map<MetaEdge,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgEdge,org.apache.commons.lang3.tuple.Triple<SqlgVertex,SqlgVertex,Map<String,Object>>>>> edgeCache)
void	flushEdgePropertyCache(SqlgGraph sqlgGraph, Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgEdge,Map<String,Object>>>> edgePropertyCache)
void	flushVertexCache(SqlgGraph sqlgGraph, Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> vertexCache)	flushes the cache via the copy command.
void	flushVertexPropertyCache(SqlgGraph sqlgGraph, Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> schemaVertexPropertyCache)
String	getArrayContainsQueryText(String column)
String	getArrayDriverType(PropertyType propertyType)
String	getArrayOverlapsQueryText(String column)
String	getAutoIncrement()
String	getAutoIncrementPrimaryKeyConstruct()
String	getBatchNull()
org.apache.commons.lang3.tuple.Pair<Boolean,String>	getBlocked(int pid, Connection connection)
String	getColumnEscapeKey()
int	getConnectionBackendPid(Connection connection)
String	getForeignKeyTypeDefinition()
String	getFullTextQueryText(FullText fullText, String column)
<X> X	getGis(SqlgGraph sqlgGraph)
List<String>	getGisSchemas()
Set<String>	getInternalSchemas()
int	getMaximumColumnNameLength()
int	getMaximumIndexNameLength()
int	getMaximumSchemaNameLength()
int	getMaximumTableNameLength()
List<Map<String,String>>	getPartitions(Connection connection)
String	getPrimaryKeyType()
int	getShardCount(SqlgGraph sqlgGraph, AbstractLabel label)
Set<String>	getSpacialRefTable()
void	grantReadOnlyUserPrivilegesToSqlgSchemas(SqlgGraph sqlgGraph)
void	handleOther(Map<String,Object> properties, String columnName, Object o, PropertyType propertyType)
boolean	isPostgresql()
boolean	isSystemIndex(String indexName)
boolean	isTimestampz(String typeName)
void	lock(SqlgGraph sqlgGraph)
void	lockTable(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
boolean	needForeignKeyIndex()
boolean	needsTimeZone()
long	nextSequenceVal(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
int	notifyChange(SqlgGraph sqlgGraph, LocalDateTime timestamp, com.fasterxml.jackson.databind.JsonNode jsonNode)
void	prepareDB(Connection conn)
int[]	propertyTypeToJavaSqlType(PropertyType propertyType)
String[]	propertyTypeToSqlDefinition(PropertyType propertyType)
void	registerListener(SqlgGraph sqlgGraph)
String	sequenceName(SqlgGraph sqlgGraph, SchemaTable outSchemaTable, String prefix)
void	setArray(PreparedStatement statement, int index, PropertyType type, Object[] values)
void	setGeographyPoint(PreparedStatement preparedStatement, int parameterStartIndex, Object point)
void	setJson(PreparedStatement preparedStatement, int parameterStartIndex, com.fasterxml.jackson.databind.JsonNode json)
void	setLineString(PreparedStatement preparedStatement, int parameterStartIndex, Object lineString)
void	setLquery(PreparedStatement preparedStatement, int parameterStartIndex, String path)
void	setLqueryArray(PreparedStatement preparedStatement, int parameterStartIndex, Array paths)
void	setLtree(PreparedStatement preparedStatement, int parameterStartIndex, String path)
void	setLtreeArray(PreparedStatement preparedStatement, int parameterStartIndex, Array paths)
void	setPoint(PreparedStatement preparedStatement, int parameterStartIndex, Object point)
void	setPolygon(PreparedStatement preparedStatement, int parameterStartIndex, Object polygon)
PropertyType	sqlArrayTypeNameToPropertyType(String typeName, SqlgGraph sqlgGraph, String schema, String table, String columnName, ListIterator<org.apache.commons.lang3.tuple.Triple<String,Integer,String>> metaDataIter)
String	sqlgAddIndexEdgeSequenceColumn()
String	sqlgCreateTopologyGraph()
List<String>	sqlgTopologyCreationScripts()
int	sqlInParameterLimit()
String	sqlToGetAllForeignKeys()
List<SqlgSqlExecutor.DropQuery>	sqlTruncate(SqlgGraph sqlgGraph, SchemaTable schemaTable)
PropertyType	sqlTypeToPropertyType(SqlgGraph sqlgGraph, String schema, String table, String column, int sqlType, String typeName, ListIterator<org.apache.commons.lang3.tuple.Triple<String,Integer,String>> metaDataIter)	This is only used for upgrading from pre sqlg_schema sqlg to a sqlg_schema
Writer	streamSql(SqlgGraph sqlgGraph, String sql)
boolean	supportsBatchMode()
boolean	supportsBulkWithinOut()
boolean	supportsClientInfo()
boolean	supportsDeferrableForeignKey()
boolean	supportsDistribution()
boolean	supportsILike()
boolean	supportsJsonArrayValues()
boolean	supportsJsonType()
boolean	supportsPartitioning()
boolean	supportsSharding()
boolean	supportsStreamingBatchMode()
boolean	supportsTruncateMultipleTablesTogether()
boolean	supportsType(PropertyType propertyType)
String	temporaryTableCopyCommandSqlVertex(SqlgGraph sqlgGraph, SchemaTable schemaTable, Set<String> keys)
void	unregisterListener()
void	validateColumnName(String column)
void	validateProperty(Object key, Object value)
void	validateSchemaName(String schema)
void	validateTableName(String table)
String	valueToValuesString(PropertyType propertyType, Object value)
void	writeStreamingEdge(Writer writer, SqlgEdge sqlgEdge, VertexLabel outVertexLabel, VertexLabel inVertexLabel, SqlgVertex outVertex, SqlgVertex inVertex, Map<String,Object> keyValueMap, EdgeLabel edgeLabel)
void	writeStreamingVertex(Writer writer, Map<String,Object> keyValueMap, VertexLabel vertexLabel)
void	writeTemporaryStreamingVertex(Writer writer, Map<String,Object> keyValueMap)

Methods inherited from class org.umlg.sqlg.sql.dialect.BaseSqlDialect

escapeQuotes, flushRemovedEdges, flushRemovedVertices, getEdgeTables, getIndexInfo, getPrimaryKeys, getSchemaNames, getTableColumns, getVertexTables

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.umlg.sqlg.sql.dialect.SqlBulkDialect

flushRemovedEdges, flushRemovedVertices

Methods inherited from interface org.umlg.sqlg.sql.dialect.SqlDialect

addColumnStatement, addDbVersionToGraph, addNotNullConstraint, canUserCreateSchemas, createTableStatement, createTemporaryTableStatement, dropIndex, dropSchemaStatement, getDefaultFetchSize, getEdgeTables, getIndexInfo, getPrimaryKeys, getPrimaryKeyStartValue, getPublicSchema, getRangeClause, getSchemaNames, getSkipClause, getTableColumns, getVertexTables, hasContainerKeyToColumn, indexName, indexName, isH2, isHsqldb, isIndexPartOfCreateTable, isMariaDb, isMssqlServer, isMysql, maybeWrapInQoutes, needsSchemaCreationPrecommit, needsSchemaDropCascade, needsSemicolon, needsTemporaryTablePrefix, needsTemporaryTableSchema, putJsonMetaObject, putJsonObject, renameColumn, renameTable, requiresIndexLengthLimit, requiresIndexName, schemaExists, sqlgSqlgSchemaCreationScript, sqlInsertEmptyValues, sqlToTurnOffReferentialConstraintCheck, sqlToTurnOnReferentialConstraintCheck, supportsBigDecimal, supportsBigDecimalArrayValues, supportsBooleanArrayValues, supportsByteArrayValues, supportsByteValues, supportsCascade, supportsDoubleArrayValues, supportsDurationArrayValues, supportsFloatArrayValues, supportsFloatValues, supportsFullValueExpression, supportsIfExists, supportsIntegerArrayValues, supportsLocalDateArrayValues, supportsLocalDateTimeArrayValues, supportsLocalTimeArrayValues, supportsLongArrayValues, supportsPeriodArrayValues, supportsSchemaIfNotExists, supportsSchemas, supportsShortArrayValues, supportsStringArrayValues, supportsTemporaryTableOnCommitDrop, supportsTransactionalSchema, supportsUUID, supportsValuesExpression, supportsZonedDateTimeArrayValues, temporaryTablePrefix, toByteArray, toRDBSStringLiteral, toRDBSStringLiteral, toSelectString, uniqueIndexConsidersNullValuesEqual

Constructor Details

PostgresDialect

public PostgresDialect()

Method Details

supportsDistribution

public boolean supportsDistribution()

Specified by:

supportsDistribution in interface SqlDialect

dialectName

public String dialectName()

Specified by:

dialectName in interface SqlDialect

createSchemaStatement

public String createSchemaStatement(String schemaName)

Specified by:

createSchemaStatement in interface SqlDialect

supportsBatchMode

public boolean supportsBatchMode()

Specified by:

supportsBatchMode in interface SqlDialect

supportsStreamingBatchMode

public boolean supportsStreamingBatchMode()

Specified by:

supportsStreamingBatchMode in interface SqlDialect

getInternalSchemas

public Set<String> getInternalSchemas()

Specified by:

getInternalSchemas in interface SqlDialect

getSpacialRefTable

public Set<String> getSpacialRefTable()

Specified by:

getSpacialRefTable in interface SqlDialect

getGisSchemas

public List<String> getGisSchemas()

Specified by:

getGisSchemas in interface SqlDialect

getForeignKeyTypeDefinition

public String getForeignKeyTypeDefinition()

Specified by:

getForeignKeyTypeDefinition in interface SqlDialect

getColumnEscapeKey

public String getColumnEscapeKey()

Specified by:

getColumnEscapeKey in interface SqlDialect

getPrimaryKeyType

public String getPrimaryKeyType()

Specified by:

getPrimaryKeyType in interface SqlDialect

getAutoIncrementPrimaryKeyConstruct

public String getAutoIncrementPrimaryKeyConstruct()

Specified by:

getAutoIncrementPrimaryKeyConstruct in interface SqlDialect

getAutoIncrement

public String getAutoIncrement()

Specified by:

getAutoIncrement in interface SqlDialect

assertTableName

public void assertTableName(String tableName)

Specified by:

assertTableName in interface SqlDialect

getArrayDriverType

public String getArrayDriverType(PropertyType propertyType)

Specified by:

getArrayDriverType in interface SqlDialect

existIndexQuery

public String existIndexQuery(SchemaTable schemaTable,
 String prefix,
 String indexName)

Specified by:

existIndexQuery in interface SqlDialect

flushVertexCache

public void flushVertexCache(SqlgGraph sqlgGraph,
 Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> vertexCache)

flushes the cache via the copy command.

Specified by:

flushVertexCache in interface SqlBulkDialect

Overrides:

flushVertexCache in class BaseSqlDialect

Parameters:

vertexCache - A rather complex object. The map's key is the vertex being cached. The Triple holds,

• The in labels
• The out labels
• the properties as a map of key values

flushEdgeCache

public void flushEdgeCache(SqlgGraph sqlgGraph,
 Map<MetaEdge,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgEdge,org.apache.commons.lang3.tuple.Triple<SqlgVertex,SqlgVertex,Map<String,Object>>>>> edgeCache)

Specified by:

flushEdgeCache in interface SqlBulkDialect

Overrides:

flushEdgeCache in class BaseSqlDialect

flushVertexPropertyCache

public void flushVertexPropertyCache(SqlgGraph sqlgGraph,
 Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> schemaVertexPropertyCache)

Specified by:

flushVertexPropertyCache in interface SqlBulkDialect

Overrides:

flushVertexPropertyCache in class BaseSqlDialect

flushEdgePropertyCache

public void flushEdgePropertyCache(SqlgGraph sqlgGraph,
 Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgEdge,Map<String,Object>>>> edgePropertyCache)

Specified by:

flushEdgePropertyCache in interface SqlBulkDialect

Overrides:

flushEdgePropertyCache in class BaseSqlDialect

constructCompleteCopyCommandTemporarySqlVertex

public String constructCompleteCopyCommandTemporarySqlVertex(SqlgGraph sqlgGraph,
 SqlgVertex vertex,
 Map<String,Object> keyValueMap)

Specified by:

constructCompleteCopyCommandTemporarySqlVertex in interface SqlBulkDialect

constructCompleteCopyCommandSqlVertex

public String constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph,
 SqlgVertex vertex,
 Map<String,Object> keyValueMap)

Specified by:

constructCompleteCopyCommandSqlVertex in interface SqlBulkDialect

constructCompleteCopyCommandSqlVertex

public String constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph,
 String schema,
 String table,
 Set<String> keys)

Specified by:

constructCompleteCopyCommandSqlVertex in interface SqlBulkDialect

constructCompleteCopyCommandSqlEdge

public String constructCompleteCopyCommandSqlEdge(SqlgGraph sqlgGraph,
 SqlgEdge sqlgEdge,
 VertexLabel outVertexLabel,
 VertexLabel inVertexLabel,
 SqlgVertex outVertex,
 SqlgVertex inVertex,
 Map<String,Object> keyValueMap)

Specified by:

constructCompleteCopyCommandSqlEdge in interface SqlBulkDialect

temporaryTableCopyCommandSqlVertex

public String temporaryTableCopyCommandSqlVertex(SqlgGraph sqlgGraph,
 SchemaTable schemaTable,
 Set<String> keys)

Specified by:

temporaryTableCopyCommandSqlVertex in interface SqlBulkDialect

writeStreamingVertex

public void writeStreamingVertex(Writer writer,
 Map<String,Object> keyValueMap,
 VertexLabel vertexLabel)

Specified by:

writeStreamingVertex in interface SqlBulkDialect

writeTemporaryStreamingVertex

public void writeTemporaryStreamingVertex(Writer writer,
 Map<String,Object> keyValueMap)

Specified by:

writeTemporaryStreamingVertex in interface SqlBulkDialect

writeStreamingEdge

public void writeStreamingEdge(Writer writer,
 SqlgEdge sqlgEdge,
 VertexLabel outVertexLabel,
 VertexLabel inVertexLabel,
 SqlgVertex outVertex,
 SqlgVertex inVertex,
 Map<String,Object> keyValueMap,
 EdgeLabel edgeLabel)

Specified by:

writeStreamingEdge in interface SqlBulkDialect

getBatchNull

public String getBatchNull()

Specified by:

getBatchNull in interface SqlBulkDialect

propertyTypeToSqlDefinition

public String[] propertyTypeToSqlDefinition(PropertyType propertyType)

Specified by:

propertyTypeToSqlDefinition in interface SqlDialect

sqlTypeToPropertyType

public PropertyType sqlTypeToPropertyType(SqlgGraph sqlgGraph,
 String schema,
 String table,
 String column,
 int sqlType,
 String typeName,
 ListIterator<org.apache.commons.lang3.tuple.Triple<String,Integer,String>> metaDataIter)

This is only used for upgrading from pre sqlg_schema sqlg to a sqlg_schema

Specified by:

sqlTypeToPropertyType in interface SqlDialect

sqlArrayTypeNameToPropertyType

public PropertyType sqlArrayTypeNameToPropertyType(String typeName,
 SqlgGraph sqlgGraph,
 String schema,
 String table,
 String columnName,
 ListIterator<org.apache.commons.lang3.tuple.Triple<String,Integer,String>> metaDataIter)

Specified by:

sqlArrayTypeNameToPropertyType in interface SqlDialect

propertyTypeToJavaSqlType

public int[] propertyTypeToJavaSqlType(PropertyType propertyType)

Specified by:

propertyTypeToJavaSqlType in interface SqlDialect

validateProperty

public void validateProperty(Object key,
 Object value)

Specified by:

validateProperty in interface SqlDialect

needForeignKeyIndex

public boolean needForeignKeyIndex()

Specified by:

needForeignKeyIndex in interface SqlDialect

supportsClientInfo

public boolean supportsClientInfo()

Specified by:

supportsClientInfo in interface SqlDialect

validateSchemaName

public void validateSchemaName(String schema)

Specified by:

validateSchemaName in interface SqlDialect

validateTableName

public void validateTableName(String table)

Specified by:

validateTableName in interface SqlDialect

validateColumnName

public void validateColumnName(String column)

Specified by:

validateColumnName in interface SqlDialect

Overrides:

validateColumnName in class BaseSqlDialect

getMaximumSchemaNameLength

public int getMaximumSchemaNameLength()

Specified by:

getMaximumSchemaNameLength in interface SqlDialect

getMaximumTableNameLength

public int getMaximumTableNameLength()

Specified by:

getMaximumTableNameLength in interface SqlDialect

getMaximumColumnNameLength

public int getMaximumColumnNameLength()

Specified by:

getMaximumColumnNameLength in interface SqlDialect

getMaximumIndexNameLength

public int getMaximumIndexNameLength()

Specified by:

getMaximumIndexNameLength in interface SqlDialect

supportsILike

public boolean supportsILike()

Specified by:

supportsILike in interface SqlDialect

needsTimeZone

public boolean needsTimeZone()

Specified by:

needsTimeZone in interface SqlDialect

setJson

public void setJson(PreparedStatement preparedStatement,
 int parameterStartIndex,
 com.fasterxml.jackson.databind.JsonNode json)

Specified by:

setJson in interface SqlDialect

Overrides:

setJson in class BaseSqlDialect

setLtree

public void setLtree(PreparedStatement preparedStatement,
 int parameterStartIndex,
 String path)

Specified by:

setLtree in interface SqlDialect

setLquery

public void setLquery(PreparedStatement preparedStatement,
 int parameterStartIndex,
 String path)

Specified by:

setLquery in interface SqlDialect

setLtreeArray

public void setLtreeArray(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Array paths)

Specified by:

setLtreeArray in interface SqlDialect

setLqueryArray

public void setLqueryArray(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Array paths)

Specified by:

setLqueryArray in interface SqlDialect

setPoint

public void setPoint(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Object point)

Specified by:

setPoint in interface SqlDialect

setLineString

public void setLineString(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Object lineString)

Specified by:

setLineString in interface SqlDialect

setPolygon

public void setPolygon(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Object polygon)

Specified by:

setPolygon in interface SqlDialect

setGeographyPoint

public void setGeographyPoint(PreparedStatement preparedStatement,
 int parameterStartIndex,
 Object point)

Specified by:

setGeographyPoint in interface SqlDialect

handleOther

public void handleOther(Map<String,Object> properties,
 String columnName,
 Object o,
 PropertyType propertyType)

Specified by:

handleOther in interface SqlDialect

Overrides:

handleOther in class BaseSqlDialect

supportsJsonType

public boolean supportsJsonType()

Specified by:

supportsJsonType in interface SqlDialect

supportsJsonArrayValues

public boolean supportsJsonArrayValues()

Specified by:

supportsJsonArrayValues in interface SqlDialect

streamSql

public Writer streamSql(SqlgGraph sqlgGraph,
 String sql)

Specified by:

streamSql in interface SqlBulkDialect

bulkAddEdges

public <L,
R> void bulkAddEdges(SqlgGraph sqlgGraph,
 SchemaTable out,
 SchemaTable in,
 String edgeLabel,
 org.apache.commons.lang3.tuple.Pair<String,String> idFields,
 Collection<org.apache.commons.lang3.tuple.Pair<L,R>> uids,
 Map<String,PropertyDefinition> edgeColumns,
 Map<String,Object> edgePropertyMap)

Specified by:

bulkAddEdges in interface SqlBulkDialect

lockTable

public void lockTable(SqlgGraph sqlgGraph,
 SchemaTable schemaTable,
 String prefix)

Specified by:

lockTable in interface SqlDialect

alterSequenceCacheSize

public void alterSequenceCacheSize(SqlgGraph sqlgGraph,
 SchemaTable schemaTable,
 String sequence,
 int batchSize)

Specified by:

alterSequenceCacheSize in interface SqlDialect

nextSequenceVal

public long nextSequenceVal(SqlgGraph sqlgGraph,
 SchemaTable schemaTable,
 String prefix)

Specified by:

nextSequenceVal in interface SqlDialect

currSequenceVal

public long currSequenceVal(SqlgGraph sqlgGraph,
 SchemaTable schemaTable,
 String prefix)

Specified by:

currSequenceVal in interface SqlDialect

sequenceName

public String sequenceName(SqlgGraph sqlgGraph,
 SchemaTable outSchemaTable,
 String prefix)

Specified by:

sequenceName in interface SqlDialect

supportsBulkWithinOut

public boolean supportsBulkWithinOut()

Specified by:

supportsBulkWithinOut in interface SqlDialect

isPostgresql

public boolean isPostgresql()

Specified by:

isPostgresql in interface SqlDialect

getGis

public <X> X getGis(SqlgGraph sqlgGraph)

Specified by:

getGis in interface SqlDialect

afterCreateTemporaryTableStatement

public String afterCreateTemporaryTableStatement()

Specified by:

afterCreateTemporaryTableStatement in interface SqlDialect

columnsToIgnore

public List<String> columnsToIgnore()

Specified by:

columnsToIgnore in interface SqlDialect

sqlgTopologyCreationScripts

public List<String> sqlgTopologyCreationScripts()

Specified by:

sqlgTopologyCreationScripts in interface SqlDialect

sqlgCreateTopologyGraph

public String sqlgCreateTopologyGraph()

Specified by:

sqlgCreateTopologyGraph in interface SqlDialect

sqlgAddIndexEdgeSequenceColumn

public String sqlgAddIndexEdgeSequenceColumn()

Specified by:

sqlgAddIndexEdgeSequenceColumn in interface SqlDialect

addHashPartitionColumns

public List<String> addHashPartitionColumns()

Specified by:

addHashPartitionColumns in interface SqlDialect

addPartitionSchemaAbstractLabelColumns

public List<String> addPartitionSchemaAbstractLabelColumns()

Specified by:

addPartitionSchemaAbstractLabelColumns in interface SqlDialect

addPartitionTables

public List<String> addPartitionTables()

Specified by:

addPartitionTables in interface SqlDialect

convertArray

public Object convertArray(PropertyType propertyType,
 Array array)
                    throws SQLException

Specified by:

convertArray in interface SqlDialect

Throws:

SQLException

setArray

public void setArray(PreparedStatement statement,
 int index,
 PropertyType type,
 Object[] values)
              throws SQLException

Specified by:

setArray in interface SqlDialect

Throws:

SQLException

prepareDB

public void prepareDB(Connection conn)

Specified by:

prepareDB in interface SqlDialect

getConnectionBackendPid

public int getConnectionBackendPid(Connection connection)

Specified by:

getConnectionBackendPid in interface SqlDialect

getBlocked

public org.apache.commons.lang3.tuple.Pair<Boolean,String> getBlocked(int pid,
 Connection connection)

Specified by:

getBlocked in interface SqlDialect

lock

public void lock(SqlgGraph sqlgGraph)

Specified by:

lock in interface SqlSchemaChangeDialect

registerListener

public void registerListener(SqlgGraph sqlgGraph)

Specified by:

registerListener in interface SqlSchemaChangeDialect

unregisterListener

public void unregisterListener()

Specified by:

unregisterListener in interface SqlSchemaChangeDialect

notifyChange

public int notifyChange(SqlgGraph sqlgGraph,
 LocalDateTime timestamp,
 com.fasterxml.jackson.databind.JsonNode jsonNode)

Specified by:

notifyChange in interface SqlSchemaChangeDialect

getFullTextQueryText

public String getFullTextQueryText(FullText fullText,
 String column)

Specified by:

getFullTextQueryText in interface SqlDialect

getArrayContainsQueryText

public String getArrayContainsQueryText(String column)

Specified by:

getArrayContainsQueryText in interface SqlDialect

getArrayOverlapsQueryText

public String getArrayOverlapsQueryText(String column)

Specified by:

getArrayOverlapsQueryText in interface SqlDialect

extractIndices

public Map<String,Set<IndexRef>> extractIndices(Connection conn,
 String catalog,
 String schema)
                                         throws SQLException

Specified by:

extractIndices in interface SqlDialect

Throws:

SQLException

isSystemIndex

public boolean isSystemIndex(String indexName)

Specified by:

isSystemIndex in interface SqlDialect

valueToValuesString

public String valueToValuesString(PropertyType propertyType,
 Object value)

Specified by:

valueToValuesString in interface SqlDialect

supportsType

public boolean supportsType(PropertyType propertyType)

Specified by:

supportsType in interface SqlDialect

sqlInParameterLimit

public int sqlInParameterLimit()

Specified by:

sqlInParameterLimit in interface SqlDialect

Overrides:

sqlInParameterLimit in class BaseSqlDialect

drop

public List<SqlgSqlExecutor.DropQuery> drop(SqlgGraph sqlgGraph,
 String leafElementsToDelete,
 String edgesToDelete,
 LinkedList<SchemaTableTree> distinctQueryStack)

Specified by:

drop in interface SqlDialect

drop

public String drop(VertexLabel vertexLabel,
 Collection<RecordId.ID> ids)

Specified by:

drop in interface SqlDialect

drop

public String drop(EdgeLabel edgeLabel,
 Collection<RecordId.ID> ids)

Specified by:

drop in interface SqlDialect

dropWithForeignKey

public String dropWithForeignKey(boolean out,
 EdgeLabel edgeLabel,
 VertexLabel vertexLabel,
 Collection<RecordId.ID> ids,
 boolean mutatingCallbacks)

Specified by:

dropWithForeignKey in interface SqlDialect

supportsDeferrableForeignKey

public boolean supportsDeferrableForeignKey()

Specified by:

supportsDeferrableForeignKey in interface SqlDialect

sqlToGetAllForeignKeys

public String sqlToGetAllForeignKeys()

Specified by:

sqlToGetAllForeignKeys in interface SqlDialect

alterForeignKeyToDeferrable

public String alterForeignKeyToDeferrable(String schema,
 String table,
 String foreignKeyName)

Specified by:

alterForeignKeyToDeferrable in interface SqlDialect

sqlTruncate

public List<SqlgSqlExecutor.DropQuery> sqlTruncate(SqlgGraph sqlgGraph,
 SchemaTable schemaTable)

Specified by:

sqlTruncate in interface SqlDialect

supportsTruncateMultipleTablesTogether

public boolean supportsTruncateMultipleTablesTogether()

Specified by:

supportsTruncateMultipleTablesTogether in interface SqlDialect

supportsPartitioning

public boolean supportsPartitioning()

Specified by:

supportsPartitioning in interface SqlDialect

getPartitions

public List<Map<String,String>> getPartitions(Connection connection)

Specified by:

getPartitions in interface SqlDialect

supportsSharding

public boolean supportsSharding()

Specified by:

supportsSharding in interface SqlDialect

getShardCount

public int getShardCount(SqlgGraph sqlgGraph,
 AbstractLabel label)

Specified by:

getShardCount in interface SqlDialect

grantReadOnlyUserPrivilegesToSqlgSchemas

public void grantReadOnlyUserPrivilegesToSqlgSchemas(SqlgGraph sqlgGraph)

Specified by:

grantReadOnlyUserPrivilegesToSqlgSchemas in interface SqlDialect

isTimestampz

public boolean isTimestampz(String typeName)

Specified by:

isTimestampz in interface SqlDialect

addPropertyDefinitions

public List<String> addPropertyDefinitions()

Specified by:

addPropertyDefinitions in interface SqlDialect

addOutEdgeDefinitions

public List<String> addOutEdgeDefinitions()

Specified by:

addOutEdgeDefinitions in interface SqlDialect

addInEdgeDefinitions

public List<String> addInEdgeDefinitions()

Specified by:

addInEdgeDefinitions in interface SqlDialect

checkConstraintName

public String checkConstraintName(SqlgGraph sqlgGraph,
 String schema,
 String table,
 String column,
 String constraint)

Specified by:

checkConstraintName in interface SqlDialect