本文整理了Java中net.sf.jsqlparser.schema.Table.getName()
方法的一些代码示例,展示了Table.getName()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Table.getName()
方法的具体详情如下:
包路径:net.sf.jsqlparser.schema.Table
类名称:Table
方法名:getName
暂无
代码示例来源:origin: baomidou/mybatis-plus
/**
* 租户字段别名设置
* <p>tableName.tenantId 或 tableAlias.tenantId</p>
*
* @param table 表对象
* @return 字段
*/
protected Column getAliasColumn(Table table) {
StringBuilder column = new StringBuilder();
if (null == table.getAlias()) {
column.append(table.getName());
} else {
column.append(table.getAlias().getName());
}
column.append(StringPool.DOT);
column.append(tenantHandler.getTenantIdColumn());
return new Column(column.toString());
}
}
代码示例来源:origin: baomidou/mybatis-plus
String tableInfo = table.getName();
代码示例来源:origin: baomidou/mybatis-plus
/**
* update 语句处理
*/
@Override
public void processUpdate(Update update) {
List<Table> tableList = update.getTables();
Assert.isTrue(null != tableList && tableList.size() < 2,
"Failed to process multiple-table update, please exclude the statementId");
Table table = tableList.get(0);
if (tenantHandler.doTableFilter(table.getName())) {
// 过滤退出执行
return;
}
update.setWhere(this.andExpression(table, update.getWhere()));
}
代码示例来源:origin: JSQLParser/JSqlParser
@Override
public void visit(Column tableColumn) {
if (allowColumnProcessing && tableColumn.getTable() != null && tableColumn.getTable().getName() != null) {
visit(tableColumn.getTable());
}
}
代码示例来源:origin: pagehelper/Mybatis-PageHelper
allColumnsTables.add(((AllTableColumns) item).getTable().getName());
String table = ((Column) expression).getTable().getName();
if (table == null) { // 表名为空
if (allColumns ||
代码示例来源:origin: baomidou/mybatis-plus
/**
* delete 语句处理
*/
@Override
public void processDelete(Delete delete) {
if (tenantHandler.doTableFilter(delete.getTable().getName())) {
// 过滤退出执行
return;
}
delete.setWhere(this.andExpression(delete.getTable(), delete.getWhere()));
}
代码示例来源:origin: baomidou/mybatis-plus
/**
* 处理联接语句
*/
protected void processJoin(Join join) {
if (join.getRightItem() instanceof Table) {
Table fromTable = (Table) join.getRightItem();
if (this.tenantHandler.doTableFilter(fromTable.getName())) {
// 过滤退出执行
return;
}
join.setOnExpression(builderExpression(join.getOnExpression(), fromTable));
}
}
代码示例来源:origin: codingapi/tx-lcn
});
for (Table table : update.getTables()) {
tables.add(table.getName());
TableStruct tableStruct = tableStructAnalyser.analyse(connection, table.getName());
tableStruct.getPrimaryKeys().forEach(key -> primaryKeys.add(table.getName() + "." + key));
代码示例来源:origin: codingapi/tx-lcn
Connection connection = (Connection) DTXLocal.cur().getResource();
Insert insert = (Insert) statementInformation.getAttachment();
TableStruct tableStruct = tableStructAnalyser.analyse(connection, insert.getTable().getName());
代码示例来源:origin: baomidou/mybatis-plus
/**
* insert 语句处理
*/
@Override
public void processInsert(Insert insert) {
if (tenantHandler.doTableFilter(insert.getTable().getName())) {
// 过滤退出执行
return;
}
insert.getColumns().add(new Column(tenantHandler.getTenantIdColumn()));
if (insert.getSelect() != null) {
processPlainSelect((PlainSelect) insert.getSelect().getSelectBody(), true);
} else if (insert.getItemsList() != null) {
// fixed github pull/295
ItemsList itemsList = insert.getItemsList();
if (itemsList instanceof MultiExpressionList) {
((MultiExpressionList) itemsList).getExprList().forEach(el -> el.getExpressions().add(tenantHandler.getTenantId()));
} else {
((ExpressionList) insert.getItemsList()).getExpressions().add(tenantHandler.getTenantId());
}
} else {
throw ExceptionUtils.mpe("Failed to process multiple-table update, please exclude the tableName or statementId");
}
}
代码示例来源:origin: codingapi/tx-lcn
TableStruct tableStruct = tableStructAnalyser.analyse(connection, table.getName());
tableStruct.getColumns().forEach((k, v) -> {
columns.add(tableStruct.getTableName() + SqlUtils.DOT + k);
代码示例来源:origin: baomidou/mybatis-plus
/**
* 处理 PlainSelect
*
* @param plainSelect ignore
* @param addColumn 是否添加租户列,insert into select语句中需要
*/
protected void processPlainSelect(PlainSelect plainSelect, boolean addColumn) {
FromItem fromItem = plainSelect.getFromItem();
if (fromItem instanceof Table) {
Table fromTable = (Table) fromItem;
if (tenantHandler.doTableFilter(fromTable.getName())) {
// 过滤退出执行
return;
}
plainSelect.setWhere(builderExpression(plainSelect.getWhere(), fromTable));
if (addColumn) {
plainSelect.getSelectItems().add(new SelectExpressionItem(new Column(tenantHandler.getTenantIdColumn())));
}
} else {
processFromItem(fromItem);
}
List<Join> joins = plainSelect.getJoins();
if (joins != null && joins.size() > 0) {
joins.forEach(j -> {
processJoin(j);
processFromItem(j.getRightItem());
});
}
}
代码示例来源:origin: codingapi/tx-lcn
Connection connection = (Connection) DTXLocal.cur().getResource();
TableStruct leftTableStruct = tableStructAnalyser.analyse(connection, leftTable.getName());
leftTableStruct.getPrimaryKeys().forEach(primaryKey -> {
Column column = new Column(leftTable, primaryKey);
代码示例来源:origin: baomidou/mybatis-plus
Expression rightExpression = ((BinaryExpression) expression).getRightExpression();
if (joinTable != null && rightExpression instanceof Column) {
if (Objects.equals(((Column) rightExpression).getTable().getName(), table.getAlias().getName())) {
validUseIndex(table, ((Column) rightExpression).getColumnName(), connection);
validUseIndex(joinTable, ((Column) leftExpression).getColumnName(), connection);
代码示例来源:origin: geotools/geotools
private static List getTableColumns(ISession session, Table table) throws IOException {
List colNames = new ArrayList();
String tableName = table.getSchemaName() + "." + table.getName();
SeColumnDefinition[] cols = session.describe(tableName);
for (int i = 0; i < cols.length; i++) {
String colName = cols[i].getName();
colName = tableName + "." + colName;
colNames.add(colName);
}
return colNames;
}
}
代码示例来源:origin: geotools/geotools
final String userName;
qualifiedTable.setName(table.getName());
qualifiedTable.setAlias(table.getAlias());
代码示例来源:origin: geotools/geotools
Table unaliasedTable = (Table) tableAliases.get(qt.getName());
String tableName = qt.getSchemaName() + "." + qt.getName();
SeColumnDefinition[] cols;
try {
代码示例来源:origin: geotools/geotools
public static Column qualify(
ISession session, Map<String, Object> tableAliases, Column column) {
Table table = column.getTable();
String columnName = column.getColumnName();
Table unaliasedTable = (Table) tableAliases.get(table.getName());
Table qualifiedTable;
if (unaliasedTable == null) {
// not an aliased table, qualify it
qualifiedTable = TableQualifier.qualify(session, table);
} else {
// AllTableColumns is refering to an aliased table in the FROM
// clause,
// replace its table by the original one to get rid of the alias
qualifiedTable = unaliasedTable;
}
Column qualifiedColumn = new Column();
qualifiedColumn.setColumnName(columnName);
qualifiedColumn.setTable(qualifiedTable);
return qualifiedColumn;
}
}
代码示例来源:origin: com.manydesigns/portofino-database
private static boolean hasEntityAlias(String entityName, FromItem fromItem) {
return fromItem instanceof net.sf.jsqlparser.schema.Table &&
((net.sf.jsqlparser.schema.Table) fromItem).getName().equals(entityName) &&
fromItem.getAlias() != null &&
!StringUtils.isBlank(fromItem.getAlias().getName());
}
代码示例来源:origin: io.konig/konig-schemagen
private Shape createTableShape(CreateTable createTable, List<ColumnDefinition> columnList) {
String tableName = createTable.getTable().getName();
String shapeId = tableName.replaceAll(tableConfig.getTableIriTemplate().getIriPattern(), tableConfig.getTableIriTemplate().getIriReplacement());
Shape shape = new Shape(new URIImpl(shapeId));
addPropertyContraint(shape, columnList);
return shape;
}
内容来源于网络,如有侵权,请联系作者删除!