.net5 core webapi項目實戰之四：數據庫操作的編碼實現

1 . 用戶表t_user的字段如下表：

字段名稱	類型	描述
user_id	int	用戶唯一編號
nickname	varchar(10)	用戶昵稱
email	varchar(30)	登錄郵箱
password	varchar(20)	登陸密碼
role_code	varchar(10)	角色代碼（1：普通用戶，2：銀卡會員，3：金卡會員，4：鑽石會員）
state_code	char(1)	狀態代碼（1：正常，0：鎖定，默認是1）
mobile	varchar(15)	手機號
age	smallint	用戶年齡
register_time	datetime	注冊日期

2 . 為了聚焦在.net core上，所有數據庫操作都用偽代碼實現，即只做接口，不具體編碼實現。

3 . 在models文件夾中新建 user.cs，用於數據的強類型操作，代碼如下：

    public class User
    {
        public int UserId{ get; set; }
        public string Nickname { get; set; }
        public string Email { get; set; }
        public string Password { get; set; }
        public int RoleCode { get; set; }
        public int StateCode { get; set; }
        public string Mobile { get; set; }
        public int Age { get; set; }
        public DateTime RegisterTime { get; set; } 

    }

4 . 在應用的根目錄上新建DataAccess的文件夾，並新增兩個文件，IUserDao.cs和MySqlUserDao.cs，

其中IUserDao.cs是接口，定義對表的操作接口，MySqlUserDao.cs是類文件，繼承自IUserDao.cs，負責針對MySQL數據庫的操作。

IUserDao.cs代碼如下：

    public interface IUserDao
    {
        public List<User> GetUserList();

        public void CreateUser(User user);

        public void UpdateUserRole(int userId, int roleCode);

        public void UpdateUserState(int userId, int stateCode);

        public User GetUser(int userId);

        public void UpdateUser(User user);

        public void UpdatePassword(int userId, string oldPassword, string newPassword);
    }

針對MySQL數據庫，我們使用MySQL官方提供的開發工具包來做數據庫的操作，在使用前，

需要先用"管理NeGet程序包(N)..."的功能引入MySql.Data開發工具包，如下：

輸入mysql后搜索即可看到此開發工具包，直接安裝就可以了，如下：

 

在MySqlUserDao.cs中用using MySql.Data.MySqlClient添加引用，然后就可以使用Connection/Command/Reader等對象了，偽代碼如下：

using System;
using System.Collections.Generic;
using MySql.Data.MySqlClient;

namespace WebApiDemo
{
    public class MySqlUserDao : IUserDao
    {
        private MySqlConnection _conn;

        public MySqlUserDao()
        {
            _conn = new MySqlConnection();
        }

        public void CreateUser(User user)
        {
            try
            {
                //do database operation... 
                return;
            }
            catch { throw; }
            finally { _conn.Close(); } 
        }

        public User GetUser(int userId)
        {
            try
            {
                User user = new User()
                {
                    UserId = 1,
                    Nickname = "張三",
                    Email = "[e-mail]",
                    Password = "56ftytysvr",
                    RoleCode = 1,
                    StateCode = 1,
                    Mobile = "",
                    Age = 28,
                    RegisterTime = DateTime.Now
                };
                return user;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }

        public List<User> GetUserList()
        {
            try
            {
                User user1 = new User()
                {
                    UserId = 1,
                    Nickname = "張三",
                    Email = "[e-mail]",
                    Password = "56ftytysvr",
                    RoleCode = 1,
                    StateCode = 1,
                    Mobile = "13856785678",
                    Age = 28,
                    RegisterTime = DateTime.Now
                };
                User user2 = new User()
                {
                    UserId = 2,
                    Nickname = "李四",
                    Email = "[e-mail]",
                    Password = "hjgh786dgsw",
                    RoleCode = 2,
                    StateCode = 1,
                    Mobile = "13866667777",
                    Age = 31,
                    RegisterTime = DateTime.Now
                };

                List<User> list = new List<User>();
                list.Add(user1);
                list.Add(user2);
                return list;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }

        public void UpdatePassword(int userId, string oldPassword, string newPassword)
        {
            try
            {
                //do database operation... 
                return;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }

        public void UpdateUser(User user)
        {
            try
            {
                //do database operation... 
                return;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }

        public void UpdateUserRole(int userId, int roleCode)
        {
            try
            {
                //do database operation... 
                return;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }

        public void UpdateUserState(int userId, int stateCode)
        {
            try
            {
                //do database operation... 
                return;
            }
            catch { throw; }
            finally { _conn.Close(); }
        }
    }
}

至此，數據庫的操作就准備好了，在具體的項目中，只需要在try{}語句中添加相關的數據庫操作代碼就可以了，

當然，如果使用的是SQL Server或Oracle等數據庫，需要添加相應的開發工具包。

 

注：在同一個項目中添加的所有類或者接口都盡可能放在同樣的命名空間下，這樣編碼會比較方便。