ReadPreferenceResolver.cs 1.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. /* Copyright 2018-present MongoDB Inc.
  2. *
  3. * Licensed under the Apache License, Version 2.0 (the "License");
  4. * you may not use this file except in compliance with the License.
  5. * You may obtain a copy of the License at
  6. *
  7. * http://www.apache.org/licenses/LICENSE-2.0
  8. *
  9. * Unless required by applicable law or agreed to in writing, software
  10. * distributed under the License is distributed on an "AS IS" BASIS,
  11. * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  12. * See the License for the specific language governing permissions and
  13. * limitations under the License.
  14. */
  15. namespace MongoDB.Driver
  16. {
  17. internal static class ReadPreferenceResolver
  18. {
  19. public static ReadPreference GetEffectiveReadPreference(
  20. IClientSessionHandle session,
  21. ReadPreference explicitReadPreference,
  22. ReadPreference defaultReadPreference)
  23. {
  24. if (explicitReadPreference != null)
  25. {
  26. return explicitReadPreference;
  27. }
  28. if (session.IsInTransaction)
  29. {
  30. var transactionReadPreference = session.WrappedCoreSession.CurrentTransaction.TransactionOptions.ReadPreference;
  31. if (transactionReadPreference != null)
  32. {
  33. return transactionReadPreference;
  34. }
  35. }
  36. return defaultReadPreference ?? ReadPreference.Primary;
  37. }
  38. }
  39. }