騾子移動文件，從數據庫查詢動態另一個位置

Question

我想將文件移動到位置d：從查詢select filepath from emp where status='y'動態\目標：

這是我的表：

emp_Name File Path  File Name Status 
ABC   D:\emp   abc.txt  y 
xyz   D:\emp   xyz.txt  y 
bcs   D:\emp   bcs.txt  n 

以下是我的源代碼：

<flow name="testdbFlow1"> 
    <http:listener config-ref="HTTP_Listener_Configuration" 
     path="/" doc:name="HTTP" /> 
    <jdbc-ee:outbound-endpoint queryKey="allEmps" 
     queryTimeout="-1" connector-ref="JDBCConnector" exchange-pattern="request-response" 
     doc:name="Database" /> 

    <foreach doc:name="Foreach"> 
     <choice doc:name="Choice"> 
      <when expression="#[payload.status == 'Y']"> 
       <processor-chain doc:name="Processor Chain"> 
        <set-variable variableName="filePath" value="#[payload.filepath]" 
         doc:name="Variable" /> 
        <set-variable variableName="filename" value="#[payload.filename]" 
         doc:name="Variable" /> 

        <logger message="#[filePath]" level="INFO" 
         doc:name="Logger" /> 
        <logger message="#[filename]" 
         level="INFO" doc:name="Logger" /> 

        <file:inbound-endpoint path="#[filePath]" name="input" doc:name="File" 
         pollingFrequency="12000" responseTimeout="10000"> <file:filename-wildcard-filter 
         pattern="#[filename]" /> </file:inbound-endpoint> 

        <file:outbound-endpoint name="output" path="D:\target" doc:name="File"/> 

       </processor-chain> 
      </when> 
      <otherwise> 
       <processor-chain doc:name="Processor Chain"> 
        <set-variable variableName="filePath" value="#[payload.filepath]" 
         doc:name="Variable" /> 
        <set-variable variableName="filename" value="#[payload.filename]" 
         doc:name="Variable" /> 

        <logger message="#[filePath]" level="INFO" 
         doc:name="Logger" /> 
        <logger message="#[filename]" 
         level="INFO" doc:name="Logger" /> 

       </processor-chain> 
      </otherwise> 
     </choice> 
    </foreach> 

</flow> 

但它不工作。

Answer 1

入站流程在流程中不可用。我會建議使用Groovy更簡單的解決方案，因爲您確切知道需要使用的文件。

而不是使用文件：入境手動創建一個輸入流：

<set-payload value="#[groovy: new java.io.FileInputStream(new java.io.File(filename))]"/> 

你將不得不刪除與消耗陸續Groovy腳本文件。