Чтение с нескольких БД с одним и тем же модулем постоянства? - PullRequest
14 голосов
/ 06 декабря 2011

Мне нужна помощь, чтобы настроить несколько соединений с несколькими базами данных, используя один и тот же модуль персистентности.

Все они имеют одинаковую схему.Поэтому я хочу использовать один и тот же модуль сохраняемости / DAO и т. Д. И не хочу настраивать 10 EntityManager, 10 постоянных XML и т. Д. Есть ли способ сделать это?Вот моя текущая конфигурация:

  <persistence-unit name="PersistenceUnit-c1" transaction-type="RESOURCE_LOCAL">
        <properties>
            <property name="hibernate.show_sql" value="${hibernate-show-sql}"/>
            <property name="hibernate.dialect" value="org.hibernate.dialect.SybaseDialect" />
            <property name="hibernate.c3p0.min_size" value="${hibernate-c3p0-min-size}" />
            <property name="hibernate.c3p0.max_size" value="${hibernate-c3p0-max-size}" />
            <property name="hibernate.c3p0.timeout" value="${hibernate-c3p0-timeout}" />
            <property name="hibernate.c3p0.max_statements" value="${hibernate-c3p0-max-statements}" />
            <property name="hibernate.c3p0.idle_test_period" value="${hibernate-c3p0-idle-test-periods}" />     
        </properties>
        <class>com.domain.TktOrder</class>
        <exclude-unlisted-classes/>
    </persistence-unit>

Я также использую Spring / hibernate для настройки моего контекста:

    <bean id="EntityManagerFactory"
    class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
    p:persistenceUnitName="PersistenceUnit-c1" 
    p:dataSource-ref="DataSource">
    <property name="persistenceXmlLocation" value="classpath:META-INF/persistence.xml" />
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
            p:showSql="${hibernate-show-sql}" 
            p:generateDdl="false" 
            p:databasePlatform="org.hibernate.dialect.SybaseDialect" />
    </property>
    <property name="loadTimeWeaver">
        <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
    </property>
</bean>

<bean id="DataSource" 
    class="com.mchange.v2.c3p0.ComboPooledDataSource" destroy-method="close" 
    p:driverClass="net.sourceforge.jtds.jdbc.Driver"
    p:jdbcUrl="jdbc:jtds:sybase://url.net:port;DatabaseName=db_1"
    p:user="user" 
    p:password="password"
    />

и, наконец, я использую:

@PersistenceContext(unitName="PersistenceUnit-c1")
public void setEntityManager(EntityManager entityManager)
{
    this.entityManager = entityManager;     

}

для внедрения моего EntityManager в мой DAO

Как расширить эту модель, чтобы иметь возможность использовать db1, затем изменить источник данных и выполнить снова для db2 и т. Д.

Большое спасибо за любую помощь заранее!

Ответы [ 3 ]

9 голосов
/ 08 декабря 2011

После нескольких попыток я нашел решение, которое, кажется, отвечает всем требованиям.

Пожалуйста, сначала взгляните на это: dynamic-datasource-routing

При этом используется несколько пользовательских классов, которые вам понадобятся, и ключевой класс - AbstractRoutingDataSource.

Это перенастраивает мой bean-источник данных следующим образом:

    <bean id="dataSource" class="com.domain.etc.etc.recon.utils.RoutingDataSource">
    <property name="targetDataSources">
        <map key-type="com.domain.etc.etc.recon.utils.DbType">
            <entry key="C1" value-ref="C1" />
            <entry key="C2" value-ref="C2" />
        </map>
    </property>
    <property name="defaultTargetDataSource" ref="C3" />
</bean>

Где Соединение один С1, С2 выглядят так:

    <bean id="parentDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"
    abstract="true">
    <property name="driverClassName" value="net.sourceforge.jtds.jdbc.Driver" />
    <property name="username" value="*******" />
    <property name="password" value="*******" />
</bean>

<bean id="C1" parent="parentDataSource">
    <property name="url" 
        value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname" />
</bean>

<bean id="C2" parent="parentDataSource">
    <property name="url"
        value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname2" />
</bean>

<bean id="C3" parent="parentDataSource">
    <property name="url"
        value="jdbc:jtds:sybase://URL:PORT;DatabaseName=dbname3" />
</bean>

Вы можете добавить это в EntityManager, как я сделал в первоначальном Вопросе;

    <bean id="EntityManagerFactory"
    class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"
    p:persistenceUnitName="PersistenceUnit" 
    p:dataSource-ref="dataSource">
    <property name="persistenceXmlLocation" value="classpath:META-INF/persistence-.xml" />
    <property name="jpaVendorAdapter">
        <bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"
            p:showSql="${hibernate-show-sql}" 
            p:generateDdl="false" 
            p:databasePlatform="org.hibernate.dialect.SybaseDialect" />
    </property>
    <property name="loadTimeWeaver">
        <bean class="org.springframework.instrument.classloading.InstrumentationLoadTimeWeaver" />
    </property>
</bean>

После этого вам нужно использовать собственную реализацию классов Java по ссылке выше, чтобы иметь возможность переключаться между источниками данных. Это не что иное, как переименование классов в более значимые для вас. Связывание Enum с C1, C2, C3 и т. Д. И, наконец, указание на своего дао для выполнения работы.

Удачи!

2 голосов
/ 07 декабря 2011

Это может быть случай использования Осколки гибернации .Мы начали оценивать его год назад, но затем отбросили, потому что внезапный осколок не был необходим.Так что я не могу дать никакого реального опыта с этим, но я думаю, что стоит посмотреть.

0 голосов
/ 10 декабря 2013

Hibernate Shard все еще развивается, если вам нужен HQL, то он не будет работать для вас, поэтому, если вы можете обойтись только запросом критериев, с вами все будет в порядке.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...