83 lines
2.7 KiB
C#
83 lines
2.7 KiB
C#
using System.Reflection;
|
||
using DispenserCommon.Events;
|
||
using DispenserCommon.Utils;
|
||
using SQLite;
|
||
|
||
namespace DispenserCommon.DB;
|
||
|
||
/// <summary>
|
||
/// 在系统启动的时候记进行数据库初始化校验
|
||
/// </summary>
|
||
public class DatabaseInitializer
|
||
{
|
||
private static readonly SqliteHelper Sqlite = ServiceLocator.GetService<SqliteHelper>();
|
||
|
||
public static void Initialize()
|
||
{
|
||
EventBus<string>.Publish(EventType.SetupNotify, "正在初始化数据库");
|
||
|
||
// 扫描所有带有[Table]特性的类
|
||
var tables = GetAssemblies()
|
||
.SelectMany(a => a.GetTypes()
|
||
.Where(t => t.GetCustomAttributes(typeof(TableAttribute), true).Length > 0))
|
||
.ToList();
|
||
|
||
|
||
tables.ForEach(table =>
|
||
{
|
||
// 判断当前的表是否存在
|
||
var tableName = table.GetCustomAttribute<TableAttribute>()?.Name ?? table.Name;
|
||
|
||
var tableInfo = Sqlite.GetTableInfo(tableName);
|
||
|
||
if (!tableInfo.Any())
|
||
{
|
||
Sqlite.CreateTable(table);
|
||
}
|
||
else
|
||
{
|
||
// 读取当前类的变量是否新增了属性
|
||
var properties = table.GetProperties();
|
||
var colNames = tableInfo.Select(col => col.Name.ToUpper()).ToHashSet();
|
||
|
||
foreach (var property in properties)
|
||
{
|
||
var colName = property.GetCustomAttribute<ColumnAttribute>()?.Name ?? property.Name;
|
||
|
||
// 统一转为大写进行判断
|
||
if (colNames.Contains(colName.ToUpper())) continue;
|
||
// 重新进行DDL时，会自动的判断是否存在新增的列，如果有则自动进行新增
|
||
Sqlite.CreateTable(table);
|
||
}
|
||
}
|
||
});
|
||
}
|
||
|
||
|
||
private static IEnumerable<Assembly> GetAssemblies()
|
||
{
|
||
var assemblies = new List<Assembly>();
|
||
foreach (var assembly in AppDomain.CurrentDomain.GetAssemblies())
|
||
{
|
||
var name = assembly.GetName().Name;
|
||
if (name != null && name.ToLower().Contains("dispenser")) GetReferenceAssemblies(assembly, assemblies);
|
||
}
|
||
|
||
return assemblies;
|
||
}
|
||
|
||
private static void GetReferenceAssemblies(Assembly assembly, ICollection<Assembly> assemblies)
|
||
{
|
||
foreach (var assemblyName in assembly.GetReferencedAssemblies())
|
||
{
|
||
var name = assemblyName.Name;
|
||
if (name != null && name.ToLower().Contains("dispenser"))
|
||
{
|
||
var ass = Assembly.Load(assemblyName);
|
||
if (assemblies.Contains(ass)) continue;
|
||
assemblies.Add(ass);
|
||
GetReferenceAssemblies(ass, assemblies);
|
||
}
|
||
}
|
||
}
|
||
} |