Package com.alibaba.druid.sql.ast.statement

Class SQLCreateTableStatement

java.lang.Object

com.alibaba.druid.sql.ast.SQLObjectImpl

com.alibaba.druid.sql.ast.SQLStatementImpl

com.alibaba.druid.sql.ast.statement.SQLCreateTableStatement

All Implemented Interfaces:

SQLDbTypedObject, SQLObject, SQLStatement, SQLCreateStatement, SQLDDLStatement

Direct Known Subclasses:

BigQueryCreateTableStatement, BlinkCreateTableStatement, CKCreateTableStatement, DB2CreateTableStatement, GaussDbCreateTableStatement, HiveCreateTableStatement, MySqlCreateTableStatement, OracleCreateTableStatement, PrestoCreateTableStatement, RedshiftCreateTableStatement, SparkCreateTableStatement, StarRocksCreateTableStatement, SynapseCreateTableStatement, TDCreateTableStatement

public class SQLCreateTableStatement
extends SQLStatementImpl
implements SQLDDLStatement, SQLCreateStatement

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	SQLCreateTableStatement.Feature

Nested classes/interfaces inherited from interface com.alibaba.druid.sql.ast.statement.SQLDDLStatement

SQLDDLStatement.DDLObjectType

Field Summary

Fields

Modifier and Type	Field	Description
protected int	buckets
protected final List<SQLSelectOrderByItem>	clusteredBy
protected ClusteringType	clusteringType
protected SQLExpr	comment
protected Boolean	compress
protected SQLExpr	engine
protected int	features
protected boolean	ignore
protected SQLExprTableSource	inherits
protected boolean	isAutoBucket
protected SQLExpr	lifeCycle
protected SQLExprTableSource	like
protected SQLPartitionBy	localPartitioning
protected SQLExpr	location
protected Boolean	logging
protected boolean	onCommitDeleteRows
protected boolean	onCommitPreserveRows
protected SQLOrderBy	orderBy
protected SQLPartitionBy	partitionBy
protected final List<SQLColumnDefinition>	partitionColumns
protected SQLPartitionOf	partitionOf
protected boolean	replace
protected SQLExternalRecordFormat	rowFormat
protected SQLSelect	select
protected int	shards
protected boolean	single
protected final List<SQLSelectOrderByItem>	sortedBy
protected SQLExpr	storedAs
protected SQLExpr	storedBy
protected List<SQLTableElement>	tableElementList
protected final List<SQLAssignItem>	tableOptions
protected SQLExprTableSource	tableSource
protected SQLName	tablespace
protected SQLUnique	unique

Fields inherited from class com.alibaba.druid.sql.ast.SQLStatementImpl

afterSemi, dbType, headHints

Fields inherited from class com.alibaba.druid.sql.ast.SQLObjectImpl

attributes, hint, parent, sourceColumn, sourceLine

Constructor Summary

Constructors

Constructor	Description
SQLCreateTableStatement()
SQLCreateTableStatement(DbType dbType)

Method Summary

