Dapper 帮助类
/// <summary>
/// Dapper 工具类
/// </summary>
public static class DapperHelper
{
static string sqlconnection = System.Configuration.ConfigurationManager.ConnectionStrings["sqlServer"].ToString();
private static SqlConnection OpenConnection()
{
SqlConnection connection = new SqlConnection(sqlconnection); //这里sqlconnection就是数据库连接字符串
connection.Open();
return connection;
}
#region 查询数据
/// <summary>
/// 查询数据
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql">sql</param>
/// <param name="entity">T</param>
/// <returns></returns>
public static List<T> Query<T>(string sql, T entity)
{
List<T> list = new List<T>();
using (IDbConnection conn = OpenConnection())
{
list = conn.Query<T>(sql, entity).ToList();
}
return list;
}
/// <summary>
/// 查询数据
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql">sql</param>
/// <param name="obj">new {}</param>
/// <returns></returns>
public static List<T> Query<T>(string sql, object obj)
{
List<T> list = new List<T>();
using (IDbConnection conn = OpenConnection())
{
list = conn.Query<T>(sql, obj).ToList();
}
return list;
}
/// <summary>
/// 查询第一行第一列的数据
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql">sql</param>
/// <param name="obj">new {}</param>
/// <returns></returns>
public static T QueryScalar<T>(string sql, object obj)
{
T result = default(T);
using (IDbConnection conn = OpenConnection())
{
result = conn.ExecuteScalar<T>(sql, obj);
}
return result;
}
#endregion
#region 执行增,删,改
/// <summary>
/// 执行增,删,改
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql">sql</param>
/// <param name="entity"></param>
/// <returns></returns>
public static int NonQuery<T>(string sql, T entity)
{
int res = 0;
using (IDbConnection conn = OpenConnection())
{
res = conn.Execute(sql, entity);
}
return res;
}
/// <summary>
/// 执行增,删,改
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="sql">sql</param>
/// <param name="entity"></param>
/// <returns></returns>
public static int NonQuery(string sql, object obj)
{
int res = 0;
using (IDbConnection conn = OpenConnection())
{
res = conn.Execute(sql, obj);
}
return res;
}
#endregion
}
调用实例1
Role role =new Role();
// 给role赋值ID,RoleName,Description,CreateTime
string sql = "INSERT INTO [Role] ([ID],[RoleName],[Description], [CreateTime]) VALUES(NEWID(),@RoleName,@Description,getdate())";
int num = DapperHelper.NonQuery<Role>(sql, role);
调用实例2
string sql = "INSERT INTO [Role] ([ID],[RoleName],[Description], [CreateTime]) VALUES(NEWID(),@RoleName,@Description,getdate())";
int num = DapperHelper.NonQuery<Role>(sql, new {ID=ID,RoleName=RoleName,Description=Description,CreateTime=CreateTime});
目前只封装了这些方法需要的话以后再写
感兴趣的可以加QQ群:765907694 一起交流,探讨技术问题