Update mongodb

This commit is contained in:
sunkaixuan 2025-05-04 21:36:41 +08:00
parent 08116a9254
commit bb6235ecdb

View File

@ -91,16 +91,12 @@ namespace MongoDb.Ado.data
var collection = GetCollection(collectionName);
return new ExecuteScalarHandlerAsync().HandleAsync(operation, collection, json);
}
public override Task<DbDataReader> ExecuteReaderAsync(CancellationToken cancellationToken)
protected override Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior,CancellationToken cancellationToken)
{
var (operation, collectionName, json) = ParseCommand(_commandText);
var collection = GetCollection(collectionName);
return new DbDataReaderFactoryAsync().HandleAsync(operation, collection, json);
}
protected override Task<DbDataReader> ExecuteDbDataReaderAsync(CommandBehavior behavior,CancellationToken cancellationToken)
{
return ExecuteReaderAsync();
}
public override void Prepare() { }