Skip to content

D
Dapper.Lite

s0611163 / Dapper.Lite
6 个月 前同步成功

通知 1
Star 0
Fork 0
D
Dapper.Lite

前往新版Gitcode，体验更适合开发者的 AI 搜索 >>

提交 ddac8cbc 编写于 作者: s0611163's avatar s0611163
浏览文件
操作

修改单元测试代码 DapperTest

上级 f5765c12
隐藏空白更改
内联 并排
Showing with 88 addition and 94 deletion
Dapper.Lite/Dapper.LiteTest/DapperTest.cs
浏览文件 @ ddac8cbc
......@@ -29,28 +29,27 @@ namespace Dapper.LiteTest
session.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = session.GetConnection()) // 获取数据库连接，也可以直接new MySqlConnection
{
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
var conn = session.GetConnection(); // 获取数据库连接，也可以直接new MySqlConnection
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
foreach (SysUser item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
foreach (SysUser item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
}
#endregion
#region 测试混合并发使用Dapper和LiteSql
#region 测试混合并发使用Dapper和Dapper.Lite
[TestMethod]
public void TestUseDapper2()
{
......@@ -83,22 +82,21 @@ namespace Dapper.LiteTest
session.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = session.GetConnection())
{
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
var conn = session.GetConnection();
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
Console.WriteLine("Dapper查询成功, count=" + list.Count);
Console.WriteLine("Dapper查询成功, count=" + list.Count);
foreach (SysUser item in list)
{
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
foreach (SysUser item in list)
{
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
}
catch (Exception ex)
......@@ -121,22 +119,21 @@ namespace Dapper.LiteTest
db.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = db.GetConnection()) // 获取数据库连接，也可以直接new MySqlConnection
{
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
var conn = db.GetConnection(); // 获取数据库连接，也可以直接new MySqlConnection
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
DynamicParameters dynamicParameters = new DynamicParameters();
dynamicParameters.Add("id", 20);
foreach (SysUser item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
List<SysUser> list = conn.Query<SysUser>(@"
select *
from sys_user
where id < @id", dynamicParameters).ToList();
foreach (SysUser item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
}
......@@ -150,18 +147,17 @@ namespace Dapper.LiteTest
db.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = db.GetConnection()) // 获取数据库连接，也可以直接new MySqlConnection
{
var sql = db.Queryable<SysUser>().Where(t => t.Id < 20 && t.RealName.Contains("管理员"));
var conn = db.GetConnection(); // 获取数据库连接，也可以直接new MySqlConnection
var list = conn.Query<SysUser>(sql.SQL, sql.DynamicParameters).ToList();
var sql = db.Queryable<SysUser>().Where(t => t.Id < 20 && t.RealName.Contains("管理员"));
foreach (var item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
var list = conn.Query<SysUser>(sql.SQL, sql.DynamicParameters).ToList();
foreach (var item in list)
{
Console.WriteLine(ModelToStringUtil.ToString(item));
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
Assert.IsTrue(!string.IsNullOrWhiteSpace(item.UserName));
}
}
......@@ -179,33 +175,32 @@ namespace Dapper.LiteTest
session.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = session.GetConnection()) // 获取数据库连接，也可以直接new MySqlConnection
try
{
try
{
var trans = session.BeginTransaction();
var tran = session.BeginTransaction();
var sql1 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark1, Id = 1 });
var sql2 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark2, Id = 2 });
trans.Connection.Execute(sql1.SQL, sql1.DynamicParameters);
trans.Connection.Execute(sql2.SQL, sql2.DynamicParameters);
var sql1 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark1, Id = 1 });
var sql2 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark2, Id = 2 });
tran.Connection.Execute(sql1.SQL, sql1.DynamicParameters);
tran.Connection.Execute(sql2.SQL, sql2.DynamicParameters);
session.CommitTransaction();
}
catch
{
session.RollbackTransaction();
throw;
}
session.CommitTransaction();
}
catch
{
session.RollbackTransaction();
throw;
}
var sql3 = session.Queryable<SysUser>().Where(t => t.Id == 1);
var user1 = conn.QuerySingleOrDefault<SysUser>(sql3.SQL, sql3.DynamicParameters);
var sql4 = session.Queryable<SysUser>().Where(t => t.Id == 2);
var user2 = conn.QuerySingleOrDefault<SysUser>(sql4.SQL, sql4.DynamicParameters);
var conn = session.GetConnection(); // 获取数据库连接，也可以直接new MySqlConnection
Assert.IsTrue(user1.Remark == remark1);
Assert.IsTrue(user2.Remark == remark2);
}
var sql3 = session.Queryable<SysUser>().Where(t => t.Id == 1);
var user1 = conn.QuerySingleOrDefault<SysUser>(sql3.SQL, sql3.DynamicParameters);
var sql4 = session.Queryable<SysUser>().Where(t => t.Id == 2);
var user2 = conn.QuerySingleOrDefault<SysUser>(sql4.SQL, sql4.DynamicParameters);
Assert.IsTrue(user1.Remark == remark1);
Assert.IsTrue(user2.Remark == remark2);
}
#endregion
......@@ -229,34 +224,33 @@ namespace Dapper.LiteTest
session.SetTypeMap<SysUser>(); //设置数据库字段名与实体类属性名映射
using (var conn = session.GetOpenedConnection()) // 获取数据库连接，也可以直接new MySqlConnection
var tran = session.BeginTransaction();
try
{
var trans = conn.BeginTransaction();
var sql1 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark1, Id = 1 });
var sql2 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark2, Id = 2 });
tran.Connection.Execute(sql1.SQL, sql1.DynamicParameters, tran);
tran.Connection.Execute(sql2.SQL, sql2.DynamicParameters, tran);
try
{
var sql1 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark1, Id = 1 });
var sql2 = session.Sql<SysUser>(@"update sys_user set remark=@Remark where id=@Id", new { Remark = remark2, Id = 2 });
conn.Execute(sql1.SQL, sql1.DynamicParameters, trans);
conn.Execute(sql2.SQL, sql2.DynamicParameters, trans);
tran.Commit();
}
catch
{
tran.Rollback();
throw;
}
trans.Commit();
}
catch
{
trans.Rollback();
throw;
}
var conn = session.GetConnection(); // 获取数据库连接，也可以直接new MySqlConnection
var sql3 = session.Queryable<SysUser>().Where(t => t.Id == 1);
var user1 = conn.QuerySingleOrDefault<SysUser>(sql3.SQL, sql3.DynamicParameters);
var sql4 = session.Queryable<SysUser>().Where(t => t.Id == 2);
var user2 = conn.QuerySingleOrDefault<SysUser>(sql4.SQL, sql4.DynamicParameters);
var sql3 = session.Queryable<SysUser>().Where(t => t.Id == 1);
var user1 = conn.QuerySingleOrDefault<SysUser>(sql3.SQL, sql3.DynamicParameters);
var sql4 = session.Queryable<SysUser>().Where(t => t.Id == 2);
var user2 = conn.QuerySingleOrDefault<SysUser>(sql4.SQL, sql4.DynamicParameters);
Assert.IsTrue(user1 != null);
Assert.IsTrue(user2 != null);
Console.WriteLine("完成" + index);
}
Assert.IsTrue(user1 != null);
Assert.IsTrue(user2 != null);
Console.WriteLine("完成" + index);
});
tasks.Add(task);
}
......
Markdown is supported
0% 或 .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑！
想要评论请 注册 或