首页 > 资讯 > 后端开发 > ASP.NET >ASP.NET MVC+EF实现异步增删改查

677

分享到

ASP.NET MVC+EF实现异步增删改查

2024-04-02 19:04:59 677人浏览安东尼

摘要

目录功能实现1、搭建UI层2、添加实体类3、添加服务接口层4、添加Entity Framework1、开启迁移2、增加迁移3、生成数据库5、添加接口的实现类6、添加控制器功能实现我

功能实现

我们以学生为例，实现增删改查功能。

1、搭建UI层

我们这里使用asp.net mvc作为界面层显示数据，首先创建一个解决方案，然后添加一个MVC项目，命名为TaskAsync.UI，创建后的项目结构如下图所示：

2、添加实体类

我们把实体类放在单独的类库里面，新建一个类型项目，命名为TaskAsync.Model，里面有一个Student类，Student类代码如下：

namespace TaskAsync.Model
{
    /// <summary>
    /// 学生类
    /// </summary>
    public class Student
    {
        /// <summary>
        /// 主键
        /// </summary>
        public int Id { get; set; }

        /// <summary>
        /// 姓名
        /// </summary>
        public string Name { get; set; }

        /// <summary>
        /// 年龄
        /// </summary>
        public int Age { get; set; }

        /// <summary>
        /// 性别
        /// </summary>
        public int Gender { get; set; }
    }
}

3、添加服务接口层

我们把增删改查的方法定义在接口里面，新添加一个类型项目，命名为TaskAsync.IService，需要引用上面创建的实体类库。里面有一个IStudentService接口，接口代码如下：

using System.Collections.Generic;
using System.Threading.Tasks;
using TaskAsync.Model;

namespace TaskAsync.IService
{
    public interface IStudentService
    {
        /// <summary>
        /// 增加的异步方法
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        Task<int> AddPersonAsync(Student entity);

        /// <summary>
        /// 删除的异步方法
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        Task<int> DeleteByIdAsync(int id);

        /// <summary>
        /// 获取所有数据
        /// </summary>
        /// <returns></returns>
        Task<IEnumerable<Student>> GetAllAsync();

        /// <summary>
        /// 根据Id获取单一值
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        Task<Student> GetStudentByIdAsync(int id);

        /// <summary>
        /// 更新的异步方法
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        Task<int> UpdateAsync(Student entity);
    }
}

所有的方法返回值都是Task<T>类型的，方法名称默认以Async结尾，标注为异步方法。

4、添加Entity Framework

我们使用EF作为ORM框架，把EF放在单独类库里面，命名为TaskAsync.Data。直接在NuGet里面安装：

安装完成以后，我们同样需要在创建的ASP.net MVC程序里面EntityFramework，然后在外层的WEB.config文件里面添加链接字符串：

<connectionStrings>
    <add name="EFContext" connectionString="Data Source=.;Initial Catalog=TaskAsyncDb;User ID=sa;PassWord=123456;" providerName="System.Data.sqlClient" />
  </connectionStrings>

注意：链接字符串里面的providerName不能省略，否则进行数据迁移的时候会报错。

我们在TaskAsync.Data项目里面添加数据上下文类，继承自父类的DbContext：

using System.Data.Entity;
using TaskAsync.Model;

namespace TaskAsync.Data
{
    /// <summary>
    /// 数据上下文类，继承自父类的DbContext
    /// </summary>
    public class AppDbContext:DbContext
    {
        /// <summary>
        /// 通过创建连接，给父类的构造函数传递参数
        /// 参数是连接字符串的名称
        /// 表示使用连接字符串中名字为DbConnectionString的去连接数据库
        /// </summary>
        public AppDbContext():base("name=DbConnectionString")
        {

        }

        /// <summary>
        /// 重写OnModelCreating方法
        /// </summary>
        /// <param name="modelBuilder"></param>
        protected override void OnModelCreating(DbModelBuilder modelBuilder)
        {
            // 配置生成的表名
            modelBuilder.Entity<Student>().ToTable("T_Student");
            base.OnModelCreating(modelBuilder);
        }

        public DbSet<Student> Students { get; set; }
    }
}

数据上下文类创建完成以后，我们接下来在程序包管理器控制台里面进行数据迁移：

注意：项目要选择EntityFramework所在的类库项目。

1、开启迁移

