/// <summary> /// 大数据块入库 /// </summary> /// <param name="dt"></param> /// <param name="targetTable"></param> public void BulkToDB(DataTable dt, string targetTable) { string err = "大批量插入时产生错误"; string conStr = PubConstant.ConnectionString; conStr = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.29.98)(PORT=1521)) (CONNECT_DATA=(SERVICE_NAME=ORCL)));User ID=bridgeSystest;Password=abc123"; Oracle.DataAccess.Client.OracleConnection conn = new Oracle.DataAccess.Client.OracleConnection(conStr); //System.Data.OracleClient.OracleConnection conn = new System.Data.OracleClient.OracleConnection(conStr); if (conn.State != ConnectionState.Open) { conn.Open(); } // Oracle.DataAccess.Client.OracleBulkCopy bulkCopy = new Oracle.DataAccess.Client.OracleBulkCopy(conn, OracleBulkCopyOptions.Default); Oracle.DataAccess.Client.OracleBulkCopy bulkCopy = new Oracle.DataAccess.Client.OracleBulkCopy(conn, OracleBulkCopyOptions.Default); bulkCopy.BatchSize = 100000; bulkCopy.BulkCopyTimeout = 260; bulkCopy.DestinationTableName = targetTable; try { if (conn.State != ConnectionState.Open) { conn.Open(); } // conn.Open(); if (dt != null && dt.Rows.Count != 0) { bulkCopy.WriteToServer(dt); } } catch (Exception ex) { // Log.WriteLog(err, ex); } finally { conn.Close(); if (bulkCopy != null) bulkCopy.Close(); } }
/// 大数据块入库
/// </summary>
/// <param name="dt"></param>
/// <param name="targetTable"></param>
public void BulkToDB(DataTable dt, string targetTable)
{
string err = "大批量插入时产生错误";
string conStr = PubConstant.ConnectionString;
conStr = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=192.168.29.98)(PORT=1521)) (CONNECT_DATA=(SERVICE_NAME=ORCL)));User ID=bridgeSystest;Password=abc123";
Oracle.DataAccess.Client.OracleConnection conn = new Oracle.DataAccess.Client.OracleConnection(conStr);
//System.Data.OracleClient.OracleConnection conn = new System.Data.OracleClient.OracleConnection(conStr);
if (conn.State != ConnectionState.Open)
{ conn.Open(); }
// Oracle.DataAccess.Client.OracleBulkCopy bulkCopy = new Oracle.DataAccess.Client.OracleBulkCopy(conn, OracleBulkCopyOptions.Default);
Oracle.DataAccess.Client.OracleBulkCopy bulkCopy = new Oracle.DataAccess.Client.OracleBulkCopy(conn, OracleBulkCopyOptions.Default);
bulkCopy.BatchSize = 100000;
bulkCopy.BulkCopyTimeout = 260;
bulkCopy.DestinationTableName = targetTable;
try
{
if (conn.State != ConnectionState.Open)
{
conn.Open();
}
// conn.Open();
if (dt != null && dt.Rows.Count != 0)
{
- 粉丝: 0
- 资源: 10
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
- vHierarchy 2 v2.0.15
- EoqcConstant.java
- 9种自动驾驶传感器融合算法.pdf
- access模式及trunk模式配置拓扑图.topo
- BEV下统一的多传感器融合框架FUTR3D.pdf
- 5A968A4B377F25ED0A1FD3C67B0CEE31
- 基于Element-UI 的二次封装图片上传组件
- Odin 2.1.8 unity package
- 04-19 周五 GitHub actions-runner 程序解释
- RecyclerView探索之通过ItemDecoration实现StickyHeader效果_stickyheadcontainer-CSDN博客.html