骡子从数据库查询动态移动文件到另一个位置

Question

我想将文件从查询select filepath from emp where status='y'动态移动到位置 D:\target:

这是我的桌子：

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 的更简单的解决方案，因为您确切知道需要使用的文件。

手动创建输入流，而不是使用 file:inbound：

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

使用后您将不得不使用另一个 groovy 脚本删除该文件。