對(duì)HelloWorldDbTest的分析
在Eclipse中到如jbpm-starters-kit-3.1"jbpm工程后，在src"examples"org"jbpm"db底下有一個(gè)HelloWorldDbTest.java的實(shí)例。我從這個(gè)實(shí)例分析開(kāi)始，構(gòu)建自己的jbpm工程在Mysql下的應(yīng)用。
首先我們來(lái)先分析一下HelloWorldDbTest實(shí)例。
基本流程
HelloWorldDbTest類是一個(gè)JUnit的測(cè)試類。里面只有一個(gè)測(cè)試函數(shù)testSimplePersistence。這個(gè)函數(shù)里面調(diào)用了三個(gè)操作，分別是：
l 將流程（processDefinition）的部署到數(shù)據(jù)庫(kù)中；
l 從數(shù)據(jù)庫(kù)中加載流程，并實(shí)例化一個(gè)流程實(shí)例（processInstance），然后運(yùn)行一半再將流程實(shí)例存回?cái)?shù)據(jù)庫(kù)；
l 從數(shù)據(jù)庫(kù)中加載流程實(shí)例，然后運(yùn)行完畢這個(gè)實(shí)例。
JbpmConfigration
在類HelloWorldDbTest中有靜態(tài)代碼段，內(nèi)容是構(gòu)造一個(gè)JbpmConfigration的實(shí)例。JbpmConfigration在Jbpm3.1中和Jbpm3中差別很大，JbpmAPI手冊(cè)描寫(xiě)如下：
“configuration of one jBPM instance. During process execution, jBPM might need to use some services. A JbpmConfiguration contains the knowledge on how to create those services.
A JbpmConfiguration is a thread safe object and serves as a factory for JbpmContexts, which means one JbpmConfiguration can be used to create JbpmContexts for all threads. The single JbpmConfiguration can be maintained in a static member or in the JNDI tree if that is available. ”
JbpmConfigration主要有兩種加載方法，一種是從配置文件中加載，一般使用jbpm.cfg.xml，jbpm-starters-kit-3.1中放在jbpm-starters-kit-3.1"jbpm"src"config.files目錄下。要使用jbpm.cfg.xml進(jìn)行配置的話，就必須把這個(gè)文件放在classpath中。因?yàn)?/span>jbpm-starters-kit-3.1"jbpm工程已經(jīng)把此目錄放在工程的classpath中，所以如果在代碼中JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();這樣書(shū)寫(xiě)的話就是使用jbpm.cfg.xml中的配置來(lái)構(gòu)造JbpmConfigration。另外一種就是本例中使用的對(duì)xml解析的方法。
使用數(shù)據(jù)庫(kù)
在加載的JbpmConfiguration的加載內(nèi)容中有如下部分：
“" <string name='resource.hibernate.cfg.xml' " +
" value='hibernate.cfg.xml' />" +”
這里面的hibernate.cfg.xml也在jbpm-starters-kit-3.1"jbpm"src"config.files目錄下，是對(duì)Jbpm使用的Hibernate的配置文檔。通過(guò)這個(gè)文檔，Jbpm就可以通過(guò)Hibernate的工具，在不同的數(shù)據(jù)庫(kù)中，把說(shuō)使用到的表全部構(gòu)建出來(lái)，而不需要再人工去操作sql語(yǔ)句在數(shù)據(jù)庫(kù)中操作，這也就是為什么這個(gè)實(shí)例中沒(méi)有需要我們自己在數(shù)據(jù)庫(kù)中建表建庫(kù)的原因。
通過(guò)HelloWorldDbTest類的注釋和用戶手冊(cè)中的文檔可以知道，在這個(gè)實(shí)例中使用的數(shù)據(jù)庫(kù)是一個(gè)內(nèi)存數(shù)據(jù)庫(kù)，在目錄下的Hibernate.cfg.xml中有如下內(nèi)容：
“ <!-- jdbc connection properties -->
<property name="hibernate.dialect">org.hibernate.dialect.HSQLDialect</property>
<property name="hibernate.connection.driver_class">org.hsqldb.jdbcDriver</property>
<property name="hibernate.connection.url">jdbc:hsqldb:mem:.;sql.enforce_strict_size=true</property>
<property name="hibernate.connection.username">sa</property>
<property name="hibernate.connection.password"></property>”
懂得Hibernate的朋友就能看出來(lái)，在jbpm工程中，使用的數(shù)據(jù)庫(kù)是hsqldb。
在加載HelloWorldDbTest類的時(shí)候，就會(huì)發(fā)現(xiàn)，在console有大量的輸出。其中包括：
“12:27:38,201 [main] INFO Configuration : Reading mappings from resource: org/jbpm/graph/def/Transition.hbm.xml
12:27:38,231 [main] INFO HbmBinder : Mapping class: org.jbpm.graph.def.Transition -> JBPM_TRANSITION“很多類似的輸出。這些輸出就是Hiernate在加載描述文件時(shí)候產(chǎn)生的說(shuō)明信息。
輸出信息中后面還包括對(duì)數(shù)據(jù)庫(kù)的連接，設(shè)置等等說(shuō)明信息。
JbpmConfiguration.createSchema()
這個(gè)方法可以實(shí)現(xiàn)自動(dòng)在數(shù)據(jù)庫(kù)中生成表結(jié)構(gòu)的。在這個(gè)實(shí)例中，在Junit的 setup()操作中調(diào)用了這個(gè)函數(shù)，在進(jìn)行測(cè)試實(shí)例前對(duì)數(shù)據(jù)庫(kù)進(jìn)行創(chuàng)建。
JbpmContext
運(yùn)行HelloWorldDbTest中的測(cè)試實(shí)例。
首先是定義一個(gè)流程，然后就實(shí)例化一個(gè)JbpmContext。
“JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext(); “
JbpmContext類是Jbpm3.1版本引進(jìn)的一個(gè)新類，以前是沒(méi)有的。
在jbpm的說(shuō)明中有對(duì)JbpmContext類的如下說(shuō)明：
JbpmContext is used to surround persistent operations to processes.
Obtain JbpmContext's via JbpmConfiguration.createJbpmContext() and put it in a try-finally block like this:
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
try {
TaskInstance taskInstance = ...
...do your process operations...
// in case you update a process object that was not fetched
// with a ...ForUpdate method, you have to save it.
jbpmContext.save(processInstance);
finally {
jbpmContext.close();
}
A JbpmContext separates jBPM from a sprecific environment. For each service that jBPM uses, there is an interface specified in the jBPM codebase. jBPM also includes implementations that implement these services by using services in a specific environment. e.g. a hibernate session, a JMS asynchronous messaging system, ...
A JbpmContext can demarcate a transaction. When a PersistenceService is fetched from the JbpmContext, the default implementation for the persistence service will create a hibernate session and start a transaction. So that transactions can be configured in the hibernate configuration.
A JbpmContext allows the user to overwrite (or make complete) the configuration by injecting objects programmatically. like e.g. a hibernate session factory or a hibernate session or any other resource that can be fetched or created from the configuration.
Last but not least, JbpmContext provides convenient access to the most common operations such as getTaskList(String), newProcessInstance(String) loadTaskInstanceForUpdate(long) and save(ProcessInstance).
All the ...ForUpdate(...) methods will automatically save the loaded objects at jbpmContext.close();
將上面這些英文讀懂，基本上就能對(duì)JbpmContext有個(gè)大致的了解。最主要的就是實(shí)現(xiàn)Jbpm對(duì)數(shù)據(jù)庫(kù)操作的所有接口的封裝。
流程部署
在deployProcessDefinition中的jbpmContext. deployProcessDefinition (processDefinition);操作，向數(shù)據(jù)庫(kù)中部署一個(gè)流程。如果跟蹤deployProcessDefinition的話，會(huì)發(fā)現(xiàn)jbpmContext還是調(diào)用的GraphSession的流程部署方法。后面我們?cè)僦v到GraphSession類。
在后面使用Mysql實(shí)現(xiàn)的例子中，我們就可以通過(guò)工具在mysql中看到這樣一個(gè)部署流程的操作對(duì)數(shù)據(jù)庫(kù)有如何影響。同樣也可以查看流程實(shí)例化保存在數(shù)據(jù)庫(kù)中的情況。
GraphSession
Jbpm中are the graph related database operations的類。可以通過(guò)GraphSession graphSession = jbpmContext.getGraphSession();來(lái)得到這個(gè)類的實(shí)例，并且JbpmContext很多方法都是封裝該類的方法。
該類中包括了幾乎所有的數(shù)據(jù)庫(kù)操作的，例如部署流程，加載流程，部署流程實(shí)例，加載變量，等等。
HelloWorldDbTest類本身就已經(jīng)有非常完整的注釋，有關(guān)分析也就寫(xiě)到這里。
Jbpm在Mysql上的demo工程
創(chuàng)建Jbpm Project
首先在Eclipse里面創(chuàng)建一個(gè)Jbpm Process Project的新項(xiàng)目。比如命名為myDemo。Eclipse的Jbpm插件會(huì)自動(dòng)創(chuàng)建一些文件，比如在processes目錄下有一個(gè)simple的流程。在src/java下面有一個(gè)MessageActionHandler的類。在src/config.files目錄下四個(gè)配置有文件。在test/java下面有一個(gè)SimpleProcessTest的JUnit類實(shí)例。可以先運(yùn)行這個(gè)測(cè)試，應(yīng)該是正確沒(méi)有問(wèn)題的。
配置Mysql數(shù)據(jù)庫(kù)
打開(kāi)MySql數(shù)據(jù)庫(kù)，假設(shè)MySql數(shù)據(jù)庫(kù)的用戶名為root，密碼1234。首先創(chuàng)建jbpm_db數(shù)據(jù)庫(kù)。然后修改src/config.files底下的Hibernate.cfg.xml文件。將連接數(shù)據(jù)庫(kù)的部分換成Mysql的內(nèi)容。如下：
<!-- jdbc connection properties -->
<property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property>
<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property>
<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/jbpm_db</property>
<property name="hibernate.connection.username">root</property>
<property name="hibernate.connection.password">1234</property>
添加代碼和流程
我們先創(chuàng)建一個(gè)自己的流程。在processes目錄下面創(chuàng)建一個(gè)叫做pro1的流程。然后添加最簡(jiǎn)單的，start-state ,end和一個(gè)state節(jié)點(diǎn)。
將Jbpm3工程中的jbpm.cfg.xml中的內(nèi)容添加到src/config.files目錄下的jbpm.cfg.xml中。
在test/java目錄下面添加一個(gè)新的Junit類。命名為SimpleDBTest。
代碼如下：
package com.sample;
import java.io.FileInputStream;
import java.util.List;
import junit.framework.TestCase;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.db.GraphSession;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.exe.ProcessInstance;
import org.jbpm.graph.exe.Token;
public class SimpleDBTest extends TestCase {
static JbpmConfiguration cfg = JbpmConfiguration.getInstance();
public void setUp() {
cfg.createSchema();
}
public void testDeployProcessDefinition() throws Exception {
assertNotNull("JbpmConfiguration should not be null", cfg);
FileInputStream fis = new FileInputStream("processes/pro1/processdefinition.xml");
ProcessDefinition processDefinition = ProcessDefinition.parseXmlInputStream(fis);
assertNotNull("Definition should not be null", processDefinition);
JbpmContext jbpmContext = cfg.createJbpmContext() ;
try {
// Deploy the process definition in the database
jbpmContext.deployProcessDefinition(processDefinition);
} finally {
jbpmContext.close();
}
}
}
執(zhí)行這個(gè)操作，會(huì)發(fā)現(xiàn)報(bào)錯(cuò)，報(bào)不能找到Hibernate的錯(cuò)誤。原來(lái)在Eclipse建立的Jbpm的工程中，雖然添加了Jbpm的包，但沒(méi)有添加Hibernate的包。因此在工程的Java Build Path的Libraries底下添加Hibernate的包（具體添加那些，請(qǐng)參考Jbpm的用戶手冊(cè)）。
部署流程
執(zhí)行SimpleDBTest .testDeployProcessDefinition()操作。如果沒(méi)有錯(cuò)誤的話，這次就可以將流程pro1部署進(jìn)入Mysql數(shù)據(jù)庫(kù)。
在jbpm_db數(shù)據(jù)庫(kù)中會(huì)看到產(chǎn)生了33個(gè)表。查看jbpm_processdefinition表，會(huì)發(fā)現(xiàn)有一個(gè)名字為pro1，ID為1，version為1的條目。
同樣可以查看jbpm_node表。
再次部署
修改流程pro1的定義，在state1節(jié)點(diǎn)添加一個(gè)Action，在node-enter事件中。完整的xml文件見(jiàn)該文檔最后部分。然后再次運(yùn)行SimpleDBTest .testDeployProcessDefinition()操作。查看jbpm_processdefinition，會(huì)發(fā)現(xiàn)有了一個(gè)pro1的version為2版本的流程。這里有了一個(gè)Jbpm流程版本的概念，可以參考用戶手冊(cè)。
還可查看jbpm_event，jbpm_action表。
實(shí)例化流程
添加代碼：
public void testLoadProcessAndInstance() throws Exception {
JbpmContext jbpmContext = cfg.createJbpmContext() ;
try {
GraphSession graphSession = jbpmContext.getGraphSession();
ProcessDefinition processDefinition =
graphSession.findLatestProcessDefinition("pro1");
ProcessInstance processInstance =
new ProcessInstance(processDefinition);
Token token = processInstance.getRootToken();
assertEquals("start", token.getNode().getName());
// Let's start the process execution
token.signal();
assertEquals("state1", token.getNode().getName());
jbpmContext.save(processInstance);
} finally {
// Tear down the pojo persistence context.
jbpmContext.close();
}
}
這段代碼把pro1流程的最新版本加載進(jìn)來(lái)，然后實(shí)例化。并開(kāi)始執(zhí)行，到state1節(jié)點(diǎn)停下來(lái)（此時(shí)Action已經(jīng)執(zhí)行過(guò)了）。然后把這個(gè)實(shí)例也存入數(shù)據(jù)庫(kù)。
這時(shí)候查看jbpm_processInstance表，jbpm_token表。
完成實(shí)例的運(yùn)行
添加代碼
public void testLoadInstanceAndDoActionAndEnd() throws Exception {
JbpmContext jbpmContext = cfg.createJbpmContext() ;
try {
GraphSession graphSession = jbpmContext.getGraphSession();
ProcessDefinition processDefinition =
graphSession.findLatestProcessDefinition("pro1");
List processInstances =
graphSession.findProcessInstances(processDefinition.getId());
ProcessInstance processInstance =
(ProcessInstance) processInstances.get(0);
this.assertEquals("message",(String)(processInstance.getContextInstance().getVariable("message")));
processInstance.signal();
assertTrue(processInstance.hasEnded());
jbpmContext.save(processInstance);
} finally {
jbpmContext.close();
}
}
這段代碼將剛才的流程實(shí)例從數(shù)據(jù)庫(kù)中加載進(jìn)來(lái)，然后執(zhí)行完畢。
查看表jbpm_processinstance表，會(huì)發(fā)現(xiàn)上次end字段還是null，現(xiàn)在已經(jīng)是填寫(xiě)了剛才執(zhí)行的事件了，表示這個(gè)流程實(shí)例已經(jīng)執(zhí)行完畢。
流程Pro1的完整xml文檔
<?xml version="1.0" encoding="UTF-8"?>
<process-definition
xmlns="urn:jbpm.org:jpdl-3.1" name="pro1">
<start-state name="start">
<transition name="" to="state1"></transition>
</start-state>
<state name="state1">
<event type="node-enter">
<action name="action1" class="com.sample.action.MessageActionHandler">
<message>message</message>
<message2>message2 </message2>
</action>
</event>
<transition name="" to="end"></transition>
</state>
<end-state name="end"></end-state>
</process-definition>
總結(jié)
通過(guò)上面的分析和實(shí)例，我們基本上可以理解Jbpm對(duì)數(shù)據(jù)庫(kù)的操作。但這還只是一個(gè)最開(kāi)始的實(shí)習(xí)。如果要理解jbpm的ER模型的話，最好能夠把數(shù)據(jù)庫(kù)中的表的ER模型做出來(lái)。在網(wǎng)上以前看到過(guò)相關(guān)的圖。但是沒(méi)有說(shuō)明。如果有朋友有相關(guān)的文檔的話，麻煩給留個(gè)信息，謝謝。
v