1

我正在尝试创建某种类型的更新端点，当您点击它时，它会从一个表插入到另一个表。基本上它取自一个名为fundswhich wasfundId和reportingfrequency的表country。IT 保留fundIds和 ，因为它获得了一个日期列表，这些日期是与 Postgres 存储过程/函数连接的结果。这是完整的 SQL 查询示例。因此，理想情况下，如果表中有 100 行，它会将所有 100 行和日期数组插入到due_dates表中。

INSERT INTO due_dates (fund_id, listdate)
SELECT fundid,
     (
        SELECT array_agg(weekdays::date)
        FROM generate_series(date'2021-01-01', date'2021-12-31', interval '1' day) as t(weekdays)
        LEFT JOIN holidays.poland(2021, 2021) f ON (weekdays = f.datestamp)
        WHERE f.datestamp IS NULL 
        AND extract(dow from weekdays) BETWEEN 1 AND 5
     )
FROM funds
WHERE reportingfrequency = 'Daily';

现在我的问题是我不确定如何...以编程方式执行此操作，以便根据funds表中的行...我不确定如何country从行中获取字段以执行特定的存储过程调用。例如，如果单行Poland在它的country字段中，那么理想情况下它会调用holidays.poland(2021, 2021)... 如果国家是美国，它会调用holidays.usa(2021, 2021). 这是我当前的 NativeQuery 的方式。

entityManager.createNativeQuery("INSERT INTO due_dates (fund_id, listdate)" +
                                        "SELECT fundid," +
                                            "(" +
                                            "SELECT array_agg(weekdays::date)" +
                                            "FROM generate_series(date'2021-01-01', date'2021-12-31', interval '1' day) as t(weekdays)" +
                                            "LEFT JOIN holidays." + country + "(" + year + "," + year + ") f ON (weekdays = f.datestamp)" +
                                            "WHERE f.datestamp IS NULL" + 
                                            "AND extract(dow from weekdays) BETWEEN 1 AND 5" +
                                            ")" +
                                        "FROM funds" +
                                        "WHERE reportingfrequency = 'Daily'; ")
        .executeUpdate();

在实现我想要做的事情之前，我需要做些什么来调整原始 SQL 语句吗？

4

0 回答 0