如何解决SqlBulkCopy 抛出“由于对象的当前状态,操作无效”
我正在尝试为 IAsyncEnumerable<T>
集合创建自定义 DataReader,以便通过 sqlBulkcopy
将记录加载到数据库表中。我正在遵循此问题中概述的代码示例和解决方案 - How to use SqlBulkCopy to write an IAsyncEnumerable
这是我的 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;
}
我的问题是,当我将 datareader 传递给 sqlBulkcopy.WritetoServerAsync(reader)
方法时,在第一次调用 DataReader.Read()
时会引发以下错误:
system.invalidOperationException: 'Operation is not valid due to the current state of the object.'
有人知道我的代码哪里出了问题吗?
解决方法
当您将 .Result
与 ValueTask<T>
一起使用时,它不会阻塞当前线程以等待结果(在您的情况下为 bool
)。>
如果 ValueTask<T>
在第一次调用期间没有及时完成,它将返回一个 Task
,CLR 将使用它来继续工作以检查它。
当您不await
调用时,CLR 可以不检查结果。
由于您希望同步运行此代码(至少从我使用 .Result
可以假设的情况来看),因此我提供了一个可以同步为您工作的解决方法。
考虑使用 .AsTask().Result
而不是 .Result
。这将强制 CLR 在返回结果之前等待任务完成。
public bool Read() => _asyncEnumerator.MoveNextAsync().AsTask().Result;
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。