Поддержка с несколькими арендами для единой базы данных общей схемой ⇐ C#

[Anonymous]

мы используем одну базу данных с моделью с многоцелевой схемой общей схемой, так как это наиболее практичный способ поддержать большое количество арендаторов. < /p>
Есть ли рекомендуем Подход в NPGSQL для автоматического добавления условия TenantID в предложение «Где все вопросы», поэтому разработчикам не нужно вручную включать его в каждый оператор SQL? < /p>
Например, если разработчик пишет: < /p>
SELECT * FROM order;
< /code>
Система должна автоматически преобразовать ее в: < /p>
SELECT * FROM order WHERE tenantid = ;
< /code>
Перед выполнением. < /p>
Схема таблицы: < /p>
CREATE TABLE order (
id INT NOT NULL,
tenantid INT NOT NULL,
name VARCHAR(255)
);
< /code>
Мы ищем способ последовательно обеспечить это в NPGSQL (без структуры сущности, мы используем базовый ngpSQL). < /p>
Подход мы являемся Попытка - это создать пользовательский обработчик команды, однако это требует много обработки условий, как показано в кодовом блоке ниже. Какой лучший подход для достижения этого? < /P>
using Npgsql;
using System;
using System.Text.RegularExpressions;

public class TenantAwareCommand : NpgsqlCommand
{
private readonly TenantContext _tenantContext;

public TenantAwareCommand(string commandText, NpgsqlConnection connection, TenantContext tenantContext)
: base(commandText, connection)
{
_tenantContext = tenantContext;
}

public override async Task ExecuteReaderAsync(CommandBehavior behavior, System.Threading.CancellationToken cancellationToken)
{
AppendTenantIdCondition();
return await base.ExecuteReaderAsync(behavior, cancellationToken);
}

public override async Task ExecuteNonQueryAsync(System.Threading.CancellationToken cancellationToken)
{
AppendTenantIdCondition();
return await base.ExecuteNonQueryAsync(cancellationToken);
}

public override async Task ExecuteScalarAsync(System.Threading.CancellationToken cancellationToken)
{
AppendTenantIdCondition();
return await base.ExecuteScalarAsync(cancellationToken);
}

private void AppendTenantIdCondition()
{
if (string.IsNullOrEmpty(_tenantContext.TenantId))
throw new InvalidOperationException("Tenant ID is not set.");

// Normalize SQL by removing extra whitespaces to avoid errors in parsing
string normalizedQuery = Regex.Replace(CommandText, @"\s+", " ").Trim();

// If the query has no WHERE clause, add the TenantId filter as the first condition
if (!normalizedQuery.Contains("WHERE", StringComparison.OrdinalIgnoreCase))
{
CommandText = $"{CommandText} WHERE TenantId = '{_tenantContext.TenantId}'";
}
else
{
// If there is a WHERE clause, append the TenantId condition using AND
if (!normalizedQuery.Contains("TenantId", StringComparison.OrdinalIgnoreCase))
{
// Ensure it's added as an AND condition if there are already other conditions
CommandText = AppendTenantConditionToExistingWhereClause(normalizedQuery);
}
}
}

private string AppendTenantConditionToExistingWhereClause(string query)
{
// Match the position of the WHERE clause or subqueries to correctly append the TenantId condition
var whereIndex = query.IndexOf("WHERE", StringComparison.OrdinalIgnoreCase);

// If there's an existing WHERE clause, we append with AND
if (whereIndex >= 0)
{
string beforeWhere = query.Substring(0, whereIndex + 5); // "WHERE" + space
string afterWhere = query.Substring(whereIndex + 5).Trim();

// Check if the afterWhere already starts with an AND or other conditions
if (string.IsNullOrEmpty(afterWhere) || afterWhere.StartsWith("AND", StringComparison.OrdinalIgnoreCase))
{
return $"{beforeWhere} TenantId = '{_tenantContext.TenantId}' AND {afterWhere}";
}
else
{
return $"{beforeWhere} TenantId = '{_tenantContext.TenantId}' AND {afterWhere}";
}
}
else
{
// Default case if WHERE is not present but should be handled with OR
return $"{query} WHERE TenantId = '{_tenantContext.TenantId}'";
}
}
}


Подробнее здесь: https://stackoverflow.com/questions/794 ... red-schema