新建一个用户表,以该有为例

1.Model层

 public class TuiUsers{public int id { get; set; }public string userName { get; set; }public string userPass { get; set; }public int userType { get; set; }public string company { get; set; }public string detail { get; set; }public DateTime create_time { get; set; }public DateTime edit_time { get; set; }public int pid { get; set; }public string alipayUrl { get; set; }public string taobaoUrl { get; set; }public string linkMan { get; set; }public string contactInfo { get; set; }public decimal priceRatio { get; set; }public int stateFlag { get; set; }}

2.Dal层

通用连接

   internal class ConnectionFactory{public static DbConnection GetOpenConnection(string connstr){var connection = new MySql.Data.MySqlClient.MySqlConnection(connstr);connection.Open();return connection;}}

数据层

  public partial class TuiUsersDal{public string ConnStr { set; get; }public List<Entities.TuiUsers> GetListUser(string strWhere){StringBuilder strSql = new StringBuilder();strSql.Append("select * ");strSql.Append(" FROM `tuiusers` ");if (strWhere.Trim() != ""){strSql.Append(" where " + strWhere);}List<Entities.TuiUsers> list = new List<Entities.TuiUsers>();using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){list = connection.Query<Entities.TuiUsers>(strSql.ToString()).ToList();}return list;}/// <summary>/// 增加一条数据/// </summary>public bool Add(Entities.TuiUsers model){DynamicParameters Parameters = new DynamicParameters();int cnt = 0;string sQuery = "INSERT INTO tuiusers (userName,userPass,userType,company,detail,create_time,edit_time,pid,alipayUrl,taobaoUrl,linkMan,contactInfo,priceRatio)"+ " VALUES(@userName,@userPass,@userType,@company,@detail,@create_time,@edit_time,@pid,@alipayUrl,@taobaoUrl,@linkMan,@contactInfo,@priceRatio)";Parameters.Add("alipayUrl", model.alipayUrl);Parameters.Add("company", model.company);Parameters.Add("contactInfo", model.contactInfo);Parameters.Add("create_time", model.create_time);Parameters.Add("detail", model.detail);Parameters.Add("edit_time", model.edit_time);Parameters.Add("linkMan", model.linkMan);Parameters.Add("pid", model.pid);Parameters.Add("priceRatio", model.priceRatio);Parameters.Add("stateFlag", model.stateFlag);Parameters.Add("taobaoUrl", model.taobaoUrl);Parameters.Add("userName", model.userName);Parameters.Add("userPass", model.userPass);Parameters.Add("userType", model.userType);using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){cnt = connection.Execute(sQuery, Parameters);}if (cnt > 0){return true;}else{return false;}}/// <summary>/// 根据ID删除一条数据/// </summary>public bool Delete(int id){DynamicParameters Parameters = new DynamicParameters();int cnt = 0;string sQuery = "Delete FROM tuiusers " + "WHERE Id=@Id";Parameters.Add("Id", id);using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){cnt = connection.Execute(sQuery, Parameters);}if (cnt > 0){return true;}else{return false;}}/// <summary>/// 更新一条数据/// </summary>public bool Update(Entities.TuiUsers model){DynamicParameters Parameters = new DynamicParameters();string sQuery = "UPDATE tuiusers SET userPass=@userPass,userType=@userType,company=@company,detail=@detail,edit_time=@edit_time,pid=@pid,alipayUrl=@alipayUrl,taobaoUrl=@taobaoUrl,linkMan=@linkMan,contactInfo=@contactInfo,priceRatio=@priceRatio where userName=@userName";Parameters.Add("alipayUrl", model.alipayUrl);Parameters.Add("company", model.company);Parameters.Add("contactInfo", model.contactInfo);Parameters.Add("create_time", model.create_time);Parameters.Add("detail", model.detail);Parameters.Add("edit_time", model.edit_time);Parameters.Add("linkMan", model.linkMan);Parameters.Add("pid", model.pid);Parameters.Add("priceRatio", model.priceRatio);Parameters.Add("stateFlag", model.stateFlag);Parameters.Add("taobaoUrl", model.taobaoUrl);Parameters.Add("userName", model.userName);Parameters.Add("userPass", model.userPass);Parameters.Add("userType", model.userType);int cnt = 0;using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){cnt = connection.Execute(sQuery, Parameters);}if (cnt > 0){return true;}else{return false;}}/// <summary>/// 根据ID获取实体对象/// </summary>public Entities.TuiUsers GetModel(int id){DynamicParameters Parameters = new DynamicParameters();string sQuery = "SELECT * FROM tuiusers " + "WHERE id = @id";Parameters.Add("id", id);using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){return connection.Query<Entities.TuiUsers>(sQuery, Parameters).FirstOrDefault();}}/// <summary>/// 根据userName获取实体对象/// </summary>public Entities.TuiUsers GetModelByUserName(string userName){DynamicParameters Parameters = new DynamicParameters();string sQuery = "SELECT * FROM tuiusers " + "WHERE userName = @userName";Parameters.Add("userName", userName);using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){return connection.Query<Entities.TuiUsers>(sQuery, Parameters).FirstOrDefault();}}/// <summary>分页获取数据列表/// /// </summary>public List<Entities.TuiUsers> GetListArray(string fileds, string orderstr, int PageSize, int PageIndex, string strWhere){string cond = string.IsNullOrEmpty(strWhere) ? "" : string.Format(" where {0}", strWhere);string sql = string.Format("select {0} from `tuiusers` {1} order by {2} limit {3},{4}", fileds, cond, orderstr, (PageIndex - 1) * PageSize, PageSize);List<Entities.TuiUsers> list = new List<Entities.TuiUsers>();using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){list = connection.Query<Entities.TuiUsers>(sql).ToList();}return list;}/// <summary>计算记录数/// /// </summary>/// <param name="p"></param>/// <returns></returns>public int CalcCount(string where){string sql = "select count(1) from `tuiusers`";if (!string.IsNullOrEmpty(where)){sql += " where " + where;}using (var connection = ConnectionFactory.GetOpenConnection(ConnStr)){int i = connection.QuerySingle<int>(sql);return i;}}}

