百度360必应搜狗淘宝本站头条
mqtt服务器xftp6vscode使用技巧mybatiscollectionkeyerror
当前位置：网站首页 > 热门文章 > 正文

使用EFCore操作Sqlite数据库

bigegpt 2024-09-08 11:26 9 浏览

一、EF Core简介

1、Entity Framework (EF) Core 是轻量化、可扩展、开源和跨平台版的常用 Entity2、Framework 数据访问技术。

3、EF Core 可用作对象关系映射程序 (O/RM)，这可以实现以下两点：

a.使 .NET 开发人员能够使用.NET 对象处理数据库。

b.无需再像通常那样编写大部分数据访问代码。

4、EF Core 支持多个数据库引擎。

5、Code First ：先编写 C# 实体类，EF Core 会根据实体类之间的关系创建数据库；

6、Database First ：先设计和创建数据库，EF Core 根据数据库的表结构生成 C# 实体类。

二. SQLite 简介

SQLite 是一种轻量级、嵌入式的关系型数据库管理系统（RDBMS）。它是一个零配置的数据库引擎，不需要服务器，可以直接访问存储在文件中的数据库。SQLite 被广泛用于移动设备、嵌入式系统以及一些小型桌面应用程序中。

优点和特点:

1、零配置：无需服务器或配置，数据库就是一个普通文件。

2、轻量级：小巧、高效，适用于嵌入式设备和资源有限的环境。

3、跨平台：支持多种操作系统，包括 Windows、Linux、macOS 和各种嵌入式系统。

4、事务支持：支持 ACID（原子性、一致性、隔离性、持久性）事务特性。

三、 EF Core与SQLite数据库的结合使用

当我们使用 Entity Framework Core（EF Core）时，分层是一种良好的实践，它有助于代码的可维护性、可测试性和扩展性。以下是一个简单的 EF Core 分层应用的示例：

1、创建项目

①首先，创建一个新的.NET Core 项目

②安装 NuGet包

在项目目录中，安装以下Entity Framework Core 相关的 NuGet 包：

1、Microsoft.EntityFrameworkCore

2、Microsoft.EntityFrameworkCore.Design

3、Microsoft.EntityFrameworkCore.Sqlite

2、创建实体类

①创建一个实体接口

public interface IEntityBase<TID>
{
   TID Id { get; set; }
}


② 创建一个实体父类，让所有的实体类都继承自这个类

/// <summary>
/// Entity父类
/// </summary>
public abstract class EntityBase : EntityBase<long>
{
}

public abstract class EntityBase<TID> :IEntityBase<TID>
{
    [Key]
    [DatabaseGenerated(DatabaseGeneratedOption.Identity)]
    public TID Id{ get; set; }
}


③创建一个实体，让所有的实体类都继承自EntityBase这个父类，这将是数据库中的表。

public class UserEntity : UserEntity<long>
{
}


[Table("t_info_Users")]
public class UserEntity<TID> : EntityBase
{
    public string UserName { get; set; }
    public string Email { get; set; }
}


3、创建一个继承自 DbContext 的类，这个类将用于处理数据库交互

public class AppDbContext : DbContext
{
    public DbSet<UserEntity> UserEntity { get; set; }
    // 其他实体类...
    protected override voidOnConfiguring(DbContextOptionsBuilder options)
     => options.UseSqlite(#34;Data Source=mydatabase.db");
}


4、为了更好地组织代码，创建一个仓储类，处理对数据库的具体操作

①定义Repository接口，指定新增、删除等方法。

/// <summary>
///Repository接口
/// </summary>
/// <typeparam name="T"></typeparam>
public interface IRepository<T, TID>
{
    /// <summary>
    /// 事务
    /// </summary>
    /// <returns></returns>
    IDbContext Transaction BeginTransaction();


    /// <summary>
    /// 查询
    /// </summary>
    /// <returns></returns>
    IQueryable<T> Query();


