Java.sql連接關閉特定服務器上的異常

Question

我得到Java.sql.Connection關閉每當我在我的生產服務器上上載我的應用程序時出現異常。生產服務器是Jboss。 我也嘗試過在QA，DEV服務器上不發生此問題。 我們是一個Web應用程序，每當我們遍歷特定的選項卡時，都會發生此異常。

這是跟蹤：

2011-11-11 14：32：12983 ERROR [STDERR] java.sql.SQLException中：關閉連接 2011-11-11 14：32：12984 ERROR [ STDERR] at oracle.jdbc.driver.DatabaseError.throwSqlException（DatabaseError.java:112） 2011-11-11 14：32：12,984 ERROR [STDERR] at oracle.jdbc.driver.DatabaseError.throwSqlException（DatabaseError.java:146 ） 2011-11-11 14：32：12,984 ERROR [STDERR] at oracle.jdbc.driver.DatabaseError.throwSqlException（DatabaseError.java:208） 2011-11-11 14：32：12,984錯誤[STDERR] at oracle .jdbc.driver.PhysicalConnection.prepareStatement（PhysicalConnection.java ：897） 2011-11-11 14：32：12,984 ERROR [STDERR] at oracle.jdbc.driver.PhysicalConnection.prepareStatement（PhysicalConnection.java:816） 2011-11-11 14：32：12,984錯誤[STDERR] at com.amadeus.mis.usermanagement.MisDb.prepareStatement（MisDb.java:72） 2011-11-11 14：32：12,984錯誤[STDERR] at com.amadeus.mis.usermanagement.MisDb.getCompId（MisDb.java ：1002） 2011-11-11 14：32：12,984錯誤[STDERR] at com.amadeus.mis.usermanagement.MisDb.loadUnLinkedUsers（MisDb.java:1033） 2011-11-11 14：32：12,984錯誤[ STDERR] at org.apache.jsp.LinkUser_jsp._jspService（LinkUser_jsp.java:445） 2011-11-11 14：32：12,985 ERROR [STDERR] at org.apache.jasper.runtime.HttpJspBase.service（HttpJspBase.java ：70） 2011-11-11 14：32：12,985錯誤[STDERR]在javax.servlet.http.HttpServlet.service（HttpServlet.java:7 17） 2011-11-11 14：32：12,985 ERROR [STDERR] at org.apache.jasper.servlet.JspServletWrapper.service（JspServletWrapper.java:387） 2011-11-11 14：32：12,985錯誤[STDERR ]在org.apache.jasper.servlet.JspServlet.serviceJspFile（JspServlet.java:320） 2011-11-11 14：32：12,985錯誤[STDERR]在org.apache.jasper.servlet.JspServlet.service（JspServlet。的java：266） 2011-11-11 14：32：12985 ERROR [STDERR]在javax.servlet.http.HttpServlet.service（HttpServlet.java:717）

我還附加一個代碼示例，這是發生錯誤的代碼。

public List<String>loadLinkedUsers(String uname) 
    throws Exception 
    { 

     List<String> userList = new ArrayList<String>(); 

     String[]temp=uname.split("_"); 
     String myschema=temp[0]+"_"+temp[1]; 
     if(!getUserType(uname).equalsIgnoreCase("RC")) 
     { 
     PreparedStatement stmt = null; 

     stmt = prepareStatement("select res_user_id from"+" "+myschema+".res_user where login_id = ? and res_user_id !='Administrator'"); 
     stmt.setString(1,uname); 

     try { 

      ResultSet rs = stmt.executeQuery(); 
      while(rs.next()) 
      { 

       userList.add(rs.getString(1)); 

      } 
      rs.close(); 
     } catch (Exception e) { 
      System.out.println("Exception"+e.getMessage()); 
     } 
     stmt.close(); 
     } 
     return userList; 

    } 

    public int getCompId(String userName) 
    { 
     PreparedStatement stmt; 
     int temp=0; 
     try{ 
     stmt = prepareStatement("Select comp_id from mis.users where login_id = ?"); 
     stmt.setString(1,userName); 
     ResultSet rs=stmt.executeQuery(); 
     while(rs.next()) 
     { 
      temp=rs.getInt(1); 
     } 

     } 
     catch(Exception e) 
     { 
      e.printStackTrace(); 
     } 

     return temp; 
    } 
    /** 
    * Load the information about users that are not Linked to 
    * the user who is logged in. 
    * (login_id, user_email, user_type_id from table mis.users) 
    * @param login 
    * @param users Vector that is filled with user information of type User. 
    *    The previous data is not cleared. 
    * @throws SQLException 
    */ 
    public List<String> loadUnLinkedUsers(String uname) 
    throws Exception 
    { 

     List<String>userList = new ArrayList<String>(); 

     String[]temp=uname.split("_"); 
     String myschema=temp[0]+"_"+temp[1]; 
     int comp_id=getCompId(uname); 

     if(!getUserType(uname).equalsIgnoreCase("RC")) 
     { 
     PreparedStatement stmt1=null; 
     String query1="select res_user_id from"+" "+myschema+".res_user where login_id=? and res_user_id='Administrator'"; 
     stmt1 = prepareStatement(query1); 
     stmt1.setString(1,uname); 
     try { 

      ResultSet rs1 = stmt1.executeQuery(); 
      /*if(!rs1.next()) 
      { 
       userList.add("Administrator"); 
      }*/ 

     } catch (Exception e) { 
      System.out.println("Exception"+e.getMessage()); 
     } 

     PreparedStatement stmt = null; 
     String query="SELECT u.login_id FROM mis.users u LEFT JOIN mis.user_type t ON u.user_type_id = t.user_type_id WHERE comp_id = ? minus select res_user_id from"+" "+myschema+".res_user where login_id =?"; 
     stmt = prepareStatement(query); 
     stmt.setInt(1,comp_id); 
     stmt.setString(2,uname); 

     try { 

      ResultSet rs = stmt.executeQuery(); 
      while(rs.next()) 
      { 
       userList.add(rs.getString(1)); 

      } 
      rs.close(); 
     } catch (Exception e) { 
      System.out.println("Exception"+e.getMessage()); 
     } 
     stmt.close(); 
     } 
     return userList; 

    } 

請注意，這是用於創建Prepared Statements的函數。

protected Connection m_Connection; 

    /** 
    * Prepare a statement from the current connection 
    * @param strSql 
    * @return Prepared statement 
    * @throws SQLException 
    */ 
    protected PreparedStatement prepareStatement(String strSql) throws SQLException 
    { 
     logger.debug("SQL= " + strSql); 
     return m_Connection.prepareStatement(strSql); 
    } 

Answer 1

我終於通過替換classes12.jar並使用初始上下文替代驅動程序管理器來解決了該問題。

Answer 2

看起來數據庫在一段時間後關閉了你的連接。確保在數據源配置文件中使用有效的檢查SQL來啓用check-valid-connection-sql屬性（例如，從雙選中選擇1），以便在重新調用給您之前自動驗證連接。另外，還要確保你沒有持有到一個類變量的連接對象，並跨多個請求

<check-valid-connection-sql>some arbitrary sql</check-valid-connection-sql> 

Answer 3

目前尚不清楚哪裏是什麼的m_Connection範圍，無論是重用，如何往往被重用重用它或者多個線程是否可以同時訪問同一個連接，這可能會導致問題。

如果m_Connection保持打開狀態並意圖由個別請求重複使用，可能發生的情況是數據庫驅動程序可能會在一段時間不活動後自動關閉它。

我的問題是，你會考慮使用JNDI DataSource來查找你的連接，而不是緩存連接m_Connection？

Context ctx = new InitialContext(); 
DataSource ds = (DataSource)ctx.lookup("java:comp/env/jdbc/TestDB"); 
Connection conn = ds.getConnection(); 

try { 
    ... DB logic ... 
} finally { 
    conn.close(); 
} 

這樣創建和管理連接的業務委託給將池中的連接應用服務器，這樣你就不會真正打開和關閉一個新的連接每次你打電話。

與代碼其他可能的問題包括：

• 不關閉所有ResultSet小號
• 不關閉PreparedStatement S IN一個最後塊（或以getCompId情況下不關閉它在所有）