Hibernate — динамическая маршрутизация таблиц

Я искал метод для динамической маршрутизации объектов в базы данных во время выполнения, используя Hibernate, и недавно я нашел решение, которое отвечает всем требованиям. Этот пост исследует проблему и определяет одно из возможных решений.

С http://www.alvinsingh.org/blog

Эта проблема

У меня есть веб-приложение (использующее Spring + Hibernate для ORM), которое использует две схемы базы данных (в одной физической базе данных). Я указываю источник данных, доступный через JNDI (используя tomcat, достигнутый с помощью контекста xml ), поэтому в разных средах развертывания я могу использовать один и тот же файл войны. Это особенно важно, так как я не хочу использовать разные двоичные файлы для разных сред. Мой принцип — хранить любую динамическую информацию, относящуюся к среде развертывания, строго за пределами файла war точно по указанной выше причине — один и тот же файл war во всех развертываниях.

Я указываю один DS (источник данных), поскольку фабрика сессий Spring Hibernate ожидает один DS. Но это дает мне только половину пути — я указал только одну строку подключения к базе данных — как насчет другой базы данных? Вы можете иметь несколько фабрик сессий, но затем вам придется иметь дело с межсессионными транзакциями.

Мы можем решить эту проблему (а не основную проблему в этом сообщении), используя элементы конфигурации «схема» и «каталог» на наших объектах, которые находятся в БД №2. Ниже приведен пример, который я буду использовать для справки с 3 объектами, охватывающими 2 схемы. Он включает в себя обычную практику, при которой информация об управлении идентификационными данными хранится в отдельной базе данных для базы данных приложений. Я пропустил большую часть информации от объектов для краткости.

@Table
@Entity
public class ApplicationUser {

private IdentityUser identityUser;

}

@Table (schema="secure", catalog="identitymanagement")
@Entity
public class IdentityUser {

@OneToMany(fetch = FetchType.LAZY)
    @JoinTable(name = "IdentityUserIdentityRole",
       schema="security",
       catalog="identitymanagement",
       joinColumns = {@JoinColumn(name = "IdentityUserID")},
               inverseJoinColumns = {@JoinColumn(name = "IdentityRoleID")})
    private Set<IdentityRole> roles;

}

@Table (schema="secure", catalog="identitymanagement")
@Entity
public class IdentityRole {

}

public class HibernateInterceptor extends EmptyInterceptor {

@Override
    public String onPrepareStatement(String sql) {
          String prepedStatement = super.onPrepareStatement(sql);
          prepedStatement = prepedStatement.replaceAll("secure.identitymanagement", "my_dynamic_goodness");
          return prepedStatement;
    }

}