appsettings.json 中配置数据库连接串
"ConnectionStrings": { "Connection": "server=172.18.2.183;port=3306;database=students;uid=root;pwd=123456;CharSet=utf8" }
新建 Entities 目录,在,根据表及字段,在目录下新建 Student 实体类,在类上加 [Table("student")] 表名、属性上加[Column("id")] 字段名等与表对应,代码如下:
using System.ComponentModel.DataAnnotations.Schema; namespace Snai.Mysql.Entities { [Table("students")] public class Student { [Column("id")] public int ID { get; set; } [Column("name")] public string Name { get; set; } } }
在根目录下加上 DataAccess 目录做为数据库操作目录,在该目录下加上 Base 目录做数据库上下文目录
在 Base 目录下新建 SqlContext 上下文类,继承 DbContext 类,通过构造函数注入数据库连接,添加 DbSet
using Microsoft.EntityFrameworkCore; using Snai.Mysql.Entities; namespace Server.DataAccess.Base { public class SqlContext : DbContext { public SqlContext(DbContextOptionsoptions) : base(options) { } public DbSet Student { get; set; } } }
在DataAccess目录下创建Interface和Implement文件夹分别为数据库对应数据的接口和实现。
接口定义:
using Server.Mysql.Entities; namespace Server.DataAccess.Interface { public interface IStudentDao { //插入数据 bool CreateStudent(Student student); //取全部记录 IEnumerableGetStudents(); //取某id记录 Student GetStudentByID(int id); //根据id更新整条记录 bool UpdateStudent(Student student); //根据id更新名称 bool UpdateNameByID(int id, string name); //根据id删掉记录 bool DeleteStudentByID(int id); } }
实现:
using Server.DataAccess.Base; using Server.DataAccess.Interface; using Server.Mysql.Entities; namespace Server.DataAccess.Implement { public class StudentDao : IStudentDao { private SqlContext _context; public StudentDao(SqlContext context) { _context = context; } //插入数据 public bool CreateStudent(Student student) { _context.Student.Add(student); return _context.SaveChanges() > 0; } //取全部记录 public IEnumerableGetStudents() { return _context.Student.ToList(); } //取某id记录 public Student? GetStudentByID(int id) { return _context.Student.SingleOrDefault(s => s.ID == id); } //根据id更新整条记录 public bool UpdateStudent(Student student) { _context.Student.Update(student); return _context.SaveChanges() > 0; } //根据id更新名称 public bool UpdateNameByID(int id, string name) { var state = false; var student = _context.Student.SingleOrDefault(s => s.ID == id); if (student != null) { student.Name = name; state = _context.SaveChanges() > 0; } return state; } //根据id删掉记录 public bool DeleteStudentByID(int id) { var student = _context.Student.SingleOrDefault(s => s.ID == id); _context.Student.Remove(student); return _context.SaveChanges() > 0; } } }
在Program.cs中写入
string? sqlConnection = builder.Configuration.GetConnectionString("Connection"); if (sqlConnection != null) { builder.Services.AddDbContext(options => { var serverVersion = ServerVersion.AutoDetect(sqlConnection); //mysql版本: {8.2.0-mysql} options.UseMySql(sqlConnection, serverVersion); }); } builder.Services.AddScoped (); //对于同一个请求返回同一个实例
private IStudentDao _iStudentDao; public TestController(IStudentDao iStudentDao) //构造函数中添加 { _iStudentDao = iStudentDao; } //调用测试方法创建 public void TestCreate() { Student student = new Student(); student.ID = 1; student.Name = "在下没有钱"; _iStudentDao.CreateStudent(student); }
运行结果: