2012-06-25 2 views
0

Я использую JP2 в своем текущем веб-проекте. В моей основной базе данных хранятся основные объекты. Для подключения по этой БД я определил блок Persitence с JTA Datasource:JPA2 подключение базы данных во время выполнения

Persistance.xml:

<?xml version="1.0" encoding="UTF-8"?> 
<persistence version="2.0" xmlns="http://java.sun.com/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"> 
<persistence-unit name="MyPU" transaction-type="JTA"> 

    <provider>org.eclipse.persistence.jpa.PersistenceProvider</provider> 

    <jta-data-source>MyDB</jta-data-source> 

    <exclude-unlisted-classes>false</exclude-unlisted-classes> 

    <properties> 
     <property name="eclipselink.logging.level" value="FINE"/> 
     <property name="eclipselink.logging.parameters" value="true"/> 
     <property name="eclipselink.logging.logger" value="ServerLogger"/> 
     <property name="eclipselink.ddl-generation" value="drop-and-create-tables"/> 
    </properties> 
</persistence-unit> 
</persistence> 

и JTA Datasource, определенной в солнечном resources.xml:

<?xml version="1.0" encoding="UTF-8"?> 
<!DOCTYPE resources PUBLIC "-//GlassFish.org//DTD GlassFish Application Server 3.1 Resource Definitions//EN" "http://glassfish.org/dtds/glassfish-resources_1_5.dtd"> 
<resources> 
    <jdbc-connection-pool allow-non-component-callers="false" associate-with-thread="false" connection-creation-retry-attempts="0" connection-creation-retry-interval-in-seconds="10" connection-leak-reclaim="false" connection-leak-timeout-in-seconds="0" connection-validation-method="auto-commit" datasource-classname="org.postgresql.ds.PGSimpleDataSource" fail-all-connections="false" idle-timeout-in-seconds="300" is-connection-validation-required="false" is-isolation-level-guaranteed="true" lazy-connection-association="false" lazy-connection-enlistment="false" match-connections="false" max-connection-usage-count="0" max-pool-size="32" max-wait-time-in-millis="60000" name="post-gre-sql_mydb_mypool" non-transactional-connections="false" pool-resize-quantity="2" res-type="javax.sql.DataSource" statement-timeout-in-seconds="-1" steady-pool-size="8" validate-atmost-once-period-in-seconds="0" wrap-jdbc-objects="false"> 
     <property name="serverName" value="localhost"/> 
     <property name="portNumber" value="5432"/> 
     <property name="databaseName" value="mydb"/> 
     <property name="User" value="myuser"/> 
     <property name="Password" value="mypass"/> 
     <property name="URL" value="jdbc:postgresql://localhost:5432/mydb"/> 
     <property name="driverClass" value="org.postgresql.Driver"/> 
     <property name="characterEncoding" value="UTF-8" /> 
    </jdbc-connection-pool> 
    <jdbc-resource enabled="true" jndi-name="MyDB" object-type="user" pool-name="post-gre-sql_mydb_mypoll"/> 
</resources> 

И это то, как я обращаюсь к базе данных по моим классам DAO (ведьма @ManagedBeans и @SessionScoped):

@ManagedBean(name = "pageDao") 
@SessionScoped 
public class PageDao implements Serializable { 

    @Resource 
    private UserTransaction utx = null; 

    @PersistenceUnit(unitName = "MyPU") 
    private EntityManagerFactory emf = null; 

    public EntityManager getEntityManager() { 
     return emf.createEntityManager(); 
    } 

    public List<PageEnt> getAll() { ... } 

    public PageEnt getOne(long pageId) { ... } 

    public void addPage(PageEnt newPage) throws RollbackFailureException, PreexistingEntityException, Exception { ... } 

    public PageEnt update(PageEnt page) throws RollbackFailureException, NonexistentEntityException, Exception { ... } 

    public void remove(PageEnt page) throws RollbackFailureException, Exception { ... } 
} 

У одного из объектов (клиента) есть свойства для подключения в отдельной (для каждого клиента) базе данных, которые определены во время выполнения. Эти свойства включают:

  • имя Databse
  • Хост и порт
  • пользователя и пароль

Мой вопрос являются:

  • Как эффективно создать соединение с базой данных в перспективе -время?
  • Как я могу создать новый EntityManager из ресурсов, управляемых контейнерами, если не определено определение PeristanceUnit и Datasources для каждого клиента (ведь они определены во время развертывания)?
  • Если мне нужно вручную разобраться с EntityManagerFactory (ведьма, как я узнал в колледже, является тяжелым и экспансивным объектом), как я могу эффективно это сделать? Есть ли хорошая практика или образец?
  • Как работает шаблон DAO? Как мой класс DAO получит EntityManager?

Большое спасибо из Бразилии.

ответ

0

Возможность переключения между несколькими источниками данных во время выполнения. Это обеспечивается весной AbstractRoutingDataSource. Требуется переопределить метод #determineCurrentLookupKey(), который вернет ключ, чтобы определить конкретный источник данных, который необходимо подключить. Также должна быть конфигурация пружины, которая отображает каждую из возможных клавиш и соответствующие источники данных, которые должны быть подключены. Некоторые вещи, как
<jee:jndi-lookup id="DataSource_Client1" jndi-name="DataSource_Client1" /> <jee:jndi-lookup id="DataSource_Client2" jndi-name="DataSource_Client" />
<bean id="DynamicDataSource" class="concrete implementation class name of AbstractRoutingDataSource">
<property name="targetDataSources">
<map key-type="java.lang.String">
<entry key="Client1" value-ref="DataSource_Client1" />
<entry key="Client2" value-ref="DataSource_Client2" />
</map>
</property>
</bean>

Возможная ссылка на этот Dynamic DataSource

Надеется, что это отвечает один из ваших вопросов