Package org.apache.derby.jdbc

Examples of org.apache.derby.jdbc.ClientDataSource


    void verifySlave()
    throws Exception
    {
        util.DEBUG("BEGIN verifySlave "+slaveServerHost+":"
                +slaveServerPort+"/"+slaveDatabasePath+FS+slaveDbSubPath+FS+replicatedDb);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(slaveDatabasePath + FS + slaveDbSubPath + FS +
                           replicatedDb);
        ds.setServerName(slaveServerHost);
        ds.setPortNumber(slaveServerPort);
        Connection conn = ds.getConnection();
           
        simpleVerify(conn);
        conn.close();
        /*
        runSlaveVerificationCLient(jvmVersion,
View Full Code Here


    void verifyMaster()
    throws Exception
    {
        util.DEBUG("BEGIN verifyMaster " + masterServerHost + ":"
                +masterServerPort+"/"+masterDatabasePath+FS+masterDbSubPath+FS+replicatedDb);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(masterDatabasePath + FS + masterDbSubPath + FS +
                           replicatedDb);
        ds.setServerName(masterServerHost);
        ds.setPortNumber(masterServerPort);
        Connection conn = ds.getConnection();
           
        simpleVerify(conn);
        conn.close();
        /*
        runMasterVerificationCLient(jvmVersion,
View Full Code Here

                     * using DriverManager.getConnection() concurrently
                     * in startMaster and startSlave!
                    Class.forName(DRIVER_CLASS_NAME); // Needed when running from classes!
                    conn = DriverManager.getConnection(URL);
                     */
                    ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
                    ds.setDatabaseName(masterDatabasePath+FS+masterDbSubPath+FS+dbName);
                    ds.setServerName(masterHost);
                    ds.setPortNumber(masterServerPort);
                    ds.setConnectionAttributes("startMaster=true"
                            +";slaveHost="+slaveReplInterface
                            +";slavePort="+slaveReplPort);
                    conn = ds.getConnection();
                   
                    done = true;
                    conn.close();
                    util.DEBUG("startMaster OK");
                }
View Full Code Here

                         * using DriverManager.getConnection() concurrently
                         * in startMaster and startSlave!
                        Class.forName(DRIVER_CLASS_NAME); // Needed when running from classes!
                        conn = DriverManager.getConnection(URL);
                         */
                        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
                        ds.setDatabaseName(fDbPath);
                        ds.setServerName(fSlaveHost);
                        ds.setPortNumber(fSlaveServerPort);
                        ds.setConnectionAttributes(fConnAttrs);
                        conn = ds.getConnection();
                        conn.close();
                    }
                    catch (SQLException se)
                    {
                        startSlaveException = se;
View Full Code Here

     */
    public void testClientDSConnectionAttributes() throws SQLException {
        if (usingEmbedded())
            return;
       
        ClientDataSource ds = new ClientDataSource();

        // DataSource - EMPTY; expect error 08001 in all cases
        // 08001: Required Derby DataSource property databaseName not set.
        dsConnectionRequests(new String[] 
            {"08001","08001","08001","08001",
             "08001","08001","08001","08001","08001"}, ds);

        // DataSource - connectionAttributes=databaseName=<valid name>
        ds.setConnectionAttributes("databaseName=" + dbName);
        dsConnectionRequests(new String[] 
            {"08001","08001","08001","08001",
             "08001","08001","08001","08001","08001"}, ds);
        ds.setConnectionAttributes(null);

        // Test that (invalid) database name specified in connection
        // attributes is not used
        // DataSource - databaseName=<valid db> and
        // connectionAttributes=databaseName=kangaroo
        ds.setConnectionAttributes("databaseName=kangaroo");
        ds.setDatabaseName(dbName);
        dsConnectionRequests(new String[] 
            {"OK","08001","OK","OK",
             "08001","08001","OK","OK","OK"}, ds);
        ds.setConnectionAttributes(null);
        ds.setDatabaseName(null);

    } // End testClientDSConnectionAttributes
View Full Code Here

    void verifySlave()
    throws Exception
    {
        util.DEBUG("BEGIN verifySlave "+slaveServerHost+":"
                +slaveServerPort+"/"+slaveDatabasePath+FS+slaveDbSubPath+FS+replicatedDb);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(slaveDatabasePath + FS + slaveDbSubPath + FS +
                           replicatedDb);
        ds.setServerName(slaveServerHost);
        ds.setPortNumber(slaveServerPort);
        Connection conn = ds.getConnection();
           
        simpleVerify(conn);
        conn.close();
        /*
        runSlaveVerificationCLient(jvmVersion,
View Full Code Here

        String retrieveMessageTextProperty = "retrieveMessageText";
        Connection conn;

        // DataSource
        // DataSource - retrieveMessageTextProperty
        ClientDataSource ds = new ClientDataSource();
        ds.setDatabaseName(dbName);
        ds.setConnectionAttributes(retrieveMessageTextProperty + "=false");
        conn = ds.getConnection();
        assertMessageText(conn,"false");
        conn.close();
        // now try with retrieveMessageText = true
        ds.setConnectionAttributes(retrieveMessageTextProperty + "=true");
        conn = ds.getConnection();
        assertMessageText(conn,"true");
        ds.setConnectionAttributes(null);
        conn.close();
    }
View Full Code Here

    void verifyMaster()
    throws Exception
    {
        util.DEBUG("BEGIN verifyMaster " + masterServerHost + ":"
                +masterServerPort+"/"+masterDatabasePath+FS+masterDbSubPath+FS+replicatedDb);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(masterDatabasePath + FS + masterDbSubPath + FS +
                           replicatedDb);
        ds.setServerName(masterServerHost);
        ds.setPortNumber(masterServerPort);
        Connection conn = ds.getConnection();
           
        simpleVerify(conn);
        conn.close();
        /*
        runMasterVerificationCLient(jvmVersion,
View Full Code Here

            String dbPath)
        throws SQLException
    {
        util.DEBUG("_testInsertUpdateDeleteOnMaster: " + serverHost + ":" +
                   serverPort + "/" + dbPath);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(dbPath);
        ds.setServerName(serverHost);
        ds.setPortNumber(serverPort);
        Connection conn = ds.getConnection();
       
        PreparedStatement ps = conn.prepareStatement("create table t(i integer primary key, s varchar(64))");
       
        ps.execute();
       
View Full Code Here

            int serverPort,
            String dbPath)
        throws SQLException
    {
        util.DEBUG("_verifyDatabase: "+serverHost+":"+serverPort+"/"+dbPath);
        ClientDataSource ds = new org.apache.derby.jdbc.ClientDataSource();
        ds.setDatabaseName(dbPath);
        ds.setServerName(serverHost);
        ds.setPortNumber(serverPort);
        Connection conn = ds.getConnection();
       
        _verify(conn);
       
        conn.close();
    }
View Full Code Here

TOP

Related Classes of org.apache.derby.jdbc.ClientDataSource

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.