來自CachedRowSet的連接

Question

我有以下Java 7代碼來創建CachedRowSet。

CachedRowSet crs = RowSetProvider.newFactory().createCachedRowSet(); 

有沒有辦法從CachedRowSet對象中獲取Connection對象？在調用CachedRowSet上的acceptChanges()之前，我想在連接對象上設置autoCommit爲false，因爲調用acceptChanges()時出現以下異常。

有上CachedRowSet一個COMMIT_ON_ACCEPT_CHANGES領域，但它已過時。

Answer 1

嗯，我花了一些時間來重現這個問題。通過conn.setAutoCommit(false);將Connection的autoCommit值設置爲false可以解決此問題。

下面是示例工作程序：

import java.sql.Connection; 
import java.sql.DriverManager; 
import java.sql.SQLException; 
import javax.sql.rowset.CachedRowSet; 
import javax.sql.rowset.RowSetProvider; 

public class CRSetChecker {  
    public static void main(String[] args) {  
     String connectString = "jdbc:oracle:thin:scott/tiger" + 
       "@(DESCRIPTION=(ADDRESS=(PROTOCOL=tcp)" + 
       "(HOST=myorahost)(PORT=5521))" + 
       "(CONNECT_DATA=(SID=myorasid)))"; 

     //Get DB connection 
     Connection conn = (new CRSet()).getConnection(connectString); 
     if (conn == null) { 
      System.out.println("Connection failed"); 

      System.exit(0); 
     } else { 
      System.out.println("Connection established successfully!"); 

      try { 
       CachedRowSet crs = 
           RowSetProvider.newFactory().createCachedRowSet(); 
       String query="select ename from emp"; 
       crs.setCommand(query); 
       crs.execute(conn); 
       //Set auto commit false 
       conn.setAutoCommit(false); 
       int count = 0; 
       while(crs.next()){ 
        String name = crs.getString(1); 
        count++;       
        System.out.println(name); 
        if(count==1){      
         crs.updateString(1, "COOPER"); 
         crs.updateRow(); 
         crs.acceptChanges(conn); 
         System.out.println("After update:"+crs.getString(1)); 
        } 
       } 
       conn.close(); 
      } catch (SQLException e1) { 
       e1.printStackTrace(); 
      } 
     } 
    } 

    public Connection getConnection(String connectString) 
     { 
     Connection con = null; 
     try { 
      try { 
      Class.forName("oracle.jdbc.OracleDriver"); 
      } catch (ClassNotFoundException e) { 
      e.printStackTrace(); 
      } 

      con = DriverManager.getConnection(connectString); 
     } catch (SQLException ex) { 
      ex.printStackTrace(); 
     } 

     return con; 
     } 
}