org.tinygroup.database.table.impl

Class SqlProcessorImpl

java.lang.Object

org.tinygroup.database.table.impl.SqlProcessorImpl

All Implemented Interfaces:

TableSqlProcessor

Direct Known Subclasses:

Db2SqlProcessorImpl, DerbySqlProcessorImpl, H2SqlProcessorImpl, InformixSqlProcessorImpl, MysqlSqlProcessorImpl, OracleSqlProcessorImpl, SqlserverSqlProcessorImpl, SybaseSqlProcessorImpl

public abstract class SqlProcessorImpl
extends Object
implements TableSqlProcessor

Field Summary

Fields inherited from interface org.tinygroup.database.table.TableSqlProcessor

COLUMN_DEF, COLUMN_NAME, COLUMN_SIZE, DATA_TYPE, DECIMAL_DIGITS, INDEX_NON_UNIQUE, NULLABLE, REMARKS, TYPE_NAME

Constructor Summary

Constructors

Constructor and Description
SqlProcessorImpl()

Method Summary

Modifier and Type	Method and Description
protected void	appendBody(StringBuffer ddlBuffer, Table table, List<String> list)
protected void	appendColumnUpdate(List<String> existUpdateList, TableField field, StandardField standardField, ColumnContext columnContext) 列字段是否发生改变
protected void	appendComment(String comment, StringBuffer ddlBuffer, List<String> list)
protected void	appendDefaultValue(String defaultValue, StringBuffer ddlBuffer)
protected void	appendField(StringBuffer ddlBuffer, TableField field, List<String> list, Table table)
protected void	appendFooter(StringBuffer ddlBuffer, Table table, List<String> list)
protected void	appendFooterComment(Table table, List<String> list) 在footer增加comment
protected String	appendIncrease()
protected void	appendIndexReverse(StringBuffer ddlBuffer, Index index)
protected void	appendPrimarySql(StringBuffer ddlBuffer, Table table, List<String> list)
protected void	appendTableSpace(StringBuffer ddlBuffer, Table table) 表空间默认实现
protected void	appendTypeAndDefault(StringBuffer ddlBuffer, TableField field, StandardField standardField)
protected void	char2DbLen(List<String> businessTypeList, BusinessType businessType, String databaseType)
protected boolean	checkCommentSame(String standardComment, String remarks) 检查comment是否改变
protected boolean	checkDefSame(String standardDefault, String columnDef)
protected boolean	checkIndexBaseSame(Index tableIndex, Map<String,String> dbIndexMap, Connection con) index基本信息是否一致
protected List<String>	checkTableColumn(Map<String,Map<String,String>> columns, Map<String,TableField> fieldDbNames, Map<String,TableField> existInTable)
boolean	checkTableExist(Table table, Connection connection)
protected boolean	checkTypeSame(String dbColumnType, String tableDataType, String dbDataType) 检查数据类型是否相同
protected boolean	checkUniqueSame(Map<String,String> uniqueColumns, String indexName, boolean isFieldUnique)
protected abstract String	createAlterTypeSql(String tableName, String fieldName, String tableDataType)
protected List<String>	dealAddFields(Map<String,TableField> fieldDbNames, String packageName, Table table)
protected void	dealConstraintIndex(Table table, List<String> preDropIndexes, Map<String,Map<String,String>> dbIndexes) 删除有关联的索引
protected String	dealDateType(String value) 处理日期类型 因为初始化数据是字符串类型,而实际是date类型,有些数据库需要进行转换。
protected void	dealDefaultValueUpdate(StringBuffer alterTypeBuffer, String fieldDefaultValue, String columnDef)
protected List<String>	dealDropFields(List<String> dropFields, Table table)
protected List<String>	dealExistFields(Map<String,TableField> existInTable, Map<String,Map<String,String>> dbColumns, Table table) 比较数据库metadata和配置中数据
protected void	dealNotNullSql(StringBuffer alterTypeBuffer, TableField field, boolean dbNullAble)
protected String	dealTableName(String tableName)
protected void	defaultChangedFooterComment(Connection connection, Table table, List<String> list)
protected String	delimiter(String name)
protected void	getChangedFooterComment(Connection connection, Table table, List<String> list)
List<String>	getClearTableSql(Table table, Connection connection)
protected Map<String,Map<String,String>>	getColumns(DatabaseMetaData metadata, String catalog, Table table)
protected String	getComment(StandardField standardField)
List<String>	getCreateSql(Table table, String packageName) 获得创建表格的语句(包含index)
protected abstract String	getDatabaseType()
protected String	getDbColumnColumnDef(Map<String,String> attributes) 获取默认值
protected String	getDbColumnRemarks(Map<String,String> attributes) 获取注释
protected String	getDbColumnType(Map<String,String> attributes)
protected List<Map<String,String>>	getDbForeignList(Connection connection, Table table)
protected Map<String,Map<String,String>>	getDbIndexColumns(DatabaseMetaData metadata, String schema, Table table) 获取表的所有索引
protected String	getDefaultValue(TableField field, StandardField standardField)
protected String	getDropForeignSql(String dropConstraint, Table table)
protected String	getDropIndexBaseSql(String dropIndexName, String nameWithOutSchema)
String	getDropSql(Table table, String packageName)
protected String	getFieldStdFieldName(String fieldId, Table table)
List<String>	getForeignKeySqls(Table table, String packageName) 获取外键,直接使用table的外键作为需要创建的外键(适用于全量sql)
List<String>	getForeignKeySqls(Table table, String packageName, List<ForeignReference> foreignReferences) 获取外键
protected void	getForeignUpdate(Table table, String packageName, Connection connection, List<String> list) 更新外键
List<String>	getIndexCreateSql(Table table, String packageName) 获得创建索引的语句
protected String	getIndexName(Index index, Table table)
protected void	getIndexUpdate(Connection connection, Table table, List<String> list)
protected StringBuffer	getKeysBuffer(Table table)
protected String	getOneFkSql(Table table, Table foreignTable, ForeignReference foreignReference)
protected void	getOtherUpdate(Table table, String packageName, Connection connection, List<String> list)
protected String	getQueryForeignSql(Table table, String schema)
protected String	getQuerySchemaName(String schema, String catalog) 获取查询语句的schema
protected String	getSchema(String schema, Connection connection)
protected String	getSchema(Table table, DatabaseMetaData metadata)
protected List<String>	getSeqTriggerSql(Table table, String packageName) 创建seq和trigger语句
protected void	getSeqTriggerUpdate(Connection connection, Table table, List<String> list)
protected void	getTableColumnUpdate(Table table, String packageName, DatabaseMetaData metadata, String catalog, List<String> list) 获取列变化增量语句
List<String>	getTableCreateSql(Table table, String packageName) 获得创建表格的语句(不包含index)
protected String	getTableName(Table table)
TableProcessor	getTableProcessor()
List<String>	getUpdateSql(Table table, String packageName, Connection connection) 获得(正向)Update表格的语句
void	initChar2Byte(String language)
protected boolean	notNeedDropIndex(List<Index> preAddIndexes, Table table, String dbIndexName, Map<String,Map<String,String>> dbIndexMaps, Connection connection)
void	setTableProcessor(TableProcessor tableProcessor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlProcessorImpl

public SqlProcessorImpl()

Method Detail

getTableProcessor

public TableProcessor getTableProcessor()

Specified by:

getTableProcessor in interface TableSqlProcessor

setTableProcessor

public void setTableProcessor(TableProcessor tableProcessor)

Specified by:

setTableProcessor in interface TableSqlProcessor

getDatabaseType

protected abstract String getDatabaseType()

getCreateSql

public List<String> getCreateSql(Table table,
                                 String packageName)

Description copied from interface: TableSqlProcessor

获得创建表格的语句(包含index)

Specified by:

getCreateSql in interface TableSqlProcessor

Returns:

getSeqTriggerSql

protected List<String> getSeqTriggerSql(Table table,
                                        String packageName)

创建seq和trigger语句

Parameters:

table -

packageName -

Returns:

appendPrimarySql

protected void appendPrimarySql(StringBuffer ddlBuffer,
                                Table table,
                                List<String> list)

getKeysBuffer

protected StringBuffer getKeysBuffer(Table table)

getForeignKeySqls

public List<String> getForeignKeySqls(Table table,
                                      String packageName)

获取外键,直接使用table的外键作为需要创建的外键(适用于全量sql)

Specified by:

getForeignKeySqls in interface TableSqlProcessor

Parameters:

table -

packageName -

Returns:

getForeignKeySqls

public List<String> getForeignKeySqls(Table table,
                                      String packageName,
                                      List<ForeignReference> foreignReferences)

获取外键

Parameters:

table -

packageName -

foreignReferences - 需要更新的外键对象

Returns:

getOneFkSql

protected String getOneFkSql(Table table,
                             Table foreignTable,
                             ForeignReference foreignReference)

getTableCreateSql

public List<String> getTableCreateSql(Table table,
                                      String packageName)

Description copied from interface: TableSqlProcessor

获得创建表格的语句(不包含index)

Specified by:

getTableCreateSql in interface TableSqlProcessor

Returns:

getIndexCreateSql

public List<String> getIndexCreateSql(Table table,
                                      String packageName)

Description copied from interface: TableSqlProcessor

获得创建索引的语句

Specified by:

getIndexCreateSql in interface TableSqlProcessor

Returns:

getUpdateSql

public List<String> getUpdateSql(Table table,
                                 String packageName,
                                 Connection connection)
                          throws SQLException

Description copied from interface: TableSqlProcessor

获得(正向)Update表格的语句

Specified by:

getUpdateSql in interface TableSqlProcessor

Returns:

Throws:

SQLException

getOtherUpdate

protected void getOtherUpdate(Table table,
                              String packageName,
                              Connection connection,
                              List<String> list)
                       throws SQLException

Throws:

SQLException

getSeqTriggerUpdate

protected void getSeqTriggerUpdate(Connection connection,
                                   Table table,
                                   List<String> list)
                            throws SQLException

Throws:

SQLException

getIndexUpdate

protected void getIndexUpdate(Connection connection,
                              Table table,
                              List<String> list)
                       throws SQLException

Throws:

SQLException

getDropIndexBaseSql

protected String getDropIndexBaseSql(String dropIndexName,
                                     String nameWithOutSchema)

getSchema

protected String getSchema(String schema,
                           Connection connection)
                    throws SQLException

Throws:

SQLException

notNeedDropIndex

protected boolean notNeedDropIndex(List<Index> preAddIndexes,
                                   Table table,
                                   String dbIndexName,
                                   Map<String,Map<String,String>> dbIndexMaps,
                                   Connection connection)

checkIndexBaseSame

protected boolean checkIndexBaseSame(Index tableIndex,
                                     Map<String,String> dbIndexMap,
                                     Connection con)

index基本信息是否一致

Parameters:

tableIndex -

dbIndexMap -

con -

Returns:

dealConstraintIndex

protected void dealConstraintIndex(Table table,
                                   List<String> preDropIndexes,
                                   Map<String,Map<String,String>> dbIndexes)

删除有关联的索引

Parameters:

table -

preDropIndexes -

getChangedFooterComment

protected void getChangedFooterComment(Connection connection,
                                       Table table,
                                       List<String> list)
                                throws SQLException

Throws:

SQLException

defaultChangedFooterComment

protected void defaultChangedFooterComment(Connection connection,
                                           Table table,
                                           List<String> list)
                                    throws SQLException

Throws:

SQLException

getDbForeignList

protected List<Map<String,String>> getDbForeignList(Connection connection,
                                                    Table table)
                                             throws SQLException

Throws:

SQLException

dealTableName

protected String dealTableName(String tableName)

getForeignUpdate

protected void getForeignUpdate(Table table,
                                String packageName,
                                Connection connection,
                                List<String> list)
                         throws SQLException

更新外键

Parameters:

table -

packageName -

connection -

list -

Throws:

SQLException

getDropForeignSql

protected String getDropForeignSql(String dropConstraint,
                                   Table table)

getQuerySchemaName

protected String getQuerySchemaName(String schema,
                                    String catalog)

获取查询语句的schema

Parameters:

schema -

catalog -

Returns:

getQueryForeignSql

protected String getQueryForeignSql(Table table,
                                    String schema)

getTableColumnUpdate

protected void getTableColumnUpdate(Table table,
                                    String packageName,
                                    DatabaseMetaData metadata,
                                    String catalog,
                                    List<String> list)
                             throws SQLException

获取列变化增量语句

Parameters:

table -

packageName -

metadata -

catalog -

list -

Throws:

SQLException

checkTableColumn

protected List<String> checkTableColumn(Map<String,Map<String,String>> columns,
                                        Map<String,TableField> fieldDbNames,
                                        Map<String,TableField> existInTable)

dealDropFields

protected List<String> dealDropFields(List<String> dropFields,
                                      Table table)

dealAddFields

protected List<String> dealAddFields(Map<String,TableField> fieldDbNames,
                                     String packageName,
                                     Table table)

dealExistFields

protected List<String> dealExistFields(Map<String,TableField> existInTable,
                                       Map<String,Map<String,String>> dbColumns,
                                       Table table)

比较数据库metadata和配置中数据

Parameters:

existInTable - 配置文件中对应tablefield k-v

dbColumns - 数据库中的metadata k-v

table - 表信息

Returns:

appendColumnUpdate

protected void appendColumnUpdate(List<String> existUpdateList,
                                  TableField field,
                                  StandardField standardField,
                                  ColumnContext columnContext)

列字段是否发生改变

Parameters:

existUpdateList -

field -

standardField -

columnContext -

dealNotNullSql

protected void dealNotNullSql(StringBuffer alterTypeBuffer,
                              TableField field,
                              boolean dbNullAble)

dealDefaultValueUpdate

protected void dealDefaultValueUpdate(StringBuffer alterTypeBuffer,
                                      String fieldDefaultValue,
                                      String columnDef)

checkUniqueSame

protected boolean checkUniqueSame(Map<String,String> uniqueColumns,
                                  String indexName,
                                  boolean isFieldUnique)

getDbIndexColumns

protected Map<String,Map<String,String>> getDbIndexColumns(DatabaseMetaData metadata,
                                                           String schema,
                                                           Table table)
                                                    throws SQLException

获取表的所有索引

Parameters:

metadata -

schema -

table -

Returns:

Throws:

SQLException

checkDefSame

protected boolean checkDefSame(String standardDefault,
                               String columnDef)

checkCommentSame

protected boolean checkCommentSame(String standardComment,
                                   String remarks)

检查comment是否改变

Parameters:

standardComment -

remarks -

Returns:

checkTypeSame

protected boolean checkTypeSame(String dbColumnType,
                                String tableDataType,
                                String dbDataType)

检查数据类型是否相同

Parameters:

dbColumnType -

tableDataType -

Returns:

createAlterTypeSql

protected abstract String createAlterTypeSql(String tableName,
                                             String fieldName,
                                             String tableDataType)

appendBody

protected void appendBody(StringBuffer ddlBuffer,
                          Table table,
                          List<String> list)

appendField

protected void appendField(StringBuffer ddlBuffer,
                           TableField field,
                           List<String> list,
                           Table table)

char2DbLen

protected void char2DbLen(List<String> businessTypeList,
                          BusinessType businessType,
                          String databaseType)

appendTypeAndDefault

protected void appendTypeAndDefault(StringBuffer ddlBuffer,
                                    TableField field,
                                    StandardField standardField)

getComment

protected String getComment(StandardField standardField)

appendComment

protected void appendComment(String comment,
                             StringBuffer ddlBuffer,
                             List<String> list)

appendFooterComment

protected void appendFooterComment(Table table,
                                   List<String> list)

在footer增加comment

Parameters:

table -

list -

appendDefaultValue

protected void appendDefaultValue(String defaultValue,
                                  StringBuffer ddlBuffer)

appendIncrease

protected String appendIncrease()

appendIndexReverse

protected void appendIndexReverse(StringBuffer ddlBuffer,
                                  Index index)

getIndexName

protected String getIndexName(Index index,
                              Table table)

getFieldStdFieldName

protected String getFieldStdFieldName(String fieldId,
                                      Table table)

appendFooter

protected void appendFooter(StringBuffer ddlBuffer,
                            Table table,
                            List<String> list)

appendTableSpace

protected void appendTableSpace(StringBuffer ddlBuffer,
                                Table table)

表空间默认实现

Parameters:

ddlBuffer -

table -

getTableName

protected String getTableName(Table table)

getDropSql

public String getDropSql(Table table,
                         String packageName)

Specified by:

getDropSql in interface TableSqlProcessor

getColumns

protected Map<String,Map<String,String>> getColumns(DatabaseMetaData metadata,
                                                    String catalog,
                                                    Table table)
                                             throws SQLException

Throws:

SQLException

getSchema

protected String getSchema(Table table,
                           DatabaseMetaData metadata)
                    throws SQLException

Throws:

SQLException

checkTableExist

public boolean checkTableExist(Table table,
                               Connection connection)
                        throws SQLException

Specified by:

checkTableExist in interface TableSqlProcessor

Throws:

SQLException

getDbColumnType

protected String getDbColumnType(Map<String,String> attributes)

getDbColumnRemarks

protected String getDbColumnRemarks(Map<String,String> attributes)

获取注释

Parameters:

attributes -

Returns:

getDbColumnColumnDef

protected String getDbColumnColumnDef(Map<String,String> attributes)

获取默认值

Parameters:

attributes -

Returns:

getDefaultValue

protected String getDefaultValue(TableField field,
                                 StandardField standardField)

Parameters:

field -

standardField -

Returns:

dealDateType

protected String dealDateType(String value)

处理日期类型 因为初始化数据是字符串类型,而实际是date类型,有些数据库需要进行转换。

Parameters:

value -

Returns:

delimiter

protected String delimiter(String name)

Parameters:

name -

Returns:

getClearTableSql

public List<String> getClearTableSql(Table table,
                                     Connection connection)
                              throws SQLException

Specified by:

getClearTableSql in interface TableSqlProcessor

Throws:

SQLException

initChar2Byte

public void initChar2Byte(String language)

Specified by:

initChar2Byte in interface TableSqlProcessor