EFcore Repository 依赖注入

2023-10-21 23:08
文章标签 依赖 注入 repository efcore

本文主要是介绍EFcore Repository 依赖注入，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

基于EFcore 实现基本的数据库操作

0.代码关系与结构如图所示：

存在两个数据表，分别是UserInfo表、Contacts表，应用Scaffold-DbContext生成Model

创建两个文件夹，分别是Services（接口）、Implementation（接口的实现）
在这里插入图片描述
在这里插入图片描述

1.操作步骤：

a.创建IRepository接口;
b.创建RepositoryBase：IRepository 实现基本数据库操作
c.分别创建IUserInfoRepository、IContactRepository
d.分别创建UserInfoRepository、ContactRepository
e.创建IRepositoryWrapper
f.创建RepositoryWrapper ： IRepositoryWrapper 用于实现依赖注入
g.依赖注入
h.构造函数注入与应用

2.创建IRepository接口：

using Microsoft.EntityFrameworkCore.Storage;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;namespace WebApplication24.Services
{public interface IRepository<T>{Task<bool> Insert(T t);Task<bool> Update(T t);Task<bool> Delete(T t);Task<IEnumerable<T>> GetAllAsync();      Task<IEnumerable<T>> GetByConditionAsync(Expression<Func<T, bool>> expression);Task<T> GetByIdAsync(object id);Task<bool> IsExistAsync(object id);Task<int> GetCountAsync(T t);Task<IDbContextTransaction> BeginTransactionAsync(IsolationLevel isolationLevel = IsolationLevel.Unspecified,CancellationToken cancellationToken = default);}
}

3.创建RepositoryBase：IRepository 实现基本数据库操作

