Package org.umlg.sqlg.sql.dialect

Interface SqlBulkDialect

All Superinterfaces:

SqlDialect

All Known Implementing Classes:

BaseSqlDialect

public interface SqlBulkDialect
extends SqlDialect

Date: 2016/09/03 Time: 2:56 PM

Field Summary

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

INDEX_POSTFIX

Method Summary

Modifier and Type	Method	Description
default <L, R> void	bulkAddEdges(SqlgGraph sqlgGraph, SchemaTable in, SchemaTable out, 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)
default String	constructCompleteCopyCommandSqlEdge(SqlgGraph sqlgGraph, SqlgEdge sqlgEdge, VertexLabel outVertexLabel, VertexLabel inVertexLabel, SqlgVertex outVertex, SqlgVertex inVertex, Map<String,Object> keyValueMap)
default String	constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph, String schema, String table, Set<String> keys)
default String	constructCompleteCopyCommandSqlVertex(SqlgGraph sqlgGraph, SqlgVertex vertex, Map<String,Object> keyValueMap)
default String	constructCompleteCopyCommandTemporarySqlVertex(SqlgGraph sqlgGraph, SqlgVertex vertex, Map<String,Object> keyValueMap)
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)
default void	flushRemovedEdges(SqlgGraph sqlgGraph, Map<SchemaTable,List<SqlgEdge>> removeEdgeCache)
void	flushRemovedVertices(SqlgGraph sqlgGraph, Map<SchemaTable,List<SqlgVertex>> removeVertexCache)
void	flushVertexCache(SqlgGraph sqlgGraph, Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> vertexCache)
void	flushVertexPropertyCache(SqlgGraph sqlgGraph, Map<SchemaTable,org.apache.commons.lang3.tuple.Pair<SortedSet<String>,Map<SqlgVertex,Map<String,Object>>>> vertexPropertyCache)
default String	getBatchNull()
default Writer	streamSql(SqlgGraph sqlgGraph, String sql)
default String	temporaryTableCopyCommandSqlVertex(SqlgGraph sqlgGraph, SchemaTable schemaTable, Set<String> keys)
default void	writeStreamingEdge(Writer writer, SqlgEdge sqlgEdge, VertexLabel outVertexLabel, VertexLabel inVertexLabel, SqlgVertex outVertex, SqlgVertex inVertex, Map<String,Object> keyValueMap, EdgeLabel edgeLabel)
default void	writeStreamingVertex(Writer writer, Map<String,Object> keyValueMap, VertexLabel vertexLabel)
default void	writeTemporaryStreamingVertex(Writer writer, Map<String,Object> keyValueMap)

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

