第 7 部分：即时构建 BPEL 流程
作者：Jerry Thomas

通过 XQuery 将数据库中存储的参数转换为 BPEL XML 定义文件来即时生成 BPEL 流程。

查看完整的“BPEL 指南”索引

本文相关下载： 示例代码 Oracle BPEL 流程管理器和 Designer Saxon XSLT 和 XQuery 分析器

2005 年 11 月发表

在本指南的第 3 部分中，您学习了如何使用端点引用操作合作伙伴链接，以实现动态的 BPEL 流程。该方法对于构建不受合作伙伴关系更改影响的流程确实很有用。但在许多流程中，除合作伙伴链接以外的各种其他变量也可能需要动态更改。

• 不同业务部门的空间使用情况如何？业务单元如何最有效地共享空间？
• 房地产租赁何时到期？通过了解公司的发展规划，怎样重新商议租赁事项？
• 如何进行最佳的规划和决策，将业务部门搬迁到其他楼层或扩大到街道对面的建筑中？

图 1 业务流程生命周期

构建实时流程分为几个步骤：分析人员使用自定义设计器以图形方式建立业务流程模型。

1. 自定义设计器将流程定义存储到数据库中。
2. BPEL Generator 读取并验证流程定义。然后，它利用数据库表示以及用于部署的相关文件生成 BPEL XML 文件。
3. BPEL 流程动态部署到 Oracle BPEL 流程管理器服务器上。

1. 当办公室隔间被占用时启动业务流程（空间的 EmployeeCount 字段设置为 0）。
2. 等待三个月（如果空间的 EmployeeCount 设置为 > 0，则退出该流）。
3. 向物业经理发送电子邮件，表明该空间不再由其原来的业务部门控制。
4. 更新该空间，将其与原属业务部门脱钩。

图 2 自定义流程设计器中的隔间管理业务流程

正如我在前面介绍的，Oracle BPEL 流程管理器引擎具备与提供的任何设计器/工具（后者可以生成有效的 BPEL 文件）集成的独特功能。

图 3 用于存储隔间管理流程定义的简化数据模式

WorkflowProcess 对象存储流程设计；它包含参数和节点，用于定义流程中的活动的序列和类型。各种 WorkflowNode 对象是设计器支持的不同类型的流程活动的设计时产物。注意，它们并不是 BPEL 结构，而是随后映射到通常多个 BPEL 活动的自定义结构。使用自定义设计器部署后，CubeManagement 流程详细信息将按如下所示存储到数据库中。

BPEL Generator 读取这些表以动态生成 BPEL 文件。下个部分介绍了该过程。

1. 迭代数据库。
生成 BPEL 是在 Java 代码中实施的，此代码读取工作流流程的每个 WorkflowNode 并创建一个由要处理的所有节点组成的列表。
2. 为每个节点创建 BPEL 活动。
向包含在 <scope 活动中的一些 BPEL 活动中生成该列表中的每个工作流节点。因此，如果对 BPEL 活动的处理需要使用 BPEL 参数，则此参数只在该作用域中可见（不存在变量名冲突等问题）。必须为每个节点创建 XQuery 模板以生成一个相应的 BPEL XML 标记。XQuery 处理器将处理 XQuery 模板以构建包含节点和实例信息的 BPEL 并返回结果。
3. 创建 BPEL 文件。
调用流程组合每个节点的 BPEL 活动并创建一个表示整个流程的主 BPEL 文件。为每个 WorkflowNode 生成的 <scope 块可以通过该方法相互添加。

<process>
	<scope>
		<!a€” start workflow node related activities -!>
	</scope>
	<scope>
		<!a€” wait workflow node related activities -!>
	</scope>
	<scope>
		<!a€” mail workflow node related activities -!>
	</scope>
	<scope>
		<!a€” update workflow node related activities -!>
	</scope>
</process>

<scope>
	<!-- generation for Message activity -->
	<variables>

	<!-- Define variables input, output and error variables-->
		<variable name="emailRequest" messageType="services:EntityAsyncMsgWSRequestMessage"
		<variable name="emailResponse" messageType="services:EntityAsyncMsgWSResultMessage"
		<variable name="fault" messageType="services:EntityFaultMessage" 
	</variables>

	<!--Begin the BPEL activities -->
	<sequence>

	<!--This is the first assign activity.It configures the input variable with 
