Oracle.DataAccess.Client.BulkCopy - 尝试在不应该的时候将varchar2转换为数字

我有一个表(A)，其中包含一个名为 confirmation_number 的列。 它被定义为一个varchar2(30)，包含类似 SMITERI-2012-02-31-4567 .

我还有另一个表(B)，其中还包括一个名为 confirmation_number 的列，它也是一个varchar2(30)。

我有一个存储过程，可以从A中提取数据，对其执行一些转换，它包括确认编号列。

我使用 C# 和 ODP.Net 来运行存储过程并加载DataTable。 然后，我执行一些其他转换。 但是，我从不触摸确认数字列。

最后，我创建一个OracleBulkCopy对象，设置列映射，告诉它update表B，并调用loader.WriteToServer(dataTable)。

我收到以下错误：

Input string was not in a correct format.
   at System.Number.StringToNumber(String str, NumberStyles options, NumberBuffer& number, NumberFormatInfo info, Boolean parseDecimal)
   at System.Number.ParseInt64(String value, NumberStyles options, NumberFormatInfo numfmt)
   at Oracle.DataAccess.Client.OracleBulkCopy.PerformBulkCopy()

我已经确认错误发生在confirmation_number列上，因为如果我不加载该列，数据加载就会成功。

知道为什么BulkCopy会试图将varchar(2)变成Number吗？

编辑：我已确认以下相关问题：

1. 这不仅仅是在确认号码上发生的。 这似乎只是字符串列的问题 - 无论是来自字符串到字符串或字符串到整数。

2. 这不会发生在每个 varchar2 列上 - 姓氏和名字没有问题。

3. 这发生在没有空值的列上（确认数字）和可能具有空值（街道类型）的列。

4. 在加载程序开始显示这些之间的列定义没有差异成功进入和未

成功进入的。

我开始怀疑 BulkCopy 本身是否存在错误，以及我是否需要使用其他实用程序执行此加载。

编辑：

下面是精简的代码。

表 A

  CREATE TABLE "APPS_UNPROCESSED" 
   (    "LAST_NAME" VARCHAR2(30 BYTE), 
    "FIRST_NAME" VARCHAR2(30 BYTE), 
    "MIDDLE_NAME" VARCHAR2(30 BYTE), 
    "NAME_SUFFIX" VARCHAR2(30 BYTE), 
    "GENDER" VARCHAR2(1 BYTE), 
    "DATE_OF_BIRTH" VARCHAR2(10 BYTE), 
    "ID" NUMBER, 
     :
     :
    "CONFIRMATION_NUMBER" VARCHAR2(30 BYTE) NOT NULL ENABLE, 
    "IS_FBO" NUMBER(1,0), 
     :
     :
     CONSTRAINT "VR_APPS_UNPROCESSED_PK" PRIMARY KEY ("CONFIRMATION_NUMBER")

表 B

  CREATE TABLE "APPS_PROCESSED"
   (    "LAST_NAME" VARCHAR2(30 BYTE), 
    "FIRST_NAME" VARCHAR2(30 BYTE), 
    "MIDDLE_NAME" VARCHAR2(30 BYTE), 
    "NAME_SUFFIX" VARCHAR2(30 BYTE), 
    "GENDER" NUMBER(1,0), 
    "DATE_OF_BIRTH" DATE,
     :
     :
    "CONFIRMATION_NUMBER" VARCHAR2(30 BYTE), 
    "ID" NUMBER, 
    "IS_FBO" NUMBER(1,0),
     :
     :
    "ID" NUMBER NOT NULL ENABLE, 
     :
     :
     CONSTRAINT "VR_APPLICATION_PK" PRIMARY KEY ("ID")

程序

 procedure getUnprocessedApps(results OUT sys_refcursor)
   as
   BEGIN
    open results for
      select 
        a.last_name
        ,a.first_name
        ,a.middle_name
        ,a.name_suffix
        ,decode(a.gender, 'M', 1, 0) as gender_id
        ,a.gender as gender_code
        ,to_char(to_date(a.date_of_birth, 'MM-DD-YYYY'), 'DD-mon-YYYY') as date_of_birth
        ,cast(a.confirmation_number as varchar2(30)) as confirmation_number
        ,a.id
        ,0 as is_fbo
     :
     :
      from vr_apps_unprocessed a

获取数据

            DataSet data = new DataSet();
                OracleConnection conn = null;
                OracleCommand cmd = null;
                OracleDataAdapter data_adapter = new OracleDataAdapter();

                //fetch the data and load
                using (conn = new OracleConnection(connString))
                {
                    using (cmd = new OracleCommand())
                    {
                        cmd.Connection = conn;
                        cmd.CommandText = "APPS.getUnprocessedApps";
                        cmd.CommandType = CommandType.StoredProcedure;
                        cmd.Parameters.Add("results", OracleDbType.RefCursor, ParameterDirection.Output);
                        conn.Open();
                        data_adapter.SelectCommand = cmd;
                        data_adapter.Fill(data, "results");
                    }
                }
                return data.Tables["results"];

设置列映射

 private static Dictionary<string, string> ColumnMappings()
    {
        Dictionary<string, string> mapping = new Dictionary<string, string>();
        mapping.Add("last_name", "last_name");
        mapping.Add("first_name", "first_name");
        mapping.Add("middle_name", "middle_name");
        mapping.Add("name_suffix", "name_suffix");
        mapping.Add("gender_id", "gender"); 
        mapping.Add("date_of_birth", "date_of_birth");
        mapping.Add("is_fbo", "is_fbo"); 
        mapping.Add("confirmation_number", "confirmation_number");
        mapping.Add("id", "id"); 
     :
     :
            return mapping;
    }

加载文件

 private static void loadFiles(DataTable dt, string connString)
        {
            OracleConnection orclconn = null;
            OracleBulkCopy loader = null;
            //now insert the data into Oracle               
            using (orclconn = new OracleConnection(connString))
            {
                orclconn.Open();
                using (loader = new OracleBulkCopy(orclconn)) 
                {
                    loader.DestinationTableName = "APPS_Processed"
                    foreach (KeyValuePair<string, string> k in ColumnMappings())
                    {
                        loader.ColumnMappings.Add(k.Key, k.Value);
                    }
                    loader.WriteToServer(dt);
                } //end using oracle bulk loader
            } //end using oracle connection
        }

编辑：我一直无法让批量副本工作，但我得到了使用数组工作的传统方法：http://www.oracle.com/technetwork/issue-archive/2009/09-sep/o59odpnet-085168.html

它肯定比成功的批量加载慢，但至少我可以获取数据。 不过，如果有人对为什么批量副本本身不断失败有任何想法，我仍然会很高兴。

public DataTable potentialFix(DataTable dt) {    
    DataTable newTable = new DataTable(dt.TableName);
    //define columns for the new table with type string (or whatever type you want)
    foreach (DataColumn dc in dt.Columns)
    {
        newTable.Columns.Add(new DataColumn(dc.ColumnName, typeof(String)));
    }
    newTable.BeginLoadData();
    DataTableReader dtReader = new DataTableReader(dt);
    newTable.Load(dtReader);
    newTable.EndLoadData();
    return newTable;
}