使用下面的命令开启数据迁移：

Enable-Migrations

命令执行如下图所示：

2、增加迁移

使用下面的命令开始迁移：

Add-Migration Init

命令执行如下图所示：

执行成功以后，会在TaskAsync.Data项目下面添加一个Migrations文件夹

这个文件夹下面有两个类文件：Configuration.cs文件里面是配置信息，另外一个是本次迁移记录文件。我们在Configuration.cs类里面添加一些种子数据：

namespace TaskAsync.Data.Migrations
{
    using System.Collections.Generic;
    using System.Data.Entity.Migrations;
    using System.Linq;
    using TaskAsync.Model;

    internal sealed class Configuration : DbMigrationsConfiguration<TaskAsync.Data.AppDbContext>
    {
        public Configuration()
        {
            AutomaticMigrationsEnabled = false;
        }

        protected override void Seed(TaskAsync.Data.AppDbContext context)
        {
            List<Student> list = new List<Student>()
            {
                new Student()
                {
                    Name="Jack",
                    Age=23,
                    Gender=1
                },
                new Student()
                {
                    Name="Tom",
                    Age=25,
                    Gender=2
                }
            };

            if(!context.Students.Any())
            {
                context.Students.AddRange(list);
            }
        }
    }
}

3、生成数据库

我们在上面配置完成以后，就可以使用下面的命令去生成数据库：

Update-Database

命令执行如下图所示：

命令执行成功，就会自动创建数据库和表，表里面插入我们添加的种子数据：

5、添加接口的实现类

我们添加IStudentService接口的实现类。添加一个单独的类库，命名为TaskAsync.Service，并添加对TaskAsync.Model、TaskAsync.IService、TaskAsync.Data的引用，然后实现IStudentService接口：

using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TaskAsync.Data;
using TaskAsync.IService;
using TaskAsync.Model;

namespace TaskAsync.Service
{
    public class StudentService : IStudentService
    {
        /// <summary>
        /// 新增 方法标注为async
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        public async Task<int> AddPersonAsync(Student entity)
        {
            using (AppDbContext dbContext = new AppDbContext())
            {
                dbContext.Students.Add(entity);
                // 调用异步方法
                int count = await dbContext.SaveChangesAsync();
                return count;
            }
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public async Task<int> DeleteByIdAsync(int id)
        {
            using (AppDbContext dbContext = new AppDbContext())
            {
                Student student =await dbContext.Students.FindAsync(new object[] { id });
                if(student!=null)
                {
                    dbContext.Students.Remove(student);
                    return await dbContext.SaveChangesAsync();
                }
                else
                {
                    return 0;
                }
            }
        }

        public async Task<IEnumerable<Student>> GetAllAsync()
        {
            List<Student> list = await Task.Run<List<Student>>(() => 
            {
                using (AppDbContext dbContext = new AppDbContext())
                {
                    return dbContext.Students.ToList();
                }
            });

            return list;
        }

        public async Task<Student> GetStudentByIdAsync(int id)
        {
            using (AppDbContext dbContext = new AppDbContext())
            {
                Student student = await dbContext.Students.FindAsync(new object[] { id });
                if (student != null)
                {
                    return student
                }
                else
                {
                    return null;
                }
            }
        }

        public async Task<int> UpdateAsync(Student entity)
        {
            using (AppDbContext dbContext = new AppDbContext())
            {
                Student student = await dbContext.Students.FindAsync(new object[] { entity.Id });
                if (student != null)
                {
                    student.Name = entity.Name;
                    student.Age = entity.Age;
                    student.Gender = entity.Gender;
                    dbContext.Entry(student).State = System.Data.Entity.EntityState.Modified;
                    return await dbContext.SaveChangesAsync();
                }
                else
                {
                    return 0;
                }
            }
        }
    }
}

注意：这里同样需要添加到EntityFramework的引用。

6、添加控制器

我们在ASP.NET MVC项目里面首先添加对上面几个类库的引用。

为了测试方法，我们直接添加一个包含视图的MVC5控制器（使用Entity Framework），这样就会自动生成UI界面了，如下图所示：

模型类选择Student，数据上下文类选择AppDbContext，如下图所示：

创建完成之后，会看到自动添加了视图：

控制器里也自动生成了代码：

using System.Data.Entity;
using System.Linq;
using System.Net;
using System.Web.Mvc;
using TaskAsync.Data;
using TaskAsync.Model;

namespace TaskAsync.UI.Controllers
{
    public class StudentController : Controller
    {
        private AppDbContext db = new AppDbContext();

