08P01：消息中为 Nullable DateTime 留下的数据不足

Question

我的数据库 table 有一列定义为 timestamp without time zone。现在，在我的 C# 应用程序中，当我尝试使用 NpgSql BeginBinaryImport 在该列中插入空值时，它会给出如下所述的错误消息：

08P01: insufficient data left in message

下面是我要执行的代码：

static void Main(string[] args)
{
    BulkInsert();
}

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("status", typeof(int));
    table.Columns.Add("id", typeof(long));

    var dataRow = table.NewRow();
    dataRow["firstname"] = "MyFirstName";
    dataRow["lastname"] = "MyLastName";
    dataRow["logdatetime"] = DBNull.Value;
    dataRow["status"] = 1;
    dataRow["id"] = 10;
    table.Rows.Add(dataRow);

    var data = new DataAccess();

    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,status,id)");
        using (var writer = npgsqlConn.BeginBinaryImport(commandFormat))
        {
            foreach (DataRow item in dataTable.Rows)
            {
                writer.StartRow();
                foreach (var item1 in item.ItemArray)
                {
                     writer.Write(item1);
                }

            }
        }

        npgsqlConn.Close();
}

Answer 1

问题是您尝试编写的 DBNull.Value - Npgsql 不支持以这种方式编写空值。要写入 null，您需要改用 WriteNull() 方法。

我可以让 Npgsql 接受 DBNull.Value，但仅限于 Write() 的重载，它也接受 NpgsqlDbType（因为 Npgsql 必须写入数据类型，并且 DBNull.Value 我们不知道那是什么）。

编辑： 已完成此操作，请参阅 https://github.com/npgsql/npgsql/issues/1122。

Answer 2

我在 table 中批量复制数据时遇到了同样的问题。为了解决这个问题，我创建了一个扩展方法，因此您不必对所有字段进行空检查

public static void WriteWithNullCheck(this NpgsqlBinaryImporter writer, string value)
        {
            if (string.IsNullOrEmpty(value))
            {
                writer.WriteNull();
            }
            else
            {
                writer.Write(value);
            }
        }

这可以通过

变得通用

public static void WriteWithNullCheck<T>(this NpgsqlBinaryImporter writer, T value,NpgsqlDbType type)
        {
            if (value == null)
            {
                writer.WriteNull();
            }
            else
            {
                writer.Write(value, type);
            }
        }

08P01：消息中为 Nullable DateTime 留下的数据不足

08P01: insufficient data left in message for Nullable DateTime

c#

npgsql