Dapper基本用法--MySql

NuGet:

• Dapper 2.0.35
• MySql.Data
• System.Data

實體（Entity）

   public class student
    {
        public int Id { get; set; }
        public string RealName { get; set; }
        public DateTime EnrollmenDate { get; set; }
    }

 

配置文件數據庫連接

  <connectionStrings>
    <add name="mysqlConn" connectionString="server=127.0.0.1;database=數據庫;User ID=root;password=密碼"/>
  </connectionStrings>

 

MySql連接字符串

private static string connStr = string.Empty;
        public MySqlOperation()
        {
            connStr = System.Configuration.ConfigurationManager.ConnectionStrings["mysqlConn"].ConnectionString;
        }

查詢語句

        /// <summary>
        /// 查詢所有
        /// </summary>
        /// <returns>lists</returns>
        public List<student> Query()
        {
            if (string.IsNullOrEmpty(connStr))
            {
                return new List<student>(); ;
            }
            try
            {
                using (IDbConnection db = new MySqlConnection(connStr))
                {
                    db.Open();//打開數據庫
                    string mysqlStr = "select * from  student";
                    List<student> lists = db.Query<student>(mysqlStr).ToList();
                    db.Close();//關閉數據庫
                    return lists;
                }
            }
            catch (Exception)
            {
                return new List<student>();
            }
        }
        /// <summary>
        /// 根據Id查詢
        /// </summary>
        /// <param name="id"></param>
        /// <returns>lists</returns>
        public List<student> Query(string id)
        {
            if (string.IsNullOrEmpty(connStr))
            {
                return new List<student>();
            }
            try
            {
                using (IDbConnection db = new MySqlConnection(connStr))
                {
                    db.Open();//打開數據庫
                    string mysqlStr = "select * from  student where Id=@id";
                    List<student> lists = db.Query<student>(mysqlStr, new { Id = id }).ToList();
                    db.Close();//關閉數據庫
                    return lists;
                }
            }
            catch (Exception)
            {
                return new List<student>();
            }
        }

 

插入語句

        /// <summary>
        /// 插入數據
        /// </summary>
        /// <param name="student">student</param>
        /// <returns>-1:連接字符串為空，-2：新增失敗</returns>
        public int Insert(student student)
        {
            if (string.IsNullOrEmpty(connStr))
            {
                return -1;
            }
            try
            {
                using (IDbConnection db = new MySqlConnection(connStr))
                {
                    db.Open();//打開數據庫
                    string mysqlStr = "insert into student(Id,RealName,EnrollmenDate) values(@Id,@RealName,@EnrollmenDate)";
                    int list = db.Execute(mysqlStr, student);
                    db.Close();//關閉數據庫
                    return list;
                }
            }
            catch (Exception)
            {
                return -2;
            }
        }

 

刪除數據

        /// <summary>
        /// 刪除數據
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public int Delect(string id)
        {
            if (string.IsNullOrEmpty(connStr))
            {
                return -1;
            }
            try
            {
                using (IDbConnection db = new MySqlConnection(connStr))
                {
                    db.Open();//打開數據庫
                    string mysqlStr = "delete from student where Id=@id";
                    int list = db.Execute(mysqlStr, new { Id = id });
                    db.Close();//關閉數據庫
                    return list;
                }
            }
            catch (Exception)
            {
                return -2;
            }
        }

更新數據

        /// <summary>
        /// 更新信息
        /// </summary>
        /// <param name="student"></param>
        /// <returns>-1:連接字符串為空，-2：更新失敗</returns>
        public int Update(student student)
        {
            if (string.IsNullOrEmpty(connStr))
            {
                return -1;
            }
            try
            {
                using (IDbConnection db = new MySqlConnection(connStr))
                {
                    db.Open();//打開數據庫
                    string mysqlStr = "update student set RealName=@RealName where Id=@Id";
                    int list = db.Execute(mysqlStr, student);
                    db.Close();//關閉數據庫
                    return list;
                }
            }
            catch (Exception)
            {
                return -2;
            }
        }