    /// <summary>
    /// 新增
    /// </summary>
    /// <param name="entity"></param>
    void Add(T entity);
    
    /// <summary>
    /// 批量新增
    /// </summary>
    /// <param name="entity"></param>
    void AddRange(IEnumerable<T> entity);


    /// <summary>
    /// 删除
    /// </summary>
    /// <param name="entity"></param>
    void Delete(T entity);


    /// <summary>
    /// 同步保存
    /// </summary>
    /// <param name="entity"></param> 
    void Save();


    /// <summary>
    /// 批量删除
    /// </summary>
    /// <param name="entity"></param>
    void RemoveRange(IEnumerable<T> entity);


    /// <summary>
    /// 异步保存
    /// </summary>
    /// <returns></returns>
    Task SaveAsync();


    /// <summary>
    /// 获取上下文
    /// </summary>
    /// <returns></returns>
    DbContext GetDbContext();
}

②实现Repository类。

public class Repository<T, TID> : IDisposable, IRepository<T, TID> where T :EntityBase<TID>
{
    /// <summary>
    /// DB上下文
    /// </summary>
    private DbContext Context;


    /// <summary>
    /// 实体集合
    /// </summary>
    private DbSet<T> DbSet;


    public Repository()
   {
       Context = new AppDbContext();
       DbSet = Context.Set<T>();
    }


    public Repository(DbContext context)
{
       Context = context ?? new AppDbContext();
       DbSet = Context.Set<T>();
    }


    ~Repository()
    {
       Context.Dispose();
    }


    publicDbContext GetDbContext()
    {
       return Context;
    }


    /// <summary>
    /// 事务
    /// </summary>
    /// <returns></returns>
    public IDbContextTransaction BeginTransaction()
{
       return Context.Database.BeginTransaction();
    }


    /// <summary>
    /// 查询
    /// </summary>
    /// <returns></returns>
    public IQueryable<T> Query()
    {
        return DbSet;
    }


    /// <summary>
    /// 新增
    /// </summary>
    /// <param name="entity"></param>
    public void Add(T entity)
{
       DbSet.Add(entity);
    }


    /// <summary>
    /// 批量新增
    /// </summary>
    /// <param name="entity"></param>
    public voidAddRange(IEnumerable<T> entity)
{
       DbSet.AddRange(entity);
    }


    /// <summary>
    /// 删除
    /// </summary>
    /// <param name="entity"></param>
    public void Delete(T entity)
{
       DbSet.Remove(entity);
    }


    /// <summary>
    /// 批量删除
    /// </summary>
    /// <param name="entity"></param>
    public voidRemoveRange(IEnumerable<T> entity)
    {
       DbSet.RemoveRange(entity);
    }


    /// <summary>
    /// 同步保存
    /// </summary>
    public void Save()
{
       Context.SaveChanges();
    }


    /// <summary>
    /// 异步保存
    /// </summary>
    /// <returns></returns>
    public TaskSaveAsync()
{
       return Context.SaveChangesAsync();
    }


    private bool disposedValue;


    protected virtual void Dispose(bool disposing)
    {
       if (!disposedValue)
       {
           if (disposing)
           {
               Context.Dispose();
               // TODO:释放托管状态(托管对象)
           }
           // TODO:释放未托管的资源(未托管的对象)并重写终结器
           // TODO:将大型字段设置为 null
           disposedValue = true;
       }
    }


    // // TODO: 仅当“Dispose(bool disposing)”拥有用于释放未托管资源的代码时才替代终结器
    // ~Repository()
    // {
    //    // 不要更改此代码。请将清理代码放入“Dispose(bool disposing)”方法中
    //    Dispose(disposing: false);
    // }
    public void Dispose()
{
       // 不要更改此代码。请将清理代码放入“Dispose(bool disposing)”方法中
       Dispose(disposing: true);
       GC.SuppressFinalize(this);
    }
}


5、利用Repository实现一个表格的增删改查操作

①定义ServiceBase接口

public interface IServiceBase<T, TID> :IRepository<T, TID> where T : IEntityBase<TID>
{
    /// <summary>
    /// 新增通过实体
    /// </summary>
    /// <param name="Entity"></param>
    /// <returns></returns>
    ExcuteResult InsertByEntity(T Entity);


