org.umlg.sqlg.sql.dialect

Class MysqlDialect

java.lang.Object

org.umlg.sqlg.sql.dialect.BaseSqlDialect

org.umlg.sqlg.sql.dialect.MysqlDialect

All Implemented Interfaces:

SqlBulkDialect, SqlDialect, SqlSchemaChangeDialect

public class MysqlDialect
extends BaseSqlDialect

Author:

Pieter Martin (https://github.com/pietermartin), Vasili Pispanen Date: 2018/05/22

Field Summary

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

INDEX_POSTFIX

Constructor Summary

Constructors

Constructor and Description
MysqlDialect()

Method Summary

Modifier and Type	Method and Description
String	afterCreateTemporaryTableStatement()
void	alterSequenceCacheSize(SqlgGraph sqlgGraph, SchemaTable schemaTable, String sequence, int batchSize)
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()
List<org.apache.commons.lang3.tuple.Triple<String,String,String>>	getEdgeTables(DatabaseMetaData metaData)
String	getForeignKeyTypeDefinition()
List<String>	getGisSchemas()
List<org.apache.commons.lang3.tuple.Triple<String,Boolean,String>>	getIndexInfo(DatabaseMetaData metaData, String catalog, String schema, String table, boolean unique, boolean approximate)
Set<String>	getInternalSchemas()
int	getMaximumColumnNameLength()
int	getMaximumIndexNameLength()
int	getMaximumSchemaNameLength()
int	getMaximumTableNameLength()
String	getPrimaryKeyType()
String	getPublicSchema()
List<String>	getSchemaNames(DatabaseMetaData metaData)
String	getSkipClause(long skip) Hardcoded the rows to return.
Set<String>	getSpacialRefTable()
List<org.apache.commons.lang3.tuple.Triple<String,Integer,String>>	getTableColumns(DatabaseMetaData metaData, String catalog, String schemaPattern, String tableNamePattern, String columnNamePattern)
List<org.apache.commons.lang3.tuple.Triple<String,String,String>>	getVertexTables(DatabaseMetaData metaData)
void	grantReadOnlyUserPrivilegesToSqlgSchemas(SqlgGraph sqlgGraph)
boolean	isMariaDb()
boolean	isMysql()
boolean	isSystemIndex(String indexName)
void	lockTable(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
String	maybeWrapInQoutes(String field)
boolean	needsTemporaryTableSchema()
long	nextSequenceVal(SqlgGraph sqlgGraph, SchemaTable schemaTable, String prefix)
int[]	propertyTypeToJavaSqlType(PropertyType propertyType)
String[]	propertyTypeToSqlDefinition(PropertyType propertyType)
boolean	requiresIndexLengthLimit()
boolean	schemaExists(DatabaseMetaData metadata, String schema)
String	sequenceName(SqlgGraph sqlgGraph, SchemaTable outSchemaTable, String prefix)
void	setArray(PreparedStatement statement, int index, PropertyType type, Object[] values)
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	sqlInsertEmptyValues()
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	supportsBooleanArrayValues()
boolean	supportsBulkWithinOut()
boolean	supportsByteValues()
boolean	supportsCascade()
boolean	supportsDoubleArrayValues()
boolean	supportsDurationArrayValues()
boolean	supportsFloatArrayValues()
boolean	supportsFloatValues()
boolean	supportsIntegerArrayValues()
boolean	supportsLocalDateArrayValues()
boolean	supportsLocalDateTimeArrayValues()
boolean	supportsLocalTimeArrayValues()
boolean	supportsLongArrayValues()
boolean	supportsPeriodArrayValues()
boolean	supportsSchemas()
boolean	supportsShortArrayValues()
boolean	supportsStringArrayValues()
boolean	supportsTemporaryTableOnCommitDrop()
boolean	supportsTransactionalSchema()
boolean	supportsType(PropertyType propertyType)
boolean	supportsValuesExpression()
boolean	supportsZonedDateTimeArrayValues()
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, flushEdgeGlobalUniqueIndexes, flushEdgeGlobalUniqueIndexPropertyCache, flushEdgePropertyCache, flushRemovedEdges, flushRemovedGlobalUniqueIndexVertices, flushRemovedVertices, flushVertexCache, flushVertexGlobalUniqueIndexes, flushVertexGlobalUniqueIndexPropertyCache, flushVertexPropertyCache, getPrimaryKeys, 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, getBatchNull, streamSql, temporaryTableCopyCommandSqlVertex, writeStreamingEdge, writeStreamingVertex, writeTemporaryStreamingVertex

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

lock, notifyChange, registerListener, unregisterListener

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

addColumnStatement, addDbVersionToGraph, addPartitionTables, alterForeignKeyToDeferrable, assertTableName, columnsToIgnore, drop, drop, drop, dropSchemaStatement, dropWithForeignKey, extractIndices, getAutoIncrement, getDefaultFetchSize, getFullTextQueryText, getGis, getPartitions, getPrimaryKeyStartValue, getRangeClause, getShardCount, hasContainerKeyToColumn, indexName, indexName, isHsqldb, isIndexPartOfCreateTable, isMssqlServer, isPostgresql, needForeignKeyIndex, needsSchemaCreationPrecommit, needsSchemaDropCascade, needsSemicolon, needsTemporaryTablePrefix, needsTimeZone, prepareDB, putJsonMetaObject, putJsonObject, requiresIndexName, setGeographyPoint, setLineString, setPoint, setPolygon, sqlgGuiSchemaCreationScript, sqlgSqlgSchemaCreationScript, sqlToGetAllForeignKeys, sqlTruncate, supportsByteArrayValues, supportsClientInfo, supportsDeferrableForeignKey, supportsDistribution, supportsFullValueExpression, supportsILike, supportsJsonArrayValues, supportsJsonType, supportsPartitioning, supportsSchemaIfNotExists, supportsSharding, supportsStreamingBatchMode, supportsTruncateMultipleTablesTogether, temporaryTablePrefix, toRDBSStringLiteral, toRDBSStringLiteral, uniqueIndexConsidersNullValuesEqual, validateSchemaName, validateTableName

Constructor Detail

MysqlDialect

public MysqlDialect()

Method Detail

getMaximumSchemaNameLength

public int getMaximumSchemaNameLength()

getMaximumTableNameLength

public int getMaximumTableNameLength()

getMaximumColumnNameLength

public int getMaximumColumnNameLength()

getMaximumIndexNameLength

public int getMaximumIndexNameLength()

isMariaDb

public boolean isMariaDb()

supportsValuesExpression

public boolean supportsValuesExpression()

supportsBatchMode

public boolean supportsBatchMode()

supportsSchemas

public boolean supportsSchemas()

createSchemaStatement

public String createSchemaStatement(String schemaName)

needsTemporaryTableSchema

public boolean needsTemporaryTableSchema()

supportsTemporaryTableOnCommitDrop

public boolean supportsTemporaryTableOnCommitDrop()

sqlInsertEmptyValues

public String sqlInsertEmptyValues()

getVertexTables

public List<org.apache.commons.lang3.tuple.Triple<String,String,String>> getVertexTables(DatabaseMetaData metaData)

Specified by:

getVertexTables in interface SqlDialect

Overrides:

getVertexTables in class BaseSqlDialect

getEdgeTables

public List<org.apache.commons.lang3.tuple.Triple<String,String,String>> getEdgeTables(DatabaseMetaData metaData)

Specified by:

getEdgeTables in interface SqlDialect

Overrides:

getEdgeTables in class BaseSqlDialect

getTableColumns

public List<org.apache.commons.lang3.tuple.Triple<String,Integer,String>> getTableColumns(DatabaseMetaData metaData,
                                                                                          String catalog,
                                                                                          String schemaPattern,
                                                                                          String tableNamePattern,
                                                                                          String columnNamePattern)

Specified by:

getTableColumns in interface SqlDialect

Overrides:

getTableColumns in class BaseSqlDialect

getIndexInfo

public List<org.apache.commons.lang3.tuple.Triple<String,Boolean,String>> getIndexInfo(DatabaseMetaData metaData,
                                                                                       String catalog,
                                                                                       String schema,
                                                                                       String table,
                                                                                       boolean unique,
                                                                                       boolean approximate)

Specified by:

getIndexInfo in interface SqlDialect

Overrides:

getIndexInfo in class BaseSqlDialect

getSchemaNames

public List<String> getSchemaNames(DatabaseMetaData metaData)

Specified by:

getSchemaNames in interface SqlDialect

Overrides:

getSchemaNames in class BaseSqlDialect

schemaExists

public boolean schemaExists(DatabaseMetaData metadata,
                            String schema)
                     throws SQLException

Throws:

SQLException

maybeWrapInQoutes

public String maybeWrapInQoutes(String field)

dialectName

public String dialectName()

getInternalSchemas

public Set<String> getInternalSchemas()

supportsCascade

public boolean supportsCascade()

getPublicSchema

public String getPublicSchema()

existIndexQuery

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

supportsTransactionalSchema

public boolean supportsTransactionalSchema()

validateProperty

public void validateProperty(Object key,
                             Object value)

getColumnEscapeKey

public String getColumnEscapeKey()

getPrimaryKeyType

public String getPrimaryKeyType()

getAutoIncrementPrimaryKeyConstruct

public String getAutoIncrementPrimaryKeyConstruct()

propertyTypeToSqlDefinition

public String[] propertyTypeToSqlDefinition(PropertyType propertyType)

propertyTypeToJavaSqlType

public int[] propertyTypeToJavaSqlType(PropertyType propertyType)

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)

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)

