Оказалось не все так просто. Передо мной стояла задача - из процесса в жБПМ обратиться за данными к БД. Нашел способ, правда, без использования всяких там спрингов и прочих технологий. Вероятно, с точки зрения высоких материй это не совсем хорошо, но мне для начала очень даже пойдет. Возможно - кому-то тоже.
Итак, что было сделано:
- скачан jbpm-5.3.0.Final-installer и установлен в соответствии с инструкцией из install.html
- в качестве ГУИ для создания процесса использовался Eclipse-based plugin, который запускается при старте демо из поставки jbpm-5.3.0.Final-installer (демо запускается при помощи команды
ant start.demo , процесс так же описан в install.html)
- импортнул прожект с примером Evaluation, в нем же и велись дальнейшие танцы с бубном
- нарисован простейший процесс со стартом, скрипт-таском и концом процесса
- прямо в скрипт-таске в свойстве Action был прописан такой ява-код:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
String ls_log;
Connection conn;
OracleDriver ora;
conn = null;
Class.forName("oracle.jdbc.driver.OracleDriver");
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
//initiate a JDBC connection
try{
conn = DriverManager.getConnection("jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = winsrv2008)(PORT = 1521)))(CONNECT_DATA =(SID = orasid)))","usr","pwd");
System.out.println("Connected!");
}catch(Exception e){
System.out.println("Exception when connecting to DB: "+e.getMessage());
return;
}
CallableStatement cs;
try {
cs = conn.prepareCall ("{call usr.auerror1_pg.AddErr(?, ?, ?)}");
cs.setString(1, "000");
cs.setInt(2, 1);
cs.setString(3, "TESTEST");
cs.execute();
cs.close();
}catch(Exception e){
System.out.println("Exception when accessing to DB: "+e.getMessage());
return;
}
try {
cs = conn.prepareCall ("{? = call usr.auerror1_pg.F_GetErrText()}");
cs.registerOutParameter (1, Types.VARCHAR);
cs.execute();
System.out.println(cs.getString(1));
cs.close();
}catch(Exception e){
System.out.println("Exception when accessing to DB: "+e.getMessage());
return;
}
conn.close();
System.out.println("End");
- там же в Action Editor указал:
1.
2.
3.
4.
5.
import oracle.jdbc.driver.OracleDriver
import java.sql.Connection
import java.sql.DriverManager
import java.sql.CallableStatement
import java.sql.Types
- создал жава-класс для запуска тестового процесса:
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
package com.sample;
import java.util.HashMap;
import java.util.Map;
import org.drools.KnowledgeBase;
import org.drools.builder.KnowledgeBuilder;
import org.drools.builder.KnowledgeBuilderFactory;
import org.drools.builder.ResourceType;
import org.drools.io.ResourceFactory;
import org.drools.logger.KnowledgeRuntimeLogger;
import org.drools.logger.KnowledgeRuntimeLoggerFactory;
import org.drools.runtime.StatefulKnowledgeSession;
import org.jbpm.process.workitem.wsht.HornetQHTWorkItemHandler;
/**
* This is a sample file to launch a process.
*/
public class ProcessTest_debtOff {
public static final void main(String[] args) {
try {
// load up the knowledge base
KnowledgeBase kbase = readKnowledgeBase();
StatefulKnowledgeSession ksession = createKnowledgeSession(kbase);
KnowledgeRuntimeLogger logger = KnowledgeRuntimeLoggerFactory.newThreadedFileLogger(ksession, "test", 1000);
// start a new process instance
Map<String, Object> params = new HashMap<String, Object>();
ksession.startProcess("test.testProc", params);
System.out.println("Process started ...");
logger.close();
} catch (Throwable t) {
t.printStackTrace();
}
}
private static KnowledgeBase readKnowledgeBase() throws Exception {
KnowledgeBuilder kbuilder = KnowledgeBuilderFactory.newKnowledgeBuilder();
kbuilder.add(ResourceFactory.newClassPathResource("test.bpmn2"), ResourceType.BPMN2);
return kbuilder.newKnowledgeBase();
}
private static StatefulKnowledgeSession createKnowledgeSession(KnowledgeBase kbase) {
StatefulKnowledgeSession ksession = kbase.newStatefulKnowledgeSession();
HornetQHTWorkItemHandler humanTaskHandler = new HornetQHTWorkItemHandler(ksession);
humanTaskHandler.setIpAddress("127.0.0.1");
humanTaskHandler.setPort(5445);
ksession.getWorkItemManager().registerWorkItemHandler("Human Task", humanTaskHandler);
return ksession;
}
}
- выбрал этот жава-класс, прямо как в описании примера - нажал "Debug/Java Application" - все по честному запустилось, в базу запихались данные, потом из этой же базы вторым стейтментом они были выбраны и выведены в консоль. Ура!
