File tree 1 file changed +9
-8
lines changed
1 file changed +9
-8
lines changed Original file line number Diff line number Diff line change @@ -517,15 +517,16 @@ function resolveReadPreference(options, sources) {
517
517
if ( options . readPreference ) {
518
518
readPreference = options . readPreference ;
519
519
} else if ( session && session . inTransaction ( ) && session . transaction . options . readPreference ) {
520
- // From transactions spec: If the user supplies an explicit readConcern via a method
521
- // option, however, drivers MUST apply the readConcern...
520
+ // The transaction’s read preference MUST override all other user configurable read preferences.
522
521
readPreference = session . transaction . options . readPreference ;
523
- } else if ( coll && coll . s . readPreference ) {
524
- readPreference = coll . s . readPreference ;
525
- } else if ( db && db . s . readPreference ) {
526
- readPreference = db . s . readPreference ;
527
- } else if ( defaultReadPreference ) {
528
- readPreference = defaultReadPreference ;
522
+ } else {
523
+ if ( defaultReadPreference ) {
524
+ readPreference = defaultReadPreference ;
525
+ } else if ( coll && coll . s . readPreference ) {
526
+ readPreference = coll . s . readPreference ;
527
+ } else if ( db && db . s . readPreference ) {
528
+ readPreference = db . s . readPreference ;
529
+ }
529
530
}
530
531
531
532
// do we even have a read preference?
You can’t perform that action at this time.
0 commit comments