database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[fix](row-policy) row policy supports external catalog (#19570)

Browse Source 
Row policy support external catalog
This commit is contained in:
Stalary
2023-05-16 08:54:06 +08:00
committed by GitHub
parent 9535ed01aa
commit 9cede6d763
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
fe/fe-core/src/main/java/org/apache/doris/analysis/StmtRewriter.java
View File

@ -21,7 +21,7 @@
package org.apache.doris.analysis;
import org.apache.doris.catalog.Column;
import org.apache.doris.catalog.Database;
import org.apache.doris.catalog.DatabaseIf;
import org.apache.doris.catalog.Env;
import org.apache.doris.catalog.ScalarType;
import org.apache.doris.catalog.TableIf;
@ -1322,7 +1322,8 @@ public class StmtRewriter {
if (dbName == null) {
dbName = analyzer.getDefaultDb();
}
Database db = currentEnv.getInternalCatalog().getDbOrAnalysisException(dbName);
DatabaseIf db = currentEnv.getCatalogMgr().getCatalogOrAnalysisException(tableRef.getName().getCtl())
.getDbOrAnalysisException(dbName);
long dbId = db.getId();
long tableId = table.getId();
RowPolicy matchPolicy = currentEnv.getPolicyMgr().getMatchTablePolicy(dbId, tableId, user);