getForeignKeyTypeDefinition

public String getForeignKeyTypeDefinition()

getArrayDriverType

public String getArrayDriverType(PropertyType propertyType)

createTableStatement

public String createTableStatement()

validateColumnName

public void validateColumnName(String column)

Specified by:

validateColumnName in interface SqlDialect

Overrides:

validateColumnName in class BaseSqlDialect

getSpacialRefTable

public Set<String> getSpacialRefTable()

getGisSchemas

public List<String> getGisSchemas()

lockTable

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

alterSequenceCacheSize

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

nextSequenceVal

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

currSequenceVal

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

sequenceName

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

supportsBulkWithinOut

public boolean supportsBulkWithinOut()

createTemporaryTableStatement

public String createTemporaryTableStatement()

afterCreateTemporaryTableStatement

public String afterCreateTemporaryTableStatement()

sqlgTopologyCreationScripts

public List<String> sqlgTopologyCreationScripts()

sqlgCreateTopologyGraph

public String sqlgCreateTopologyGraph()

sqlgAddIndexEdgeSequenceColumn

public String sqlgAddIndexEdgeSequenceColumn()

convertArray

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

Throws:

SQLException

setArray

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

Throws:

SQLException

isSystemIndex

public boolean isSystemIndex(String indexName)

supportsBooleanArrayValues

