程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> jBPM-4.0中文開發指南-第14章持久化

jBPM-4.0中文開發指南-第14章持久化

編輯：關於JAVA

第 14 章持久化

14.1. 標准環境配置

這一節描述了環境如何配置來在標准Java環境中使用hibernate.

line 04在流程引擎環境下指定了一個hibernate會話。這意味著hibernate會話工廠會被延遲創建，當它第一次需要時，會緩存到EnvironmentFactory中。

一個hibernate會話工廠在一個hibernate配置中通過調用buildSessionFactory（）方法創建。默認情況下，hibernate配置會根據類型進行查找。

line 05指定一個hibernate配置。

line 06指定資源文件 hibernate.properties應該被加載到配置中。

line 07 - 13指定映射資源文件。

line 14 - 15提供一個單獨的地方來指定 hibernate緩存策略，為所有的PVM類和集合。

line 20指定一個標准事務。這是一個非常簡單的全局事務策略，沒有可以用在標准環境下的恢復，會獲得所有或沒有符合語義的多個事務型資源之上。

line 21指定hibernate會話，會自動注冊它自己，使用標准事務。

line 22指定一個PvmDbSession. 那是一個類，添加了方法綁定到特定的查詢，將在hiberante會話中執行。

14.2. 標准hibernate配置

這兒是一系列的默認配置，來在標准Java環境下和hsqldb一起配置hibernate.

hibernate.dialect　　　　　　　　　　　　　　　　　　　　　 org.hibernate.dialect.HSQLDialect hibernate.connection.driver_class　　　　　 org.hsqldb.jdbcDriver hibernate.connection.url　　　　　　　　　　　　　　 jdbc:hsqldb:mem:. hibernate.connection.username　　　　　　　　　 sa hibernate.connection.password hibernate.cache.use_second_level_cache true hibernate.cache.provider_class　　　　　　　　 org.hibernate.cache.HashtableCacheProvider

在開發中可以選擇數據庫結構導出，在會話工廠創建的時候創建數據庫結構，在會話工廠關閉的時候刪除數據庫結構。

hibernate.hbm2ddl.auto　　　　　　　　　　　　　　　　 create-drop

為了了解更多關於hibernate配置，可以參考hibernate引用手冊。

14.3. 標准事務

默認情況下，<hibernate-session />會使用 session.beginTransaction（）啟動hibernate事務。然後hibernate事務會封裝成一個 org.jbpm.pvm.internal.hibernate.HibernateTransactionResource 資源被支持在<standard- transaction /> （org.jbpm.tx.StandardTransaction）。

在環境塊內部，通過environment.getTransaction（）獲得事務。所以在環境塊內，事務可以通過 environment.getTransaction（）。setRollbackOnly（）回滾。

當初創建時，標准事務會把自己注冊，在環境關閉時會被提醒。所以在關閉時，標准事務會提交或回滾根據是否地調用了setRollbackOnly（）。

所以在上面的配置中，每個環境塊會擁有獨立的事務。至少，如果使用的是hibernate會話。

14.4. 流程實例化的基礎

在下個例子中，我們將演示hibernate持久化是如何使用在一個具體例子中的。'persistent process'是一個簡單的三步流程：

圖 14.1. 持久化流程

三個活動會是等待狀態，就像第 5.4 節 “ExternalActivity實例”。

為了確認我們持久化了這個類，我們為它創建了hibernate映射，並像這樣把它添加到配置文件中：

<hibernate-configuration> 　 <properties resource="hibernate.properties" /> 　 <mapping resource="jbpm.pvm.typedefs.hbm.xml" /> 　 <mapping resource="jbpm.pvm.wire.hbm.xml" /> 　 <mapping resource="jbpm.pvm.definition.hbm.xml" /> 　 <mapping resource="jbpm.pvm.execution.hbm.xml" /> 　 <mapping resource="jbpm.pvm.variable.hbm.xml" /> 　 <mapping resource="jbpm.pvm.job.hbm.xml" /> 　 <mapping resource="jbpm.jpdl.hbm.xml" /> 　 <mapping resource="org/jbpm/examples/ch09/state.hbm.xml" /> 　 <cache-configuration resource="jbpm.pvm.cache.xml" 　　　　　　　　　　　　　　　　　　　　　　 usage="nonstrict-read-write" /> </hibernate-configuration>

下一個代碼片段演示了一個單元測試方法的內容。這個方法首先創建環境工廠，然後，在第一個事務中，一個流程定義會被創建，並保存到數據庫。然後第二個事務會創建這那個流程的一個新執行。下面的兩個事物會向執行提供外部觸發器。

EnvironmentFactory environmentFactory = EnvironmentFactory.parse(new ResourceStreamSource( 　　　 "org/jbpm/examples/ch09/environment.cfg.xml" ));

然後在第一個事務中，一個流程被創建了，並保存到數據庫中。這是一個通常的引用，像是發布一個流程，它只需要執行一次。

Environment environment = environmentFactory.openEnvironment(); try { 　 PvmDbSession pvmDbSession = environment.get(PvmDbSession.class); 　 ProcessDefinition processDefinition = ProcessFactory.build("persisted process") 　　　 .activity ("one").initial().behaviour(new State()) 　　　　　 .transition().to("two") 　　　 .activity("two").behaviour(new State()) 　　　　　 .transition().to("three") 　　　 .activity("three").behaviour(new State()) 　 .done(); 　 pvmDbSession.save (processDefinition); } finally { 　 environment.close(); }

在前一個事務中，流程定義，活動，轉移會被插入到數據庫表中。

接下來我們演示一個流程定義的新流程執行是如何啟動的。注意在這個情況下，我們提供了一個業務鍵叫做'first'.這會讓我們更簡單的處理相同的執行從數據庫的事務中。在啟動新流程執行後，它會等待'one'活動因為行為是一個等待狀態。

environment = environmentFactory.openEnvironment(); try { 　 PvmDbSession pvmDbSession = environment.get(PvmDbSession.class); 　 ProcessDefinition processDefinition = pvmDbSession.findProcessDefinition("persisted process"); 　 assertNotNull(processDefinition); 　 Execution execution = processDefinition.startExecution("first"); 　 assertEquals("one", execution.getActivity ().getName()); 　 pvmDbSession.save(execution); } finally { 　 environment.close(); }

在上一個事務中，一個新執行記錄會被插入到數據庫中。

下一步，我們反饋一個外部觸發器到這個存在的流程執行中。我們讀取執行，提供一個signal，然後只是把它保存回數據庫中。

environment = environmentFactory.openEnvironment(); try { 　 PvmDbSession pvmDbSession = environment.get(PvmDbSession.class); 　 Execution execution = pvmDbSession.findExecution("persisted process", "first"); 　 assertNotNull (execution); 　 assertEquals("one", execution.getActivity().getName()); 　 // external trigger that will cause the execution to execute until 　 // it reaches the next wait state 　 execution.signal(); 　 assertEquals("two", execution.getActivity ().getName()); 　 pvmDbSession.save(execution); } finally { 　 environment.close(); }