SqlBulkCopy 抛出 "Operation is not valid due to the current state of the object"

Question

我正在尝试为 IAsyncEnumerable<T> 集合创建自定义 DataReader，以便通过 SqlBulkCopy 将记录加载到数据库 table 中。我遵循这个问题中概述的代码示例和解决方案的思路 -

这是我的 DataReader 的要点：

internal sealed class AsyncEnumerableDataReader<T> : IDataReader
    {
        private readonly IAsyncEnumerator<T> _asyncEnumerator;
        private readonly List<PropertyInfo> _properties = new List<PropertyInfo>();
        private bool _isClosed = false;

        public AsyncEnumerableDataReader(IAsyncEnumerable<T> asyncEnumerable)
        {
            _asyncEnumerator = asyncEnumerable.GetAsyncEnumerator();

            foreach (PropertyInfo propertyInfo in typeof(T).GetProperties(BindingFlags.Instance | BindingFlags.Public))
            {
                _properties.Add(propertyInfo);
            }
        }

 //.... Other method implementations here

public bool Read() => _asyncEnumerator.MoveNextAsync().Result;
}

我的问题是，当我将数据读取器传递给 SqlBulkCopy.WriteToServerAsync(reader) 方法时，在第一次调用 DataReader.Read() 时它抛出以下错误：

System.InvalidOperationException: 'Operation is not valid due to the current state of the object.'

有人知道我的代码哪里出了问题吗？

Answer 1

当您将 .Result 与 ValueTask<T> 一起使用时，它会 而不是 阻塞当前线程以等待结果（bool 在您的例）。

如果 ValueTask<T> 在第一次调用期间没有及时完成，它将 return 一个 Task CLR 稍后将使用它来继续工作以检查它。

当您不await调用时，CLR 可以不会稍后检查结果。

由于您想同步运行这段代码（至少从我使用 .Result 可以假设的情况来看）我已经包含了一个应该适合您的变通方法同步.

考虑使用 .AsTask().Result 而不是 .Result。这将强制 CLR 在 returning 结果之前等待任务完成。

public bool Read() => _asyncEnumerator.MoveNextAsync().AsTask().Result;

SqlBulkCopy 抛出 "Operation is not valid due to the current state of the object"

SqlBulkCopy throws "Operation is not valid due to the current state of the object"

c#

sqlbulkcopy

iasyncenumerable