Package org.umlg.sqlg.sql.dialect.impl

Class HsqldbDialect

java.lang.Object

org.umlg.sqlg.sql.dialect.BaseSqlDialect

org.umlg.sqlg.sql.dialect.impl.HsqldbDialect

All Implemented Interfaces:

SqlBulkDialect, SqlDialect, SqlSchemaChangeDialect

public class HsqldbDialect
extends BaseSqlDialect
implements SqlBulkDialect

Date: 2014/07/16 Time: 3:09 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
HsqldbDialect()

Method Summary

Modifier and Type	Method	Description
String	addDbVersionToGraph(DatabaseMetaData metadata)
List<String>	addHashPartitionColumns()
List<String>	addInEdgeDefinitions()
List<String>	addOutEdgeDefinitions()
List<String>	addPartitionTables()
List<String>	addPropertyDefinitions()
String	afterCreateTemporaryTableStatement()
void	alterSequenceCacheSize(SqlgGraph sqlgGraph, SchemaTable schemaTable, String sequence, int batchSize)
boolean	canUserCreateSchemas(SqlgGraph sqlgGraph)
String	checkConstraintName(SqlgGraph sqlgGraph, String schema, String table, String column, String constraint)
Object	convertArray(PropertyType propertyType, Array array)
String	createSchemaStatement(String schemaName)
String	createTableStatement()
String	createTemporaryTableStatement()
long	currSequenceVal(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
String	dialectName()
String	existIndexQuery(SchemaTable schemaTable, String prefix, String indexName)
String	getArrayDriverType(PropertyType propertyType)
String	getAutoIncrementPrimaryKeyConstruct()
String	getColumnEscapeKey()
String	getForeignKeyTypeDefinition()
<T> T	getGis(SqlgGraph sqlgGraph)
List<String>	getGisSchemas()
Set<String>	getInternalSchemas()
Long	getPrimaryKeyStartValue()
String	getPrimaryKeyType()
String	getPublicSchema()
Set<String>	getSpacialRefTable()
void	grantReadOnlyUserPrivilegesToSqlgSchemas(SqlgGraph sqlgGraph)
boolean	isHsqldb()
boolean	isSystemIndex(String indexName)
boolean	isTimestampz(String typeName)
void	lockTable(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
long	nextSequenceVal(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
void	prepareDB(Connection conn)
int[]	propertyTypeToJavaSqlType(PropertyType propertyType)
String[]	propertyTypeToSqlDefinition(PropertyType propertyType)
String	renameColumn(String schema, String table, String column, String newName)
boolean	requiresIndexName()
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	setLineString(PreparedStatement preparedStatement, int parameterStartIndex, Object lineString)
void	setPoint(PreparedStatement preparedStatement, int parameterStartIndex, Object point)
void	setPolygon(PreparedStatement preparedStatement, int parameterStartIndex, Object point)
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()
String	sqlToTurnOffReferentialConstraintCheck(String tableName)
String	sqlToTurnOnReferentialConstraintCheck(String tableName)
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)
boolean	supportsBatchMode()
boolean	supportsBulkWithinOut()
boolean	supportsByteValues()
boolean	supportsFloatArrayValues()
boolean	supportsFloatValues()
boolean	supportsIfExists()
boolean	supportsJsonArrayValues()
boolean	supportsTransactionalSchema()
boolean	supportsType(PropertyType propertyType)
void	validateColumnName(String column)
void	validateProperty(Object key, Object value)
String	valueToValuesString(PropertyType propertyType, Object value)

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

escapeQuotes, flushEdgeCache, flushEdgePropertyCache, flushRemovedEdges, flushRemovedVertices, flushVertexCache, flushVertexPropertyCache, getEdgeTables, getIndexInfo, getPrimaryKeys, getSchemaNames, getTableColumns, getVertexTables, handleOther, setJson, sqlInParameterLimit

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

bulkAddEdges, constructCompleteCopyCommandSqlEdge, constructCompleteCopyCommandSqlVertex, constructCompleteCopyCommandSqlVertex, constructCompleteCopyCommandTemporarySqlVertex, flushEdgeCache, flushEdgePropertyCache, flushRemovedEdges, flushRemovedVertices, flushVertexCache, flushVertexPropertyCache, getBatchNull, streamSql, temporaryTableCopyCommandSqlVertex, writeStreamingEdge, writeStreamingVertex, writeTemporaryStreamingVertex

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

addColumnStatement, addNotNullConstraint, addPartitionSchemaAbstractLabelColumns, alterForeignKeyToDeferrable, assertTableName, columnsToIgnore, drop, drop, drop, dropIndex, dropSchemaStatement, dropWithForeignKey, extractIndices, getArrayContainsQueryText, getArrayOverlapsQueryText, getAutoIncrement, getBlocked, getConnectionBackendPid, getDefaultFetchSize, getEdgeTables, getFullTextQueryText, getIndexInfo, getMaximumColumnNameLength, getMaximumIndexNameLength, getMaximumSchemaNameLength, getMaximumTableNameLength, getPartitions, getPrimaryKeys, getRangeClause, getSchemaNames, getShardCount, getSkipClause, getTableColumns, getVertexTables, handleOther, hasContainerKeyToColumn, indexName, indexName, isH2, isIndexPartOfCreateTable, isMariaDb, isMssqlServer, isMysql, isPostgresql, maybeWrapInQoutes, needForeignKeyIndex, needsSchemaCreationPrecommit, needsSchemaDropCascade, needsSemicolon, needsTemporaryTablePrefix, needsTemporaryTableSchema, needsTimeZone, putJsonMetaObject, putJsonObject, renameTable, requiresIndexLengthLimit, schemaExists, setJson, setLquery, setLqueryArray, setLtree, setLtreeArray, sqlgSqlgSchemaCreationScript, sqlInParameterLimit, sqlInsertEmptyValues, sqlToGetAllForeignKeys, sqlTruncate, supportsBigDecimal, supportsBigDecimalArrayValues, supportsBooleanArrayValues, supportsByteArrayValues, supportsCascade, supportsClientInfo, supportsDeferrableForeignKey, supportsDistribution, supportsDoubleArrayValues, supportsDurationArrayValues, supportsFullValueExpression, supportsILike, supportsIntegerArrayValues, supportsJsonType, supportsLocalDateArrayValues, supportsLocalDateTimeArrayValues, supportsLocalTimeArrayValues, supportsLongArrayValues, supportsPartitioning, supportsPeriodArrayValues, supportsSchemaIfNotExists, supportsSchemas, supportsSharding, supportsShortArrayValues, supportsStreamingBatchMode, supportsStringArrayValues, supportsTemporaryTableOnCommitDrop, supportsTruncateMultipleTablesTogether, supportsUUID, supportsValuesExpression, supportsZonedDateTimeArrayValues, temporaryTablePrefix, toByteArray, toRDBSStringLiteral, toRDBSStringLiteral, toSelectString, uniqueIndexConsidersNullValuesEqual, validateSchemaName, validateTableName

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

lock, notifyChange, registerListener, unregisterListener

Constructor Details

HsqldbDialect

public HsqldbDialect()

Method Details

dialectName

public String dialectName()

Specified by:

dialectName in interface SqlDialect

getInternalSchemas

public Set<String> getInternalSchemas()

Specified by:

getInternalSchemas in interface SqlDialect

valueToValuesString

public String valueToValuesString(PropertyType propertyType,
 Object value)

Specified by:

valueToValuesString in interface SqlDialect

getPublicSchema

public String getPublicSchema()

Specified by:

getPublicSchema in interface SqlDialect

existIndexQuery

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

Specified by:

existIndexQuery in interface SqlDialect

requiresIndexName

public boolean requiresIndexName()

Specified by:

requiresIndexName in interface SqlDialect

supportsTransactionalSchema

public boolean supportsTransactionalSchema()

Specified by:

supportsTransactionalSchema in interface SqlDialect

supportsIfExists

public boolean supportsIfExists()

Specified by:

supportsIfExists in interface SqlDialect

validateProperty

public void validateProperty(Object key,
 Object value)

Specified by:

validateProperty 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

propertyTypeToSqlDefinition

public String[] propertyTypeToSqlDefinition(PropertyType propertyType)

Specified by:

propertyTypeToSqlDefinition in interface SqlDialect

propertyTypeToJavaSqlType

public int[] propertyTypeToJavaSqlType(PropertyType propertyType)

Specified by:

propertyTypeToJavaSqlType 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)

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

getForeignKeyTypeDefinition

public String getForeignKeyTypeDefinition()

Specified by:

getForeignKeyTypeDefinition in interface SqlDialect

supportsFloatValues

public boolean supportsFloatValues()

Specified by:

supportsFloatValues in interface SqlDialect

supportsByteValues

public boolean supportsByteValues()

Specified by:

supportsByteValues in interface SqlDialect

supportsFloatArrayValues

public boolean supportsFloatArrayValues()

Specified by:

supportsFloatArrayValues in interface SqlDialect

getArrayDriverType

public String getArrayDriverType(PropertyType propertyType)

Specified by:

getArrayDriverType in interface SqlDialect

createTableStatement

public String createTableStatement()

Specified by:

createTableStatement in interface SqlDialect

prepareDB

public void prepareDB(Connection conn)

Specified by:

prepareDB in interface SqlDialect

validateColumnName

public void validateColumnName(String column)

Specified by:

validateColumnName in interface SqlDialect

Overrides:

validateColumnName in class BaseSqlDialect

getSpacialRefTable

public Set<String> getSpacialRefTable()

Specified by:

getSpacialRefTable in interface SqlDialect

getGisSchemas

public List<String> getGisSchemas()

Specified by:

getGisSchemas 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 point)

