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

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 = ;
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 > )
{
return true;
}
else
{
return false;
}
} /// <summary>
/// 根据ID删除一条数据
/// </summary>
public bool Delete(int id)
{
DynamicParameters Parameters = new DynamicParameters();
int cnt = ;
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 > )
{
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 = ;
using (var connection = ConnectionFactory.GetOpenConnection(ConnStr))
{
cnt = connection.Execute(sQuery, Parameters);
}
if (cnt > )
{
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 - ) * 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": "*"
}

.net Core+Dapper MySQL增删改查的更多相关文章

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

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

  2. PHP MySql增删改查

    mysql_connect()连接数据库 mysql_select_db选择数据库 mysql_fetch_assoc()获取结果集 mysql_query()执行sql语句 实例如下: <?p ...

  3. mysql增删改查练习

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

  4. Django学习之mysql增删改查

    上节介绍了如何使用命令行操作mysql增删改查,现在介绍如何使用python管理mysql 使用pip 下载完mysql后,mysql会以pymysql模块的形式存储在pycharm的包文件里.我们通 ...

  5. mysql增删改查相关操作

    mysql增删改查相关操作 以前用mysql用的少,对于数据库相关的操作不熟悉,现在开始要接触数据库了,记录一下相关的基础操作吧. 1.数据库的授权操作 # mysql -u root -p Ente ...

  6. 基于gin的golang web开发:mysql增删改查

    Go语言访问mysql数据库需要用到标准库database/sql和mysql的驱动.标准库的Api使用比较繁琐这里再引入另一个库github.com/jmoiron/sqlx. go get git ...

  7. 使用轻量级ORM Dapper进行增删改查

      项目背景 前一段时间,开始做一个项目,在考虑数据访问层是考虑技术选型,考虑过原始的ADO.NET.微软的EF.NH等.再跟经理讨论后,经理强调不要用Ef,NH做ORM,后期的sql优化不好做,公司 ...

  8. Dapper进行增删改查 z

    http://www.cnblogs.com/huangkaiyan10/p/4640548.html 项目背景 前一段时间,开始做一个项目,在考虑数据访问层是考虑技术选型,考虑过原始的ADO.NET ...

  9. nodejs+express+mysql 增删改查

    之前,一直使用的是nodejs+thinkjs来完成自己所需的项目需求,而对于nodejs中另外一中应用框架express却了解的少之又少,这两天就简单的了解了一下如何使用express来做一些数据库 ...

随机推荐

  1. eclipse自动排版JSP问题

    eclipse自动排版JSP非常难看,标签每行显示不完整,开发时很难受,下面设置一下这个就好多了: window-->preferences-->Web-->HTML Files-- ...

  2. Sublime文件夹显示过滤

    Preferences/Setting-User添加如下命令: "file_exclude_patterns": ["*.mate", "*.gif& ...

  3. Cadence 建立封装:多个引脚于芯片内部连接的封装建立方式

    Ti 家有一种片子,型号为CSD19534Q5A.此芯片的外观样式如图: 可以看到,这个片子共有8个引脚,其中5.6.7和8这四个引脚的内部是连接在一起的. Ti 在数据手册中也介绍了封装的样式: 下 ...

  4. Rhel6-tomcat+nginx+memcached配置文档

    理论基础: User - > web ->nginx  ->tomcat1 ->*.jsp 80          8080 ↓      -> tomcat2 html ...

  5. hdu 4628 动态规划

    思路:首先就是状态压缩,然后判断哪些状态是回文串.最后就是动态方程:dp[i]=min(dp[i],dp[j]+1).这个方程得前提条件是状态(j-i)为回文串. #include<iostre ...

  6. Go学习笔记 - 使用jsonrpc进行远程访问

    Go学习笔记 - 使用jsonrpc进行远程访问 JSON-RPC JSON-RPC是一个轻量级的远程调用协议,简单易用. 请求数据体: { "method": "get ...

  7. python decorator 基础

    一般来说,装饰器是一个函数,接受一个函数(或者类)作为参数,返回值也是也是一个函数(或者类).首先来看一个简单的例子: # -*- coding: utf-8 -*- def log_cost_tim ...

  8. IdentityServer4 中文文档 -13- (快速入门)切换到混合流并添加 API 访问

    IdentityServer4 中文文档 -13- (快速入门)切换到混合流并添加 API 访问 原文:http://docs.identityserver.io/en/release/quickst ...

  9. scala 模式匹配详解 2 scala里是怎么实现的?

    在这篇martin和另外两位模式匹配领域专家的论文里说了模式匹配的几种实现方式,以及scala是选择哪种方式来实现的.http://lampwww.epfl.ch/~emir/written/Matc ...

  10. 囤币一族,被中国市场遗忘的价值币ADA

    囤币一族,被中国市场遗忘的价值币ADA ==========================长期囤币目标:trx十万个,ada一万个,eos五千个,nas一千个,ont一千个,eth一百个,比特币十个 ...