<jdbc-ee:mysql-data-source name="MySQL_Data_Source" user="root" password="root" url="jdbc:mysql://localhost:3306/test" transactionIsolation="UNSPECIFIED" doc:name="MySQL Data Source"/>
<jdbc-ee:connector name="test" dataSource-ref="MySQL_Data_Source" validateConnections="true" queryTimeout="-1" pollingFrequency="0" doc:name="Database"/>
<data-mapper:config name="DataMapper" transformationGraphPath="mapper.grf" doc:name="DataMapper"/>
<flow name="EmployeeListFlow1" doc:name="EmployeeListFlow1">
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" port="8082" doc:name="HTTP" path="employeelist"/>
<json:json-to-object-transformer doc:name="JSON to Object" returnClass="java.util.Map"/>
<choice doc:name="Choice">
<when expression="payload.storeId == null || payload.storeId <= 0 ">
<set-variable variableName="query" value="select e.employeeid,e.companyid,e.firstName,e.lastName from employees e where companyid = #[message.payload.companyId]" doc:name="CompanyId"/>
</when>
<otherwise>
<set-variable variableName="query" value="select e.employeeid,e.companyid,e.firstName,e.lastName from employees e where employeeid in (select employeeid from employeestores where storeid =#[message.payload.storeId] )" doc:name="StoreId"/>
</otherwise>
</choice>
<jdbc-ee:outbound-endpoint exchange-pattern="request-response" queryTimeout="-1" doc:name="EmployeeListFetch" connector-ref="Theatro" queryKey="employees_list">
<jdbc-ee:query key="employees_list" value="#[flowVars['query']]"/>
</jdbc-ee:outbound-endpoint>
<json:object-to-json-transformer doc:name="Object to JSON"/>
</flow>
例外:
根异常堆栈跟踪:java.lang.IllegalArgumentException: 找不到 SQL 语句的 SQL 策略: #[flowVars['query']] at com.mulesoft.mule.transport.jdbc.sqlstrategy.EESqlStatementStrategyFactory.create(EESqlStatementStrategyFactory.java:109) at org.mule.transport.jdbc.JdbcMessageDispatcher.doSend(JdbcMessageDispatcher.java:69) at org.mule.transport.AbstractMessageDispatcher.process(AbstractMessageDispatcher.java:81) + 3 更多(为所有内容设置调试级别日志记录或"-Dmule.verbose.exceptions=true")
在这里,我想基于输入构建动态 jdbc 查询。
json data {"companyId":"1","storeId":"1"}请帮助我。
尝试对 JDBC 动态出站端点使用类似以下内容的内容:
<outbound-endpoint address="jdbc://select * from ${datasource.table} #[variable:where-statement]" exchange-pattern="request-response"/>
呵呵
这里有 2 个错误,
在"选择"中,表达式缺失[]
类似<when expression="[payload.storeId == null || payload.storeId <= 0] ">
接下来你的查询应该是这样的:-
select e.employeeid,e.companyid,e.firstName,e.lastName from employees e where employeeid in (select employeeid from employeestores where storeid ='#[message.payload.storeId]' )
其中#[message.payload.storeId]
应该在''
内,因为storeId是一个字符串