3.Startup注入

        public Startup(IConfiguration configuration){Configuration = configuration;}public IConfiguration Configuration { get; }// This method gets called by the runtime. Use this method to add services to the container.public void ConfigureServices(IServiceCollection services){//取出appsetting.json中的数据库连接字符串string connStr = Configuration.GetSection("ConnStr").Value;//注入services.AddSingleton<DAL.UsersDAL>(new DAL.UsersDAL() { ConnStr = connStr });services.AddSingleton<DAL.TuiUsersDal>(new DAL.TuiUsersDal() { ConnStr = connStr });//解决中文被编码
            services.AddSingleton(HtmlEncoder.Create(UnicodeRanges.All));services.Configure<CookiePolicyOptions>(options =>{// This lambda determines whether user consent for non-essential cookies is needed for a given request.options.CheckConsentNeeded = context => true;options.MinimumSameSitePolicy = SameSiteMode.None;});//开启授权认证相关模块(中间件)
            services.AddAuthentication(options =>{options.DefaultChallengeScheme = CookieAuthenticationDefaults.AuthenticationScheme;options.DefaultAuthenticateScheme = CookieAuthenticationDefaults.AuthenticationScheme;}).AddCookie(options =>{options.LoginPath = "/Account/";options.Cookie.HttpOnly = true;});services.AddTransient<HttpContextAccessor>();services.AddMvc().SetCompatibilityVersion(CompatibilityVersion.Version_2_1);}

4.配置文件

{"ConnStr": "server=localhost;database=phone_card;uid=root;pwd=123456;charset=utf8;SslMode=None","Logging": {"LogLevel": {"Default": "Warning"}},"AllowedHosts": "*"
}

转载于:https://www.cnblogs.com/Guroer/p/10403966.html

.net Core+Dapper MySQL增删改查相关推荐

  1. MySQL—增删改查,分组,连表,limit,union,alter,排序,去重

    MySQL增删改查 在表格的增删改查中,查的内容是最多的,包括group by ,join,limit,union,alter,排序都是服务于查的 #sql语句数据行操作补充#增加:#insert i ...

  2. koa2 mysql增删改查_koa2实现对mysql的增删改查函数封装

    // 项目开始先造一个简单的node服务器server.js: const Koa = require('koa'); const Path= require('path'); const Stati ...

  3. python pymysql实例_Python使用pymysql模块操作mysql增删改查实例分析

    Python使用pymysql模块操作mysql增删改查实例分析 发布时间:2020-09-30 16:42:12 来源:脚本之家 阅读:92 本文实例讲述了Python使用pymysql模块操作My ...

  4. mysql 增删改查时的错误解决方法大全

    mysql 增删改查时的错误解决方法大全     信息1:Error: Access denied for user: 'linanma@localhost' (Using password: YES ...

  5. Mysql增删改查sql语句练习

    Mysql增删改查sql语句练习 关于数据库的一些操作: 进入mysql 命令行: mysql -uroot –p 查看所有数据库: show databases; 创建数据库: create dat ...

  6. mysql增删改查,模糊查询及链表(一)

    在Nodejs中mysql增删改查及链表 欢迎点击: 个人官网博客 1.连接mysql数据库 let mysql=require('mysql') let connextion=mysql.creat ...

  7. 运维之道 | MySQL增删改查插入必会命令大全

    MySQL增删改查插入必会命令大全 基本命令 1.登录mysql [root@localhost ~]# mysql -u root -p 2.查询当前所存在的库 MariaDB [(none)]&g ...

  8. mysql增删改查,连表,排序,等

    (mysql增删改查,连表,排序,等,)–教学来自(bilibili狂神!)(笔记是自己学习过程中纯手写,由于是直接复制笔记,有些可以忽略) (学习方法"先理解,在敲一遍"之后复习 ...

  9. 二进制安装mysql及MySQL增删改查

    二进制安装mysql及MySQL增删改查 1. MySQL简介 2. MySQL的特点 3. 数据库在 Web 开发中的重要地位 4. 安装MySQL 4.1 首先需要下载MySQL的包 4.3 解决 ...

最新文章

  1. oracle数据库 pc6,使用logdump 查看ogg的CSN
  2. 现在无法停止通用卷设备_软化和柔顺有什么区别吗?头发粗硬适合拉直还是烫卷?...
  3. MASM5.0汇编环境安装
  4. 【Unity】Planar Shadows平面阴影的实现
  5. FCS编程之NetConnect对象
  6. 关于Qomo OpenProject的进度(2006.01.04)
  7. 软件工程现行国标汇集
  8. 全国计算机一级知识题及答案解析,全国计算机等级考试一级试题库大全完整版附参考答案...
  9. Redis入门(三)Redis的基本数据类型
  10. 【leveldb】资料
  11. 基于jquery的异步提交例子
  12. 老段工作室成立两周年
  13. 医疗搜索中的query词权重算法探索
  14. 网络规划设计师教程知识点精讲之计算机网络分类
  15. 计算机视觉 图像算法工程师 面试问题总结
  16. IDEA配置JDK版本
  17. 互联网公司的“江湖绰号”盘点,你知道几个?
  18. 声纹识别(一)——简介
  19. PostgreSQL助力小微企业管理系统变革
  20. oracle安装时创建应答文件,12c 应答方式安装 (二) 创建cdb+pdb+netca

热门文章

  1. WebBrowser组件和MSHTML
  2. [LCS]半个月的成果,用RTCClient开发的Robot!
  3. python文件对象提供了3个读方法、分别是-Python读写文件模式和文件对象方法实例详解...
  4. python开发安卓程序-如何使用python开发android应用
  5. python下载安装包-python安装包 官方版
  6. python pip-python的pip安装以及使用教程
  7. python界面图片-python如何实现读取并显示图片(不需要图形界面)
  8. 如何自学python数据分析-如何轻松学习Python数据分析?
  9. python开发微信小程序-微信小程序开发:python+sanic 实现小程序登录注册
  10. 一个python程序员需要掌握的知识-python初学者搭建网站需要了解的基础知识