1

我有一个有四列的表，这就是它的样子。我会称之为 T_BPR_KPI_MONTHLY_VALUES

 KPI_NAME_SHORT_S | MONTH_N | YEAR_N | VALUE_N
-----------------------------------------------
 MY_KPI_1         |       1 |   2015 |   99.87
 MY_KPI_2         |       1 |   2015 |   97.62
 ...              |       1 |   2015 |     ...
 MY_KPI_1         |       2 |   2015 |     ...
 ...              |     ... |   2015 |     ...

每个 kpi 代表一个测量值，每个 kpi 都有每日值，这些值保存在另一个名为 T_BPR_KPI_DY 的表中。我的目标是计算并保存每个 KPI 的每月值。

有可能在某一天，某些 kpi 的每日值仍然缺失，为了精确计算每月值，我必须能够替换数据库中的现有值，并为未来的月份和年份插入新的数据。

我认为 oracle sql 合并操作将是这项任务的不错选择。这个想法是检查一个条目是否已经存在，如果存在则更新它的值，如果不插入新的。

这就是查询的样子

MERGE INTO T_BPR_KPI_MONTHLY_VALUE A
USING( SELECT 'MY_KPI_1' AS KPI_NAME_SHORT_S, 1 AS MONTH_N, 2014 AS YEAR_N FROM DUAL ) B 
ON ( A.KPI_NAME_SHORT_S = B.KPI_NAME_SHORT_S ) 
WHEN MATCHED THEN 
UPDATE SET VALUE_N = ( select AVG(MY_KPI_1) from T_BPR_KPI_DY where DAY_D between '01.01.2014' AND '31.01.2014') 
WHEN NOT MATCHED THEN 
INSERT (KPI_NAME_SHORT_S, MONTH_N, YEAR_N, VALUE_N) VALUES ('MY_KPI_1', 1, 2014, ( select AVG(MY_KPI_1) from T_BPR_KPI_DY where DAY_D between '01.01.2014' AND '31.01.2014') )

我认为即时计算平均每月值并不是一个坏主意，所以你可以看到我有另一个选择查询，它只计算特定 kpi 的平均每月值。我不确定这是否是最佳实用解决方案，但是当我在 oracle sql 开发人员工具中执行此查询时它工作正常。但是，当我尝试从应用程序执行它时，它不起作用。

这就是方法的样子

public static void storeValuesToDb(ArrayList<String> kpiNames) throws SQLException {

    Connection conn = getOracleJDBCConnection_DASH();

    int currentYear = cal.get(Calendar.YEAR);
    int startYear = cal.get(Calendar.YEAR) - 1;
    for (String kpiName : kpiNames) {
        for (int i = startYear; i <= currentYear; i++) {
            for (int j = 0; j < 12; j++) {

                try {
                    String myMergeSQL = ""
                            + "MERGE INTO T_BPR_KPI_MONTHLY_VALUE A "
                            + "USING( SELECT '" + kpiName + "' AS KPI_NAME_SHORT_S, " + (j + 1) + " AS MONTH_N, " + i + " AS YEAR_N FROM DUAL ) B ON ( A.KPI_NAME_SHORT_S = B.KPI_NAME_SHORT_S ) "
                            + "WHEN MATCHED THEN "
                            + "UPDATE SET VALUE_N = ( select AVG(" + kpiName + ") from T_BPR_KPI_DY where DAY_D between '" + getFirstDateOfMonth(j, i) + "' AND '" + getLastDateOfMonth(j, i) + "') "
                            + "WHEN NOT MATCHED THEN "
                            + "INSERT (KPI_NAME_SHORT_S, MONTH_N, YEAR_N, VALUE_N) VALUES ('" + kpiName + "', " + (j + 1) + ", " + i + ", ( select AVG(" + kpiName + ") from T_BPR_KPI_DY where DAY_D between '" + getFirstDateOfMonth(j, i) + "' AND '" + getLastDateOfMonth(j, i) + "') )";

                    System.out.println(myMergeSQL);

                    Statement stmt_dash = conn.createStatement();
                    stmt_dash.executeUpdate(myMergeSQL);
                    conn.commit();
                    stmt_dash.close();
                } catch (SQLException ex) {
                    conn.close();
                }
            }
        }
    }

    conn.close();
}

在终端中它只打印出第一个合并 sql。它既不完成操作也不抛出异常。它以某种方式阻塞，并且在数据库中也没有发生任何事情。我的合并查询可能不正确，或者无法使用语句对象执行这种操作。如果有人能够看到这个问题是什么情况，请帮助。

提前谢谢

4

1 回答 1

1

我将首先重新制定您的合并查询并解决一些问题：

  1. MERGE 的使用部分实际上意味着您的“原始数据来源”。您正在使用带有硬编码值的双重选择。在这里，您应该选择所有 KPI，并按 KPI 计算平均值。编写查询，选择所有 KPI 及其对应的 VALUE_N 并在 USING 部分中使用它
  2. 匹配时，UPDATE SET 使用代码中别名 B 的“原始数据源”中的值，而不是在 UPDATE 子句内计算。
  3. 当不匹配时插入值 - 再次，使用来自“原始数据源”的值，即代码中的别名 B，不要尝试在插入中计算 VALUE_N - 至少不是以这种方式，我认为这是你的查询主要问题。
  4. MERGE INTO xxx A using () B 您为表提供了 2 个别名，但在 WHEN MATCHED 或 NOT 内的行中，您没有使用别名。如果 A 和 B 具有相似的命名列，这可能会引发问题。

我如何在生产中使用合并的一个示例：合并到目标，使用从表源中选择（在从源中选择中，您显然还可以添加其他计算，在您的情况下是平均值）

T_REPORT_DAILY_SNAPSHOT_2G 应该在您的代码中选择 kpi 名称、值和平均值或您在 INSERT 和 UPDATE 上需要的任何内容

MERGE INTO T_CELLS_2G dest 
 USING (SELECT DISTINCT *
        FROM T_REPORT_DAILY_SNAPSHOT_2G) src
 ON (dest.lac = src.lac and dest.cell_id = src.cell_id)
 WHEN MATCHED THEN
 UPDATE SET 
      dest.cell_name = src.cell_name, 
      dest.loc_code = src.loc_code,
      dest.site_code = src.site_code,
      dest.rac = src.rac
WHEN NOT MATCHED THEN
     INSERT (dest.cell_name, 
      dest.loc_code,
      dest.site_code,
      dest.lac,
      dest.cell_id,
      dest.rac) 
     VALUES (src.cell_name, 
      src.loc_code,
      src.site_code,
      src.lac,
      src.cell_id,
      src.rac);

希望这在某种程度上有所帮助。

于 2015-06-18T08:24:15.770 回答