EF Core + MySQL 基本增删改查

昊辰

前言

基于EF Core + MySQL的基本增删改查，示例是基于.NET6 + EF Core + MySQL 创建实体和数据库、EFCore 数据迁移项目基础上的内容增加。同时也是对基于Canal实现MySQL 8.0 数据库数据同步项目的验证。
创建控制器

Controllers---->添加---->控制器，选择api---->包含读写操作的API控制器。

依赖注入

将上下文类注入到UsersController中，ASP.NET Core 支持依赖关系注入 (DI) 软件设计模式，这是一种在类及其依赖关系之间实现控制反转 (IoC) 的技术。有三种具体实现方式，我们这里用到的是构造函数注入，关于这块的内容，以后我们也可以专门出一期。直接上代码。

1.                 private readonly MyDataBaseContext_mian _dbmain;
2.         private readonly MyDataBaseContext_from _dbfrom;
3.         public UsersController(MyDataBaseContext_mian dbmain, MyDataBaseContext_from dbfrom)
4.         {
5.             _dbmain = dbmain;
6.             _dbfrom = dbfrom;
7.         }

复制代码

CRUD基本代码

一下内容是UsersController的完整内容

1. using Microsoft.AspNetCore.Http;
2. using Microsoft.AspNetCore.Mvc;
3. using Microsoft.EntityFrameworkCore;
4. using test.Models;
5. using test.MyDataBaseContext;
7. namespace test.Controllers
8. {
9.     [ApiController]
10.     [Route("api/[controller]")]
11.     public class UsersController : Controller
12.     {
13.         private readonly MyDataBaseContext_mian _dbmain;
14.         private readonly MyDataBaseContext_from _dbfrom;
15.         public UsersController(MyDataBaseContext_mian dbmain, MyDataBaseContext_from dbfrom)
16.         {
17.             _dbmain = dbmain;
18.             _dbfrom = dbfrom;
19.         }
20.         [HttpGet]
21.         // GET: UsersController
22.         public IEnumerable<User> Index()
23.         {
24.             return _dbfrom.Users.ToList();
25.         }
27.         [HttpGet("{id}")]
28.         // GET: UsersController/Details/5
29.         public async Task<IActionResult> Details(int? id)
30.         {
31.             return CreatedAtAction(nameof(Index), await _dbfrom.Users.AsNoTracking().FirstOrDefaultAsync(m => m.UserId == id));
32.         }
34.         // POST: UsersController/Create
35.         [HttpPost]
36.         public async Task<IActionResult> Create(User user)
37.         {
38.             _dbmain.Users.Add(user);
39.             await _dbmain.SaveChangesAsync();
40.             return CreatedAtAction(nameof(Index), new { id = user.UserId }, user);
41.         }
43.        // POST: UsersController/Edit/5
44.         [HttpPut("{id}")]
45.         public async Task<bool> Edit(int? id, [FromBody] User user)
46.         {
47.             _dbmain.Set<User>().Update(user);
48.             return await _dbmain.SaveChangesAsync() > 0;
49.         }
51.         // POST: UsersController/Delete/5
52.         [HttpDelete("{id}")]
53.         public async Task<IActionResult> Delete(int id)
54.         {
56.             User user = new User();
58.             user = await _dbmain.Users.FindAsync(id);
59.             if (user == null)
60.             {
61.                 return RedirectToAction(nameof(Index));
62.             }
63.             try
64.             {
65.                 _dbmain.Users.Remove(user);
66.                 await _dbmain.SaveChangesAsync();
67.                 return RedirectToAction(nameof(Index));
68.             }
69.             catch (DbUpdateException /* ex */)
70.             {
71.                 //Log the error (uncomment ex variable name and write a log.)
72.                 return RedirectToAction(nameof(Index), new { id = id, saveChangesError = true });
73.             }
75.         }
76.     }
77. }

复制代码

注：我对方法进行的改造，采用官网提供的新写法，有兴趣的小伙伴可以看看官网。
swagger接口测试文档看效果

向主库添加用户信息

从库查询用户信息

从库查询详细信息

主库修改用户信息

再从从库查询用户信息

删除用户信息

到此，EFCore的增删改查就完事了。有不懂的小伙伴可以把问题打在评论区，我来为大家解答。

来源:https://www.cnblogs.com/lym003/archive/2023/06/09/17467099.html
免责声明：由于采集信息均来自互联网，如果侵犯了您的权益，请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容，谢谢合作！