Update unit test

This commit is contained in:
sunkaixuna 2021-11-21 13:06:43 +08:00
parent c9a7e4ad37
commit 9ae235746e
3 changed files with 32 additions and 2 deletions

View File

@ -56,8 +56,36 @@ namespace OrmTest
{ {
throw new Exception("unit Bulk"); throw new Exception("unit Bulk");
} }
Db.CodeFirst.InitTables<UnitIdentity111>();
Db.DbMaintenance.TruncateTable<UnitIdentity111>();
var count = Db.Fastest<UnitIdentity111111111>().AS("UnitIdentity111").BulkCopy(new List<UnitIdentity111111111> {
new UnitIdentity111111111(){ Id=1, Name="jack" }
});
if (count == 0)
{
throw new Exception("unit Bulk");
}
count = Db.Fastest<UnitIdentity111111111>().AS("UnitIdentity111").BulkUpdate(new List<UnitIdentity111111111> {
new UnitIdentity111111111(){ Id=1, Name="jack" }
});
if (count == 0)
{
throw new Exception("unit Bulk");
}
} }
} }
public class UnitIdentity111
{
public int Id { get; set; }
public string Name { get; set; }
}
public class UnitIdentity111111111
{
[SqlSugar.SugarColumn(IsPrimaryKey = true)]
public int Id { get; set; }
public string Name { get; set; }
}
public class UnitIdentity1 public class UnitIdentity1
{ {
[SqlSugar.SugarColumn(IsPrimaryKey =true,IsIdentity =true)] [SqlSugar.SugarColumn(IsPrimaryKey =true,IsIdentity =true)]

View File

@ -41,7 +41,7 @@ namespace OrmTest
} }
} }
}); });
public static SqlSugarClient singleDb = new SqlSugarClient(new ConnectionConfig() public static SqlSugarScope singleDb = new SqlSugarScope(new ConnectionConfig()
{ {
DbType = DbType.MySql, DbType = DbType.MySql,
ConnectionString = Config.ConnectionString, ConnectionString = Config.ConnectionString,

View File

@ -64,8 +64,10 @@ namespace SqlSugar
} }
public override async Task CreateTempAsync<T>(DataTable dt) public override async Task CreateTempAsync<T>(DataTable dt)
{ {
var queryable = this.Context.Queryable<T>();
var tableName = queryable.SqlBuilder.GetTranslationTableName(dt.TableName);
dt.TableName = "temp"+SnowFlakeSingle.instance.getID(); dt.TableName = "temp"+SnowFlakeSingle.instance.getID();
var sql = this.Context.Queryable<T>().Where(it => false).ToSql().Key; var sql = queryable.AS(tableName).Where(it => false).ToSql().Key;
await this.Context.Ado.ExecuteCommandAsync($"Create TEMPORARY table {dt.TableName}({sql}) "); await this.Context.Ado.ExecuteCommandAsync($"Create TEMPORARY table {dt.TableName}({sql}) ");
} }
} }