备案控制台
探索云世界
开发者社区 数据库 文章 正文

C# Dapper 简单实例

2017-11-26 1705
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL Serverless，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
简介：

/// <summary>

/// 分页信息
/// </summary>
public class PageInfo<T>
{
/// <summary>
/// 分页信息
/// </summary>
public PageInfo()
{
}
/// <summary>
/// 总页数
/// </summary>
public long TotalCount
{
get; set;
}
/// <summary>
///
/// </summary>
public IEnumerable<T> Data
{
get; set;
}
/// <summary>
///
/// </summary>
/// <param name="total"></param>
/// <param name="data"></param>
public PageInfo(long total, IEnumerable<T> data)
{
this.TotalCount = total;
this.Data = data;
}
}

*************

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)
{

}
}




本文转自94cool博客园博客，原文链接：http://www.cnblogs.com/94cool/p/6424774.html，如需转载请自行联系原作者

文章标签：
云数据库 RDS MySQL 版
C#
机器学习/深度学习
关系型数据库
数据库
索引
安全
数据库连接
相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境，其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
老朱教授
目录
相关文章
编程乐趣
|
5月前
|
SQL C# 数据库
推荐一个Dapper扩展CRUD基本操作的开源库
推荐一个Dapper扩展CRUD基本操作的开源库
编程乐趣
34 0
老码识途
|
9月前
|
SQL 开发框架 缓存
C# Abp框架入门系列文章（一）（上）
C# Abp框架入门系列文章（一）
老码识途
241 0
老码识途
|
9月前
|
前端开发 API 数据库
C# Abp框架入门系列文章（一）（下）
C# Abp框架入门系列文章（一）（下）
老码识途
316 0
陈珙
|
SQL 关系型数据库 MySQL
开源Dapper的Lambda扩展-Sikiro.Dapper.Extension V2.0
开源Dapper的Lambda扩展-Sikiro.Dapper.Extension V2.0
陈珙
200 0
开源Dapper的Lambda扩展-Sikiro.Dapper.Extension V2.0
喵叔哟
|
SQL 存储 C#
C#中如何使用Dapper
C#中如何使用Dapper
喵叔哟
227 0
阿笨net
|
SQL MySQL 关系型数据库
.NET轻量级ORM组件Dapper葵花宝典
一、摘要 为什么取名叫《葵花宝典》？ 从行走江湖的世界角度来讲您可以理解为一本"武功秘籍"，站在我们IT编程的世界角度应该叫"开发宝典"。 如果您在工作中主要接触的是操作MySQL数据库，但您又想学习和了解.NET轻量级ORM框架Dapper，那么就请跟着阿笨一起学习本次的分享课《.NET轻量级ORM框架Dapper葵花宝典》。
阿笨net
2181 0
嗯哼9925
|
测试技术 数据库
ABP理论学习之EntityFramework集成
嗯哼9925
964 0
青夜之衫
|
Scala
《快学Scala》第六章 对象 第七章 包和引入
青夜之衫
877 0
橘子红了呐
|
Java 前端开发
MonoRail学习笔记一：一个小例子
橘子红了呐
848 0
吞吞吐吐的
|
数据库 存储 SQL
[SPLEB]CodeSmith原理剖析(2)
吞吞吐吐的
1096 0

热门文章

最新文章

  • 1
    疑犯追踪第一季/全集Person Of Interest迅雷下载
  • 2
    【直播系列之一】1篇文章看懂峰值带宽、流量、转码、连麦、截图五大直播计费方式
  • 3
    理解事务的4种隔离级别
  • 4
    阿里云网站域名备案流程全过程讲解(图文)
  • 5
    在服务器的raid1中安装windows server系统（踩坑记录）
  • 6
    如何用Vue实现简易的富文本编辑器，并支持Markdown语法
  • 7
    怎么才能快速提高小程序留存率！
  • 8
    程序员请放下浮躁的心
  • 9
    如何解决域中普通用户只限于10台客户机加入域的数量问题
  • 10
    博客园模板 样式优化
  • 1
    未来技术纵横谈：区块链、物联网与虚拟现实的融合与创新
    47
  • 2
    软件体系结构 - 缓存技术（9）缓存穿透
    49
  • 3
    提升Android应用性能的实用技巧
    41
  • 4
    工具变量法(两阶段最小二乘法2SLS)线性模型分析人均食品消费时间序列数据和回归诊断（下）
    45
  • 5
    软件体系结构 - 缓存技术（8）缓存雪崩
    45
  • 6
    软件体系结构 - 缓存技术（7）Redis持久化方法
    52
  • 7
    Python用KShape对时间序列进行聚类和肘方法确定最优聚类数k可视化
    45
  • 8
    软件体系结构 - 缓存技术（6）淘汰策略
    48
  • 9
    基于R语言股票市场收益的统计可视化分析
    52
  • 10
    软件体系结构 - 数据分片（2）一致性哈希分片
    49

    • 相关课程

    更多
  • Go语言核心编程 - 面向对象、文件、单元测试、反射、TCP编程
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段
  • Java面向对象开发

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册

    • 相关实验场景

    更多
  • 语言入门-1：环境构建
  • 使用Java面向对象编写网络通信程序应用
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）