addColumnStatement, addDbVersionToGraph, addHashPartitionColumns, addInEdgeDefinitions, addNotNullConstraint, addOutEdgeDefinitions, addPartitionSchemaAbstractLabelColumns, addPartitionTables, addPropertyDefinitions, afterCreateTemporaryTableStatement, alterForeignKeyToDeferrable, alterSequenceCacheSize, assertTableName, canUserCreateSchemas, checkConstraintName, columnsToIgnore, convertArray, createSchemaStatement, createTableStatement, createTemporaryTableStatement, currSequenceVal, dialectName, drop, drop, drop, dropIndex, dropSchemaStatement, dropWithForeignKey, existIndexQuery, extractIndices, getArrayContainsQueryText, getArrayDriverType, getArrayOverlapsQueryText, getAutoIncrement, getAutoIncrementPrimaryKeyConstruct, getBlocked, getColumnEscapeKey, getConnectionBackendPid, getDefaultFetchSize, getEdgeTables, getForeignKeyTypeDefinition, getFullTextQueryText, getGis, getGisSchemas, getIndexInfo, getInternalSchemas, getMaximumColumnNameLength, getMaximumIndexNameLength, getMaximumSchemaNameLength, getMaximumTableNameLength, getPartitions, getPrimaryKeys, getPrimaryKeyStartValue, getPrimaryKeyType, getPublicSchema, getRangeClause, getSchemaNames, getShardCount, getSkipClause, getSpacialRefTable, getTableColumns, getVertexTables, grantReadOnlyUserPrivilegesToSqlgSchemas, handleOther, hasContainerKeyToColumn, indexName, indexName, isH2, isHsqldb, isIndexPartOfCreateTable, isMariaDb, isMssqlServer, isMysql, isPostgresql, isSystemIndex, isTimestampz, lockTable, maybeWrapInQoutes, needForeignKeyIndex, needsSchemaCreationPrecommit, needsSchemaDropCascade, needsSemicolon, needsTemporaryTablePrefix, needsTemporaryTableSchema, needsTimeZone, nextSequenceVal, prepareDB, propertyTypeToJavaSqlType, propertyTypeToSqlDefinition, putJsonMetaObject, putJsonObject, renameColumn, renameTable, requiresIndexLengthLimit, requiresIndexName, schemaExists, sequenceName, setArray, setGeographyPoint, setJson, setLineString, setLquery, setLqueryArray, setLtree, setLtreeArray, setPoint, setPolygon, sqlArrayTypeNameToPropertyType, sqlgAddIndexEdgeSequenceColumn, sqlgCreateTopologyGraph, sqlgSqlgSchemaCreationScript, sqlgTopologyCreationScripts, sqlInParameterLimit, sqlInsertEmptyValues, sqlToGetAllForeignKeys, sqlToTurnOffReferentialConstraintCheck, sqlToTurnOnReferentialConstraintCheck, sqlTruncate, sqlTypeToPropertyType, supportsBatchMode, supportsBigDecimal, supportsBigDecimalArrayValues, supportsBooleanArrayValues, supportsBulkWithinOut, supportsByteArrayValues, supportsByteValues, supportsCascade, supportsClientInfo, supportsDeferrableForeignKey, supportsDistribution, supportsDoubleArrayValues, supportsDurationArrayValues, supportsFloatArrayValues, supportsFloatValues, supportsFullValueExpression, supportsIfExists, supportsILike, supportsIntegerArrayValues, supportsJsonArrayValues, supportsJsonType, supportsLocalDateArrayValues, supportsLocalDateTimeArrayValues, supportsLocalTimeArrayValues, supportsLongArrayValues, supportsPartitioning, supportsPeriodArrayValues, supportsSchemaIfNotExists, supportsSchemas, supportsSharding, supportsShortArrayValues, supportsStreamingBatchMode, supportsStringArrayValues, supportsTemporaryTableOnCommitDrop, supportsTransactionalSchema, supportsTruncateMultipleTablesTogether, supportsType, supportsUUID, supportsValuesExpression, supportsZonedDateTimeArrayValues, temporaryTablePrefix, toByteArray, toRDBSStringLiteral, toRDBSStringLiteral, toSelectString, uniqueIndexConsidersNullValuesEqual, validateColumnName, validateProperty, validateSchemaName, validateTableName, valueToValuesString

Method Details

flushVertexCache

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

flushEdgeCache

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)

flushVertexPropertyCache

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

flushEdgePropertyCache

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

flushRemovedVertices

void flushRemovedVertices(SqlgGraph sqlgGraph,
 Map<SchemaTable,List<SqlgVertex>> removeVertexCache)

flushRemovedEdges

default void flushRemovedEdges(SqlgGraph sqlgGraph,
 Map<SchemaTable,List<SqlgEdge>> removeEdgeCache)

getBatchNull

default String getBatchNull()

bulkAddEdges

default <L,
R> void bulkAddEdges(SqlgGraph sqlgGraph,
 SchemaTable in,
 SchemaTable out,
 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)

constructCompleteCopyCommandTemporarySqlVertex

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

constructCompleteCopyCommandSqlVertex

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

constructCompleteCopyCommandSqlVertex

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

constructCompleteCopyCommandSqlEdge

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

writeStreamingVertex

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

writeTemporaryStreamingVertex

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

writeStreamingEdge

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

temporaryTableCopyCommandSqlVertex

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

streamSql

default Writer streamSql(SqlgGraph sqlgGraph,
 String sql)