    /// <summary>
    /// 批量新增通过实体
    /// </summary>
    /// <param name="Entities"></param>
    /// <returns></returns>
    ExcuteResult InsertByEntity(List<T> Entities);


    /// <summary>
    /// 删除通过ID
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    ExcuteResult DeleteByID(TID id);


    /// <summary>
    /// 删除通过实体
    /// </summary>
    /// <param name="Entity"></param>
    /// <returns></returns>
    ExcuteResult DeleteByEntity(T Entity);


    /// <summary>
    /// 更新通过实体
    /// </summary>
    /// <param name="Entity"></param>
    /// <returns></returns>
    ExcuteResult UpdateByEntity(T Entity);


    /// <summary>
    /// 获取通过ID
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    ExcuteResult<T> GetByID(TID id);


    /// <summary>
    /// 获取通过实体
    /// </summary>
    /// <param name="Entity"></param>
    /// <returns></returns>
    ExcuteResult<T> GetByEntity(T Entity);
}


② 实现ServiceBase类,让所有用户服务类继承这个父类

public class ServiceBase<T, TID> : Repository<T, TID>, IServiceBase<T,TID> where T :EntityBase<TID>, new()
{
    public ServiceBase() : base()
    {
    }


    public ServiceBase(AppDbContext appDbContext) : base(appDbContext)
    {
    }


