Npgsql - BulkCopy来自ConcurrentQueue<T>

Question

假设我有这样的方法：

public async Task BulkCopy(ConcurrentQueue<Model> modelQueue, string connectionString)
{
    while(modelQueue.IsEmpty == false)
    {
        try
        {
            using(NpgsqlConnection connection = new NpgsqlConnection(connectionString))
            {
                await connection.OpenAsync();

                using(var writer = connection.BeginBinaryImport("COPY myTable (Id,Name,Something,SomethingElse)"))
                {
                    // Is this what I'm supposed to do?
                    foreach(Model item in modelQueue)
                    {
                        writer.WriteRow(item);
                    }
                }
            }
        }
    }
}

模型具有Guid、string名称、string string、string SomethingElse(就像表一样)的属性。

我可以使用WriteRow()并传入整个对象吗？这是实现的方式，还是我做错了？

Answer 1

这个问题的答案非常简单，因为ConcurrentQueue实现了IEnumerable，我所要做的就是在队列中运行并写入数据。

public async Task BulkCopy(ConcurrentQueue<Model> modelQueue, string connectionString)
{
    while(modelQueue.IsEmpty == false)
    {
        try
        {
            using(NpgsqlConnection connection = new NpgsqlConnection(connectionString))
            {
                await connection.OpenAsync();

                using(var writer = connection.BeginBinaryImport("COPY myTable (Id,Name,Something,SomethingElse) FROM STDIN (FORMAT BINARY)"))
                {
                    foreach(Model item in modelQueue)
                    {
                        writer.StartRow();
                        writer.Write(item.Id, NpgsqlTypes.NpgsqlDbType.Uuid);
                        writer.Write(item.Name);
                        writer.Write(item.Something);
                        writer.Write(item.SomethingElse);
                    }
                }
            }
        }
    }
}

这似乎能胜任这项工作。30000张唱片所需的时间平均为540毫秒。