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

fix: view name parse issue

Browse Source 
npe when no database selected

(cherry picked from commit 2d0bca0085)
This commit is contained in:
guoaomen
2023-04-04 15:59:04 +08:00
committed by wenyh1
parent 97ff060e2d
commit f9b92e7199
3 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
src/main/java/com/actiontech/dble/meta/ViewMetaParser.java
View File

@@ -73,7 +73,6 @@ public class ViewMetaParser {
continue;
case '/':
offset = ParseUtil.comment(originalSql, offset);
offset++;
break;
case 'a':
offset = offset + 5;

3
src/main/java/com/actiontech/dble/route/parser/druid/impl/ddl/DruidAlterViewParser.java
View File

@@ -31,7 +31,8 @@ public class DruidAlterViewParser extends DruidImplicitCommitParser {
@Override
public SchemaConfig doVisitorParse(SchemaConfig schema, RouteResultset rrs, SQLStatement stmt, ServerSchemaStatVisitor visitor, ShardingService service, boolean isExplain) throws SQLException {
String sql = rrs.getStatement();
vm = new ViewMeta(schema.getName(), sql, ProxyMeta.getInstance().getTmManager());
String schemaName = schema == null ? null : schema.getName();
vm = new ViewMeta(schemaName, sql, ProxyMeta.getInstance().getTmManager());
vm.init();
checkSchema(vm.getSchema());
PlanNode oldViewNode = ProxyMeta.getInstance().getTmManager().getSyncView(vm.getSchema(), vm.getViewName());

3
src/main/java/com/actiontech/dble/route/parser/druid/impl/ddl/DruidCreateOrReplaceViewParser.java
View File

@@ -32,7 +32,8 @@ public class DruidCreateOrReplaceViewParser extends DruidImplicitCommitParser {
@Override
public SchemaConfig doVisitorParse(SchemaConfig schema, RouteResultset rrs, SQLStatement stmt, ServerSchemaStatVisitor visitor, ShardingService service, boolean isExplain) throws SQLException {
String sql = rrs.getStatement();
vm = new ViewMeta(schema.getName(), sql, ProxyMeta.getInstance().getTmManager());
String schemaName = schema == null ? null : schema.getName();
vm = new ViewMeta(schemaName, sql, ProxyMeta.getInstance().getTmManager());
vm.init();
SQLCreateViewStatement createViewStatement = (SQLCreateViewStatement) stmt;
checkSchema(vm.getSchema());