并发处理datareader结果

Question

我的目标是读取从Datareader返回的结果，以获得更好的性能。请考虑下面的示例，以便更好地理解问题。

我们假设有10个结果集从datareader返回。当我们遍历这些记录来填充我们的对象时，总时间大约是3秒，现在有人问我如何在1秒内完成这项工作。

这可以通过在datareader中并发处理读取操作来实现吗？如果是，我们该怎么做呢？

IDataAccessMapper _dataAccessMapper;

var query = new StringBuilder();
query.Append("SELECT * FROM Step01");
query.Append("SELECT * FROM Step02");
query.Append("SELECT * FROM Step03");
......
query.Append("SELECT * FROM Step10");
var selCommand = dbContracts.GetTextCommand(query.ToString());
var dataReader = selCommand.AsReader();
while (dataReader.Read()){
    //Do something
}

var step1Details = new Collection<Step1Details>
if (dataReader.NextResult()){
    _dataAccessMapper.MapRecords<Step1Details>(dataReader, step1Details);
}
var step2Details = new Collection<Step2Details>
if (dataReader.NextResult()){
    _dataAccessMapper.MapRecords<Step2Details>(dataReader, step2Details);
}
....
....
var step10Details = new Collection<Step10Details>
if (dataReader.NextResult()){
    _dataAccessMapper.MapRecords<Step10Details>(dataReader, step10Details);
}
....

Answer 1

DataReader不能保证是线程安全的，尽管我认为这个问题源于Connection类，它不是线程安全的。您可以做的是运行独立的线程(使用它们自己的连接)来执行单独的select语句并并发地处理数据。这也将确保每个线程使用自己的DataReader。

请注意，在SQL Server中有一个使用相同连接执行多线程的选项，称为MARS (多活动记录集)。但我认为对于你想要实现的目标来说，这不是一个好方法。