Specified by:

setPolygon in interface SqlDialect

setGeographyPoint

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

Specified by:

setGeographyPoint in interface SqlDialect

getGis

public <T> T getGis(SqlgGraph sqlgGraph)

Specified by:

getGis in interface SqlDialect

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

supportsBatchMode

public boolean supportsBatchMode()

Specified by:

supportsBatchMode in interface SqlDialect

supportsBulkWithinOut

public boolean supportsBulkWithinOut()

Specified by:

supportsBulkWithinOut in interface SqlDialect

createTemporaryTableStatement

public String createTemporaryTableStatement()

Specified by:

createTemporaryTableStatement in interface SqlDialect

afterCreateTemporaryTableStatement

public String afterCreateTemporaryTableStatement()

Specified by:

afterCreateTemporaryTableStatement 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

getPrimaryKeyStartValue

public Long getPrimaryKeyStartValue()

Specified by:

getPrimaryKeyStartValue 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

isSystemIndex

public boolean isSystemIndex(String indexName)

Specified by:

isSystemIndex in interface SqlDialect

supportsJsonArrayValues

public boolean supportsJsonArrayValues()

Specified by:

supportsJsonArrayValues in interface SqlDialect

supportsType

public boolean supportsType(PropertyType propertyType)

Specified by:

supportsType in interface SqlDialect

createSchemaStatement

public String createSchemaStatement(String schemaName)

Specified by:

createSchemaStatement in interface SqlDialect

isHsqldb

public boolean isHsqldb()

Specified by:

isHsqldb in interface SqlDialect

sqlToTurnOffReferentialConstraintCheck

public String sqlToTurnOffReferentialConstraintCheck(String tableName)

Specified by:

sqlToTurnOffReferentialConstraintCheck in interface SqlDialect

sqlToTurnOnReferentialConstraintCheck

public String sqlToTurnOnReferentialConstraintCheck(String tableName)

Specified by:

sqlToTurnOnReferentialConstraintCheck in interface SqlDialect

addPartitionTables

public List<String> addPartitionTables()

Specified by:

addPartitionTables in interface SqlDialect

addHashPartitionColumns

public List<String> addHashPartitionColumns()

Specified by:

addHashPartitionColumns in interface SqlDialect

addDbVersionToGraph

public String addDbVersionToGraph(DatabaseMetaData metadata)

Specified by:

addDbVersionToGraph 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

canUserCreateSchemas

public boolean canUserCreateSchemas(SqlgGraph sqlgGraph)

Specified by:

canUserCreateSchemas in interface SqlDialect

renameColumn

public String renameColumn(String schema,
 String table,
 String column,
 String newName)

Specified by:

renameColumn 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