Oracle 批量插入 运行 速度慢且小巧
Oracle bulk insert running slow with dapper
当我们按照文档中的说明使用Oracle执行批量插入时,它在10秒内传输了200条数据。我怎样才能更有效地做到这一点?
public async Task InsertAsync()
{
var items = GetItems();
using var connection = OpenOracleConnection();
var transaction = connection.BeginTransaction();
await connection.ExecuteAsync(@"insert into TableName
(Column1, Column2, Column3, Column4, Column5, Column6, Column7, Column8 ,Column9, Column10) VALUES
(:p1, :p2, :p3, :p4, :p5, :p6, :p7, :p8, :p9, :p10) ", items, transaction: transaction);
transaction.Commit();
}
private static IEnumerable<object> GetItems()
{
var list = new List<object>();
for (int i = 0; i < 200; i++)
{
list.Add(new
{
p1 = new Random().Next(0,999999),
p2 = 1,
p3 = "-",
p4 = "--",
p5 = "--",
p6 = "---",
p7 = "----",
p8 = DateTime.Now,
p9 = "-",
p10 = 1
});
}
return list;
}
您当前的代码并没有真正执行 Bulk Insertion
。它一次一次插入列表中的每个项目
如果您真的想在 Oracle 中以最快的速度执行 BulkInsert
,请了解数组绑定插入。
免责声明:我是项目的所有者Dapper Plus
这个项目不是免费的,但可以让您轻松地在 Oracle 中进行批量插入(也可以在后台使用数组绑定)。
// Your mapping
DapperPlusManager.Entity<TEntity>().ToTable("TableName")
// ...code...
transaction.BulkInsert(items)
当我们按照文档中的说明使用Oracle执行批量插入时,它在10秒内传输了200条数据。我怎样才能更有效地做到这一点?
public async Task InsertAsync()
{
var items = GetItems();
using var connection = OpenOracleConnection();
var transaction = connection.BeginTransaction();
await connection.ExecuteAsync(@"insert into TableName
(Column1, Column2, Column3, Column4, Column5, Column6, Column7, Column8 ,Column9, Column10) VALUES
(:p1, :p2, :p3, :p4, :p5, :p6, :p7, :p8, :p9, :p10) ", items, transaction: transaction);
transaction.Commit();
}
private static IEnumerable<object> GetItems()
{
var list = new List<object>();
for (int i = 0; i < 200; i++)
{
list.Add(new
{
p1 = new Random().Next(0,999999),
p2 = 1,
p3 = "-",
p4 = "--",
p5 = "--",
p6 = "---",
p7 = "----",
p8 = DateTime.Now,
p9 = "-",
p10 = 1
});
}
return list;
}
您当前的代码并没有真正执行 Bulk Insertion
。它一次一次插入列表中的每个项目
如果您真的想在 Oracle 中以最快的速度执行 BulkInsert
,请了解数组绑定插入。
免责声明:我是项目的所有者Dapper Plus
这个项目不是免费的,但可以让您轻松地在 Oracle 中进行批量插入(也可以在后台使用数组绑定)。
// Your mapping
DapperPlusManager.Entity<TEntity>().ToTable("TableName")
// ...code...
transaction.BulkInsert(items)