Modifier and Type	Method	Description
protected void	accept0(SQLASTVisitor v)
protected void	acceptChild(SQLASTVisitor v)
void	addBodyBeforeComment(List<String> comments)
void	addClusteredByItem(SQLSelectOrderByItem item)
void	addColumn(SQLColumnDefinition column)
void	addColumn(String name, SQLDataType dataType)
void	addColumn(String columnName, String dataType)
void	addOption(String name, SQLExpr value)
void	addPartitionColumn(SQLColumnDefinition column)
void	addSortedByItem(SQLSelectOrderByItem item)
void	addTblProperty(String name, SQLExpr value)	Deprecated.
protected boolean	alterApply(SQLAlterTableItem item)
protected boolean	apply(SQLAlterTableAddIndex item)
boolean	apply(SQLAlterTableStatement alter)
protected boolean	apply(SQLAlterTableTruncatePartition item)
boolean	apply(SQLCommentStatement x)
boolean	apply(SQLDropIndexStatement x)
SQLCreateTableStatement	clone()
void	cloneTo(SQLCreateTableStatement x)
protected int	columnIndexOf(SQLName column)
String	computeName()
void	config(SQLCreateTableStatement.Feature feature)
void	config(SQLCreateTableStatement.Feature feature, boolean state)
boolean	containsColumn(String columName)
boolean	containsDuplicateColumnNames()
boolean	containsDuplicateColumnNames(boolean throwException)
SQLColumnDefinition	findColumn(long columName_hash)
SQLColumnDefinition	findColumn(String columName)
List<SQLForeignKeyConstraint>	findForeignKey()
SQLTableElement	findIndex(String columnName)
SQLPrimaryKey	findPrimaryKey()
MySqlUnique	findUnique(String columnName)
void	forEachColumn(Consumer<SQLColumnDefinition> columnConsumer)
SQLAlterTableStatement	foreignKeyToAlterTable()
List<String>	getBodyBeforeCommentsDirect()
int	getBuckets()
String	getCatalog()
List<SQLObject>	getChildren()
List<SQLSelectOrderByItem>	getClusteredBy()
ClusteringType	getClusteringType()
SQLColumnDefinition	getColumn(String columnName)
List<String>	getColumnComments()
List<SQLColumnDefinition>	getColumnDefinitions()
List<String>	getColumnNames(boolean normalized)
SQLExpr	getComment()
Boolean	getCompress()
SQLDDLStatement.DDLObjectType	getDDLObjectType()
SQLExpr	getEngine()
SQLExprTableSource	getInherits()
SQLExpr	getLifeCycle()
SQLExprTableSource	getLike()
SQLPartitionBy	getLocalPartitioning()
SQLExpr	getLocation()
Boolean	getLogging()
SQLName	getName()
SQLExpr	getOption(String name)
Object	getOptionOrTblPropertyValue(String name)
Object	getOptionValue(String name)
SQLOrderBy	getOrderBy()
List<SQLColumnDefinition>	getPartitionColumns()
SQLPartitionBy	getPartitioning()
SQLPartitionOf	getPartitionOf()
List<String>	getPrimaryKeyNames()
SQLExternalRecordFormat	getRowFormat()
String	getSchema()
SQLSelect	getSelect()
int	getShards()
List<SQLSelectOrderByItem>	getSortedBy()
SQLExpr	getStoredAs()
SQLExpr	getStoredBy()
List<SQLTableElement>	getTableElementList()
String	getTableName()
List<SQLAssignItem>	getTableOptions()
SQLExprTableSource	getTableSource()
SQLName	getTablespace()
List<SQLAssignItem>	getTblProperties()	Deprecated.
SQLExpr	getTblProperty(String name)
Object	getTblPropertyValue(String name)
SQLUnique	getUnique()
boolean	hasBodyBeforeComment()
boolean	hashForeignKey()
boolean	isAutoBucket()
boolean	isDimension()
boolean	isEnabled(SQLCreateTableStatement.Feature feature)
boolean	isExternal()
boolean	isIfNotExists()
boolean	isIgnore()
boolean	isMUL(String columnName)	only for show columns
boolean	isOnCommitPreserveRows()
boolean	isOnlyPrimaryKey(long columnNameHash)
boolean	isPrimaryColumn(long columnNameHash)
boolean	isPrimaryColumn(String columnName)
boolean	isReferenced(SQLName tableName)
boolean	isReferenced(String tableName)
boolean	isReplace()
boolean	isSingle()
boolean	isTemporary()
boolean	isUNI(String columnName)	only for show columns
boolean	removeOption(String name)
boolean	renameColumn(String colummName, String newColumnName)
void	setAutoBucket(boolean autoBucket)
void	setBuckets(int buckets)
void	setClusteringType(ClusteringType clusteringType)
void	setComment(SQLExpr comment)
void	setCompress(Boolean compress)
void	setDimension(boolean dimension)
void	setEngine(SQLExpr x)
void	setExternal(boolean external)
void	setIfNotExists(boolean value)
void	setIgnore(boolean ignore)
void	setInherits(SQLExprTableSource inherits)
void	setLifeCycle(SQLExpr x)
void	setLike(SQLName like)
void	setLike(SQLExprTableSource like)
void	setLocalPartitioning(SQLPartitionBy localPartitioning)
void	setLocation(SQLExpr x)
void	setLogging(Boolean logging)
void	setName(SQLName name)
void	setName(String name)
void	setOnCommitPreserveRows(boolean onCommitPreserveRows)
void	setOrderBy(SQLOrderBy orderBy)
void	setPartitionBy(SQLPartitionBy partitionBy)
void	setPartitionOf(SQLPartitionOf partitionOf)
void	setReplace(boolean replace)
void	setRowFormat(SQLExternalRecordFormat x)
void	setSchema(String name)
void	setSelect(SQLSelect select)
void	setShards(int shards)
void	setSingle(boolean single)
void	setStoredAs(SQLExpr x)
void	setStoredBy(SQLExpr x)
void	setTableName(String tableName)
void	setTableSource(SQLExprTableSource tableSource)
void	setTablespace(SQLName x)
void	setTemporary(boolean value)
void	setUnique(SQLUnique unique)
void	simplify()
static void	sort(List<SQLStatement> stmtList)
String	toString()