public boolean supportsBooleanArrayValues()

supportsDoubleArrayValues

public boolean supportsDoubleArrayValues()

supportsFloatArrayValues

public boolean supportsFloatArrayValues()

supportsIntegerArrayValues

public boolean supportsIntegerArrayValues()

supportsShortArrayValues

public boolean supportsShortArrayValues()

supportsLongArrayValues

public boolean supportsLongArrayValues()

supportsStringArrayValues

public boolean supportsStringArrayValues()

supportsFloatValues

public boolean supportsFloatValues()

supportsByteValues

public boolean supportsByteValues()

supportsLocalDateTimeArrayValues

public boolean supportsLocalDateTimeArrayValues()

supportsLocalTimeArrayValues

public boolean supportsLocalTimeArrayValues()

supportsLocalDateArrayValues

public boolean supportsLocalDateArrayValues()

supportsZonedDateTimeArrayValues

public boolean supportsZonedDateTimeArrayValues()

supportsPeriodArrayValues

public boolean supportsPeriodArrayValues()

supportsDurationArrayValues

public boolean supportsDurationArrayValues()

requiresIndexLengthLimit

public boolean requiresIndexLengthLimit()

valueToValuesString

public String valueToValuesString(PropertyType propertyType,
                                  Object value)

supportsType

public boolean supportsType(PropertyType propertyType)

sqlToTurnOffReferentialConstraintCheck

public String sqlToTurnOffReferentialConstraintCheck(String tableName)

sqlToTurnOnReferentialConstraintCheck

public String sqlToTurnOnReferentialConstraintCheck(String tableName)

getSkipClause

public String getSkipClause(long skip)

Hardcoded the rows to return. Mysql does nto support just an offset.

Parameters:

skip - The number of rows to skip. i.e. OFFSET

Returns:

The sql fragment.

isMysql

public boolean isMysql()

grantReadOnlyUserPrivilegesToSqlgSchemas

public void grantReadOnlyUserPrivilegesToSqlgSchemas(SqlgGraph sqlgGraph)