2

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

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

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

我使用C#andODP.Net运行存储过程并DataTable用它加载 a 。然后我执行一些额外的转换。但是，我从来没有碰过确认号码栏。

最后，我创建一个OracleBulkCopy对象，设置列映射，告诉它updateTable 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会试图把 avarchar(2)变成 a 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

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

4

2 回答 2

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;
}
于 2012-08-06T20:02:24.623 回答
0

我相信问题出在您的“date_of_birth”列中。您传递的是字符串而不是日期。由于日期是数字，它会尝试转换它们，但它不是它期望的格式，您更改了月份和日期的顺序。

于 2012-04-11T06:27:09.770 回答