From 99da631aea974465ab842e28485785983c301e76 Mon Sep 17 00:00:00 2001 From: Alessio Dal Santo Date: Wed, 2 Jul 2025 00:22:09 +0200 Subject: [PATCH] Correzione selezione database/schema nell'interfaccia Data Coupler - Implementato discovery intelligente database vs schemi per ogni DBMS - Aggiornate query SQL per mostrare solo database effettivi (non ruoli/schemi di sistema) - Aggiunta UI modal per selezione database con riconnessione automatica - Aggiunta UI modal fallback per selezione schema quando necessario - Migliorate query discovery per SQL Server, PostgreSQL, MySQL e Oracle - Implementata logica di riconnessione automatica al database selezionato - Aggiornati testi e descrizioni dell'interfaccia per maggiore chiarezza - Gestione prioritaria: database disponibili fallback su schemi se necessario Fixes: Menu selezione mostrava ruoli invece dei database reali --- Data_Coupler/Pages/DataCoupler.razor | 71 +++++- Data_Coupler/Pages/DataCoupler.razor.cs | 273 ++++++++++++++++++++++-- 2 files changed, 327 insertions(+), 17 deletions(-) diff --git a/Data_Coupler/Pages/DataCoupler.razor b/Data_Coupler/Pages/DataCoupler.razor index d5c57fb..2d1718c 100644 --- a/Data_Coupler/Pages/DataCoupler.razor +++ b/Data_Coupler/Pages/DataCoupler.razor @@ -1155,7 +1155,7 @@

- Il server non ha un database predefinito. Seleziona il database su cui eseguire le operazioni: + Sono stati trovati più database nel server. Seleziona il database da utilizzare:

@if (availableDatabases != null && availableDatabases.Any()) @@ -1169,6 +1169,10 @@ } + + + Il database determina quali tabelle e viste saranno disponibili per il mapping. +
} else @@ -1185,7 +1189,70 @@ + + + + +} + + +@if (showSchemaSelectionModal) +{ +
+
+
+
+
+ Seleziona Schema +
+
+
+

+ + Sono stati trovati più schemi nel database. Seleziona lo schema da utilizzare: +

+ + @if (isLoadingSchemas) + { +
+ + Caricamento schemi... +
+ } + else if (availableSchemas != null && availableSchemas.Any()) + { +
+ + + + + Lo schema determina quali tabelle e viste saranno disponibili per il mapping. + +
+ } + else + { +
+ + Nessuno schema trovato o errore nel caricamento. +
+ } +
+
+ +
diff --git a/Data_Coupler/Pages/DataCoupler.razor.cs b/Data_Coupler/Pages/DataCoupler.razor.cs index 880a2a5..e4fa7c7 100644 --- a/Data_Coupler/Pages/DataCoupler.razor.cs +++ b/Data_Coupler/Pages/DataCoupler.razor.cs @@ -53,10 +53,14 @@ public partial class DataCoupler // Database selection private List availableDatabases = new(); + private List availableSchemas = new(); private string selectedDatabase = ""; + private string selectedSchema = ""; private bool showDatabaseSelection = false; private bool showDatabaseSelectionModal = false; + private bool showSchemaSelectionModal = false; private bool isLoadingDatabases = false; + private bool isLoadingSchemas = false; // Custom query functionality private bool useCustomQuery = false; @@ -1910,23 +1914,46 @@ public partial class DataCoupler } /// - /// Gestisce la situazione quando è richiesta la selezione di un database specifico + /// Gestisce la situazione quando è richiesta la selezione di un database o schema specifico /// - private void HandleDatabaseSelectionRequired() + private async void HandleDatabaseSelectionRequired() { try { - // Prova a ottenere la lista dei database disponibili - // TODO: Implementare se il DatabaseManager supporta GetAvailableDatabases - Logger.LogInformation("Database selection richiesta - implementazione da completare"); + Logger.LogInformation("Schema discovery non ha restituito risultati. Tentativo di scoprire database disponibili..."); - // Per ora, impostiamo un messaggio di errore informativo - databaseErrorMessage = "Schema discovery non ha restituito risultati. Potrebbe essere necessario specificare un database o schema specifico nella connessione."; + // Prima prova a ottenere la lista dei database disponibili + await LoadAvailableDatabases(); + + if (availableDatabases.Any()) + { + // Se abbiamo database disponibili, mostra il modal per la selezione del database + Logger.LogInformation("Trovati {DatabaseCount} database disponibili", availableDatabases.Count); + showDatabaseSelectionModal = true; + StateHasChanged(); + } + else + { + // Se non ci sono database, prova con gli schemi + await LoadAvailableSchemas(); + + if (availableSchemas.Any()) + { + Logger.LogInformation("Trovati {SchemaCount} schemi disponibili", availableSchemas.Count); + showSchemaSelectionModal = true; + StateHasChanged(); + } + else + { + // Nessuna opzione disponibile + databaseErrorMessage = "Impossibile rilevare database o schemi. Verificare le credenziali di connessione o il tipo di database."; + } + } } catch (Exception ex) { - Logger.LogError(ex, "Errore nella gestione della selezione database"); - databaseErrorMessage = $"Errore nella selezione database: {ex.Message}"; + Logger.LogError(ex, "Errore nella gestione della selezione database/schema"); + databaseErrorMessage = $"Errore nella rilevazione di database/schemi: {ex.Message}"; } } @@ -2166,6 +2193,16 @@ public partial class DataCoupler StateHasChanged(); } + /// + /// Annulla la selezione dello schema + /// + private void CancelSchemaSelection() + { + showSchemaSelectionModal = false; + selectedSchema = ""; + StateHasChanged(); + } + /// /// Conferma la selezione del database /// @@ -2178,19 +2215,225 @@ public partial class DataCoupler try { - // TODO: Implementare la logica per connettersi al database selezionato - Logger.LogInformation("Database selezionato: {Database}", selectedDatabase); + Logger.LogInformation("Database selezionato: {Database}. Riconnessione al database...", selectedDatabase); - // Per ora, chiudi semplicemente il dialog - await Task.CompletedTask; + // Riconnetti al database utilizzando il database selezionato come schema + await ConnectToDatabaseWithSchema(selectedDatabase); + + if (isDatabaseConnected) + { + Logger.LogInformation("Connessione completata con successo usando il database {Database}", selectedDatabase); + databaseErrorMessage = ""; // Pulisci eventuali errori precedenti + } } catch (Exception ex) { - Logger.LogError(ex, "Errore nella selezione del database"); - databaseErrorMessage = $"Errore nella selezione database: {ex.Message}"; + Logger.LogError(ex, "Errore nella connessione con il database selezionato"); + databaseErrorMessage = $"Errore nella connessione con database {selectedDatabase}: {ex.Message}"; } StateHasChanged(); } + + /// + /// Conferma la selezione dello schema + /// + private async Task OnSchemaSelected() + { + if (string.IsNullOrEmpty(selectedSchema)) + return; + + showSchemaSelectionModal = false; + + try + { + Logger.LogInformation("Schema selezionato: {Schema}. Riconnessione al database...", selectedSchema); + + // Riconnetti al database utilizzando lo schema selezionato + await ConnectToDatabaseWithSchema(selectedSchema); + + if (isDatabaseConnected) + { + Logger.LogInformation("Connessione completata con successo usando lo schema {Schema}", selectedSchema); + databaseErrorMessage = ""; // Pulisci eventuali errori precedenti + } + } + catch (Exception ex) + { + Logger.LogError(ex, "Errore nella connessione con lo schema selezionato"); + databaseErrorMessage = $"Errore nella connessione con schema {selectedSchema}: {ex.Message}"; + } + + StateHasChanged(); + } + + /// + /// Carica la lista degli schemi disponibili + /// + private async Task LoadAvailableSchemas() + { + if (currentDatabaseManager == null) + return; + + isLoadingSchemas = true; + availableSchemas.Clear(); + + try + { + // Prova a ottenere tutti gli schemi/database disponibili + // Questo metodo potrebbe non essere disponibile su tutti i database manager + // In tal caso, proveremo con una query diretta + try + { + var allSchemas = await currentDatabaseManager.GetDatabaseSchemaAsync(); + + if (allSchemas != null) + { + // Estrai i nomi degli schemi dalle chiavi delle tabelle + var schemaNames = allSchemas.Keys + .Where(key => key.Contains('.')) + .Select(key => key.Split('.')[0]) + .Distinct() + .OrderBy(schema => schema) + .ToList(); + + if (schemaNames.Any()) + { + availableSchemas.AddRange(schemaNames); + Logger.LogInformation("Rilevati {SchemaCount} schemi dalle tabelle: {Schemas}", + schemaNames.Count, string.Join(", ", schemaNames)); + return; + } + } + } + catch (Exception ex) + { + Logger.LogWarning(ex, "Impossibile ottenere schemi dal database manager, provo con query dirette"); + } + + // Se il metodo sopra non funziona, prova con query SQL specifiche per database + await TryLoadSchemasWithDirectQuery(); + } + catch (Exception ex) + { + Logger.LogError(ex, "Errore nel caricamento degli schemi disponibili"); + } + finally + { + isLoadingSchemas = false; + } + } + + /// + /// Prova a caricare gli schemi con query SQL dirette + /// + private async Task TryLoadSchemasWithDirectQuery() + { + if (currentDatabaseManager == null) + return; + + try + { + // Query diverse per ogni tipo di database - focalizzate sui database/cataloghi + var credential = databaseCredentials.FirstOrDefault(c => c.Name == selectedDatabaseCredential); + if (credential == null) return; + + string? schemaQuery = credential.DatabaseType switch + { + DatabaseType.SqlServer => "SELECT name FROM sys.databases WHERE name NOT IN ('master', 'tempdb', 'model', 'msdb') AND state = 0", + DatabaseType.PostgreSql => "SELECT datname FROM pg_database WHERE datistemplate = false AND datname NOT IN ('postgres', 'template0', 'template1')", + DatabaseType.MySql => "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME NOT IN ('information_schema', 'performance_schema', 'mysql', 'sys')", + DatabaseType.Oracle => "SELECT DISTINCT OWNER FROM ALL_TABLES WHERE OWNER NOT IN ('SYS', 'SYSTEM', 'DBSNMP', 'SYSMAN', 'OUTLN', 'ANONYMOUS', 'CTXSYS', 'EXFSYS', 'LBACSYS', 'MDSYS', 'MGMT_VIEW', 'OLAPSYS', 'OWBSYS', 'ORDDATA', 'ORDSYS', 'SI_INFORMTN_SCHEMA', 'WK_TEST', 'WKPROXY', 'WMSYS', 'XDB', 'APEX_040000', 'APEX_PUBLIC_USER', 'DIP', 'FLOWS_FILES', 'HR', 'IX', 'OE', 'PM', 'SCOTT', 'SH', 'BI')", + _ => null + }; + + if (!string.IsNullOrEmpty(schemaQuery)) + { + Logger.LogInformation("Eseguendo query per database/schemi: {Query}", schemaQuery); + var results = await currentDatabaseManager.ExecuteRawQueryAsync(schemaQuery); + + if (results != null && results.Any()) + { + var schemas = results.Select(row => + { + var firstValue = row.Values.FirstOrDefault(); + return firstValue?.ToString() ?? ""; + }) + .Where(schema => !string.IsNullOrEmpty(schema)) + .OrderBy(schema => schema) + .ToList(); + + if (schemas.Any()) + { + availableSchemas.AddRange(schemas); + Logger.LogInformation("Caricati {SchemaCount} database/schemi via query diretta per {DatabaseType}: {Schemas}", + schemas.Count, credential.DatabaseType, string.Join(", ", schemas)); + } + } + } + } + catch (Exception ex) + { + Logger.LogWarning(ex, "Errore nel caricamento database/schemi via query diretta"); + } + } + + /// + /// Carica la lista dei database disponibili + /// + private async Task LoadAvailableDatabases() + { + if (currentDatabaseManager == null) + return; + + isLoadingDatabases = true; + availableDatabases.Clear(); + + try + { + var credential = databaseCredentials.FirstOrDefault(c => c.Name == selectedDatabaseCredential); + if (credential == null) return; + + string? databaseQuery = credential.DatabaseType switch + { + DatabaseType.SqlServer => "SELECT name FROM sys.databases WHERE name NOT IN ('master', 'tempdb', 'model', 'msdb')", + DatabaseType.PostgreSql => "SELECT datname FROM pg_database WHERE datistemplate = false AND datname NOT IN ('postgres', 'template0', 'template1')", + DatabaseType.MySql => "SELECT SCHEMA_NAME FROM INFORMATION_SCHEMA.SCHEMATA WHERE SCHEMA_NAME NOT IN ('information_schema', 'performance_schema', 'mysql', 'sys')", + _ => null + }; + + if (!string.IsNullOrEmpty(databaseQuery)) + { + var results = await currentDatabaseManager.ExecuteRawQueryAsync(databaseQuery); + + if (results != null && results.Any()) + { + var databases = results.Select(row => + { + var firstValue = row.Values.FirstOrDefault(); + return firstValue?.ToString() ?? ""; + }) + .Where(db => !string.IsNullOrEmpty(db)) + .OrderBy(db => db) + .ToList(); + + if (databases.Any()) + { + availableDatabases.AddRange(databases); + Logger.LogInformation("Caricati {DatabaseCount} database per {DatabaseType}: {Databases}", + databases.Count, credential.DatabaseType, string.Join(", ", databases)); + } + } + } + } + catch (Exception ex) + { + Logger.LogError(ex, "Errore nel caricamento dei database disponibili"); + } + finally + { + isLoadingDatabases = false; + } + } }