        // GET: Student
        public ActionResult Index()
        {
            return View(db.Students.ToList());
        }

        // GET: Student/Details/5
        public ActionResult Details(int? id)
        {
            if (id == null)
            {
                return new httpstatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student = db.Students.Find(id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // GET: Student/Create
        public ActionResult Create()
        {
            return View();
        }

        // POST: Student/Create
        // 为了防止“过多发布”攻击，请启用要绑定到的特定属性，有关 
        // 详细信息，请参阅 https://Go.microsoft.com/fwlink/?LinkId=317598。
        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult Create([Bind(Include = "Id,Name,Age,Gender")] Student student)
        {
            if (ModelState.IsValid)
            {
                db.Students.Add(student);
                db.SaveChanges();
                return RedirectToAction("Index");
            }

            return View(student);
        }

        // GET: Student/Edit/5
        public ActionResult Edit(int? id)
        {
            if (id == null)
            {
                return new HttpStatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student = db.Students.Find(id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // POST: Student/Edit/5
        // 为了防止“过多发布”攻击，请启用要绑定到的特定属性，有关 
        // 详细信息，请参阅 https://go.microsoft.com/fwlink/?LinkId=317598。
        [HttpPost]
        [ValidateAntiForgeryToken]
        public ActionResult Edit([Bind(Include = "Id,Name,Age,Gender")] Student student)
        {
            if (ModelState.IsValid)
            {
                db.Entry(student).State = EntityState.Modified;
                db.SaveChanges();
                return RedirectToAction("Index");
            }
            return View(student);
        }

        // GET: Student/Delete/5
        public ActionResult Delete(int? id)
        {
            if (id == null)
            {
                return new HttpStatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student = db.Students.Find(id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // POST: Student/Delete/5
        [HttpPost, ActionName("Delete")]
        [ValidateAntiForgeryToken]
        public ActionResult DeleteConfirmed(int id)
        {
            Student student = db.Students.Find(id);
            db.Students.Remove(student);
            db.SaveChanges();
            return RedirectToAction("Index");
        }

        protected override void Dispose(bool disposing)
        {
            if (disposing)
            {
                db.Dispose();
            }
            base.Dispose(disposing);
        }
    }
}

但是框架生成的代码都是同步方法的，不是我们需要的，我们改成异步的方法：

using System.Data.Entity;
using System.Linq;
using System.Net;
using System.Threading.Tasks;
using System.Web.Mvc;
using TaskAsync.Data;
using TaskAsync.IService;
using TaskAsync.Model;
using TaskAsync.Service;

namespace TaskAsync.UI.Controllers
{
    public class StudentController : Controller
    {
        //private AppDbContext db = new AppDbContext();

        IStudentService service = new StudentService();
        // GET: Student
        public async Task<ActionResult> Index()
        {
            return View(await service.GetAllAsync());
        }

        // GET: Student/Details/5
        public async Task<ActionResult> Details(int? id)
        {
            if (id == null)
            {
                return new HttpStatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student =await service.GetStudentByIdAsync((int)id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // GET: Student/Create
        public ActionResult Create()
        {
            return View();
        }

        // POST: Student/Create
        // 为了防止“过多发布”攻击，请启用要绑定到的特定属性，有关 
        // 详细信息，请参阅 https://go.microsoft.com/fwlink/?LinkId=317598。
        [HttpPost]
        [ValidateAntiForgeryToken]
        public async  Task<ActionResult> Create([Bind(Include = "Id,Name,Age,Gender")] Student student)
        {
            if (ModelState.IsValid)
            {
                int count = await service.AddPersonAsync(student);
                if(count>0)
                {
                    return RedirectToAction("Index");
                }
            }

            return View(student);
        }

        // GET: Student/Edit/5
        public async Task<ActionResult> Edit(int? id)
        {
            if (id == null)
            {
                return new HttpStatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student = await service.GetStudentByIdAsync((int)id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // POST: Student/Edit/5
        // 为了防止“过多发布”攻击，请启用要绑定到的特定属性，有关 
        // 详细信息，请参阅 https://go.microsoft.com/fwlink/?LinkId=317598。
        [HttpPost]
        [ValidateAntiForgeryToken]
        public async Task<ActionResult> Edit([Bind(Include = "Id,Name,Age,Gender")] Student student)
        {
            if (ModelState.IsValid)
            {
                int count = await service.UpdateAsync(student);
                if (count > 0)
                {
                    return RedirectToAction("Index");
                }
            }
            return View(student);
        }

        // GET: Student/Delete/5
        public async  Task<ActionResult> Delete(int? id)
        {
            if (id == null)
            {
                return new HttpStatusCodeResult(HttpStatusCode.BadRequest);
            }
            Student student = await service.GetStudentByIdAsync((int)id);
            if (student == null)
            {
                return HttpNotFound();
            }
            return View(student);
        }

        // POST: Student/Delete/5
        [HttpPost, ActionName("Delete")]
        [ValidateAntiForgeryToken]
        public async Task<ActionResult> DeleteConfirmed(int id)
        {
            int count = await service.DeleteByIdAsync(id);
            return RedirectToAction("Index");
        }

        //protected override void Dispose(bool disposing)
        //{
        //    if (disposing)
        //    {
        //        db.Dispose();
        //    }
        //    base.Dispose(disposing);
        //}
    }
}

然后我们在修改_Layout.cshtml视图文件，添加学生管理的一个标签：

<!DOCTYPE html>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8"/>
    <meta charset="utf-8" />
    <meta name="viewport" content="width=device-width, initial-scale=1.0">
    <title>@ViewBag.Title - 我的 ASP.NET 应用程序</title>
    @Styles.Render("~/Content/CSS")
    @Scripts.Render("~/bundles/modernizr")
</head>
<body>
    <div class="navbar navbar-inverse navbar-fixed-top">
        <div class="container">
            <div class="navbar-header">
                <button type="button" class="navbar-toggle" data-toggle="collapse" data-target=".navbar-collapse">
                    <span class="icon-bar"></span>
                    <span class="icon-bar"></span>
                    <span class="icon-bar"></span>
                </button>
                @Html.ActionLink("应用程序名称", "Index", "Home", new { area = "" }, new { @class = "navbar-brand" })
            </div>
            <div class="navbar-collapse collapse">
                <ul class="nav navbar-nav">
                    <li>@Html.ActionLink("主页", "Index", "Home")</li>
                    <li>@Html.ActionLink("关于", "About", "Home")</li>
                    <li>@Html.ActionLink("联系方式", "Contact", "Home")</li>
                    <li>@Html.ActionLink("学生管理", "Index", "Student")</li>
                </ul>
            </div>
        </div>
    </div>
    <div class="container body-content">
        @RenderBody()
        <hr />
        <footer>
            <p>© @DateTime.Now.Year - 我的 ASP.NET 应用程序</p>
        </footer>
    </div>

    @Scripts.Render("~/bundles/Jquery")
    @Scripts.Render("~/bundles/bootstrap")
    @RenderSection("scripts", required: false)
</body>
</html>

运行程序，点击“学生管理”标签，就可以看到列表数据了：

这样我们就完成了一个ASP.NET MVC+EF实现异步增删改查的方法了。最终项目结构：

GitHub代码地址：https://github.com/jxl1024/TaskAsync。

到此这篇关于ASP.NET MVC+EF实现异步增删改查的文章就介绍到这了。希望对大家的学习有所帮助，也希望大家多多支持编程网。

点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: ASP.NET MVC+EF实现异步增删改查

本文链接: https://www.lsjlt.com/news/143546.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档

去做题

猜你喜欢

ASP.NET MVC+EF实现异步增删改查

目录功能实现1、搭建UI层2、添加实体类3、添加服务接口层4、添加Entity Framework1、开启迁移2、增加迁移3、生成数据库5、添加接口的实现类6、添加控制器功能实现我...

99+

2024-04-02
ASP.NET MVC使用Identity增删改查用户

源码在这里：https://github.com/darrenji/UseIdentityCRUDUserInMVC，本地下载在VS2013中创建一个MVC项目，用默认的"...

99+

2022-11-13

ASP.NET MVC Identity 增删改查用户
ASP.NET Core使用EF SQLite对数据库增删改查

目录1新建ASP.NETCoreMVC应用1.1新建MVC应用1.2引入NuGet包引入教程依赖项2新建模型和上下文2.1新建模型类2.2新建上下文步骤1步骤2步骤33配置服务1直接...

99+

2024-04-02
ASP.NET MVC如何使用Identity增删改查用户

这篇文章主要讲解了“ASP.NET MVC如何使用Identity增删改查用户”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“ASP.NET MVC如何使用Identity...

99+

2023-07-04
ASP.NET Core怎么使用EF SQLite对数据库增删改查

这篇文章将为大家详细讲解有关ASP.NET Core怎么使用EF SQLite对数据库增删改查，文章内容质量较高，因此小编分享给大家做个参考，希望大家阅读完这篇文章后对相关知识有一定的了解。1 新建ASP.NET Cor...

99+

2023-06-26
ASP.NET MVC创建XML文件并实现元素增删改

如果创建如下的XML： <xml version="1.0" encoding="utf-8" standalone="yes"> <Students> ...

99+

2022-11-13

ASP.NET MVC 创建XML XML增删改元素
EF Core的CRUD(增删改查)基本操作

一、增加（C）单笔增加 //添加 static void Add() { using (var db = n...

99+

2024-04-02
MongoDB实现增删改查

一、增加 insert向数据库中插入集合插入一条记录，传入集合 db..insert() db.students.insert({name:"唐僧",age:60,gender:"...

99+

2024-04-02
Mybatis实现增删改查

目录一.mybatis的配置1.1 添加相应的jar包1.2 配置mybatis.xml文件1.3 创建数据库1.4 创建实体类1.5 创建接口实现的方法1.6 配置UserMapp...

99+

2024-04-02
Mybatis（二）：实现“增删改查”

Mybatis（二）：实现“增删改查” 前言一、MyBatis的增删改查1、添加2、修改3、删除4、查询4.1 查询一个实体4.1 查询集合二、MyBatis获取参数值的两种方式（...

99+

2023-10-08

mybatis java 数据库
python实现mongodb的增删改查

python实现mongodb的增删改查环境：192.168.122.1 python192.168.122.11 mong...

99+

2023-01-31

python mongodb
Mybatis如何实现增删改查

这篇文章主要介绍了Mybatis如何实现增删改查，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。Mybatis实现增删改查一.mybatis的配置1.1 添加相应的jar包在l...

99+

2023-06-26
MongoDB怎么实现增删改查

这篇“MongoDB怎么实现增删改查”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“MongoDB怎么实现增删改查”文章吧。一...

99+

2023-06-30
SQL如何实现增删改查

这篇文章给大家分享的是有关SQL如何实现增删改查的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。SQL 是用于访问和处理数据库的标准的计算机语言。注意哟，SQL是一门语言。而MyS...

99+

2024-04-02
Java网络开发（Tomcat同步数据增删改查）—— 用Jsp语法实现同步请求的增删改查

目录引出显示所有数据到前端（1）前端代码：list.jsp（2）后端代码：CompanyListServlet.java 新增数据---转发类型信息---新增信息业务（1）在list.j...

99+

2023-09-05

java tomcat servlet
Mybatis步骤分解实现一个增删改查程序

目录 1.idea新建Maven项目Mybatis-study 将项目里的src文件夹删掉依次将此项目作为父项目 2.在Mybatis-study中新建模块mybatis-01 在...

99+

2024-04-02
python Django如何实现增删改查

这篇文章主要介绍python Django如何实现增删改查，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！1.先创建个app子级python .\manage.py startapp&nb...

99+

2023-06-29
C++_String增删查改模拟实现

C++_String增删查改模拟实现前言一、string默认构造、析构函数、拷贝构造、赋值重载1.1 默认构造1.2 析构函数1.3 拷贝构造1.4 赋值重载二、迭代器和范围for三、元素相关：operator[ ]四、容量...

99+

2023-12-23

c++ java jvm c语言笔记 stl
QT5连接MySQL实现增删改查

目录实现代码运行结果测试数据实现代码 #include #include #include #include #include #include #include #i...

99+

2022-12-28

QT5 MySQL增删改查 QT MySQL增删改查
MongoDB增删改查之查询怎么实现

这篇文章主要介绍MongoDB增删改查之查询怎么实现，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！详述1.简单查询：>db.t1.find() { "_id...

99+

2024-04-02