mirror/dble
1
0
Fork 0
mirror of https://github.com/actiontech/dble.git synced 2026-01-04 11:50:15 -06:00
Code Issues Packages Projects Releases Wiki Activity

fix hang inner 1981 (#3473)

Browse Source
This commit is contained in:
ylinzhu
2022-11-15 10:03:58 +08:00
committed by GitHub
parent 0b7b84c14f
commit b3a2fa8a58
2 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/actiontech/dble/services/mysqlsharding/MySQLShardingSQLHandler.java
View File

@@ -48,6 +48,7 @@ public class MySQLShardingSQLHandler {
try {
rrs = RouteService.getInstance().route(schemaConfig, type, sql, service);
if (rrs == null) {
service.writeErrMessage(ErrorCode.ER_PARSE_ERROR, "The sql cannot be parsed to the specified node");
return;
}
if (rrs.getSqlType() == ServerParse.DDL && rrs.getSchema() != null) {

2
src/main/java/com/actiontech/dble/singleton/RouteService.java
View File

@@ -65,6 +65,8 @@ public final class RouteService {
rrs = HintPlanHandler.route(hintInfo.getHintValue(), sqlType, hintInfo.getRealSql());
} else if (type == DbleHintParser.DB_TYPE) {
rrs = HintMasterDBHandler.route(schema, hintInfo.getHintValue(), sqlType, hintInfo.getRealSql(), service);
} else {
throw new SQLException("current hint type is not supported");
}
}