MES-ETL/MesETL.Test/MesDatabaseHelper.cs
2024-02-10 17:12:26 +08:00

21 lines
586 B
C#

using MesETL.App.Helpers;
using MesETL.Shared.Helper;
namespace TestProject1;
public static class MesDatabaseHelper
{
public static async Task<int?> TrySearchCompanyId(string connStr, IEnumerable<string> dbNames, string scalarQuery)
{
foreach (var db in dbNames)
{
var result = await DatabaseHelper.QueryScalarAsync(connStr + $"Database={db};", scalarQuery);
if (result is null or 0) continue;
var companyId = Convert.ToInt32(result);
return companyId;
}
return null;
}
}