Apache DBCP 和 Oracle 透明应用程序连续性

Question

当我们的 Oracle RAC 的一个节点出现故障时，我们有一个较旧的应用程序无法进行故障转移。它似乎使用了旧版本的 org.apache.commons.dbcp.BasicDataSource。当我使用 Oracle 的 UCP 时，我可以完成这项工作，但是当我使用 apache 版本时，只要我关闭它所连接的 RAC 的节点，应用程序就会死掉。我是否遗漏了什么或者它不适用于 Apache DBCP？谢谢

这是我的代码。

import org.apache.commons.dbcp.BasicDataSource;

import java.io.PrintStream;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;


public class BasicDB{



    final static String DB_URL ="jdbc:oracle:thin:user/password@pdb_tac";
    final static String driverClassName = "oracle.jdbc.replay.OracleDataSourceImpl";

    private void pressAnyKeyToContinue()
    {
        System.out.print("Press any key to continue...");
        try { System.in.read(); }
        catch(Exception e) { e.printStackTrace(); }
    }
    public String getInstanceName(Connection conn) throws SQLException {
        PreparedStatement pstmt = conn.prepareStatement("select instance_name from v$instance");
        String r = new String();

        for(ResultSet result = pstmt.executeQuery(); result.next(); r = result.getString("instance_name")) {
        }

        pstmt.close();
        return r;
    }



    private void doTx(Connection c, int numValue) throws SQLException {
        String updsql = "UPDATE test SET v=UPPER(v) WHERE id=?";
        PreparedStatement pstmt = null;
        pstmt = c.prepareStatement(updsql);
        c.setAutoCommit(false);

        for(int i = 0; i < numValue; ++i) {
            pstmt.setInt(1, i);
            pstmt.executeUpdate();
        }

        c.commit();
        pstmt.close();
    }

    public static void main(String[] args) throws SQLException {
        Connection conn = null;
        int numValue = 5000;
;

        try {

            BasicDataSource bods = new BasicDataSource();
            bods.setUrl(DB_URL);
            bods.setDriverClassName(driverClassName);
            bods.setDefaultAutoCommit(false);
            BasicDB self = new BasicDB();
            conn = bods.getConnection();
            String var10001 = self.getInstanceName(conn);
            var10000.println("Instance Name = " + var10001);
            System.out.println("Performing transactions");
            self.pressAnyKeyToContinue();
            self.doTx(conn, numValue);
            var10001 = self.getInstanceName(conn);
            var10000.println("Instance Name = " + var10001);

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

    }
}

Answer 1

好的，所以它与使用 DataSource 而不是 DataDriver 类有关。我遇到了另一个错误，因此将为此创建一个新问题。