.net Core+Dapper MySQL增删改查
新建一个用户表,以该有为例
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增删改查相关推荐
- MySQL—增删改查,分组,连表,limit,union,alter,排序,去重
MySQL增删改查 在表格的增删改查中,查的内容是最多的,包括group by ,join,limit,union,alter,排序都是服务于查的 #sql语句数据行操作补充#增加:#insert i ...
- koa2 mysql增删改查_koa2实现对mysql的增删改查函数封装
// 项目开始先造一个简单的node服务器server.js: const Koa = require('koa'); const Path= require('path'); const Stati ...
- python pymysql实例_Python使用pymysql模块操作mysql增删改查实例分析
Python使用pymysql模块操作mysql增删改查实例分析 发布时间:2020-09-30 16:42:12 来源:脚本之家 阅读:92 本文实例讲述了Python使用pymysql模块操作My ...
- mysql 增删改查时的错误解决方法大全
mysql 增删改查时的错误解决方法大全 信息1:Error: Access denied for user: 'linanma@localhost' (Using password: YES ...
- Mysql增删改查sql语句练习
Mysql增删改查sql语句练习 关于数据库的一些操作: 进入mysql 命令行: mysql -uroot –p 查看所有数据库: show databases; 创建数据库: create dat ...
- mysql增删改查,模糊查询及链表(一)
在Nodejs中mysql增删改查及链表 欢迎点击: 个人官网博客 1.连接mysql数据库 let mysql=require('mysql') let connextion=mysql.creat ...
- 运维之道 | MySQL增删改查插入必会命令大全
MySQL增删改查插入必会命令大全 基本命令 1.登录mysql [root@localhost ~]# mysql -u root -p 2.查询当前所存在的库 MariaDB [(none)]&g ...
- mysql增删改查,连表,排序,等
(mysql增删改查,连表,排序,等,)–教学来自(bilibili狂神!)(笔记是自己学习过程中纯手写,由于是直接复制笔记,有些可以忽略) (学习方法"先理解,在敲一遍"之后复习 ...
- 二进制安装mysql及MySQL增删改查
二进制安装mysql及MySQL增删改查 1. MySQL简介 2. MySQL的特点 3. 数据库在 Web 开发中的重要地位 4. 安装MySQL 4.1 首先需要下载MySQL的包 4.3 解决 ...
最新文章
- oracle数据库 pc6,使用logdump 查看ogg的CSN
- 现在无法停止通用卷设备_软化和柔顺有什么区别吗?头发粗硬适合拉直还是烫卷?...
- MASM5.0汇编环境安装
- 【Unity】Planar Shadows平面阴影的实现
- FCS编程之NetConnect对象
- 关于Qomo OpenProject的进度(2006.01.04)
- 软件工程现行国标汇集
- 全国计算机一级知识题及答案解析,全国计算机等级考试一级试题库大全完整版附参考答案...
- Redis入门(三)Redis的基本数据类型
- 【leveldb】资料
- 基于jquery的异步提交例子
- 老段工作室成立两周年
- 医疗搜索中的query词权重算法探索
- 网络规划设计师教程知识点精讲之计算机网络分类
- 计算机视觉 图像算法工程师 面试问题总结
- IDEA配置JDK版本
- 互联网公司的“江湖绰号”盘点,你知道几个?
- 声纹识别(一)——简介
- PostgreSQL助力小微企业管理系统变革
- oracle安装时创建应答文件,12c 应答方式安装 (二) 创建cdb+pdb+netca
热门文章
- WebBrowser组件和MSHTML
- [LCS]半个月的成果,用RTCClient开发的Robot!
- python文件对象提供了3个读方法、分别是-Python读写文件模式和文件对象方法实例详解...
- python开发安卓程序-如何使用python开发android应用
- python下载安装包-python安装包 官方版
- python pip-python的pip安装以及使用教程
- python界面图片-python如何实现读取并显示图片(不需要图形界面)
- 如何自学python数据分析-如何轻松学习Python数据分析?
- python开发微信小程序-微信小程序开发:python+sanic 实现小程序登录注册
- 一个python程序员需要掌握的知识-python初学者搭建网站需要了解的基础知识