C#实现Oracle批量写入数据的方法详解

//OracleDataAdapter.Update(DataTable dataTable)方式
using System.Data.OracleClient;
public static int BulkCopy(DataTable dataTable) {
            int result = 0;


            List<string> sql_column = new List<string>();
            List<string> sql_para = new List<string>();

            List<OracleParameter> paras = new List<OracleParameter>();
            foreach(DataColumn column in dataTable.Columns) {
                sql_column.Add(column.ColumnName);
                sql_para.Add(":" + column.ColumnName);

                OracleParameter para = new OracleParameter(column.ColumnName, ConvertOracleDbType(column.DataType));
                para.SourceColumn = column.ColumnName;
                paras.Add(para);
            }

            using(OracleConnection conn = new OracleConnection(ConfigurationManager.ConnectionStrings["default"].ConnectionString)) {
                conn.Open();
                string sql = $"insert into {dataTable.TableName}({string.Join(",", sql_column)}) values ({string.Join(",", sql_para)})";
                OracleCommand cmd = new OracleCommand(sql, conn);
                cmd.Parameters.AddRange(paras.ToArray());
                OracleDataAdapter adapter = new OracleDataAdapter();
                adapter.InsertCommand = cmd;
                result = adapter.Update(dataTable);
                conn.Close();
            }
            return result;
        }

        public static OracleType ConvertOracleDbType(Type type) {
            switch(type.Name.ToLower()) {
                case "decimal":
                return OracleType.Number;
                case "string":
                return OracleType.VarChar;
                case "datetime":
                return OracleType.DateTime;
                default:
                return OracleType.VarChar;
            }
        }

//OracleBulkCopy
using Oracle.DataAccess.Client;
public static int BulkCopy(DataTable dataTable) {

            int result = 0;

            using(OracleConnection conn = new OracleConnection(ConfigurationManager.ConnectionStrings["default"].ConnectionString)) {
                conn.Open();
                OracleBulkCopy oracleBulkCopy = new OracleBulkCopy(conn, OracleBulkCopyOptions.UseInternalTransaction);
                oracleBulkCopy.DestinationTableName = dataTable.TableName;

                foreach(DataColumn column in dataTable.Columns) {
                    oracleBulkCopy.ColumnMappings.Add(new OracleBulkCopyColumnMapping(column.ColumnName, column.ColumnName));
                }

                oracleBulkCopy.WriteToServer(dataTable);
                conn.Close();
            }
            return result;
        }

//ArrayBindCount
using Oracle.ManagedDataAccess.Client;
   public static OracleDbType ConvertOracleDbType(Type type) {
            switch(type.Name.ToLower()) {
                case "decimal":
                return OracleDbType.Decimal;
                case "string":
                return OracleDbType.Varchar2;
                case "datetime":
                return OracleDbType.Date;
                default:
                return OracleDbType.Varchar2;
            }
        }
        public static dynamic InitList(Type type) {
            switch(type.Name.ToLower()) {
                case "decimal":
                return new List<decimal>();
                case "string":
                return new List<string>();
                case "datetime":
                return new List<DateTime>();
                default:
                return new List<string>();
            }
        }
        public static void AddValue(dynamic list, Type type, object value) {
            switch(type.Name.ToLower()) {
                case "decimal":
                list.Add(Convert.ToDecimal(value));
                break;
                case "string":
                list.Add(Convert.ToString(value));
                break;
                case "datetime":
                list.Add(Convert.ToDateTime(value));
                break;
                default:
                list.Add(Convert.ToString(value));
                break;
            }
        }

        public static int BulkCopy(DataTable dataTable) {

            string connStr = "";
            int result = 0;

            List<string> sql_column = new List<string>();
            List<string> sql_para = new List<string>();

            List<OracleParameter> paras = new List<OracleParameter>();
            foreach(DataColumn column in dataTable.Columns) {

                sql_column.Add(column.ColumnName);
                sql_para.Add(":" + column.ColumnName);

                dynamic list = InitList(column.DataType);

                foreach(DataRow dr in dataTable.Rows) {
                    AddValue(list, column.DataType, dr[column]);
                }
                OracleParameter para = new OracleParameter(column.ColumnName, ConvertOracleDbType(column.DataType));
                para.Value = list.ToArray();
                paras.Add(para);
            }
            using(var connection = new OracleConnection(connStr)) {
                connection.Open();
                string sql = $"insert into {dataTable.TableName}({string.Join(",", sql_column)}) values ({string.Join(",", sql_para)})";
                OracleCommand cmd = new OracleCommand(sql, connection);
                cmd.Parameters.AddRange(paras.ToArray());
                cmd.ArrayBindCount = dataTable.Rows.Count;
                result = cmd.ExecuteNonQuery();
                connection.Close();
            }
            return result;
        }