Сохранение одних и тех же изменений в нескольких базах данных с помощью Entity Framework

Я еще не использовал EntityFramework для базы данных Oracle, но это должно быть похоже на подключение к SQL Server, поскольку имя базы данных указывается через ConnectionString. В вашем проекте должен быть файл конфигурации (web.config, app.config или, если это приложение .NET Core, он может быть в appsettings.json) с этой ConnectionString.

Например:

<add name = "YourConnectionString" providerName = "YourOracleProviderName" connectionString = "User Id=test;Password=testpassword;Data Source=eftest" />

Базовый конструктор DbContext принимает строковый аргумент, указывающий, какую ConnectionString следует использовать и, следовательно, к какой базе данных подключаться. Если вы посмотрите на свой класс контекста, конструктор по умолчанию должен вызвать базовый конструктор с этим аргументом.

public YourDbContext() : base("YourConnectionString") {}

Чтобы сохранить в несколько баз данных, вам нужно будет работать с разными экземплярами DbContext, каждый из которых имеет свой аргумент ConnectionString. Таким образом, ваша конфигурация должна будет перечислить несколько разных строк подключения для каждого Db, и вы, вероятно, захотите, чтобы ваш класс DbContext также разрешал аргумент в своем конструкторе.

Возможно, реализация метода SaveChanges может создать экземпляры других DbContext, которые вам понадобятся:

    public void SaveChanges(int auditPersonNumber)
    {
        using (var context = new Context("OtherConnectionString1"))
        {
            // apply same changes
            context.SaveChanges();
        }

        using (var context = new Context("OtherConnectionString2"))
        {
            // apply same changes
            context.SaveChanges();
        }

        base.SaveChanges();
    }

Что касается применения тех же изменений, я ожидаю, что вы сможете прочитать их из DbContext ChangeTracker. Здесь есть объяснение использования EF Core, но в более ранних версиях оно похоже: http://www.entityframeworktutorial.net/efcore/changetracker-in-ef-core.aspx.

Также имейте в виду, что вызов SaveChanges для OtherConnectionString1 может завершиться успешно, в то время как другие вызовы могут завершиться ошибкой, поэтому данные в разных базах данных могут быть несогласованными. Возможно, вам придется изучить возможность использования транзакций в нескольких базах данных, но я сам еще этого не делал.

Я смог найти решение благодаря помощи Сангмана.

public class Context : Shared.Data.Context
{
    new public void SaveChanges(int auditPersonNumber)
    {
        var errors = string.Empty;
        var testConnectionString = "ConnectionString";
        var developmentConnectionString = "ConnectionString";

        //Save to test database
        if (SecurityMaintenanceUser.ApplyToTest)
            errors = ApplyToDatabase(testConnectionString, auditPersonNumber, "Test");

        if (!string.IsNullOrWhiteSpace(errors))
            errors += "\n\n";

        //Save to development database
        if (SecurityMaintenanceUser.ApplyToDevelopment)
            errors += ApplyToDatabase(developmentConnectionString, auditPersonNumber, "Development");

        if (!string.IsNullOrWhiteSpace(errors))
            MessageBox.Show(errors, "Error", MessageBoxButtons.OK, MessageBoxIcon.Error);

        //Save to production database
        base.SaveChanges(auditPersonNumber);
    }

    private string ApplyToDatabase(string connectionString, int auditPersonNumber, string server)
    {
        try
        {
            using (var context = new Context(connectionString))
            {
                context.Configuration.ValidateOnSaveEnabled = false;

                foreach (var entry in ChangeTracker.Entries())
                {
                    var dataSet = context.Set(entry.Entity.GetType());

                    if (entry.State == EntityState.Added)
                    {
                        dataSet.Add(entry.Entity);
                    }
                    else if (entry.State == EntityState.Deleted)
                    {
                        var contextEntity = dataSet.Find(GetPrimaryKeyValues(entry));
                        context.DeleteEntity(contextEntity, auditPersonNumber);
                    }
                    else if (entry.State == EntityState.Modified)
                    {
                        var contextEntity = dataSet.Find(GetPrimaryKeyValues(entry));
                        context.Entry(CopyProperties(entry.Entity, contextEntity)).State = EntityState.Modified;
                    }
                }

                context.SaveChanges(auditPersonNumber);
                return string.Empty;
            }
        }
        catch (Exception e)
        {
            return $"Failed to apply database changes to {server}.\n{e.GetFullMessage()}";
        }
    }

    private object CopyProperties(object source, object destination)
    {
        if (source == null || destination == null)
            throw new Exception("Source or/and Destination Objects are null");

        var typeDest = destination.GetType();
        var typeSrc = source.GetType();

        foreach (var srcProp in typeSrc.GetProperties())
        {
            if (srcProp.Name == "Type" || srcProp.Name == "AuthenticationLog")
                continue;

            //This blocks any complex objects attached to the entity, will need to be changed for your application
            if (srcProp.PropertyType.FullName.Contains("Library.Shared"))
                continue;

            if (!srcProp.CanRead)
                continue;

            var targetProperty = typeDest.GetProperty(srcProp.Name);

            if (targetProperty == null)
                continue;

            if (!targetProperty.CanWrite)
                continue;

            if (targetProperty.GetSetMethod(true)?.IsPrivate == true)
                continue;

            if ((targetProperty.GetSetMethod().Attributes & MethodAttributes.Static) != 0)
                continue;

            if (!targetProperty.PropertyType.IsAssignableFrom(srcProp.PropertyType))
                continue;

            targetProperty.SetValue(destination, srcProp.GetValue(source, null), null);
        }

        return destination;
    }

    private object GetPrimaryKeyValues(DbEntityEntry entry)
    {
        var objectStateEntry = ((IObjectContextAdapter)this).ObjectContext.ObjectStateManager.GetObjectStateEntry(entry.Entity);
        return objectStateEntry.EntityKey.EntityKeyValues[0].Value;
    }

    public static string GetFullMessage(this Exception ex)
    {
        return ex.InnerException == null ? ex.Message : $"{ex.Message}\n{ex.InnerException.GetFullMessage()}";
    }

    public static string Replace(this string source, string oldString, string newString, StringComparison comp)
    {
        int index = source.IndexOf(oldString, comp);

        if (index >= 0)
        {
            source = source.Remove(index, oldString.Length);
            source = source.Insert(index, newString);
        }

        if (source.IndexOf(oldString, comp) != -1)
            source = Replace(source, oldString, newString, comp);

        return source;
    }
}