fix(dameng): support configurable system schemas

apps/desktop/src/lib/connection/connectionVisibleDatabases.ts

@@ -12,6 +12,8 @@ type VisibleDatabaseConnectionFields = Pick<
   "db_type" | "driver_profile" | "host" | "port" | "username" | "database" | "connection_string" | "url_params" | "redis_connection_mode" | "redis_sentinel_master" | "redis_sentinel_nodes" | "redis_cluster_nodes" | "etcd_endpoints" | "jdbc_driver_class"
 >;
 
+type VisibleObjectFilterConnectionFields = VisibleDatabaseConnectionFields & Pick<ConnectionConfig, "visible_databases" | "visible_schemas">;
+
 export function buildDraftVisibleDatabasesConnectionId(seed: string): string {
   return `${DRAFT_VISIBLE_DATABASES_PREFIX}${seed}`;
 }
@@ -38,6 +40,12 @@ export function visibleDatabaseSelectionIsStale(previous: VisibleDatabaseConnect
   return visibleDatabaseFingerprint(previous) !== visibleDatabaseFingerprint(current);
 }
 
+export function visibleObjectFiltersNeedReset(previous: VisibleObjectFilterConnectionFields, current: VisibleObjectFilterConnectionFields): boolean {
+  const hasVisibleDatabaseFilter = Array.isArray(current.visible_databases);
+  const hasVisibleSchemaFilter = !!current.visible_schemas && Object.keys(current.visible_schemas).length > 0;
+  return (hasVisibleDatabaseFilter || hasVisibleSchemaFilter) && visibleDatabaseSelectionIsStale(previous, current);
+}
+
 function visibleDatabaseFingerprint(connection: VisibleDatabaseConnectionFields): string {
   return JSON.stringify({
     db_type: connection.db_type,

apps/desktop/src/lib/database/visibleDatabases.ts

@@ -51,7 +51,7 @@ const SYSTEM_DATABASE_RULES: Partial<Record<DatabaseType, ReadonlySet<string>>>
     "xdb",
     "xs$null",
   ]),
-  dameng: new Set(["ctisys", "dba", "sys", "sysauditor", "syssso", "system"]),
+  dameng: new Set(["_sys_statistics", "ctisys", "dba", "sys", "sys_dba", "sys_phm", "sysauditor", "sysdba", "sysdbo", "syssso", "system"]),
   saphana: new Set(["_sys_afl", "_sys_bi", "_sys_bic", "_sys_repo", "_sys_statistics", "sys"]),
   cassandra: new Set(["system", "system_auth", "system_distributed", "system_schema", "system_traces", "system_views", "system_virtual_schema"]),
   neo4j: new Set(["system"]),
@@ -102,6 +102,11 @@ export function filterDatabaseNamesForVisiblePicker(databaseNames: string[], con
   return databaseNames.filter((name) => !isSystemDatabaseName(connection?.db_type, name));
 }
 
+export function filterSchemaNamesForVisiblePicker(schemaNames: string[], connection: Partial<Pick<ConnectionConfig, "db_type" | "username">> | undefined): string[] {
+  const currentSchema = connection?.username?.trim().toLowerCase();
+  return schemaNames.filter((name) => name.toLowerCase() === currentSchema || !isSystemDatabaseName(connection?.db_type, name));
+}
+
 export function connectionUsesVisibleSchemaFilter(connection: Pick<ConnectionConfig, "db_type"> | undefined): boolean {
   return connection?.db_type === "oracle" || connection?.db_type === "dameng" || connection?.db_type === "oceanbase-oracle";
 }
@@ -110,13 +115,13 @@ export function visibleSchemaFilterIsEnabled(visibleSchemas: Record<string, stri
   return Array.isArray(visibleSchemas?.[database]);
 }
 
-export function filterSchemaNamesForConnection(schemaNames: string[], connection: Pick<ConnectionConfig, "db_type" | "visible_schemas" | "visible_databases"> | undefined, database: string): string[] {
+export function filterSchemaNamesForConnection(schemaNames: string[], connection: (Pick<ConnectionConfig, "db_type" | "visible_schemas" | "visible_databases"> & Partial<Pick<ConnectionConfig, "username">>) | undefined, database: string): string[] {
   const visibleSchemas = connection?.visible_schemas;
   if (!visibleSchemaFilterIsEnabled(visibleSchemas, database)) {
     if (connectionUsesVisibleSchemaFilter(connection) && visibleDatabaseFilterIsEnabled(connection?.visible_databases)) {
       return filterVisibleDatabaseNames(schemaNames, connection?.visible_databases);
     }
-    return schemaNames.filter((name) => !isSystemDatabaseName(connection?.db_type, name));
+    return filterSchemaNamesForVisiblePicker(schemaNames, connection);
   }
   const visible = new Set(visibleSchemas![database]);
   return schemaNames.filter((name) => visible.has(name));