using Microsoft.EntityFrameworkCore;
using Microsoft.EntityFrameworkCore.ChangeTracking;
using Microsoft.EntityFrameworkCore.Metadata;
using Microsoft.EntityFrameworkCore.Storage;
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Linq.Expressions;
using System.Threading;
using System.Threading.Tasks;namespace WebApplication24.Services
{public class RepositoryBase<T> : IRepository<T> where T : class{private readonly DbContext dbContext;public RepositoryBase(DbContext dbContext) => this.dbContext = dbContext;public async Task<bool> Insert(T entity){bool bRet = false;if (entity == null){return bRet;}bRet = IsEntityValid(entity);if (!bRet){return bRet;}dbContext.Set<T>().Add(entity);return await dbContext.SaveChangesAsync() > 0;}public async Task<bool> Update(T entity){bool bRet = false;if (entity == null){return bRet;}bRet = IsEntityTracked(entity);if (!bRet){return bRet;}bRet = IsEntityValid(entity);if (!bRet){return bRet;}dbContext.Set<T>().Update(entity);return await dbContext.SaveChangesAsync() > 0;}public async Task<bool> Delete(T entity){bool bRet = false;if (entity == null){return bRet;}bRet = IsEntityTracked(entity);if (!bRet){return bRet;}bRet = IsEntityValid(entity);if (!bRet){return bRet;}dbContext.Set<T>().Remove(entity);return await dbContext.SaveChangesAsync() > 0;}public Task<IEnumerable<T>> GetAllAsync(){return Task.FromResult(dbContext.Set<T>().AsEnumerable());}public Task<IEnumerable<T>> GetByConditionAsync(Expression<Func<T, bool>> expression){return Task.FromResult(dbContext.Set<T>().Where(expression).AsEnumerable());}public async Task<T> GetByIdAsync(object id){if (id == null){return null;}return await dbContext.Set<T>().FindAsync(id);}public async Task<bool> IsExistAsync(object id){if (id == null){return false;}return await dbContext.Set<T>().FindAsync(id) != null;}public async Task<int> GetCountAsync(T entity){return await dbContext.Set<T>().CountAsync();}public async Task<IDbContextTransaction> BeginTransactionAsync(IsolationLevel isolationLevel = System.Data.IsolationLevel.Unspecified, CancellationToken cancellationToken = default){return await dbContext.Database.BeginTransactionAsync(isolationLevel, cancellationToken);}private bool IsEntityValid(T entity){//判断entity是否是DbContext的ModelIEntityType entityType = dbContext.Model.FindEntityType(typeof(T));if (entityType == null){return false;}//获取主键值名称string keyName = entityType.FindPrimaryKey().Properties.Select(p => p.Name).FirstOrDefault();if (string.IsNullOrEmpty(keyName)){return false;}//获取主键类型Type keyType = entityType.FindPrimaryKey().Properties.Select(p => p.ClrType).FirstOrDefault();if (keyType == null){return false;}//获取主键值类型的默认值object keyDefaultValue = keyType.IsValueType ? Activator.CreateInstance(keyType) : null;//获取当前主键值object keyValue = entity.GetType().GetProperty(keyName).GetValue(entity, null);if (keyDefaultValue.Equals(keyValue)){return false;}           else{return true;}}private bool IsEntityTracked(T entity){EntityEntry<T> trackedEntity = dbContext.ChangeTracker.Entries<T>().FirstOrDefault(o => o.Entity == entity);if (trackedEntity == null){return false;}else{return true;}}}     
}

4.创建IUserInfoRepository、IContactRepository

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WebApplication24.Models;namespace WebApplication24.Services
{public interface IUserInfoRepository : IRepository<UserInfo>{}public interface IContactRepository : IRepository<Contact>{}
}

5.创建UserInfoRepository、ContactRepository

using Microsoft.EntityFrameworkCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WebApplication24.Models;namespace WebApplication24.Services
{public class UserInfoRepository : RepositoryBase<UserInfo>,IUserInfoRepository{public UserInfoRepository(DbContext dbContext):base(dbContext){}}public class ContactRepository : RepositoryBase<Contact>,IContactRepository{public ContactRepository(DbContext dbContext):base(dbContext){}}
}

6.创建IRepositoryWrapper

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;namespace WebApplication24.Services
{public interface IRepositoryWrapper{IUserInfoRepository UserInfo{ get; }IContactRepository Contact { get; }}
}

7.创建RepositoryWrapper

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using WebApplication24.Models;namespace WebApplication24.Services
{public class RepositoryWrapper : IRepositoryWrapper{private readonly ExampleContext _exampleContext;public RepositoryWrapper(ExampleContext exampleContext) => _exampleContext = exampleContext;public IUserInfoRepository UserInfo => new UserInfoRepository(_exampleContext);public IContactRepository Contact => new ContactRepository(_exampleContext);}
}

8.依赖注入 StartUp类

public void ConfigureServices(IServiceCollection services)
{services.AddControllersWithViews();services.AddDbContext<ExampleContext>(options => {options.UseSqlServer(Configuration.GetConnectionString("defaultConnection"));});services.AddScoped<IRepositoryWrapper, RepositoryWrapper>();
}

9.构造注入

using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore.Storage;
using Microsoft.Extensions.Logging;
using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Threading.Tasks;
using WebApplication24.Models;
using WebApplication24.Services;namespace WebApplication24.Controllers
{public class HomeController : Controller{private readonly ILogger<HomeController> _logger;private readonly IRepositoryWrapper _db;public HomeController(ILogger<HomeController> logger,IRepositoryWrapper repositoryWrapper){_logger = logger;_db = repositoryWrapper;}public async Task<IActionResult> Index(){IDbContextTransaction transaction = await _db.UserInfo.BeginTransactionAsync(IsolationLevel.ReadCommitted);try{                await _db.UserInfo.Delete(new UserInfo() { Id = 4, Name = "Hanmeimei", Age = 30 });await _db.Contact.Insert(new Contact() { Id = 40, Name = "Hanmeimei", Phone = "13155556666", Address = "Beijing" });await transaction.CommitAsync();}catch (Exception){await transaction.RollbackAsync();}return View();           }        }
}

自学EFCore，具体源码在我的Space里可以下载，共勉喽
Happy Ending

这篇关于EFcore Repository 依赖注入的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/257520。

相关文章

每天认识几个maven依赖（ActiveMQ+activemq-jaxb+activesoap+activespace+adarwin）

每天认识几个maven依赖（ActiveMQ+activemq-jaxb+activesoap+activespace+adarwin）

八、ActiveMQ 1、是什么？ ActiveMQ 是一个开源的消息中间件（Message Broker），由 Apache 软件基金会开发和维护。它实现了 Java 消息服务（Java Message Service, JMS）规范，并支持多种消息传递协议，包括 AMQP、MQTT 和 OpenWire 等。 2、有什么用？ 可靠性：ActiveMQ 提供了消息持久性和事务支持，确保消
阅读更多...
pip-tools：打造可重复、可控的 Python 开发环境，解决依赖关系，让代码更稳定

pip-tools：打造可重复、可控的 Python 开发环境，解决依赖关系，让代码更稳定

在 Python 开发中，管理依赖关系是一项繁琐且容易出错的任务。手动更新依赖版本、处理冲突、确保一致性等等，都可能让开发者感到头疼。而 pip-tools 为开发者提供了一套稳定可靠的解决方案。 什么是 pip-tools？ pip-tools 是一组命令行工具，旨在简化 Python 依赖关系的管理，确保项目环境的稳定性和可重复性。它主要包含两个核心工具：pip-compile 和 pip
阅读更多...
深入理解数据库的 4NF：多值依赖与消除数据异常

深入理解数据库的 4NF：多值依赖与消除数据异常

在数据库设计中， "范式" 是一个常常被提到的重要概念。许多初学者在学习数据库设计时，经常听到第一范式（1NF）、第二范式（2NF）、第三范式（3NF）以及 BCNF（Boyce-Codd范式）。这些范式都旨在通过消除数据冗余和异常来优化数据库结构。然而，当我们谈到 4NF（第四范式）时，事情变得更加复杂。本文将带你深入了解 多值依赖 和 4NF，帮助你在数据库设计中消除更高级别的异常。 什么是
阅读更多...
PHP防止SQL注入详解及防范

PHP防止SQL注入详解及防范

SQL 注入是PHP应用中最常见的漏洞之一。事实上令人惊奇的是，开发者要同时犯两个错误才会引发一个SQL注入漏洞。 一个是没有对输入的数据进行过滤（过滤输入），还有一个是没有对发送到数据库的数据进行转义（转义输出）。这两个重要的步骤缺一不可，需要同时加以特别关注以减少程序错误。 对于攻击者来说，进行SQL注入攻击需要思考和试验，对数据库方案进行有根有据的推理非常有必要（当然假设攻击者看不到你的
阅读更多...
PHP防止SQL注入的方法（2）

PHP防止SQL注入的方法（2）

如果用户输入的是直接插入到一个SQL语句中的查询，应用程序会很容易受到SQL注入，例如下面的例子: $unsafe_variable = $_POST['user_input'];mysql_query("INSERT INTO table (column) VALUES ('" . $unsafe_variable . "')"); 这是因为用户可以输入类似VALUE”); DROP TA
阅读更多...
PHP防止SQL注入的方法（1）

PHP防止SQL注入的方法（1）

（1）mysql_real_escape_string – 转义 SQL 语句中使用的字符串中的特殊字符，并考虑到连接的当前字符集 使用方法如下： $sql = "select count(*) as ctr from users where username ='".mysql_real_escape_string($username)."' and password='". mysql_r
阅读更多...
PHP7扩展开发之依赖其他扩展

PHP7扩展开发之依赖其他扩展

前言 有的时候，我们的扩展要依赖其他扩展。比如，我们PHP的mysqli扩展就依赖mysqlnd扩展。这中情况下，我们怎么使用其他扩展呢？这个就是本文讲述的内容。 我们新建立一个扩展，名字叫 demo_dep ， 依赖之前的say扩展。 在demo_dep扩展中，我们实现demo_say方法。这个方法调用say扩展的say方法。 代码 基础代码 确保say扩展的头文件正确安装到了php
阅读更多...
Go 依赖注入库dig

Go 依赖注入库dig

简介 今天我们来介绍 Go 语言的一个依赖注入（DI）库——dig。dig 是 uber 开源的库。Java 依赖注入的库有很多，相信即使不是做 Java 开发的童鞋也听过大名鼎鼎的 Spring。相比庞大的 Spring，dig 很小巧，实现和使用都比较简洁。 快速使用 第三方库需要先安装，由于我们的示例中使用了前面介绍的go-ini和go-flags，这两个库也需要安装： $ go g
阅读更多...
Android 项目依赖

Android 项目依赖

先上个简单的压压惊： 导入三方项目供自己使用： 由于Google重AndroidStudio  轻 Eclipse ，致使现在很多 开元的项目 都是AndroidStudio 版本了；那么如何把别人的项目导入到AndroidStudio 用于自己使用参考呢？ 很简单：下载好别人的项目后 ；首先改下 配置信息； 作为配置参数的参考：首先大家应该有一个自己的在AndroidStudio 上
阅读更多...
六、Maven依赖管理、依赖传递和依赖冲突

六、Maven依赖管理、依赖传递和依赖冲突

1.Maven依赖管理 Maven 依赖管理是 Maven 软件中最重要的功能之一。Maven 的依赖管理能够帮助开发人员自动解决软件包依赖问题，使得开发人员能够轻松地将其他开发人员开发的模块或第三方框架集成到自己的应用程序或模块中，避免出现版本冲突和依赖缺失等问题。 我们通过定义 POM 文件，Maven 能够自动解析项目的依赖关系，并通过 Maven 仓库自动下载和管理依赖，从而避免了手动
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2