mirror of
https://gitee.com/dotnetchina/SqlSugar.git
synced 2025-07-15 05:13:27 +08:00
MySql bluk copy
This commit is contained in:
parent
d9c3013fa3
commit
d3733ffddb
@ -24,6 +24,62 @@ namespace OrmTest
|
|||||||
new Unit4ASDF() { Id=2, Id2=1 }}).UseMySql().ExecuteBlueCopy();
|
new Unit4ASDF() { Id=2, Id2=1 }}).UseMySql().ExecuteBlueCopy();
|
||||||
|
|
||||||
var list = Db.Queryable<Unit4ASDF>().ToList();
|
var list = Db.Queryable<Unit4ASDF>().ToList();
|
||||||
|
|
||||||
|
Db.CodeFirst.InitTables<testdb>();
|
||||||
|
Db.DbMaintenance.TruncateTable("testdb");
|
||||||
|
var list1 = new List<testdb>();
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
for (int i = 0; i < 10; i++)
|
||||||
|
|
||||||
|
{
|
||||||
|
|
||||||
|
var id = i.ToString();
|
||||||
|
|
||||||
|
list1.Add(new testdb
|
||||||
|
|
||||||
|
{
|
||||||
|
|
||||||
|
id = id,
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
Console.WriteLine(id + " Length:" + id.Length);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
Db.Insertable(list1).UseMySql().ExecuteBlueCopy();
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
var queryList = Db.Queryable<testdb>().ToList();
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
foreach (var item in queryList)
|
||||||
|
|
||||||
|
{
|
||||||
|
|
||||||
|
if (item.id.Length != 1)
|
||||||
|
|
||||||
|
{
|
||||||
|
|
||||||
|
throw new Exception("blue copy");
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public class testdb
|
||||||
|
|
||||||
|
{
|
||||||
|
|
||||||
|
public string id { get; set; }
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -74,7 +74,7 @@ namespace SqlSugar
|
|||||||
}
|
}
|
||||||
var fileName = dllPath + "\\" + Guid.NewGuid().ToString() + ".csv";
|
var fileName = dllPath + "\\" + Guid.NewGuid().ToString() + ".csv";
|
||||||
var dataTableToCsv = DataTableToCsvString(dt);
|
var dataTableToCsv = DataTableToCsvString(dt);
|
||||||
File.WriteAllText(fileName, dataTableToCsv, Encoding.UTF8);
|
File.WriteAllText(fileName, dataTableToCsv, new UTF8Encoding(false));
|
||||||
MySqlConnection conn = this.Context.Ado.Connection as MySqlConnection;
|
MySqlConnection conn = this.Context.Ado.Connection as MySqlConnection;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user