Ошибка при вставке данных с использованием SqlBulkCopy - PullRequest
Новая
       12

Ошибка при вставке данных с использованием SqlBulkCopy

15 голосов
/ 21 июня 2009

Я пытаюсь пакетно вставить данные в SQL 2008, используя SqlBulkCopy.

Вот мой стол: 

IF OBJECT_ID(N'statement', N'U') IS NOT NULL
DROP TABLE [statement]
GO
CREATE TABLE [statement](
  [ID] INT IDENTITY(1, 1) NOT NULL,
  [date] DATE NOT NULL DEFAULT GETDATE(),
  [amount] DECIMAL(14,2) NOT NULL,
CONSTRAINT [PK_statement] PRIMARY KEY CLUSTERED
(
    [ID] ASC
) WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
) ON [PRIMARY]
GO

Вот мой код: 

private DataTable GetTable()
{
    var list = new List<DataColumn>();
    list.Add(new DataColumn("amount", typeof(SqlDecimal)));
    list.Add(new DataColumn("date", typeof(SqlDateTime)));

    var table = new DataTable("statement");
    table.Columns.AddRange(list.ToArray());

    var row = table.NewRow();
    row["amount"] = (SqlDecimal)myObj.Amount; // decimal Amount { get; set; }
    row["date"] = (SqlDateTime)myObj.Date; // DateTime Date { get; set }
    table.Rows.Add(row);

    return table;
}

private void WriteData()
{
    using (var bulk = new SqlBulkCopy(strConnection, SqlBulkCopyOptions.KeepIdentity & SqlBulkCopyOptions.KeepNulls))
    {
        //table.Columns.ForEach(c => bulk.ColumnMappings.Add(new SqlBulkCopyColumnMapping(c.ColumnName, c.ColumnName)));
        bulk.BatchSize = 25;
        bulk.DestinationTableName = "statement";
        bulk.WriteToServer(GetTable()); // a table from GetTable() 
    }
}

Итак, я получаю сообщение об ошибке:

Указанное значение типа SqlDateTime из источника данных не может быть преобразовано в тип date указанного целевого столбца.

Почему ?? Как я могу это исправить? Помогите мне, пожалуйста!

Ответы [ 3 ]

20 голосов
/ 21 июня 2009

Используя ваш оригинальный табличный скрипт, работает следующий код. 

private static DataTable GetTable()
{
    var list = new List<DataColumn>();
    list.Add(new DataColumn("amount", typeof(Double)));
    list.Add(new DataColumn("date", typeof(DateTime)));
    var table = new DataTable("statement");
    table.Columns.AddRange(list.ToArray());

    var row = table.NewRow();
    row["amount"] = 1.2d;
    row["date"] = DateTime.Now.Date;

    table.Rows.Add(row);
    return table;
}
private static void WriteData()
{
    string strConnection = "Server=(local);Database=ScratchDb;Trusted_Connection=True;";
    using (var bulk = new SqlBulkCopy(strConnection, SqlBulkCopyOptions.KeepIdentity & SqlBulkCopyOptions.KeepNulls))
    {
        bulk.ColumnMappings.Add(new SqlBulkCopyColumnMapping("amount", "amount"));
        bulk.ColumnMappings.Add(new SqlBulkCopyColumnMapping("date", "date"));
        bulk.BatchSize = 25;
        bulk.DestinationTableName = "statement";
        bulk.WriteToServer(GetTable());
    }
}

Как уже сказал Амаль, вам нужно сопоставить столбцы из-за столбца Identity.

6 голосов
/ 21 июня 2009

Тип SQL Date отличается от типа SQL DateTime. Я думаю, что столбец даты в вашей таблице должен иметь тип DateTime, в зависимости от того, как вы его используете.

Тип даты SQL
SQL DateTime тип

Обновление:

Я думаю, что ответ Марка должен сработать, но вам, вероятно, нужно указать SqlBulkCopyColumnMappings из вашего исходного DataTable в место назначения, иначе это может привести к неправильному отображению, потому что структура вашей входной таблицы не точно соответствует выходной таблице, т.е. столбцы даты и строки поменялись местами.

например 

var amount = new SqlBulkCopyColumnMapping("amount", "amount");
var date = new SqlBulkCopyColumnMapping("date", "date");
bulk.ColumnMappings.Add(amount);
bulk.ColumnMappings.Add(date);
2 голосов
/ 21 июня 2009

SqlDateTime представляет исходный тип datetime. Вы пробовали просто использовать тип DateTime .NET в DataTable? Я надеюсь, что он может преобразовать это в типы TSQL datetime или date. То же самое decimal вместо SqlDecimal.

...