SQLBULKCOPY получил исключение: «Получил неверную длину столбца от клиента BCP для Colid». ⇐ C#

[Anonymous]

У меня есть код с использованием sqlbulkcopy , чтобы клонировать множество таблиц, он раньше работал, но очень странно, недавно получил исключение

Получил неверную длину столбца от клиента BCP для Colid

. />

Код: Выделить всё

sqlBulkCopy.WriteToServer(reader)

поднимет это исключение, если таблица имеет два непрерывных столбца, которые имеют тип char (1) или nvarchar (nn) , и оба имеют null . Иногда изменение sqlbulkcopy.batchsize < /code> заставляет его работать, но много раз это не будет. < /P>
После упрощения у меня есть тестовый пример следующего образом, и он воспроизводится на двух серверах: < /p>

• Создать таблицу. Sp2) < /p>

  Код: Выделить всё

   IF OBJECT_ID('dbo.TestTable', 'U') IS NOT NULL
  DROP TABLE dbo.TestTable;
  
  CREATE TABLE [dbo].[TestTable]
  (
  [value2] [char](1) NULL,
  [value1] [char](1) NULL
  ) ON [PRIMARY]
  GO
  
  DECLARE @i int = 0
  
  WHILE @i < 262
  BEGIN
  SET @i = @i + 1
  
  INSERT INTO [dbo].[TestTable]([value2], [value1])
  VALUES (null, null)
  END
  < /code>
  < /li>
    c# console (.net framework 4.7), как ниже < /p>
   class Program
  {
  // [change here]
  static string sourceConn = @"Server={YourServer};Database={YourDatabase};User ID={userYourName};Password={yourPassword};connect timeout=15";
  
  static void Main(string[] args)
  {
  CopyTable(sourceConn, sourceConn, "TestTable", "testTableBAK");
  Console.ReadLine();
  }
  
  static void CopyTable(string sConnSource, string sConnDest, string sTableSource, string sTableDest)
  {
  if (IsTableExist(sConnDest, sTableDest))
  {
  RunNonQuerySQL(sConnDest, "DROP TABLE " + sTableDest);
  Console.WriteLine($"existing table  {sTableDest} dropped");
  }
  
  CopySchema(sConnDest, sTableSource, sTableDest);
  
  using (SqlConnection connSource = new SqlConnection(sConnSource))
  {
  connSource.Open();
  SqlCommand cmd = new SqlCommand();
  cmd.Connection = connSource;
  cmd.CommandText = "SELECT * FROM " + sTableSource;
  
  // using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(sConnDest, SqlBulkCopyOptions.KeepNulls | SqlBulkCopyOptions.KeepIdentity))
  using (SqlBulkCopy sqlBulkCopy = new SqlBulkCopy(sConnDest))
  {
  // sqlBulkCopy.BatchSize = 1380; // this optional setting will work if set value smaller than 1397 for testTable on my new server (SQL server  13.0.5102.14)
  // sqlBulkCopy.BatchSize = 261; // this optional setting will work if set value smaller than 261 for testTable on 2 older server (SQL server  11.0.7001)
  sqlBulkCopy.DestinationTableName = sTableDest;
  SqlDataReader reader = cmd.ExecuteReader();
  
  try
  {
  // exception here
  sqlBulkCopy.WriteToServer(reader);
  Console.WriteLine("table copied");
  }
  catch (SqlException ex)
  {
  Console.WriteLine(ex.Message);
  }
  
  sqlBulkCopy.Close();
  }
  }
  }
  
  static bool IsTableExist(string sConn, string sTableName)
  {
  bool result = false;
  
  using (SqlConnection conn = new SqlConnection(sConn))
  {
  conn.Open();
  SqlCommand cmd = new SqlCommand();
  string[] s = sTableName.Split('.');
  
  if (s.Length > 1)
  {
  cmd.CommandText = "select count (*) as counter from information_schema.tables where table_name = '" + s[1] + "' and TABLE_SCHEMA='" + s[0] + "'";
  }
  else
  {
  cmd.CommandText = "select count (*) as counter from information_schema.tables  where table_name = '" + sTableName + "'";
  }
  cmd.Connection = conn;
  var count = Convert.ToInt32(cmd.ExecuteScalar());
  result = count > 0;
  }
  
  return result;
  }
  
  static bool RunNonQuerySQL(string sConn, string sSQL)
  {
  bool result = false;
  
  using (SqlConnection conn = new SqlConnection(sConn))
  {
  conn.Open();
  
  SqlCommand cmd = new SqlCommand();
  cmd.CommandText = sSQL;
  cmd.Connection = conn;
  
  var count = cmd.ExecuteNonQuery();
  result = true;
  }
  
  return result;
  }
  
  static public bool CopySchema(string sConn, string sTableSource, string sTableDest)
  {
  return RunQuerySQL(sConn, "select * into " + sTableDest + " from " + sTableSource + "  where 1=2");
  }
  
  static public bool RunQuerySQL(string sConn, string sSQL)
  {
  using (SqlConnection conn = new SqlConnection(sConn))
  {
  conn.Open();
  
  SqlCommand cmd = new SqlCommand();
  cmd.CommandText = sSQL;
  cmd.Connection = conn;
  
  SqlDataReader reader = cmd.ExecuteReader();
  
  if (reader.Read())
  {
  return true;
  }
  else
  {
  return false;
  }
  }
  }
  }
  

Подробнее здесь: https://stackoverflow.com/questions/656 ... e-bcp-clie