Reading from Read Replica database and write to primary database #9857

5 Answer(s)

• 

  0

  zony created 3 years ago

  Support Team

  Hi bulutyonetim, There are two ways to achieve this:

  1. Use multiple DbContexts, DbContext1 reads data, DbContext2 writes data. This is an example.
  2. The database connection string of DbContext is parsed from IConnectionStringResolver, you can reimplement it and add your own logic.

  Save Cancel
• 

  0

  bulutyonetim created 3 years ago

  Hi Zony,

  Thanks for answer.

  I saw first solution, but it is not good solution for my scenario because In that case I will have all tables and Dbsets and etc.. duplicated and project will turn into mess.

  Can you describe second solution a bit more? Is ther any documentation for this. any code sample?

  Thanks

  Save Cancel
• 

  0

  bulutyonetim created 3 years ago

  Hi,

  I managed to override IConnectionStringResolver successfully and now I can change connection string dynamically but how should I know that this is a read request so I should change connection string to Read Replica database?

  I found this solution in one of support tickets. It says:

  You can define an attribute (for Get only) and use it the operations you want to use read-only database.

  Can you show me how to add attribute to ConnectionStringResolveArgs for example when calling a get method in any repository? So, in this case I can decide based on that attribute inside my custom IConnectionStringResolver and change connection string.

  Save Cancel
• 

  0

  zony created 3 years ago

  Support Team

  Hi bulutyonetim, ConnectionStringResolveArgs will only be assigned when the DbContext is created by the unit of work, and it is generally not recommended to change it. You can try to use IAmbientDataContext to share configuration, such as the following pseudo code:

      public class YourAppService : ApplicationService
      {
          private readonly IAmbientDataContext _ambientDataContext;
          public const string ReadOrWrite = nameof(ReadOrWrite);
  
          public YourAppService(IAmbientDataContext ambientDataContext)
          {
              _ambientDataContext = ambientDataContext;
          }
  
          public async Task YourAction()
          {
              _ambientDataContext.SetData(ReadOrWrite,"Write");
  
              await Task.CompletedTask;
          }
      }
  
      public class YourConnectionStringResolver : IConnectionStringResolver
      {
          private readonly IAmbientDataContext _ambientDataContext;
  
          public YourConnectionStringResolver(IAmbientDataContext ambientDataContext)
          {
              _ambientDataContext = ambientDataContext;
          }
  
          public string GetNameOrConnectionString(ConnectionStringResolveArgs args)
          {
              if ((string) _ambientDataContext.GetData(YourAppService.ReadOrWrite) == "Write")
              {
                  return "Write Database";
              }
              else
              {
                  return "Read Database";
              }
          }
      }
  

  Another idea is to combine HTTP Header and inject IHttpContextAccessor in ConnectionStringResolveArgs to get a specific request header (depending on you). Switch to different databases according to different request headers.

  Save Cancel
• 

  0

  bulutyonetim created 3 years ago

  IAmbientDataContext helped me to achive what I need.

  Thanks @zony.

  Save Cancel