OracleBulkCopy 批量插入oracle数据库的方法
2018-03-27 13:52
513 查看
只有安装了Oracle 11G客户端的机器上才可以用,要用到ODP.NET组件中的oracleDataAccess.DLL,命名空间引用为Oracle.DataAccess.Client;
[csharp] view plain copy print?#region 批量插入数据
/// <summary>
/// 批量插入数据
/// </summary>
/// <param name=”dt”>要插入的数据</param>
/// <param name=”targetTable”>数据库中的表</param>
public static void BulkToDB(DataTable dt, string targetTable)
{
OracleConnection conn = new OracleConnection(connOrcleString);
OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.UseInternalTransaction); //用其它源的数据有效批量加载Oracle表中
//conn.BeginTransaction();
//OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.Default);
bulkCopy.BatchSize = 100000;
bulkCopy.BulkCopyTimeout = 260;
bulkCopy.DestinationTableName = targetTable; //服务器上目标表的名称
bulkCopy.BatchSize = dt.Rows.Count; //每一批次中的行数
try
{
conn.Open();
if (dt != null && dt.Rows.Count != 0)
bulkCopy.WriteToServer(dt); //将提供的数据源中的所有行复制到目标表中
}
catch (Exception ex)
{
throw ex;
}
finally
{
conn.Close();
if (bulkCopy != null)
bulkCopy.Close();
}
}
#endregion
————————————————————————————————–
第二种方法:
public static void AddDBSqlBulkCopy()
4000
{
DataTable dt = new DataTable();
DataColumn dcname = new DataColumn(“Name”,typeof(System.String));
dt.Columns.Add(dcname);
for (int i = 0; i < 10; i++)
{
DataRow row = dt.NewRow();
row[”Name”] =“Name_” + i.ToString();
dt.Rows.Add(row);
}
DataSet ds = new DataSet();
ds.Tables.Add(dt);
SqlConnection conn = new SqlConnection(connectionString);
conn.Open();
//声明SqlBulkCopy ,using释放非托管资源
using (SqlBulkCopy sqlBC = new SqlBulkCopy(conn))
{
//一次批量的插入的数据量
sqlBC.BatchSize = 1000;
//超时之前操作完成所允许的秒数,如果超时则事务不会提交 ,数据将回滚,所有已复制的行都会从目标表中移除
sqlBC.BulkCopyTimeout = 60;
//設定NotifyAfter 属性,以便在每插入10000 条数据时,呼叫相应事件。
sqlBC.NotifyAfter = 10000;
sqlBC.SqlRowsCopied += newSqlRowsCopiedEventHandler(sqlBC_SqlRowsCopied);
//设置要批量写入的表
sqlBC.DestinationTableName =”dbo.Name”;
//自定义的datatable和数据库的字段进行对应
sqlBC.ColumnMappings.Add(”Name”, “userName”);
// sqlBC.ColumnMappings.Add(“Name”,1);
//批量写入
sqlBC.WriteToServer(dt);
}
conn.Dispose();
}
static void sqlBC_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
}
第二种方法:
public static void AddDBSqlBulkCopy()
{
DataTable dt = new DataTable();
DataColumn dcname = new DataColumn("Name",typeof(System.String));
dt.Columns.Add(dcname);
for (int i = 0; i < 10; i++)
{
DataRow row = dt.NewRow();
row["Name"] ="Name_" + i.ToString();
dt.Rows.Add(row);
}
DataSet ds = new DataSet();
ds.Tables.Add(dt);
SqlConnection conn = new SqlConnection(connectionString);
conn.Open();
//声明SqlBulkCopy ,using释放非托管资源
using (SqlBulkCopy sqlBC = new SqlBulkCopy(conn))
{
//一次批量的插入的数据量
sqlBC.BatchSize = 1000;
//超时之前操作完成所允许的秒数,如果超时则事务不会提交 ,数据将回滚,所有已复制的行都会从目标表中移除
sqlBC.BulkCopyTimeout = 60;
//設定NotifyAfter 属性,以便在每插入10000 条数据时,呼叫相应事件。
sqlBC.NotifyAfter = 10000;
sqlBC.SqlRowsCopied += newSqlRowsCopiedEventHandler(sqlBC_SqlRowsCopied);
//设置要批量写入的表
sqlBC.DestinationTableName ="dbo.Name";
//自定义的datatable和数据库的字段进行对应
sqlBC.ColumnMappings.Add("Name", "userName");
// sqlBC.ColumnMappings.Add("Name",1);
//批量写入
sqlBC.WriteToServer(dt);
}
conn.Dispose();
}
static void sqlBC_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
[csharp] view plain copy print?#region 批量插入数据
/// <summary>
/// 批量插入数据
/// </summary>
/// <param name=”dt”>要插入的数据</param>
/// <param name=”targetTable”>数据库中的表</param>
public static void BulkToDB(DataTable dt, string targetTable)
{
OracleConnection conn = new OracleConnection(connOrcleString);
OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.UseInternalTransaction); //用其它源的数据有效批量加载Oracle表中
//conn.BeginTransaction();
//OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.Default);
bulkCopy.BatchSize = 100000;
bulkCopy.BulkCopyTimeout = 260;
bulkCopy.DestinationTableName = targetTable; //服务器上目标表的名称
bulkCopy.BatchSize = dt.Rows.Count; //每一批次中的行数
try
{
conn.Open();
if (dt != null && dt.Rows.Count != 0)
bulkCopy.WriteToServer(dt); //将提供的数据源中的所有行复制到目标表中
}
catch (Exception ex)
{
throw ex;
}
finally
{
conn.Close();
if (bulkCopy != null)
bulkCopy.Close();
}
}
#endregion
————————————————————————————————–
第二种方法:
public static void AddDBSqlBulkCopy()
4000
{
DataTable dt = new DataTable();
DataColumn dcname = new DataColumn(“Name”,typeof(System.String));
dt.Columns.Add(dcname);
for (int i = 0; i < 10; i++)
{
DataRow row = dt.NewRow();
row[”Name”] =“Name_” + i.ToString();
dt.Rows.Add(row);
}
DataSet ds = new DataSet();
ds.Tables.Add(dt);
SqlConnection conn = new SqlConnection(connectionString);
conn.Open();
//声明SqlBulkCopy ,using释放非托管资源
using (SqlBulkCopy sqlBC = new SqlBulkCopy(conn))
{
//一次批量的插入的数据量
sqlBC.BatchSize = 1000;
//超时之前操作完成所允许的秒数,如果超时则事务不会提交 ,数据将回滚,所有已复制的行都会从目标表中移除
sqlBC.BulkCopyTimeout = 60;
//設定NotifyAfter 属性,以便在每插入10000 条数据时,呼叫相应事件。
sqlBC.NotifyAfter = 10000;
sqlBC.SqlRowsCopied += newSqlRowsCopiedEventHandler(sqlBC_SqlRowsCopied);
//设置要批量写入的表
sqlBC.DestinationTableName =”dbo.Name”;
//自定义的datatable和数据库的字段进行对应
sqlBC.ColumnMappings.Add(”Name”, “userName”);
// sqlBC.ColumnMappings.Add(“Name”,1);
//批量写入
sqlBC.WriteToServer(dt);
}
conn.Dispose();
}
static void sqlBC_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
}
#region 批量插入数据 /// <summary> /// 批量插入数据 /// </summary> /// <param name="dt">要插入的数据</param> /// <param name="targetTable">数据库中的表</param> public static void BulkToDB(DataTable dt, string targetTable) { OracleConnection conn = new OracleConnection(connOrcleString); OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.UseInternalTransaction); //用其它源的数据有效批量加载Oracle表中 //conn.BeginTransaction(); //OracleBulkCopy bulkCopy = new OracleBulkCopy(connOrcleString, OracleBulkCopyOptions.Default); bulkCopy.BatchSize = 100000; bulkCopy.BulkCopyTimeout = 260; bulkCopy.DestinationTableName = targetTable; //服务器上目标表的名称 bulkCopy.BatchSize = dt.Rows.Count; //每一批次中的行数 try { conn.Open(); if (dt != null && dt.Rows.Count != 0) bulkCopy.WriteToServer(dt); //将提供的数据源中的所有行复制到目标表中 } catch (Exception ex) { throw ex; } finally { conn.Close(); if (bulkCopy != null) bulkCopy.Close(); } } #endregion
第二种方法:
public static void AddDBSqlBulkCopy()
{
DataTable dt = new DataTable();
DataColumn dcname = new DataColumn("Name",typeof(System.String));
dt.Columns.Add(dcname);
for (int i = 0; i < 10; i++)
{
DataRow row = dt.NewRow();
row["Name"] ="Name_" + i.ToString();
dt.Rows.Add(row);
}
DataSet ds = new DataSet();
ds.Tables.Add(dt);
SqlConnection conn = new SqlConnection(connectionString);
conn.Open();
//声明SqlBulkCopy ,using释放非托管资源
using (SqlBulkCopy sqlBC = new SqlBulkCopy(conn))
{
//一次批量的插入的数据量
sqlBC.BatchSize = 1000;
//超时之前操作完成所允许的秒数,如果超时则事务不会提交 ,数据将回滚,所有已复制的行都会从目标表中移除
sqlBC.BulkCopyTimeout = 60;
//設定NotifyAfter 属性,以便在每插入10000 条数据时,呼叫相应事件。
sqlBC.NotifyAfter = 10000;
sqlBC.SqlRowsCopied += newSqlRowsCopiedEventHandler(sqlBC_SqlRowsCopied);
//设置要批量写入的表
sqlBC.DestinationTableName ="dbo.Name";
//自定义的datatable和数据库的字段进行对应
sqlBC.ColumnMappings.Add("Name", "userName");
// sqlBC.ColumnMappings.Add("Name",1);
//批量写入
sqlBC.WriteToServer(dt);
}
conn.Dispose();
}
static void sqlBC_SqlRowsCopied(object sender, SqlRowsCopiedEventArgs e)
{
}</pre><br><br> </div> </div>
相关文章推荐
- OracleBulkCopy 批量插入oracle数据库的方法
- C# OracleBulkCopy 批量插入oracle数据库的方法
- C# 用SqlBulkCopy 批量插入oracle数据 遇到了 ORA-00054: 资源正忙, 但指定以 NOWAIT 方式获取资源, 或者超时失效
- DataTable数据批量插入数据的库三种方法:SqlCommand.EcecuteNonQurery(),SqlDataAdapter.Update(DataTable) ,SqlBulkCopy.
- 使用SqlBulkCopy将DataTable中的数据批量插入数据库中
- 使用SqlBulkCopy将DataTable中的数据批量插入数据库中
- 记录一下C#+Oracle批量插入的一个方法
- 点评 ibatis+oracle 批量插入的三种方法.
- 【物流系统】——C#Oracle批量导入(二)OracleBulkCopy
- EF结合SqlBulkCopy实现高效的批量数据插入 |EF插件EntityFramework.Extended实现批量更新和删除
- SqlBulkCopy方法批量导入DataTable表中的数据
- DataTable 批量插入SqlServer数据库 使用:SqlBulkCopy
- 使用SqlBulkCopy进行批量插入数据时踩过的坑
- SqlBulkCopy(批量复制)使用方法
- SqlServer批量插入数据方法--SqlBulkCopy
- [转]C#:用SqlBulkCopy来实现批量插入数据
- 采用SqlBulkCopy向数据库批量插入数据(大数据效果显著)
- c# 数据库批量插入数据SqlBulkCopy 示例
- SqlBulkCopy简单封装,让批量插入更方便
- SqlBulkCopy与触发器,批量插入表(存在则更新,不存在则插入)