xiaoxue_admin
/
dbx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(dameng): 修复物化视图相关问题 

排除达表节点中的物化视图
修复使用使用SYSDBA登录时无法获取物化视图

Co-authored-by: qmk <qinmingk@sina.com>
This commit is contained in:
private20 2026-06-27 21:44:35 +08:00 committed by GitHub
parent e9e9e8587a
commit 2835460c03
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
agents/drivers/dameng/src/main/java/com/dbx/agent/dameng/DamengAgent.java
View File

@ -176,7 +176,7 @@ public final class DamengAgent extends BaseDatabaseAgent {
SELECT o.OBJECT_NAME AS TABLE_NAME, c.COMMENTS
FROM ALL_OBJECTS o
LEFT JOIN ALL_TAB_COMMENTS c ON c.OWNER = o.OWNER AND c.TABLE_NAME = o.OBJECT_NAME
WHERE o.OWNER = ? AND o.OBJECT_TYPE = '%s'
WHERE o.OWNER = ? AND o.OBJECT_TYPE = '%s' AND ( (o.OBJECT_TYPE = 'TABLE' AND o.OBJECT_NAME NOT LIKE 'MTAB$_%%') OR o.OBJECT_TYPE = 'VIEW')
ORDER BY o.OBJECT_NAME
""").formatted(tableType).stripIndent().trim();
try (PreparedStatement stmt = requireConnected().prepareStatement(sql)) {
@ -196,7 +196,7 @@ public final class DamengAgent extends BaseDatabaseAgent {
String sql = ("""
SELECT TABLE_NAME, COMMENTS
FROM ALL_TAB_COMMENTS
WHERE OWNER = ? AND TABLE_TYPE = '%s'
WHERE OWNER = ? AND TABLE_TYPE = '%s' AND ( (o.OBJECT_TYPE = 'TABLE' AND o.OBJECT_NAME NOT LIKE 'MTAB$_%') OR o.OBJECT_TYPE = 'VIEW')
ORDER BY TABLE_NAME
""").formatted(tableType).stripIndent().trim();
try (PreparedStatement stmt = requireConnected().prepareStatement(sql)) {
@ -213,16 +213,16 @@ public final class DamengAgent extends BaseDatabaseAgent {
private void loadMaterializedViews(String schema, Map<String, TableInfo> tablesByName) {
loadMaterializedViewsFromAllObjects(schema, tablesByName);
loadMaterializedViewsFromUserMviews(schema, tablesByName);
//loadMaterializedViewsFromUserMviews(schema, tablesByName);
}
private void loadMaterializedViewsFromAllObjects(String schema, Map<String, TableInfo> tablesByName) {
String sql = """
SELECT o.OBJECT_NAME AS TABLE_NAME, c.COMMENTS
FROM ALL_OBJECTS o
LEFT JOIN ALL_TAB_COMMENTS c ON c.OWNER = o.OWNER AND c.TABLE_NAME = o.OBJECT_NAME
WHERE o.OWNER = ? AND o.OBJECT_TYPE IN ('MATERIALIZED VIEW', 'MATERIALIZED_VIEW')
ORDER BY o.OBJECT_NAME
SELECT m.MVIEW_NAME AS TABLE_NAME, c.COMMENTS
FROM USER_MVIEWS m LEFT JOIN ALL_OBJECTS o ON m.SCHID = o.OBJECT_ID
LEFT JOIN ALL_TAB_COMMENTS c ON c.OWNER = o.OWNER AND c.TABLE_NAME = m.MVIEW_NAME
WHERE o.OWNER = ?
ORDER BY TABLE_NAME
""".stripIndent().trim();
try (PreparedStatement stmt = requireConnected().prepareStatement(sql)) {
stmt.setString(1, schema);
@ -256,9 +256,9 @@ public final class DamengAgent extends BaseDatabaseAgent {
}
private void removeMaterializedViewsFromRegularViews(String schema, Map<String, TableInfo> tablesByName) {
if (!schemaMatchesConnectedUser(schema)) {
/*if (!schemaMatchesConnectedUser(schema)) {
return;
}
}*/
for (String name : listUserMviewNames()) {
tablesByName.remove(name);
}