Avalonia 使用EFCore调用SQLite实现Singleton全局注册

本篇博客是我的开源项目TerraMours.Chat.Ava的更新的记录分享，本次更新使用EntityFrameWork Core调用SQLite，实现数据的本地化和查询的优化，删除了dbpross类（直接调用SQLite的操作类）。大大提高了代码的简洁度和易读性。通过全局注册的ChatDbcontext对象，是操作数据库变的非常方便。对项目感兴趣的同学可以到github上搜索TerraMours.Chat.Ava。希望通过该项目了解和学习Avalonia开发的朋友可以在我的github上拉取代码，同时希望大家多多点点star。

https://github.com/raokun/TerraMours.Chat.Ava

项目的基础通用功能和业务代码开发在之前博客中介绍过了，想了解的同学跳转学习：

基于Avalonia 11.0.0+ReactiveUI 的跨平台项目开发1-通用框架

基于Avalonia 11.0.0+ReactiveUI 的跨平台项目开发2-功能开发

了解Avalonia创建模板项目-基础可跳转：

创建Avalonia 模板项目-基础

本次我主要分享的内容是项目中使用EFCore调用SQLite的实现。

1.安装nuget包

<PackageReference Include="Microsoft.EntityFrameworkCore.Sqlite" Version="8.0.0-preview.6.23329.4" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Tools" Version="8.0.0-preview.6.23329.4">
    <PrivateAssets>all</PrivateAssets>
    <IncludeAssets>runtime; build; native; contentfiles; analyzers</IncludeAssets>
</PackageReference>

2.创建一个继承自 `DbContext` 的类

创建ChatDbcontext继承自 DbContext 的类，并在构造函数中将连接字符串传递给 DbContextOptions 对象。

代码如下：

public class ChatDbcontext :DbContext{
    public DbSet<ChatMessage> ChatMessages { get; set; }
    public DbSet<ChatList> ChatLists { get; set; }

    protected override void OnConfiguring(DbContextOptionsBuilder options)
        => options.UseSqlite($"Data Source={AppSettings.Instance.DbPath}"); // 这里是您的 SQLite 连接字符串
    protected override void OnModelCreating(ModelBuilder modelBuilder) {
        // 添加实体配置
        modelBuilder.Entity<ChatMessage>().HasKey(e => e.ChatRecordId);
        modelBuilder.Entity<ChatList>().HasKey(e => e.Id);

        base.OnModelCreating(modelBuilder);
    }

    //切换数据库连接
    public void ChangeConnection(string connectionString) {
        // 修改数据库连接字符串，并重新配置 DbContext
        Database.GetDbConnection().ConnectionString = connectionString;
        ChangeTracker.AutoDetectChangesEnabled = false;
        ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
        ChangeTracker.AutoDetectChangesEnabled = true;
    }
    /// <summary>
    /// 检查表是否存在
    /// </summary>
    /// <typeparam name="T"></typeparam>
    /// <returns></returns>
    public bool CheckIfTableExists<T>() where T : class {
        var tableExists = this.Model.FindEntityType(typeof(T)) != null;

        return tableExists;
    }

}

其中包括：

OnConfiguring 根据配置文件中的数据库地址设置数据库连接
OnModelCreating 中设置实体类的主键
ChangeConnection 方法实现切换数据库连接
CheckIfTableExists 方法 检查指定的表是否存在

3.DbContext 注册为全局服务

1.创建一个静态字段

VMLocator类中，创建一个静态字段来保存 DbContext 的实例

代码如下：

private static ChatDbcontext _chatDbcontext;
public static ChatDbcontext ChatDbcontext {
    get => (_chatDbcontext ??= new ChatDbcontext());
    set => _chatDbcontext = value;
}

2.创建ChatProcess数据库操作类

代码如下：

 /// <summary>
/// 创建并初始化数据库
/// </summary>
public void CreateDatabase() {
    using (var context = new ChatDbcontext()) {
        context.Database.Migrate();
        VMLocator.ChatDbcontext = context;
    }
}

/// <summary>
/// 判断加载的数据库表是否完整
/// </summary>
public async Task<bool> CheckTableExists(string selectedFilePath) {
    VMLocator.ChatDbcontext.ChangeConnection(selectedFilePath);
    return (VMLocator.ChatDbcontext.CheckIfTableExists<ChatMessage>() && VMLocator.ChatDbcontext.CheckIfTableExists<ChatList>());
}

其中：

CreateDatabase方法的作用是初始化数据库，如果在指定的数据库文件地址中不存在文件，则在访问数据库时，SQLite 数据库引擎会尝试创建一个新的数据库文件。这意味着，如果指定的数据库文件地址没有文件，EF Core 与 SQLite 的集成会自动创建一个新的数据库文件。
CheckTableExists 方法判断加载的数据库表是否完整

3.ChatDbcontext初始化和赋值

ChatDbcontext初始化和赋值在MainWindow_Loaded方法中，在首页加载时，判断配置中的数据库文件地址。并加载数据库。

4.DbContext的使用

如何在程序中使用DbContext来查询数据库是重点，下面是一些应用的场景：

代码如下：

//数据加载
            VMLocator.DataGridViewModel.ChatList=VMLocator.ChatDbcontext.ChatLists.ToObservableCollection();
            VMLocator.ChatViewModel.ChatHistory = VMLocator.ChatDbcontext.ChatMessages.ToObservableCollection();

这里查询数据库的记录赋值给DataGridViewModel和ChatViewModel，实现数据库的数据的加载。

简简单单的两行代码，完成了会话列表和聊天记录的数据加载。

ToObservableCollection扩展

我们需要把数据库查询的数据转换成ObservableCollection的集合做Binding，我们写一个EF的扩展方法来实现这个转换。

代码如下：

/// <summary>
/// 扩展方法
/// </summary>
public static class ObservableCollectionExtensions {
    public static ObservableCollection<T> ToObservableCollection<T>(this IEnumerable<T> source) {
        return new ObservableCollection<T>(source);
    }
}

更多的使用方法可以在代码中查看TerraMours.Chat.Ava