Methods inherited from class com.alibaba.druid.sql.ast.SQLStatementImpl

cloneTo, getDbType, getHeadHintsDirect, isAfterSemi, setAfterSemi, setDbType, setHeadHints, toLowerCaseString, toParameterizedString, toString, toUnformattedString

Methods inherited from class com.alibaba.druid.sql.ast.SQLObjectImpl

accept, acceptChild, acceptChild, addAfterComment, addAfterComment, addBeforeComment, addBeforeComment, cloneTo, computeDataType, containsAttribute, getAfterCommentsDirect, getAttribute, getAttributes, getAttributesDirect, getBeforeCommentsDirect, getHint, getParent, getParent, getSourceColumn, getSourceLine, hasAfterComment, hasBeforeComment, output, putAttribute, setHint, setParent, setSource, setSourceLine

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.alibaba.druid.sql.ast.SQLObject

accept, addAfterComment, addAfterComment, addBeforeComment, addBeforeComment, containsAttribute, getAfterCommentsDirect, getAttribute, getAttributes, getAttributesDirect, getBeforeCommentsDirect, getParent, getParent, getSourceColumn, getSourceLine, hasAfterComment, hasBeforeComment, output, putAttribute, setParent, setSource

Methods inherited from interface com.alibaba.druid.sql.ast.SQLStatement

getDbType, getHeadHintsDirect, isAfterSemi, setAfterSemi, setHeadHints, toLowerCaseString, toParameterizedString, toString

Field Details

features

protected int features

tableSource

protected SQLExprTableSource tableSource

tableElementList

protected List<SQLTableElement> tableElementList

inherits

protected SQLExprTableSource inherits

select

protected SQLSelect select

comment

protected SQLExpr comment

like

protected SQLExprTableSource like

compress

protected Boolean compress

logging

protected Boolean logging

tablespace

protected SQLName tablespace

partitionBy

protected SQLPartitionBy partitionBy

partitionOf

protected SQLPartitionOf partitionOf

localPartitioning

protected SQLPartitionBy localPartitioning

unique

protected SQLUnique unique

storedAs

protected SQLExpr storedAs

storedBy

protected SQLExpr storedBy

location

protected SQLExpr location

engine

protected SQLExpr engine

orderBy

protected SQLOrderBy orderBy

onCommitPreserveRows

protected boolean onCommitPreserveRows

onCommitDeleteRows

protected boolean onCommitDeleteRows

rowFormat

protected SQLExternalRecordFormat rowFormat

partitionColumns

protected final List<SQLColumnDefinition> partitionColumns

clusteringType

protected ClusteringType clusteringType

clusteredBy

protected final List<SQLSelectOrderByItem> clusteredBy

sortedBy

protected final List<SQLSelectOrderByItem> sortedBy

isAutoBucket

protected boolean isAutoBucket

buckets

protected int buckets

shards

protected int shards

tableOptions

protected final List<SQLAssignItem> tableOptions

replace

protected boolean replace

ignore

protected boolean ignore

single

protected boolean single

lifeCycle

protected SQLExpr lifeCycle

Constructor Details

SQLCreateTableStatement

public SQLCreateTableStatement()

SQLCreateTableStatement

public SQLCreateTableStatement(DbType dbType)

Method Details

accept0

protected void accept0(SQLASTVisitor v)

Overrides:

accept0 in class SQLStatementImpl

acceptChild

protected void acceptChild(SQLASTVisitor v)

isAutoBucket

public boolean isAutoBucket()

setAutoBucket

public void setAutoBucket(boolean autoBucket)

getEngine

public SQLExpr getEngine()

setEngine

public void setEngine(SQLExpr x)

getOrderBy

