C# Dapper 简单实例
*************
using DapperExtensions.Mapper;
using Statistics.Model;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace FlowStatistics
{
public static class Mappings
{
public static void Initialize()
{
DapperExtensions.DapperExtensions.DefaultMapper = typeof(PluralizedAutoClassMapper<>);
DapperExtensions.DapperExtensions.SetMappingAssemblies(new[]
{
typeof(Mappings).Assembly
});
}
public class FlowCellMapper : ClassMapper<FlowCell>
{
public FlowCellMapper()
{
Table("jxc_flow_cell");
//Map(fcel => fcel.id).Column("id");
//Map(fcel => fcel.parent_id).Column("parent_id");
//Map(fcel => fcel.create_time).Column("create_time");
//Map(fcel => fcel.type_id).Column("type_id");
Map(fcel => fcel.comId).Column("bloc_code");
//Map(fcel => fcel.bloc_name).Column("bloc_name");
//Map(fcel => fcel.cell_number).Column("cell_number");
//Map(fcel => fcel.name).Column("name");
//Map(fcel => fcel.flows).Column("flows");
//Map(fcel => fcel.status).Column("status");
//Map(fcel => fcel.del).Column("del");
AutoMap();
}
}
}
}
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Dapper;
using DapperExtensions;
using DapperExtensions.Sql;
using MySql.Data.MySqlClient;
using System.Data;
using Z.Dapper.Plus;
namespace FlowStatistics
{
/// <summary>
/// 数据客户端
/// 参考：https://github.com/StackExchange/dapper-dot-net
/// Predicates参考：https://github.com/tmsmith/Dapper-Extensions/wiki/Predicates
/// https://github.com/zzzprojects/Dapper-Plus
/// </summary>
public class DbClient : IDisposable, IDbClient
{
string connStr = @"Data Source=.\sqlexpress;Initial Catalog=tempdb;Integrated Security=True;uid=sa;pwd=123456";
int commandTimeout = 30;
/// <summary>
/// 数据客户端
/// </summary>
/// <param name="connStr">数据库连接字符串</param>
/// <param name="dbType">数据库类型</param>
/// <param name="commandTimeout">操作超时,单位：秒</param>
/// <param name="autoEditEntityTime">是否自动更实体对象的创建时间、更新时间</param>
public DbClient(string connStr, int commandTimeout = 30)
{
if (string.IsNullOrWhiteSpace(connStr)) throw new NoNullAllowedException("数据库连接字符串不允许为空");
this.connStr = connStr;
this.commandTimeout = commandTimeout;
DapperExtensions.DapperExtensions.SqlDialect = new MySqlDialect();
Mappings.Initialize();
//DapperExtensions.DapperExtensions.DefaultMapper = typeof(CustomPluralizedMapper<>);
}
/// <summary>
/// 获取打开的连接
/// </summary>
/// <param name="mars">MSSql数据库下有效：如果为 true，则应用程序可以保留多活动结果集 (MARS)。 如果为 false，则应用程序必须处理或取消一个批处理中的所有结果集，然后才能对该连接执行任何其他批处理。</param>
/// <returns></returns>
public IDbConnection GetOpenConnection()
{
IDbConnection connection = null;
string cs = connStr;
connection = new MySqlConnection(cs);
connection.Open();
return connection;
}
#region Add
/// <summary>
/// 批量新增
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="entities">实体对象集</param>
public void Add<T>(IEnumerable<T> entities) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
using (var trans = cnn.BeginTransaction())
{
try
{
cnn.Insert(entities, trans, commandTimeout);
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
}
//using (IDbConnection cnn = GetOpenConnection())
//{
// var trans = cnn.BeginTransaction();
// cnn.Execute(@"insert Member(Username, IsActive) values(@Username, @IsActive)", entities, transaction: trans);
// trans.Commit();
//}
}
/// <summary>
/// 新增
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="entity">实体对象</param>
/// <returns>实体对象</returns>
public T Add<T>(T entity) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
T res = null;
using (var trans = cnn.BeginTransaction())
{
try
{
int id = cnn.Insert(entity, trans, commandTimeout);
if (id > 0)
{
res = entity;
}
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
return res;
}
}
#endregion
#region Update
/// <summary>
/// 更新
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="entity">实体对象</param>
/// <returns>是否成功</returns>
public bool Update<T>(T entity) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
bool res = false;
using (var trans = cnn.BeginTransaction())
{
try
{
res = cnn.Update(entity, trans, commandTimeout);
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
return res;
}
}
public bool Update<T>(IEnumerable<T> entities) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
bool res = false;
using (var trans = cnn.BeginTransaction())
{
try
{
trans.BulkUpdate(entities);
res = true;
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
return res;
}
}
#endregion
#region Delete
/// <summary>
/// 删除
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="entity">实体对象</param>
/// <returns>是否成功</returns>
public bool Delete<T>(T entity) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
bool res = false;
using (var trans = cnn.BeginTransaction())
{
try
{
res = cnn.Delete(entity, trans, commandTimeout);
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
return res;
}
}
/// <summary>
/// 条件删除
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="predicate">实体对象</param>
/// <returns>是否成功</returns>
public bool Delete<T>(object predicate) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
bool res = false;
using (var trans = cnn.BeginTransaction())
{
try
{
res = cnn.Delete(predicate, trans, commandTimeout);
}
catch (DataException ex)
{
trans.Rollback();
throw ex;
}
trans.Commit();
}
return res;
}
}
#endregion
#region Query/Get
/// <summary>
/// 查询单个结果
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="id">实体的Id属性值</param>
/// <returns>查询结果</returns>
public T Get<T>(object id) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
T res = null;
try
{
res = cnn.Get<T>(id, null, commandTimeout);
}
catch (DataException ex)
{
throw ex;
}
return res;
}
}
/// <summary>
/// 查询结果集合
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="predicate">分页查询条件</param>
/// <param name="sort">是否排序</param>
/// <returns>查询结果</returns>
public IEnumerable<T> Get<T>(object predicate = null, IList<ISort> sort = null) where T : class, new()
{
using (IDbConnection cnn = GetOpenConnection())
{
IEnumerable<T> res = null;
try
{
res = cnn.GetList<T>(predicate, sort, null, commandTimeout);
}
catch (DataException ex)
{
throw ex;
}
return res;
}
}
/// <summary>
/// 查询结果分页
/// </summary>
/// <typeparam name="T">实体类型</typeparam>
/// <param name="predicate">分页查询条件</param>
/// <param name="sort">是否排序</param>
/// <param name="pageIndex">分页索引</param>
/// <param name="pageSize">分页大小</param>
/// <returns>查询结果</returns>
public PageInfo<T> Get<T>(object predicate, IList<ISort> sort, int pageIndex, int pageSize) where T : class, new()
{
if (sort == null) throw new ArgumentNullException("sort 不允许为null");
if (pageIndex < 0) pageIndex = 0;
using (IDbConnection cnn = GetOpenConnection())
{
PageInfo<T> pInfo = null;
try
{
int count = cnn.Count<T>(predicate, null, commandTimeout);
pInfo = new PageInfo<T>();
pInfo.TotalCount = count;
pInfo.Data = cnn.GetPage<T>(predicate, sort, pageIndex, pageSize, null, commandTimeout);
}
catch (DataException ex)
{
throw ex;
}
return pInfo;
}
}
#endregion
#region IDisposable Support
private bool disposedValue = false; // 要检测冗余调用
protected virtual void Dispose(bool disposing)
{
if (!disposedValue)
{
if (disposing)
{
// TODO: 释放托管状态(托管对象)。
}
// TODO: 释放未托管的资源(未托管的对象)并在以下内容中替代终结器。
// TODO: 将大型字段设置为 null。
disposedValue = true;
}
}
// TODO: 仅当以上 Dispose(bool disposing) 拥有用于释放未托管资源的代码时才替代终结器。
// ~DbClient() {
// // 请勿更改此代码。将清理代码放入以上 Dispose(bool disposing) 中。
// Dispose(false);
// }
// 添加此代码以正确实现可处置模式。
void IDisposable.Dispose()
{
// 请勿更改此代码。将清理代码放入以上 Dispose(bool disposing) 中。
Dispose(true);
// TODO: 如果在以上内容中替代了终结器，则取消注释以下行。
// GC.SuppressFinalize(this);
}
#endregion
}
}
public class FlowCell
{
public int Id { get; set; }
public int type_id { get; set; }
public string comId { get; set; }
public string bloc_name { get; set; }
public string cell_number { get; set; }
public string name { get; set; }
public int flows { get; set; }
public int status { get; set; }
public int del { get; set; }
}
使用：
public void Statistics()
{
try
{
DbClient dbClient = new DbClient(mysqlConstr);
var pg = new PredicateGroup { Operator = GroupOperator.Or, Predicates = new List<IPredicate>() };
pg.Predicates.Add(Predicates.Field<FlowCell>(f => f.status, Operator.Eq, 1));
pg.Predicates.Add(Predicates.Field<FlowCell>(f => f.del, Operator.Eq, 0));
var flowCell = dbClient.Get<FlowCell>(4);
IList<ISort> sorts = new List<ISort>();
ISort sort = new Sort();
sort.Ascending = false;
sort.PropertyName = "name"; //如果有Map，则此次要填写Map对象的字段名称，而不是数据库表字段名称
sorts.Add(sort);
var flowCell2 = dbClient.Get<FlowCell>(pg, sorts);
var flowCell3 = dbClient.Get<FlowCell>(pg, sorts, 0, 2);
}
catch (Exception ex)
{
}
}
C# Dapper 简单实例相关推荐
- java查询mysql装载bean_jsp与javabean链接mysql数据库并查询数据表的简单实例源码
jsp与javabean链接mysql数据库并查询数据表的简单实例源码.这个简单的实例是给新手学习的,或者一些高手临时忘记怎么使用jsp操作mysql数据库时候查找的,包括了建立mysql数据库连接的 ...
- js入门·循环与判断/利用函数的简单实例/使用对象/列举对象属性的名称
1,列举对象属性的名称 <script language="javascript"> var obj=new Object(); obj.a="您好,我是田洪 ...
- 关于webservice的异步调用简单实例
于webservice的异步调用简单实例 无论在任何情况下,被调用方的代码无论是被异步调用还是同步调用的情况下,被调用方的代码都是一样的, 下面,我们就以异步调用一个webservice 为例作说明. ...
- （三）AJAX基本介绍和简单实例03
(三)AJAX基本介绍和简单实例03-----Ajax与数据库的动态应用 前台显示界面: 选择所有客户之后: 选择其中一个客户---杜森: Demo03.html代码 <html> < ...
- protobuf和socket通信简单实例
protobuf和socket通信简单实例 protobuf是 Google 公司内部的混合语言数据标准,可以用来定义通信的协议,由于其有序列化和反序列化的操作,减小了存储或通信的数据量,从而达到 ...
- 转载 jsonrpc环境搭建和简单实例
jsonrpc环境搭建和简单实例 一.环境准备 下载需要的jar包和js文件,下载地址:https://yunpan.cn/cxvbm9DhK9tDq 访问密码 6a50 二.新建一个web工程,j ...
- spring之AOP的简单实例
AOP:面向切面编程,就是把除去业务部分以外的东西单独模块化,比如打日志等,就像学生信息的增删改查,可以把输出日志单独模块化出来,通过切面对的方式进行编程. 在进行实例编写之前先进行一些专业术语的了解 ...
- Hibernate搭建开发环境+简单实例（二）
2019独角兽企业重金招聘Python工程师标准>>> Hibernate是非常典型的持久层框架,持久化的思想是非常值得我们学习和研究的.这篇博文,我们主要以实例的形式学习Hiber ...
- WPF MvvmLight简单实例(1) 页面导航
原文:WPF MvvmLight简单实例(1) 页面导航 实现了那些功能,先看看截图: 操作描述: 在程序运行后,点击"Load"按钮,页面会加载PageOne,点击PageOne ...
最新文章
- 为您解析大数据的未来趋势
- 把所有的谎言献给你β（找规律数学题）
- 从内涵段子到皮皮虾，娱乐App为何不能一鱼两吃？
- matlab交替隐式迭代,jQuery关于隐式迭代的个人理解~
- jQuery.sap.factory
- java like a_如何在Java中实现类似“ LIKE”运算符的SQL？
- 支持向量所在超平面方程_深入浅出机器学习算法：支持向量机
- USB Mass Storage大容量存储 The Thirteen Class章节的理解
- SPC控制图——单值移动极差图（X- MR）详解
- 如何在博途精智面板及WinCC RT ADV中创建面板
- 如何将网页保存保存为PDF格式？
- Python图像匹配
- 计算机防止检查清理软件吗,清除电脑垃圾用什么软件好 如何预防电脑卡顿
- HTML特殊符号表示方法
- nginx配置详解及设置代理服务器（1）
- mysql 统计七日留存率_1.七日留存率-SQL实现
- 用js获取ios时间戳，结果为NaN或不显示
- 正点原子 核心板IMX6ULL IIC RTC驱动 PCF8563
- Axure的页面交互
- 关于百度“凤巢”的猜想及其它