mirror of
https://github.com/actiontech/dble.git
synced 2026-04-28 10:10:22 -05:00
@@ -186,10 +186,10 @@ public final class SchemaUtil {
|
|||||||
private static boolean isNoSharding(ShardingService service, SQLExprTableSource table, SQLStatement stmt, SQLStatement childSelectStmt, String contextSchema, Set<String> schemas, StringPtr shardingNode)
|
private static boolean isNoSharding(ShardingService service, SQLExprTableSource table, SQLStatement stmt, SQLStatement childSelectStmt, String contextSchema, Set<String> schemas, StringPtr shardingNode)
|
||||||
throws SQLException {
|
throws SQLException {
|
||||||
SchemaInfo schemaInfo = SchemaUtil.getSchemaInfo(service.getUser(), contextSchema, table);
|
SchemaInfo schemaInfo = SchemaUtil.getSchemaInfo(service.getUser(), contextSchema, table);
|
||||||
String currentSchema = schemaInfo.schema.toUpperCase();
|
|
||||||
if (schemaInfo.dual) {
|
if (schemaInfo.dual) {
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
String currentSchema = schemaInfo.schema.toUpperCase();
|
||||||
if (SchemaUtil.MYSQL_SYS_SCHEMA.contains(currentSchema)) {
|
if (SchemaUtil.MYSQL_SYS_SCHEMA.contains(currentSchema)) {
|
||||||
schemas.add(currentSchema);
|
schemas.add(currentSchema);
|
||||||
return false;
|
return false;
|
||||||
|
|||||||
Reference in New Issue
Block a user