public SQLOrderBy getOrderBy()

setOrderBy

public void setOrderBy(SQLOrderBy orderBy)

getComment

public SQLExpr getComment()

setComment

public void setComment(SQLExpr comment)

getName

public SQLName getName()

Specified by:

getName in interface SQLCreateStatement

getTableName

public String getTableName()

getSchema

public String getSchema()

setSchema

public void setSchema(String name)

setName

public void setName(SQLName name)

setName

public void setName(String name)

getTableSource

public SQLExprTableSource getTableSource()

setTableSource

public void setTableSource(SQLExprTableSource tableSource)

setTableName

public void setTableName(String tableName)

config

public void config(SQLCreateTableStatement.Feature feature)

isEnabled

public boolean isEnabled(SQLCreateTableStatement.Feature feature)

config

public void config(SQLCreateTableStatement.Feature feature,
 boolean state)

isTemporary

public boolean isTemporary()

setTemporary

public void setTemporary(boolean value)

getTableElementList

public List<SQLTableElement> getTableElementList()

getColumn

public SQLColumnDefinition getColumn(String columnName)

getColumnDefinitions

public List<SQLColumnDefinition> getColumnDefinitions()

getColumnNames

public List<String> getColumnNames(boolean normalized)

getColumnComments

public List<String> getColumnComments()

getPrimaryKeyNames

public List<String> getPrimaryKeyNames()

addColumn

public void addColumn(String columnName,
 String dataType)

addColumn

public void addColumn(String name,
 SQLDataType dataType)

addColumn

public void addColumn(SQLColumnDefinition column)

isIfNotExists

public boolean isIfNotExists()

setIfNotExists

public void setIfNotExists(boolean value)

getInherits

public SQLExprTableSource getInherits()

setInherits

public void setInherits(SQLExprTableSource inherits)

getSelect

public SQLSelect getSelect()

setSelect

public void setSelect(SQLSelect select)

getUnique

public SQLUnique getUnique()

setUnique

public void setUnique(SQLUnique unique)

getLike

public SQLExprTableSource getLike()

setLike

public void setLike(SQLName like)

setLike

public void setLike(SQLExprTableSource like)

getCompress

public Boolean getCompress()

setCompress

public void setCompress(Boolean compress)

getLogging

public Boolean getLogging()

setLogging

public void setLogging(Boolean logging)

getTablespace

public SQLName getTablespace()

setTablespace

public void setTablespace(SQLName x)

getPartitioning

public SQLPartitionBy getPartitioning()

getLocalPartitioning

public SQLPartitionBy getLocalPartitioning()

setPartitionBy

public void setPartitionBy(SQLPartitionBy partitionBy)

getPartitionOf

public SQLPartitionOf getPartitionOf()

setPartitionOf

public void setPartitionOf(SQLPartitionOf partitionOf)

setLocalPartitioning

public void setLocalPartitioning(SQLPartitionBy localPartitioning)

getChildren

public List<SQLObject> getChildren()

Specified by:

getChildren in interface SQLStatement

Overrides:

getChildren in class SQLStatementImpl

addBodyBeforeComment

public void addBodyBeforeComment(List<String> comments)

getBodyBeforeCommentsDirect

public List<String> getBodyBeforeCommentsDirect()

hasBodyBeforeComment

public boolean hasBodyBeforeComment()

computeName

public String computeName()

containsColumn

public boolean containsColumn(String columName)

findColumn

public SQLColumnDefinition findColumn(String columName)

findColumn

public SQLColumnDefinition findColumn(long columName_hash)

isPrimaryColumn

public boolean isPrimaryColumn(String columnName)

isPrimaryColumn

public boolean isPrimaryColumn(long columnNameHash)

isOnlyPrimaryKey

public boolean isOnlyPrimaryKey(long columnNameHash)

isMUL

public boolean isMUL(String columnName)

only for show columns

isUNI

public boolean isUNI(String columnName)

only for show columns

findUnique

public MySqlUnique findUnique(String columnName)

findIndex

public SQLTableElement findIndex(String columnName)

forEachColumn

public void forEachColumn(Consumer<SQLColumnDefinition> columnConsumer)

findPrimaryKey

public SQLPrimaryKey findPrimaryKey()

findForeignKey

public List<SQLForeignKeyConstraint> findForeignKey()

hashForeignKey

public boolean hashForeignKey()

