java - Oracle Select for update 不起作用，有时会在一段时间后挂起

Question

我正在使用 Java 执行 Oracle Select for Update，它有时会工作，有时它会随着 session 挂起并且无法删除锁定的 session (必须手动终止 session )这在大多数情况下都可以正常工作，但是当我将它部署在两个服务器(Web 服务)中并同时请求它们时，我无法理解这是否是我的代码有问题，我的代码

 public boolean checkJobStatus(long taskId)
{
    Connection con = null;
    PreparedStatement selectForUpdate = null;
    String lastJobStatus = null;
    boolean runNow = false;
    try
    {
        con = conPool.getConnection();
        con.setAutoCommit(false);
        selectForUpdate  = con.prepareStatement("SELECT LAST_JOB_STATUS FROM ADM_JOB WHERE TASK_ID = ? FOR UPDATE ");
        selectForUpdate.setLong(1, taskId);
        ResultSet resultSet = selectForUpdate.executeQuery();

        while(resultSet.next())
        {
            if (resultSet.getObject("LAST_JOB_STATUS") == null)
            {
                lastJobStatus = ScheduledJob.STATUS_FAILED;
            }
            else
            {
                lastJobStatus = resultSet.getString("LAST_JOB_STATUS");
            }
        }

     if(ScheduledJob.STATUS_RUNNING.equalsIgnoreCase(lastJobStatus) || ScheduledJob.STATUS_STARTED.equalsIgnoreCase(lastJobStatus))
     {
         runNow = false;
         // commit n update setting autocommit to true
         selectForUpdate = con.prepareStatement("UPDATE ADM_JOB SET LAST_JOB_STATUS =? WHERE TASK_ID = ?");
         selectForUpdate.setString(1, lastJobStatus);
         selectForUpdate.setLong(2, taskId);
         selectForUpdate.executeUpdate();
     }
     else
     {
         runNow =true;
         // commit n update setting autocommit to true
         selectForUpdate  = con.prepareStatement("UPDATE ADM_JOB SET LAST_JOB_STATUS =? WHERE TASK_ID = ?");
         selectForUpdate.setString(1, ScheduledJob.STATUS_STARTED);
         selectForUpdate.setLong(2, taskId);
         selectForUpdate.executeUpdate();

         con.commit();
         con.setAutoCommit(true);
     }

    } catch (SQLException e)
    {
        Logger.getLogger( "" ).log(Level.SEVERE, "Error in getting database connection", e);
        try
        {
            con.rollback();   // rolling back the row lock in case of a exception
        } catch (SQLException e1)
        {
            e1.printStackTrace();
        }
    }
    finally
    {
        DBUtility.close( selectForUpdate  );
        DBUtility.close( con );
    }


    return runNow;
}

Answer 1

提交仅发生在 else 分支中。如果这种情况没有发生，事务就不会关闭，所以第二个线程在选择更新时永远挂起。