public class DmTableOperator extends BaseTableOperator
dialect, jdbcTemplate, logger| 构造器和说明 |
|---|
DmTableOperator() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
addColumn(String tableName,
Column model)
在表中添加列。
|
void |
addForeignKey(String pkTableName,
String fkTableName,
String pkField,
String fkField)
添加外键
|
void |
createPartition(String tableName,
String partition)
创建分区。
|
void |
createTable(Table table)
根据Tble创建表。
|
void |
dropForeignKey(String tableName,
String keyName)
删除外键
|
void |
dropTable(String tableName)
根据表名删除表。
|
String |
getColumnType(Column column)
获取字段类型
|
String |
getColumnType(String columnType,
int charLen,
int intLen,
int decimalLen)
获取字段类型
|
Map<String,List<String>> |
getPKColumns(List<String> tableNames)
根据表名列表,取得相应的主键的列列表的Map。
|
List<String> |
getPKColumns(String tableName)
根据表名,取得相应的主键的列表
|
boolean |
isExsitPartition(String tableName,
String partition)
判断指定表的分区是否存在。
|
boolean |
isTableExist(String tableName)
判断表是否存在。
|
boolean |
supportPartition(String tableName)
是否支持分区。
|
void |
updateColumn(String tableName,
String columnName,
Column column)
更新列。
|
void |
updateTableComment(String tableName,
String comment)
修改表的注释
|
replaceLineThroughsetDialect, setJdbcTemplateclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetDialect, setJdbcTemplatepublic void createTable(Table table) throws SQLException
ITableOperatortable - 表SQLExceptionpublic String getColumnType(Column column)
ITableOperatorcolumn - 字段public String getColumnType(String columnType, int charLen, int intLen, int decimalLen)
ITableOperatorcolumnType - 字段类型charLen - 字符串长度intLen - 整型长度decimalLen - 小数长度public void dropTable(String tableName) throws SQLException
ITableOperatorSQLExceptionpublic void updateTableComment(String tableName, String comment) throws SQLException
ITableOperatortableName - 表名comment - 表注释SQLExceptionpublic void addColumn(String tableName, Column model) throws SQLException
ITableOperatortableName - 表名model - 字段SQLExceptionpublic void updateColumn(String tableName, String columnName, Column column) throws SQLException
ITableOperatortableName - 表名columnName - 列名column - 字段SQLExceptionpublic void addForeignKey(String pkTableName, String fkTableName, String pkField, String fkField)
ITableOperatorpkTableName - 主键表fkTableName - 外键表pkField - 主键fkField - 外键public void dropForeignKey(String tableName, String keyName)
ITableOperatorpublic List<String> getPKColumns(String tableName) throws SQLException
ITableOperatortableName - 表名SQLExceptionpublic Map<String,List<String>> getPKColumns(List<String> tableNames) throws SQLException
ITableOperatortableNames - 表名列表SQLExceptionpublic boolean isTableExist(String tableName)
ITableOperatorpublic boolean isExsitPartition(String tableName, String partition)
ITableOperatorpublic void createPartition(String tableName, String partition)
ITableOperatorpublic boolean supportPartition(String tableName)
ITableOperatorCopyright © 2018. All rights reserved.