isReferenced

public boolean isReferenced(SQLName tableName)

isReferenced

public boolean isReferenced(String tableName)

foreignKeyToAlterTable

public SQLAlterTableStatement foreignKeyToAlterTable()

sort

public static void sort(List<SQLStatement> stmtList)

simplify

public void simplify()

apply

public boolean apply(SQLDropIndexStatement x)

apply

public boolean apply(SQLCommentStatement x)

apply

public boolean apply(SQLAlterTableStatement alter)

alterApply

protected boolean alterApply(SQLAlterTableItem item)

renameColumn

public boolean renameColumn(String colummName,
 String newColumnName)

apply

protected boolean apply(SQLAlterTableTruncatePartition item)

apply

protected boolean apply(SQLAlterTableAddIndex item)

columnIndexOf

protected int columnIndexOf(SQLName column)

cloneTo

public void cloneTo(SQLCreateTableStatement x)

isReplace

public boolean isReplace()

setReplace

public void setReplace(boolean replace)

isIgnore

public boolean isIgnore()

setIgnore

public void setIgnore(boolean ignore)

isSingle

public boolean isSingle()

setSingle

public void setSingle(boolean single)

getStoredAs

public SQLExpr getStoredAs()

setStoredAs

public void setStoredAs(SQLExpr x)

getStoredBy

public SQLExpr getStoredBy()

setStoredBy

public void setStoredBy(SQLExpr x)

clone

public SQLCreateTableStatement clone()

Specified by:

clone in interface SQLObject

Specified by:

clone in interface SQLStatement

Overrides:

clone in class SQLStatementImpl

toString

public String toString()

Specified by:

toString in interface SQLStatement

Overrides:

toString in class SQLStatementImpl

isOnCommitPreserveRows

public boolean isOnCommitPreserveRows()

setOnCommitPreserveRows

public void setOnCommitPreserveRows(boolean onCommitPreserveRows)

isExternal

public boolean isExternal()

setExternal

public void setExternal(boolean external)

getClusteringType

public ClusteringType getClusteringType()

setClusteringType

public void setClusteringType(ClusteringType clusteringType)

getClusteredBy

public List<SQLSelectOrderByItem> getClusteredBy()

addClusteredByItem

public void addClusteredByItem(SQLSelectOrderByItem item)

getSortedBy

public List<SQLSelectOrderByItem> getSortedBy()

addSortedByItem

public void addSortedByItem(SQLSelectOrderByItem item)

getBuckets

public int getBuckets()

setBuckets

public void setBuckets(int buckets)

getShards

public int getShards()

setShards

public void setShards(int shards)

getPartitionColumns

public List<SQLColumnDefinition> getPartitionColumns()

addPartitionColumn

public void addPartitionColumn(SQLColumnDefinition column)

getTableOptions

public List<SQLAssignItem> getTableOptions()

getTblProperties

@Deprecated
public List<SQLAssignItem> getTblProperties()

Deprecated.

addTblProperty

@Deprecated
public void addTblProperty(String name,
 SQLExpr value)

Deprecated.

getRowFormat

public SQLExternalRecordFormat getRowFormat()

setRowFormat

public void setRowFormat(SQLExternalRecordFormat x)

isDimension

public boolean isDimension()

setDimension

public void setDimension(boolean dimension)

getLocation

public SQLExpr getLocation()

setLocation

public void setLocation(SQLExpr x)

addOption

public void addOption(String name,
 SQLExpr value)

getOption

public SQLExpr getOption(String name)

removeOption

public boolean removeOption(String name)

getTblProperty

public SQLExpr getTblProperty(String name)

getOptionValue

public Object getOptionValue(String name)

getTblPropertyValue

public Object getTblPropertyValue(String name)

getOptionOrTblPropertyValue

public Object getOptionOrTblPropertyValue(String name)

getCatalog

public String getCatalog()

containsDuplicateColumnNames

public boolean containsDuplicateColumnNames()

containsDuplicateColumnNames

public boolean containsDuplicateColumnNames(boolean throwException)

getDDLObjectType

public SQLDDLStatement.DDLObjectType getDDLObjectType()

Specified by:

getDDLObjectType in interface SQLDDLStatement

getLifeCycle

public SQLExpr getLifeCycle()

setLifeCycle

public void setLifeCycle(SQLExpr x)