c# - Oracle.DataAccess.Client.BulkCopy - 试图在不应该将 varchar2 转换为数字

Question

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

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

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

我使用 C# 和 ODP.Net 来运行存储过程并加载 DataTable。然后我执行一些额外的转换。但是，我从不触摸确认号码栏。

最后，我创建一个 OracleBulkCopy 对象，设置列映射，告诉它update Table 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. 正在调查数据表的内容loader begins 显示它们之间的列定义没有差异成功进入和未成功进入的。

我开始怀疑 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

        }

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

它肯定比成功的批量加载慢，但至少我可以获取数据。不过，如果有人对批量复制本身不断失败的原因有任何想法，我仍然很乐意。

Answer 1

BulkCopy 似乎根据给定的 DataTable 中列的声明类型进行某种类型转换。

如果您为导致问题的列打印 Column.DataType.ToString()，您很可能会看到数据库所期望的类型以外的类型。

您可以使用旧数据表创建一个新数据表，但显式地将有问题的列的 Column.DataType 更改为数据库期望的类型。

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;
}