<!-- identification of node ($nodekey) and function to be called -->
	<!-- by the external webService (bpelSendEmail). -->

		<assign>
			<copy>
				<from>
					<ent:EntityCollectionElem xmlns:ent="http://www.centerstonesoft.com/schema/entity" >
						<ent:Header
						<ent:entityName
						<ent:EntityElem>
							<ent:entityKey>{ $nodeKey }</ent:entityKey>
							<ent:method >
								<ent:methodName>bpelSendEmail</ent:methodName>
								<ent:parameter>
									<ent:PropName>thread</ent:PropName>
									<ent:Type>string</ent:Type>
									<ent:Value
								</ent:parameter>
							</ent:method>
						</ent:EntityElem>
					</ent:EntityCollectionElem>
				</from>
				<to variable="emailRequest" part="payload"
			</copy>
		</assign>

	<!--Second and third assign activity configure the input variable -->
	<!--with identification of actual process instance -->

		<assign>
			<copy>
				<from variable="input" part="parameters" query="//ent:Header"
				<to variable="emailRequest" part="payload" query="//ent:Header"
			</copy>
		</assign>
		<assign>
			<copy>
				<from variable="threadKey" part="value"
				<to variable="emailRequest" part="payload" query="//ent:parameter[ent:PropName = 'thread']/ent:Value"
			</copy>
		</assign>

		<!--After configuring input variable with node, instance and function to be called, 
		       invoke the external service -->
		<invoke name="invoke" partnerLink="EntityAsyncMsgWSLink" 
		           portType="services:EntityAsyncMsgWS" operation="invoke" inputVariable="emailRequest"

		<!--Check response from external service.If response indicates fault, throw exception. -->
		<!--If no response is received for 10 days, throw exception -->
		<pick name="deadlined_receive" >

			<!--Set output variable if return result from external webservice is OK-->
			<onMessage partnerLink="EntityAsyncMsgWSLink" portType="services:EntityAsyncMsgWSCallback" 
			      operation="onResult" variable="emailResponse">
				<empty
			</onMessage>

		<!--On fault, check the fault code and throw  appropriate exception-->

			<onMessage operation="onFault" partnerLink="EntityAsyncMsgWSLink" 
			      portType="services:EntityAsyncMsgWSCallback" variable="fault">
				<switch>
					<case condition="bpws:getVariableData('fault', 'value',  
					      '/EntityFault/faultcode') = 'MailException' ">
						<throw faultName="ent:MailException" faultVariable="fault" 
					</case>
					<otherwise>
						<throw faultName="ent:SystemException" faultVariable="fault" 
					</otherwise>
				</switch>
			</onMessage>

			<!--If no response for 10 days, throw  exception-->
			<onAlarm  for="'P10D'">
				<throw faultName="ent:SystemException"
			</onAlarm>   
		</pick>
	</sequence>
</scope>

/**
* Recursively generates an activity including any child activities.
* @param activity the node that is being generated, the value is null for the top-level
* process node
* @return typically the root element of the generated XML document
* @throws EntityException
 */
protected String generateActivity(WorkflowNode activity) throws EntityException
    {
	//Find the next node in the list to be processed
BpelActivityType activityType = getBpeBpelActivityType(activity);
	//Get the parameters to be passed to node
HashMap params = calculateParameters(activity, activityType);
try {
//Get corresponding XQuery file for the node
XQuery q = XQuery.newXQueryFromResource("bpelgen/" + activityType.getQuery());
//Call the Saxon XQuery Processor to run the query. 
XQueryResult result = q.run(null, params, null);
//Convert the result into a string 
String parentXml = result.serializeString();
if (logger.isDebugEnabled()) {
logger.debug("Generated for parent '" + activityType.getName() + "' is \n" + parentXml);
            }
//If there are child nodes, recursively invoke generate activity
if (_process.hasChildren(activity)) {
//Call java relational class
Iterator it = _process.getChildrenIterator(activity);
//Recursively call generateActivity for child nodes.For a€?Cube Management Processa€?, these will be 
	//start, wait, message, update & end
while (it.hasNext()) {
WorkflowNode childActivity = (WorkflowNode) it.next();
String childXml = generateActivity(childActivity);
// now use Saxon XSLT to add the document generated for the children to the result document
	// Get the Transformer used for this transformation
Transformer transformer = getPrependTransformer();
transformer.setParameter("inserted", DomUtils.getDocument(new ByteArrayInputStream(childXml.getBytes())));
StreamResult saveResult = new StreamResult(new ByteArrayOutputStream());
try {
StreamSource src = new StreamSource(new ByteArrayInputStream(parentXml.getBytes()));
	   // Transform the XML Source
transformer.transform(src, saveResult);
                    }
finally {
transformer.clearParameters();
                    }
parentXml = ((ByteArrayOutputStream)saveResult.getOutputStream()).toString();
if (logger.isDebugEnabled()) {
BpelActivityType childType = getBpeBpelActivityType(childActivity);
logger.debug("Preprocessed for parent '" + activityType.getName() + "' and child '" +
childType.getName() + "' is \n" + parentXml);
                    }
                }
            }
// remove the <insert-here> node
Transformer transformer = getRemovePrependTransformer();
StreamResult saveResult = new StreamResult(new ByteArrayOutputStream());
StreamSource src = new StreamSource(new ByteArrayInputStream(parentXml.getBytes()));
transformer.transform(src, saveResult);
parentXml = ((ByteArrayOutputStream)saveResult.getOutputStream()).toString();
if (logger.isDebugEnabled()) {
logger.debug("Generated for '"+activityType.getName()+"' is \n" + parentXml);
            }
return parentXml;
        }
catch (SAXException ex) {
throw new EntityException("Failed to run transform "+activityType.getQuery(), ex);
        }
catch (TransformerException ex) {
throw new EntityException("Failed to run transform "+activityType.getQuery(), ex);
        }
catch (IOException ex) {
throw new EntityException("Failed to load query "+activityType.getQuery(), ex);
        }
    }

<?xml version="1.0" encoding="UTF-8" ?>
<project default="main" basedir="C:/DOCUME~1/jerry/LOCALS~1/Temp/cs_bpelgen_simple24369" name="BpelDeploy">
<target name="main">
<bpelc keepGenerated="true" deploy="jt_dev" rev="1.0" home="c:\orabpel"
</target>
</project>

String args[] = new String[1];
args[0] = "c:/orabpelpm/integration/orabpel/bin/obant.bat";
            
Execute exe = new Execute();
exe.setCommandline(args);
exe.setWorkingDirectory(_deploydir);
int retval = exe.execute();
if ( retval != 0 ) {
throw new ExecuteException("process failed to deploy");