orga0063
/
BootstrapAdmin11
4
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix: 数据库健康检查支持 MongoDB

This commit is contained in:
Argo Zhang 2019-08-23 22:33:44 +08:00
parent 217af27c41
commit 1cf5de03ec
1 changed files with 32 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
Bootstrap.Admin/HealthChecks/DBHealthCheck.cs
View File

@ -1,6 +1,7 @@
using Bootstrap.DataAccess;
using Bootstrap.Security;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Diagnostics.HealthChecks;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading;
@ -14,6 +15,20 @@ namespace Bootstrap.Admin.HealthChecks
/// </summary>
public class DBHealthCheck : IHealthCheck
{
private IConfiguration _configuration;
private static readonly Func<IConfiguration, string, string> ConnectionStringResolve = (c, name) => string.IsNullOrEmpty(name)
? c.GetSection("ConnectionStrings").GetChildren().FirstOrDefault()?.Value
: c.GetConnectionString(name);
/// <summary>
/// 构造函数
/// </summary>
/// <param name="configuration"></param>
public DBHealthCheck(IConfiguration configuration)
{
_configuration = configuration;
}
/// <summary>
/// 异步检查方法
/// </summary>
@ -22,18 +37,23 @@ namespace Bootstrap.Admin.HealthChecks
/// <returns></returns>
public Task<HealthCheckResult> CheckHealthAsync(HealthCheckContext context, CancellationToken cancellationToken = default)
{
using (var db = DbManager.Create())
{
var connStr = db.ConnectionString;
var dicts = db.Fetch<BootstrapDict>("Select * from Dicts");
var data = new Dictionary<string, object>()
var db = _configuration.GetSection("DB").GetChildren()
.Select(config => new
{
{ "ConnectionString", connStr },
{ "DbType", db.Provider.GetType().Name },
{ "Dicts", dicts.Count }
};
return dicts.Any() ? Task.FromResult(HealthCheckResult.Healthy("Ok", data)) : Task.FromResult(HealthCheckResult.Degraded("No init data in DB"));
}
Enabled = bool.TryParse(config["Enabled"], out var en) ? en : false,
ProviderName = config["ProviderName"],
Widget = config["Widget"],
ConnectionString = ConnectionStringResolve(config.GetSection("ConnectionStrings").Exists() ? config : _configuration, string.Empty)
}).FirstOrDefault(i => i.Enabled);
var dicts = DictHelper.RetrieveDicts();
var data = new Dictionary<string, object>()
{
{ "ConnectionString", db.ConnectionString },
{ "Widget", db.Widget },
{ "DbType", db.ProviderName },
{ "Dicts", dicts.Count() }
};
return dicts.Any() ? Task.FromResult(HealthCheckResult.Healthy("Ok", data)) : Task.FromResult(HealthCheckResult.Degraded("No init data in DB"));
}
}
}