Update Mongodb

This commit is contained in:
sunkaixuan
2025-05-02 14:31:35 +08:00
parent df4460c5a9
commit d287455502

View File

@@ -17,11 +17,11 @@ namespace MongoDb.Ado.data
private List<Type> _fieldTypes; private List<Type> _fieldTypes;
public MongoDbBsonDocumentDataReader(IEnumerable<BsonDocument> documents) public MongoDbBsonDocumentDataReader(IEnumerable<BsonDocument> documents)
{ {
var docList = documents.ToList(); var docList = documents.Take(1).ToList();
_enumerator = docList.GetEnumerator(); _enumerator = docList.GetEnumerator();
if (docList.Any()==true) if (docList.Any()==true)
{ {
_fieldNames = docList.Take(1).SelectMany(d => d.Names).Distinct(StringComparer.OrdinalIgnoreCase).ToList(); _fieldNames = docList.SelectMany(d => d.Names).Distinct(StringComparer.OrdinalIgnoreCase).ToList();
_fieldTypes = new List<Type>(); _fieldTypes = new List<Type>();
foreach (var fieldName in _fieldNames) foreach (var fieldName in _fieldNames)
{ {