选择后插入（Java sql）

Question

挣扎于一些执行存储过程调用的java / sql代码，然后是select，然后是insert into -

对存储过程的调用起作用并创建了“持续时间”表——

while(true) {

  boolean var1 = false;
  Connection var2 = DBConnPool.getInstance().getConnection();
  Statement var3 = null;
  ResultSet var4 = null;

try {
     var3 = var2.createStatement();
     String var5;
     var5 = "CALL totalduration('%', NOW() - INTERVAL 20 MINUTE, NOW());";
     var3.executeQuery(var5);

然后select语句运行并正确输出多行——

var5 = "SELECT duration.name, zone, duration, asset.id as assetid, node.id as nodeid\n" +
        "FROM duration\n" +
        "inner join asset\n" +
        "on asset.name = duration.name\n" +
        "inner join node\n" +
        "on node.zonename = duration.zone\n" +
        "where Duration > '00:10:00'\n" +
        "and Zone = 'Reception'\n" +
        "group by duration.name DESC";
        var4 = var3.executeQuery(var5);

然后我想从生成的 ResultSet 中插入表数据，如果我使用以下内容，那么它只插入 1 行

 If (var4.next()) 
             {
                int var6 = var4.getInt("assetid");
                int var7 = var4.getInt("nodeid");
                String var8;
                var8 = "insert into alerts (ts, assetid, alerttypeid, nodeid, ack) values (now(), " + var6 + ", " + 11 + ", " + var7 + ", 0)";
                var3.executeUpdate(var8);
         }

因此，我假设以下内容会将插入应用到所有 ResultSet 行 –

while(var4.next()) 
         {
            int var6 = var4.getInt("assetid");
            int var7 = var4.getInt("nodeid");
            String var8;
var8 = "insert into alerts (ts, assetid, alerttypeid, nodeid, ack) values (now(), " + var6 + ", " + 11 + ", " + var7 + ", 0)";
            var3.executeUpdate(var8);
         }

但是错误'Operation not allowed after ResultSet closed'暗示var4被关闭了？

我显然在做一些愚蠢的事情，也许插入应该在选择之前，所以希望得到一些关于解决这个问题的“正确方法”的指导。

问候 活跃

Answer 1

JavaDoc from ResultSet :

当生成它的 Statement 对象关闭、重新执行或用于从多个结果序列中检索下一个结果时，ResultSet 对象会自动关闭。

您正在使用Statement var3 在循环中执行更新查询。由于这与用于恢复ResultSet var4 的Statement 相同，因此该实例将在下一个execute# 关闭。这就是为什么您能够读取第一行，执行更新，然后出现错误。

您需要使用不同的Statement 实例来保持ResultSet 处于打开状态。实际上，ResultSet 绑定到 Statement。

注意：

1. var# 不是变量的好名称，stmt、rs、...是一些更合适的名称，并且无需搜索声明即可轻松理解每个实例的含义。

2. 请注意，您还应该关闭 Statement, ResultSet, ... 当您完成它们时（即使出现异常）。在这里，我将在下面的示例中添加一个try-with-resource

3. 使用 PreparedStament 而不是连接 String，这将更具可读性，并且在 String 值的情况下，这将更安全（针对 SQL 注入）

示例（对注释进行了一些改进）：

try (PreparedStatement ps = conn.prepareStatement("insert into a(b, c) values (?, ?)") ) {
    while(var4.next()) {
        ps.setInt(1, rs.getInt("b"));
        ps.setInt(2, rs.getInt("c"));
        ps.executeUpdate();
    }
} catch( SQLException e){
    ...
}