Oracle DB - 应用程序连续性 - 如何测试它

Question

如何测试/POC应用程序连续性概念。我尝试编写代码来保存连接，以便应用程序无法获取连接并尝试从池中获取。我确信这不是测试应用程序连续性的正确方法，但我不知道如何创建适当的方案。

这是在交易进行时降低数据库的唯一方法吗？

我使用以下代码来模拟 AC，其中每次使用新连接在 20 个线程中调用 20 次过程。我正在创建一个场景，其中一个线程去等待连接，超时为没有及时获得连接，然后退休以获得连接，这是一个正确的 AC 测试。(以下是测试类(

package com.ac;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import oracle.ucp.jdbc.PoolDataSourceFactory;
import oracle.ucp.jdbc.PoolDataSource;
import oracle.ucp.jdbc.ValidConnection;
import java.sql.ResultSet;
public class App {
    public static void main(String[] args) {
        try {
            new App().acSimulation();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public void acSimulation() throws Exception{
            final PoolDataSource  pds = PoolDataSourceFactory.getPoolDataSource();
            pds.setConnectionFactoryClassName("oracle.jdbc.replay.OracleDataSourceImpl");
            System.out.println("connection factory set");
            String URL = "jdbc:oracle:thin:@(DESCRIPTION = (TRANSPORT_CONNECT_TIMEOUT=3) (RETRY_COUNT=20)(FAILOVER=ON) " +
             " (ADDRESS = (PROTOCOL = TCP)(HOST = localhost)(PORT = 1521)) (CONNECT_DATA = " +
             " (SERVER = DEDICATED) (SERVICE_NAME=orcl)))";
            System.out.println("Using URLn" + URL);
            pds.setURL(URL);
            pds.setUser("system");
            pds.setPassword("oracle");
            pds.setInitialPoolSize(1);
            pds.setMinPoolSize(1);
            pds.setMaxPoolSize(3);
            pds.setConnectionWaitTimeout(10);
            // RAC Features
            pds.setConnectionPoolName("Application Continuity Pool");
            pds.setFastConnectionFailoverEnabled(true);
            // use srvctl config nodeapps to get the ONS ports on the cluster
//          pds.setONSConfiguration("nodes=192.168.100.30:6200,192.168.100.32:6200");
            System.out.println("pool configured, trying to get a connection");
//          final Connection conn = null;

            final Connection conn = pds.getConnection();
            if (conn == null || !((ValidConnection) conn).isValid())  {
              System.out.println("connection is not valid");
              throw new Exception ("invalid connection obtained from the pool");
            }
            if ( conn instanceof oracle.jdbc.replay.ReplayableConnection ) {
              System.out.println("got a replay data source");
            } else {
              System.out.println("this is not a replay data source. Why not?");
            }
            System.out.println("got a connection! Getting some stats if possible");
            oracle.ucp.jdbc.JDBCConnectionPoolStatistics stats = pds.getStatistics();
            System.out.println("tgetAvailableConnectionsCount() " + stats.getAvailableConnectionsCount());
            System.out.println("tgetBorrowedConnectionsCount() " + stats.getBorrowedConnectionsCount() );
            System.out.println("tgetRemainingPoolCapacityCount() " + stats.getRemainingPoolCapacityCount());
            System.out.println("tgetTotalConnectionsCount() " + stats.getTotalConnectionsCount());
            System.out.println(((oracle.ucp.jdbc.oracle.OracleJDBCConnectionPoolStatistics)pds.getStatistics()).getFCFProcessingInfo());
            System.out.println("Now working");
            int i=0;
            while(i < 20){
                new Runnable() {
                    public void run() {                     
                        try {
                            seperateInstance(conn, pds);
                        } catch (SQLException e) {
                            e.printStackTrace();
                        }
                    }
                }.run();
                i++;
            }
    }
    private void seperateInstance(Connection conn, PoolDataSource pds) throws SQLException{
        java.sql.CallableStatement cstmt = null;
        oracle.ucp.jdbc.JDBCConnectionPoolStatistics stats = pds.getStatistics();
            conn = pds.getConnection();
            cstmt = conn.prepareCall("{call P_M_emp(?,?)}");
            cstmt.setLong(1, 1);
            cstmt.setString(2, "TEST");
            cstmt.execute();
            System.out.println("Statement executed. Now closing down");
            System.out.println("Almost done! Getting some more stats if possible");
            stats = pds.getStatistics();
            System.out.println("tgetAvailableConnectionsCount() " + stats.getAvailableConnectionsCount());
            System.out.println("tgetBorrowedConnectionsCount() " + stats.getBorrowedConnectionsCount() );
            System.out.println("tgetRemainingPoolCapacityCount() " + stats.getRemainingPoolCapacityCount());
            System.out.println("tgetTotalConnectionsCount() " + stats.getTotalConnectionsCount());
            System.out.println(((oracle.ucp.jdbc.oracle.OracleJDBCConnectionPoolStatistics)pds.getStatistics()).getFCFProcessingInfo());
            try {
                Thread.currentThread().sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Closing connection "+ conn);
            cstmt.close();
            conn.close();
            conn = null;
    }
}

我从下面的站点获取代码并进行了一些修改以添加线程和模拟 AC。但是我无法获得可重放的数据源。

https://martincarstenbach.wordpress.com/2013/12/13/playing-with-application-continuity-in-rac-12c/

Answer 1

要测试应用程序连续性，您可以通过执行模拟故障ALTER SYSTEM KILL SESSION 'sid,serial#'来终止服务器上的会话。