paulwong

          小議JPA

          以前和數據庫打交道的標準INTERFACE是JDBC,放SQL語句,執行,就可以有結果。隨著近年ORM的興起,以對象的方式存取數據庫大行其道。于是產生了JPA。

          也是一套INTERFACE,以ORM的方式提供,由廠商實現,如ECLIPSE LINK,HIBERNATE,OPENEJB等。

          ENTITYMANAGERFACTORY:根據配置文件制造ENTITYMANAGER
          ENTITYMANAGER:以ORM的方式提供操作數據庫的功能
          TRANSACTION:事務保證
          PERSISTENCE.XML:鏈接數據庫信息,事務類型,重定義JPA的實現廠商等的配置信息

          在容器環境下使用:

          如果事務是RESOURCE_LOCAL的方式,則合用端需干所有的事情,如構造ENTITYMANAGER,打開事務,關閉事務等。類似于BMT。
          以下是在服務器環境中合用RESOURCE_LOCAL型的JPA

          事先要在容器中添加數據源。

           persistence.xml
          <?xml version="1.0" encoding="UTF-8" ?>
          <persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">

            <!-- Tutorial "unit" -->
            <persistence-unit name="Tutorial" transaction-type="RESOURCE_LOCAL">
              <non-jta-data-source>myNonJtaDataSource</non-jta-data-source>
              <class>org.superbiz.jpa.Account</class>
            </persistence-unit>

          </persistence>


          import javax.persistence.EntityManagerFactory;
          import javax.persistence.EntityManager;
          import javax.persistence.EntityTransaction;
          import javax.persistence.PersistenceUnit;

          public class MyEjbOrServlet  {

              @PersistenceUnit(unitName="Tutorial")
              private EntityManagerFactory factory;

              // Proper exception handling left out for simplicity
              public void ejbMethodOrServletServiceMethod() throws Exception {
                  EntityManager entityManager = factory.createEntityManager();

                  EntityTransaction entityTransaction = entityManager.getTransaction();

                  entityTransaction.begin();

                  Account account = entityManager.find(Account.class, 12345);

                  account.setBalance(5000);

                  entityTransaction.commit();
              }

              
          }


          以下是JTA方式的JPA,容器+EJB+JPA+JTA,容器會在EJB的方法調用前打開一個事務,在方法退出后,提交事務,并且如果是多個數據源的,即有多個ENTITYMANAGER的
          可以保證一致性,即全局事務。相當于之前的先調用USERTRANSACTION,BEGIN,COMMIT。

          事先要在容器中添加數據源。

           persistence.xml
          <?xml version="1.0" encoding="UTF-8" ?>
          <persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">

            <!-- Tutorial "unit" -->
            <persistence-unit name="Tutorial" transaction-type="JTA">
              <jta-data-source>myJtaDataSource</jta-data-source>
              <non-jta-data-source>myNonJtaDataSource</non-jta-data-source>
              <class>org.superbiz.jpa.Account</class>
            </persistence-unit>

          </persistence>


          EJB
          import javax.ejb.Stateless;
          import javax.ejb.TransactionAttribute;
          import javax.ejb.TransactionAttributeType;
          import javax.persistence.EntityManager;
          import javax.persistence.PersistenceContext;

          @Stateless
          public class MyEjb implements MyEjbInterface {

              @PersistenceContext(unitName = "Tutorial")
              private EntityManager entityManager;

              // Proper exception handling left out for simplicity
              @TransactionAttribute(TransactionAttributeType.REQUIRED)
              public void ejbMethod() throws Exception {

              Account account = entityManager.find(Account.class, 12345);

              account.setBalance(5000);

              }
          }


          如果是J2SE環境下使用JPA,則又是不一樣的。


          persistence.xml

          <?xml version="1.0" encoding="UTF-8"?>
          <persistence xmlns="http://java.sun.com/xml/ns/persistence" version="1.0">
              <persistence-unit name="SimplePU" transaction-type="RESOURCE_LOCAL">
                  <provider>org.hibernate.ejb.HibernatePersistence</provider>
                  <class>com.someone.jmail.valueobject.CallActivity</class>
                  <class>com.someone.jmail.valueobject.Email</class>
                  <properties>
                      <property name="hibernate.connection.driver_class" value="com.mysql.jdbc.Driver" />
                      <property name="hibernate.connection.url" value="jdbc:mysql://localhost:3306/test" />
                      <property name="hibernate.connection.username" value="root" />
                      <property name="hibernate.connection.password" value="12345" />
                      <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect" />
                      <property name="hibernate.show_sql" value="false"/>
                      <property name="hibernate.format_sql" value="true"/>
                      <property name="hibernate.use_sql_comments" value="false"/>
                      <property name="hibernate.hbm2ddl.auto" value="none"/>
                  </properties>
              </persistence-unit>
              
          </persistence>


          Dao:

          public class UserDaoImpl implements UserDao { 
           public AccountInfo save(AccountInfo accountInfo) { 
           EntityManagerFactory emf = 
           Persistence.createEntityManagerFactory("SimplePU"); 
           EntityManager em = emf.createEntityManager(); 
           em.getTransaction().begin(); 
           em.persist(accountInfo); 
           em.getTransaction().commit(); 
           emf.close(); 
           return accountInfo; 
              } 
           } 


          posted on 2013-08-14 18:17 paulwong 閱讀(605) 評論(0)  編輯  收藏 所屬分類: J2EE

          主站蜘蛛池模板: 海门市| 太保市| 开平市| 阜南县| 班戈县| 三穗县| 信阳市| 平遥县| 宿松县| 渭源县| 濉溪县| 伊川县| 资源县| 监利县| 叙永县| 赤水市| 洪雅县| 藁城市| 且末县| 三江| 府谷县| 深圳市| 齐齐哈尔市| 肥西县| 阿拉善右旗| 龙海市| 通榆县| 武城县| 武强县| 苍溪县| 和林格尔县| 怀安县| 漯河市| 遂昌县| 北流市| 元朗区| 鸡泽县| 东安县| 万源市| 敦煌市| 宁城县|