oqtane.framework/Oqtane.Client/Modules/Admin/Sql/Index.razor

@namespace Oqtane.Modules.Admin.Sql
@inherits ModuleBase
@inject NavigationManager NavigationManager
@inject ITenantService TenantService
@inject IDatabaseService DatabaseService
@inject ISqlService SqlService
@inject IStringLocalizer<Index> Localizer
@inject IStringLocalizer<SharedResources> SharedLocalizer

@if (_tenants == null)
{
    <p><em>@SharedLocalizer["Loading"]</em></p>
}
else
{
    <div class="container">

        <div class="row mb-1 align-items-center">
            <Label Class="col-sm-3" For="tenant" HelpText="Select the tenant for the SQL server" ResourceKey="Tenant">Tenant: </Label>
            <div class="col-sm-9">
                <select id="tenant" class="form-select" value="@_tenantid" @onchange="(e => TenantChanged(e))">
                    <option value="-1">&lt;@Localizer["Tenant.Select"]&gt;</option>
                    @foreach (Tenant tenant in _tenants)
                    {
                        <option value="@tenant.TenantId">@tenant.Name</option>
                    }
                </select>
            </div>
        </div>
        @if (_tenantid != "-1")
        {
            <div class="row mb-1 align-items-center">
                <Label Class="col-sm-3" For="database" HelpText="The database for the tenant" ResourceKey="Database">Database: </Label>
                <div class="col-sm-9">
                    <input id="database" class="form-control" @bind="@_database" readonly />
                </div>
            </div>
            <div class="row mb-1 align-items-center">
                <Label Class="col-sm-3" For="connectionstring" HelpText="The connection information for the database" ResourceKey="ConnectionString">Connection: </Label>
                <div class="col-sm-9">
                    <textarea id="connectionstring" class="form-control" @bind="@_connectionstring" rows="2" readonly></textarea>
                </div>
            </div>
            <div class="row mb-1 align-items-center">
                <Label Class="col-sm-3" For="sqlQeury" HelpText="Enter the query for the SQL server" ResourceKey="SqlQuery">SQL Query: </Label>
                <div class="col-sm-9">
                    <textarea id="sqlQeury" class="form-control" @bind="@_sql" rows="5"></textarea>
                </div>
            </div>
        }
    </div>
    <br />
    <button type="button" class="btn btn-success" @onclick="Execute">@Localizer["Execute"]</button>
    <br />
    <br />
    @if (!string.IsNullOrEmpty(_results))
    {
        @((MarkupString)_results)
        <br />
        <br />
    }
}

@code {
    private List<Tenant> _tenants;
    private string _tenantid = "-1";
    private string _database = string.Empty;
    private string _connectionstring = string.Empty;
    private string _sql = string.Empty;
    private string _results = string.Empty;

    public override SecurityAccessLevel SecurityAccessLevel => SecurityAccessLevel.Host;

    protected override async Task OnInitializedAsync()
    {
        try
        {
            _tenants = await TenantService.GetTenantsAsync();
        }
        catch (Exception ex)
        {
            await logger.LogError(ex, "Error Loading Tenants {Error}", ex.Message);
            AddModuleMessage(ex.Message, MessageType.Error);
        }
    }

    private async void TenantChanged(ChangeEventArgs e)
    {
        try
        {
            _tenantid = (string)e.Value;
            var tenants = await TenantService.GetTenantsAsync();
            var _databases = await DatabaseService.GetDatabasesAsync();
            var tenant = tenants.Find(item => item.TenantId == int.Parse(_tenantid));
            if (tenant != null)
            {
                _database = _databases.Find(item => item.DBType == tenant.DBType)?.Name;
                _connectionstring = tenant.DBConnectionString;
            }
            StateHasChanged();
        }
        catch (Exception ex)
        {
            await logger.LogError(ex, "Error Loading Tenant {TenantId} {Error}", _tenantid, ex.Message);
            AddModuleMessage(ex.Message, MessageType.Error);
        }
    }

    private async Task Execute()
    {
        try
        {
            if (_tenantid != "-1" && !string.IsNullOrEmpty(_sql))
            {
                var sqlquery = new SqlQuery { TenantId = int.Parse(_tenantid), Query = _sql };
                sqlquery = await SqlService.ExecuteQueryAsync(sqlquery);
                _results = DisplayResults(sqlquery.Results);
                AddModuleMessage(Localizer["Success.QueryExecuted"], MessageType.Success);
            }
            else
            {
                AddModuleMessage(Localizer["Message.Required.Tenant"], MessageType.Warning);
            }
        }
        catch (Exception ex)
        {
            await logger.LogError(ex, "Error Executing SQL Query {SQL} {Error}", _sql, ex.Message);
            AddModuleMessage(ex.Message, MessageType.Error);
        }
    }

    private string DisplayResults(List<Dictionary<string, string>> results)
    {
        var table = string.Empty;
        foreach (Dictionary<string, string> item in results)
        {
            if (table == string.Empty)
            {
                table = "<div class=\"table-responsive\">";
                table += "<table class=\"table table-bordered\"><thead><tr>";

                foreach (KeyValuePair<string, string> kvp in item)
                {
                    table += "<th scope=\"col\">" + kvp.Key + "</th>";
                }

                table += "</tr></thead><tbody>";
            }

            table += "<tr>";

            foreach (KeyValuePair<string, string> kvp in item)
            {
                table += "<td>" + kvp.Value + "</td>";
            }

            table += "</tr>";
        }

        if (table != string.Empty)
        {
            table += "</tbody></table></div>";
        }
        else
        {
            table = Localizer["Return.NoResult"];
        }

        return table;
    }
}