    public ExcuteResult InsertByEntity(T Entity)
    {
       try
       {       
           Add(Entity);
           Save();
           return ExcuteResult.CreateSuccessResult();
       }
       catch (Exception ex)
       {
           return new ExcuteResult(#34;增加{nameof(T)}失败:{ex.Message}");
       }
    }


    public ExcuteResult InsertByEntity(List<T> Entities)
    {
       try
       {
           AddRange(Entities);
           Save();
           return ExcuteResult.CreateSuccessResult();
       }
       catch (Exception ex)
       {
           return new ExcuteResult(#34;增加{nameof(T)}失败:{ex.Message}");
       }
    }


    public ExcuteResult DeleteByEntity(T Entity)
    {
       return DeleteByID(Entity.Id);
    }


    public ExcuteResult DeleteByID(TID id)
    {
       try
       {
           var Data = GetByID(id);
           if (!Data.IsSuccess) return new ExcuteResult(Data.Message);
           Delete(Data.Content);
           Save();
       }
       catch (Exception ex)
       {
           return new ExcuteResult(#34;移除{nameof(T)}失败:{ex.Message}");
       }
       return ExcuteResult.CreateSuccessResult();
    }


    public ExcuteResult UpdateByEntity(T Entity)
    {
       try
       {
           if (Entity.Id == null)
           return new ExcuteResult(#34;更新对象失败,对象的id为空!");
           var ret = GetByID(Entity.Id);
           if (ret.IsSuccess && ret.Content != null)
           {
               var retUpdate = ret.Content.UpdateEntityValue(Entity);
               if (!retUpdate.IsSuccess)
               return retUpdate;
           }
           else
           {
               return ret;
           }
           Save();
       }
       catch (Exception ex)
       {
           return new ExcuteResult(#34;增加{nameof(T)}失败:{ex.Message}");
       }
       return ExcuteResult.CreateSuccessResult();
    }


    public ExcuteResult<T> GetByEntity(T Entity)
    {
       return GetByID(Entity.Id);
    }


    public ExcuteResult<T> GetByID(TID id)
    {
       try
       {
           var Data = Query().Where(b => b.Id.Equals(id)).FirstOrDefault();
           if (Data == null)
           return new ExcuteResult<T>(#34;{typeof(T)}Id: {id} is null");
           return ExcuteResult.CreateSuccessResult(Data);
       }
       catch (Exception ex)
       {
           return new ExcuteResult<T>(ex.Message);
       }
    }
}


③创建用户服务接口

public interface IUserEntityService
{
    /// <summary>
    /// 获取用户信息
    /// </summary>
    /// <param name="user"></param>
    /// <returns></returns>
    ExcuteResult<UserEntity> GetUserEntity(UserEntity user);


    /// <summary>
    /// 获取用户信息
    /// </summary>
    /// <param name="Id"></param>
    /// <returns></returns>
    ExcuteResult<UserEntity> GetUserEntityById(long Id);


    /// <summary>
    /// 添加用户信息
    /// </summary>
    /// <param name="user"></param>
    /// <returns>ID</returns>
    ExcuteResult InsetUserEntity(UserEntity user);


    /// <summary>
    /// 删除用户信息
    /// </summary>
    /// <param name="Id"></param>
    /// <returns></returns>
    ExcuteResult DeleteUserEntity(long Id);


    /// <summary>
    /// 批量添加
    /// </summary>
    /// <param name="users"></param>
    /// <returns></returns>
    ExcuteResult InsetUserEntity(List<UserEntity> users);


    /// <summary>
    /// 更新
    /// </summary>
    /// <param name="user"></param>
    /// <returns></returns>
    ExcuteResult UpdataUserEntity(UserEntity user);
}


④实现用户服务接口

public class UserEntityService : IUserEntityService
{
      publiC ExcuteResult DeleteUserEntity(long Id)
      {
         using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
         {
             return serviceBase.DeleteByID(Id);
         }
      }


      public ExcuteResult<UserEntity> GetUserEntity(UserEntity user)
      {
         using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
         {
             return serviceBase.GetByEntity(user);
         }
      }


      public ExcuteResult<UserEntity> GetUserEntityById(long Id)
      {
           using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
           {
               return serviceBase.GetByID(Id);
           }
      }


      public ExcuteResult InsetUserEntity(UserEntity user)
      {
           using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
           {
               return serviceBase.InsertByEntity(user);
           }
      }


      public ExcuteResult InsetUserEntity(List<UserEntity> users)
      {
           using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
           {
               return serviceBase.InsertByEntity(users);
           }
      }


      public ExcuteResult UpdataUserEntity(UserEntity user)
      {
           using (var serviceBase = new ServiceBase<UserEntity, long>(new AppDbContext()))
           {
               return serviceBase.UpdateByEntity(user);
           }
      }
}


6、在应用层注入服务类和仓储类，可以编写业务逻辑和调用仓储类。

四、数据库的迁移

Entity Framework Core（EF Core）支持 SQLite 数据库迁移。可以使用 EF Core 的 Migration 工具来管理 SQLite 数据库模式的变更。

以下是使用 EF Core 进行 SQLite 数据库迁移的一般步骤：

1、打开程序包管理控制台

2、生成迁移：Add-Migration InitialCreate

3、应用迁移：Update-Database

相关推荐

恢复软件6款汇总推荐，帮你减轻数据恢复压力!

在当今数字化生活中，数据丢失的风险如影随形。无论是误删文件、硬盘故障，还是遭遇病毒攻击，丢失的数据都可能给我们带来不小的麻烦。此时，一款优秀的数据恢复软件就成为了挽救数据的关键。今天，为大家汇总推荐...

中兴星星一号刷回官方原版recovery的教程

【搞科技教程】中兴星星一号的官方recovery也来说一下了，因为之前给大家分享过了第三方的recovery了，之前给大家分享的第三方recovery也是采用一键刷入的方式，如果细心的朋友会发现，之前...

新玩机工具箱，Uotan柚坛工具箱软件体验

以前的手机系统功能比较单调，各厂商的重视程度不一样，所以喜欢玩机的朋友会解锁手机系统的读写权限，来进行刷机或者ROOT之类的操作，让使用体验更好。随着现在的手机系统越来越保守，以及自身功能的增强，...

三星g906k刷recovery教程_三星g906k中文recovery下载

【搞科技教程】看到有一些机友在找三星g906k的第三方recovery，下面就来说一下详细的recovery的刷入方法了，因为手机只有有了第三方的recovery之后才可以刷第三方的root包和系统包...

中兴星星2号刷recovery教程_星星二号中文recovery下载

【搞科技教程】咱们的中兴星星2手机也就是中兴星星二号手机的第三方recovery已经出来了，并且是中文版的，有了这个recovery之后，咱们的手机就可以轻松的刷第三方的系统包了，如果没有第三方的re...

数据恢复软件有哪些值得推荐?这 6 款亲测好用的工具汇总请收好!

在数字生活中，数据丢失的阴霾常常突如其来。无论是误删工作文档、格式化重要磁盘，还是遭遇系统崩溃，都可能让我们陷入焦虑。关键时刻，一款得力的数据恢复软件便是那根“救命稻草”。今天，为大家精心汇总6...

中兴u956刷入recovery的教程（中兴e5900刷机）

【搞科技教程】这次主要来给大家说说中兴u956手机如何刷入第三方的recovery，因为第三方的recovery工具是咱们刷第三方rom包的基础，可是很我欠却不会刷，所以太这里来给大家整理了一下详细的...

联想A850+刷recovery教程 联想A850+第三方recovery下载

【搞科技教程】联想A850+的第三方recovery出来了，这个第三方的recovery是非常的重要的，比如咱们的手机要刷第三方的系统包的时候，都是需要用到这个第三方的recovery的，在网上也是有...

工具侠重大更新 智能机上刷机一条龙完成

工具侠是针对玩机的机油开发的一款工具，不管是发烧级别的粉丝，还是普通小白用户，都可以在工具侠上找到你喜欢的工具应用。这不，最新的工具侠2.0.16版本，更新了专门为小白准备的刷机助手工具，以及MTK超...

shift+delete删除的文件找回6种硬盘数据恢复工具

硬盘作为电脑的重要存储设备，如同一个巨大的数字仓库，承载着我们日常工作、学习和生活中的各种文件，从珍贵的照片、重要的工作文档到喜爱的视频、音乐等，都依赖硬盘来安全存放。但有时，我们可能会不小心用sh...

使用vscode+Deepseek 实现AI编程 基于Cline和continue

尊敬的诸位！我是一名专注于嵌入式开发的物联网工程师。关注我，持续分享最新物联网与AI资讯和开发实战。期望与您携手探寻物联网与AI的无尽可能。这两天deepseek3.0上线，据说编程能力比肩Cl...

详解如何使用VSCode搭建TypeScript环境(适合小白)

搭建Javascript环境因为TypeScript不能直接在浏览器上运行。它需要编译器来编译并生成JavaScript文件。所以需要首先安装好javascript环境，可以参考文章：https://...

使用VSCode来书写你的Jupyter Notebooks

现在你可以在VScode里面来书写你的notebook了，使用起来十分的方便。下面来给大家演示一下环境的搭建。首先需要安装一个jupyter的包，使用下面的命令安装：pip3install-ih...

使用VSCode模板提高Vue开发效率（vscode开发vue插件）

安装VSCode安装Vetur和VueHelper插件，安装完成后需要重启VScode。在扩展插件搜索框中找到如下Vetur和VueHelper两个插件，注意看图标。添加Vue模板打...

干货!VsCode接入DeepSeek实现AI编程的5种主流插件详解

AI大模型对编程的影响非常之大，可以说首当其冲，Cursor等对话式编程工具渐渐渗透到开发者的工作中，作为AI编程的明星产品，Cursor虽然好用，但是贵啊，所以咱们得找平替，最好免费那种。俗话说，不...

一周热门
最近发表
标签列表