小编Tan*_*ain的帖子

我正在使用Mysql,我很难尝试从SELECT查询中获取结果.我有3张桌子.第一个表部分,第二个表部分成员和第三个表部分成员状态(此表中的数据是静态的).

select * from Sections;

| section_id | title  | description | section_ownerid |
-------------------------------------------------------
| 1          | title1 | desc1       | 100             |
| 2          | title2 | desc2       | 100             |
| 3          | title3 | desc3       | 100             |
| 4          | title4 | desc4       | 100             |
| 5          | title5 | desc5       | 100             |
| 6          | title6 | desc6       | 100             |

select * from SectionMembers;

| SectionMembers_id | section_id  | status_code | …

根据此文档，找不到从远程 SFTP 重新下载本地删除文件的正确过程。

要求是删除已经从远程 SFTP 获取的本地文件，并在需要时使用 sftp-inbound-adapter（DSL 配置）重新获取相同的文件。在此实现，MetadataStore没有持续到任何外部系统，如PropertiesPersistingMetadataStore或Redis的元数据存储。因此，根据doc，MetadataStore存储在In-Memory 中。

找不到任何方法来删除该远程文件的元数据，MetadataStore以使用file_name. 并且没有任何线索，应该如何removeRemoteFileMetadata()实现这个回调（根据这个文档）。

配置类包含以下内容：

    @Bean
    public IntegrationFlow fileFlow() {
        SftpInboundChannelAdapterSpec spec = Sftp.inboundAdapter(sftpConfig.getSftpSessionFactory())
                .preserveTimestamp(true)
                .patternFilter(Constants.FILE_NAME_CONVENTION)
                .remoteDirectory(sftpConfig.getSourceLocation())
                .autoCreateLocalDirectory(true)
                .deleteRemoteFiles(false)
                .localDirectory(new File(sftpConfig.getDestinationLocation()));

        return IntegrationFlows
                .from(spec, e -> e.id("sftpInboundAdapter").autoStartup(false)
                        .poller(Pollers.fixedDelay(5000).get()))
                .channel(MessageChannels.direct().get())
                .handle(message -> {
                    log.info("Fetching File : " + message.getHeaders().get("file_name").toString());
                })
                .get();
    }