在NpgSql插入位數據類型使用BeginBinaryImport批量數據插入

我一直在嘗試使用Npgsql版本3.1.2來實現對postgre數據庫的批量插入操作，但我面臨一個問題（'留在消息中的數據不足'）數據類型未匹配postgre表中的列paymentdone（位（1））數據類型。我曾嘗試使用bool，char，integer數據類型（C＃），但也有同樣的錯誤。在NpgSql插入位數據類型使用BeginBinaryImport批量數據插入

Code For bulk data insertion 


    public void BulkInsert(string connectionString, DataTable dataTable) 
    { 
     using (var npgsqlConn = new NpgsqlConnection(connectionString)) 
     { 
      npgsqlConn.Open(); 
      var commandFormat = string.Format(CultureInfo.InvariantCulture, "COPY {0} {1} FROM STDIN BINARY", "logging.testtable", "(firstName,LastName,LogDateTime,RowStatus,active,id,paymentdone)"); 
      using (var writer = npgsqlConn.BeginBinaryImport(commandFormat)) 
      { 
       foreach (DataRow item in dataTable.Rows) 
       { 
        writer.WriteRow(item.ItemArray); 
       } 
      } 

      npgsqlConn.Close(); 
     } 
    } 

DataTable Function 

private static void BulkInsert() 
    { 

     DataTable table = new DataTable(); 
     table.Columns.Add("firstName", typeof(String)); 
     table.Columns.Add("LastName", typeof(String)); 
     table.Columns.Add("LogDateTime", typeof(DateTime)); 
     table.Columns.Add("RowStatus", typeof(int)); 
     table.Columns.Add("active", typeof(bool)); 
     table.Columns.Add("id", typeof(long)); 
     table.Columns.Add("paymentdone", typeof(bool)); 
     var dataRow = table.NewRow(); 
     dataRow[0] = "Test"; 
     dataRow[1] = "Temp"; 
     dataRow[2] = DateTime.Now; 
     dataRow[3] = 1; 
     dataRow[4] = true; 
     dataRow[5] = 10; 
     dataRow[6] = true; 
     table.Rows.Add(dataRow); 

     BulkInsert(ConfigurationManager.ConnectionStrings["StoreEntities"].ConnectionString, table); 
    }

來源

2016-05-24 Tejal Barot

這可能是因爲當Npgsql看到一個布爾值時，它的默認值是發送PostgreSQL布爾值而不是BIT（1）。當使用二進制COPY時，你必須準確寫出PostgreSQL期望的類型。

一種解決方案可能是使用.NET BitArray而不是布爾值。 Npgsql會從該類型推斷PostgreSQL BIT（），並且所有內容都應該可以工作。

但是一個更安全的解決方案就是簡單地調用StartRow()，然後使用接受NpgsqlDbType的Write()的重載。這使您可以明確指定要發送的PostgreSQL類型。

來源

2016-05-24 13:26:23

感謝它的工作 –

在NpgSql插入位數據類型使用BeginBinaryImport批量數據插入

回答

相關問題