/*
Derby - Class org.apache.derbyTesting.functionTests.tests.jdbcapi.checkDataSource30
Copyright 2002, 2005 The Apache Software Foundation or its licensors, as applicable.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
package org.apache.derbyTesting.functionTests.tests.jdbcapi;
import org.apache.derby.jdbc.EmbeddedDataSource;
import org.apache.derby.jdbc.EmbeddedConnectionPoolDataSource;
import org.apache.derby.jdbc.EmbeddedXADataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.CallableStatement;
import java.sql.Statement;
import java.sql.SQLException;
import java.sql.DriverManager;
import java.sql.Savepoint;
import java.sql.ParameterMetaData;
import javax.sql.DataSource;
import javax.sql.XADataSource;
import javax.sql.XAConnection;
import javax.sql.ConnectionPoolDataSource;
import javax.transaction.xa.XAResource;
import javax.transaction.xa.XAException;
import javax.transaction.xa.Xid;
import javax.sql.ConnectionEventListener;
import javax.sql.ConnectionEvent;
import org.apache.derby.tools.JDBCDisplayUtil;
import org.apache.derby.tools.ij;
import java.io.*;
import java.util.Hashtable;
import javax.naming.*;
import javax.naming.directory.*;
public class checkDataSource30 extends checkDataSource
{
public static void main(String[] args) throws Exception {
checkDataSource30 tester = new checkDataSource30();
tester.runTest(args);
tester.checkXAHoldability();
System.out.println("Completed checkDataSource30");
}
public checkDataSource30() throws Exception {
}
public void checkConnection(String dsName, Connection conn) throws SQLException {
System.out.println("Running JDBC 3.0 connection checks on " + dsName);
System.out.println(" holdability " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
// check it's a 3.0 connection object
try {
conn.releaseSavepoint(conn.setSavepoint());
System.out.println("JDBC 3.0 savepoint OK");
} catch (SQLException sqle) {
// we expect savepoints exceptions because either
// it's a global transaction, or it's in auto commit mode.
System.out.println("JDBC 3.0 savepoint " + sqle.toString());
}
super.checkConnection(dsName, conn);
}
protected void checkConnectionPreClose(String dsName, Connection conn) throws SQLException {
conn.setHoldability(ResultSet.CLOSE_CURSORS_AT_COMMIT);
super.checkConnectionPreClose(dsName, conn);
}
protected void setHoldability(Connection conn, boolean hold) throws SQLException {
conn.setHoldability(hold ? ResultSet.HOLD_CURSORS_OVER_COMMIT : ResultSet.CLOSE_CURSORS_AT_COMMIT);
}
protected void getHoldability(Connection conn) throws SQLException {
System.out.println(" holdability " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
}
protected Statement internalCreateFloatStatementForStateChecking(Connection conn) throws SQLException {
return conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
}
protected PreparedStatement internalCreateFloatStatementForStateChecking(Connection conn, String sql) throws SQLException {
return conn.prepareStatement(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
}
protected CallableStatement internalCreateFloatCallForStateChecking(Connection conn, String sql) throws SQLException {
return conn.prepareCall(sql, ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
}
protected void showStatementState(String when, Statement s) throws SQLException {
super.showStatementState(when, s);
System.out.println(" getResultSetHoldability() " + rsHoldability(s.getResultSetHoldability()));
if (s instanceof PreparedStatement) {
PreparedStatement ps = (PreparedStatement) s;
ParameterMetaData psmd = ps.getParameterMetaData();
System.out.println(" Parameter Count " + psmd.getParameterCount());
for (int i = 1; i <= psmd.getParameterCount(); i++) {
System.out.println(" " + i + " type " + psmd.getParameterType(i));
}
}
}
protected void showXAException(String tag, XAException xae) {
super.showXAException(tag, xae);
Throwable t = xae.getCause();
if (t instanceof SQLException)
JDBCDisplayUtil.ShowSQLException(System.out, (SQLException) t);
}
static String rsHoldability(int type) {
switch (type) {
case ResultSet.HOLD_CURSORS_OVER_COMMIT :
return "HOLD_CURSORS_OVER_COMMIT ";
case ResultSet.CLOSE_CURSORS_AT_COMMIT :
return "CLOSE_CURSORS_AT_COMMIT ";
default:
return "?? HOLDABILITY UNKNOWN ??";
}
}
private void checkXAHoldability() {
System.out.println("START XA HOLDABILITY TEST");
try {
EmbeddedXADataSource dscsx = new EmbeddedXADataSource();
dscsx.setDatabaseName("wombat");
XAConnection xac = dscsx.getXAConnection("fred", "wilma");
XAResource xr = xac.getXAResource();
Xid xid = getXid(25, (byte) 21, (byte) 01);
Connection conn1 = xac.getConnection();
System.out.println("By default, autocommit is " + conn1.getAutoCommit() + " for a connection");
System.out.println("Default holdability for a connection is HOLD_CURSORS_OVER_COMMIT");
System.out.println("CONNECTION(not in xa transaction yet) HOLDABILITY " + (conn1.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
//start a global transaction and default holdability and autocommit will be switched to match Derby XA restrictions
xr.start(xid, XAResource.TMNOFLAGS);
System.out.println("Notice that autocommit now is " + conn1.getAutoCommit() + " for connection because it is part of the global transaction");
System.out.println("Notice that connection's holdability at this point is CLOSE_CURSORS_AT_COMMIT because it is part of the global transaction");
System.out.println("CONNECTION(in xa transaction) HOLDABILITY " + (conn1.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
xr.end(xid, XAResource.TMSUCCESS);
conn1.commit();
conn1.close();
xid = getXid(27, (byte) 21, (byte) 01);
xr.start(xid, XAResource.TMNOFLAGS);
conn1 = xac.getConnection();
System.out.println("CONNECTION(in xa transaction) HOLDABILITY " + (conn1.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("Autocommit on Connection inside global transaction has been set correctly to " + conn1.getAutoCommit());
xr.end(xid, XAResource.TMSUCCESS);
conn1.rollback();
Connection conn = xac.getConnection();
conn.setAutoCommit(false);
conn.setHoldability(ResultSet.CLOSE_CURSORS_AT_COMMIT);
System.out.println("CONNECTION(non-xa) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
Statement s = conn.createStatement();
System.out.println("STATEMENT HOLDABILITY " + (s.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
s.executeUpdate("create table hold_30 (id int not null primary key, b char(30))");
s.executeUpdate("insert into hold_30 values (1,'init2'), (2, 'init3'), (3,'init3')");
s.executeUpdate("insert into hold_30 values (4,'init4'), (5, 'init5'), (6,'init6')");
s.executeUpdate("insert into hold_30 values (7,'init7'), (8, 'init8'), (9,'init9')");
System.out.println("STATEMENT HOLDABILITY " + (s.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
Statement sh = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
PreparedStatement psh = conn.prepareStatement("select id from hold_30 for update",
ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
CallableStatement csh = conn.prepareCall("select id from hold_30 for update",
ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("STATEMENT HOLDABILITY " + (sh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("PREPARED STATEMENT HOLDABILITY " + (psh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("CALLABLE STATEMENT HOLDABILITY " + (csh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
ResultSet rsh = sh.executeQuery("select id from hold_30 for update");
rsh.next(); System.out.println("H@1 id " + rsh.getInt(1));
rsh.next(); System.out.println("H@2 id " + rsh.getInt(1));
conn.commit();
rsh.next(); System.out.println("H@3 id " + rsh.getInt(1));
conn.commit();
xid = getXid(23, (byte) 21, (byte) 01);
xr.start(xid, XAResource.TMNOFLAGS);
Statement stmtInsideGlobalTransaction = conn.createStatement();
PreparedStatement prepstmtInsideGlobalTransaction = conn.prepareStatement("select id from hold_30");
CallableStatement callablestmtInsideGlobalTransaction = conn.prepareCall("select id from hold_30");
System.out.println("CONNECTION(xa) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with holdability false, outside the global transaction. Check it's holdability inside global transaction) HOLDABILITY " + (s.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with holdability true, outside the global transaction. Check it's holdability inside global transaction) HOLDABILITY " + (sh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with default holdability inside this global transaction. Check it's holdability) HOLDABILITY " + (stmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("PREPAREDSTATEMENT(this one was created with default holdability inside this global transaction. Check it's holdability) HOLDABILITY " + (prepstmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("CALLABLESTATEMENT(this one was created with default holdability inside this global transaction. Check it's holdability) HOLDABILITY " + (callablestmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
ResultSet rsx = s.executeQuery("select id from hold_30 for update");
rsx.next(); System.out.println("X@1 id " + rsx.getInt(1));
rsx.next(); System.out.println("X@2 id " + rsx.getInt(1));
xr.end(xid, XAResource.TMSUCCESS);
// result set should not be useable, since it is part of a detached
// XAConnection
try {
rsx.next(); System.out.println("FAIL - rsx's connection not active id " + rsx.getInt(1));
} catch (SQLException sqle) {
System.out.println("Expected SQLException " + sqle.getMessage());
}
// result set should not be useable, it should have been closed by the xa start.
try {
rsh.next(); System.out.println("FAIL - rsh's should be closed " + rsx.getInt(1));
} catch (SQLException sqle) {
System.out.println("Expected SQLException " + sqle.getMessage());
}
System.out.println("resume XA transaction and keep using rs");
xr.start(xid, XAResource.TMJOIN);
Statement stmtAfterGlobalTransactionResume = conn.createStatement();
PreparedStatement prepstmtAfterGlobalTransactionResume = conn.prepareStatement("select id from hold_30");
CallableStatement callablestmtAfterGlobalTransactionResume = conn.prepareCall("select id from hold_30");
System.out.println("Check holdability of various jdbc objects after resuming XA transaction");
System.out.println("CONNECTION(xa) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with holdability false, outside the global transaction. Check it's holdability inside global transaction) HOLDABILITY " + (s.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with holdability true, outside the global transaction. Check it's holdability inside global transaction) HOLDABILITY " + (sh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with default holdability inside the global transaction when it was first started. Check it's holdability) HOLDABILITY " + (stmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("PREPAREDSTATEMENT(this one was created with default holdability inside the global transaction when it was first started. Check it's holdability) HOLDABILITY " + (prepstmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("CALLABLESTATEMENT(this one was created with default holdability inside the global transaction when it was first started. Check it's holdability) HOLDABILITY " + (callablestmtInsideGlobalTransaction.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("STATEMENT(this one was created with default holdability after the global transaction was resumed. Check it's holdability) HOLDABILITY " + (stmtAfterGlobalTransactionResume.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("PREPAREDSTATEMENT(this one was created with default holdability after the global transaction was resumed. Check it's holdability) HOLDABILITY " + (prepstmtAfterGlobalTransactionResume.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
System.out.println("CALLABLESTATEMENT(this one was created with default holdability after the global transaction was resumed. Check it's holdability) HOLDABILITY " + (callablestmtAfterGlobalTransactionResume.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
rsx.next(); System.out.println("X@3 id " + rsx.getInt(1));
xr.end(xid, XAResource.TMSUCCESS);
if (xr.prepare(xid) != XAResource.XA_RDONLY)
xr.commit(xid, false);
// try again once the xa transaction has been committed.
try {
rsx.next(); System.out.println("FAIL - rsx's connection not active id (B)" + rsx.getInt(1));
} catch (SQLException sqle) {
System.out.println("Expected SQLException " + sqle.getMessage());
}
try {
rsh.next(); System.out.println("FAIL - rsh's should be closed (B) " + rsx.getInt(1));
} catch (SQLException sqle) {
System.out.println("Expected SQLException " + sqle.getMessage());
}
System.out.println("Set connection to hold ");
conn.setHoldability(ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("CONNECTION(held) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
xid = getXid(24, (byte) 21, (byte) 01);
xr.start(xid, XAResource.TMNOFLAGS);
System.out.println("CONNECTION(xa) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
try {
conn.setHoldability(ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("FAIL allowed to set hold mode in xa transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException(setHoldability) " + sqle.getMessage());
}
// try to create a statement with held attributes
try {
Statement shxa = conn.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("FAIL opened statement with hold cursor attribute in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (Statement hold) " + sqle.getMessage());
}
try {
Statement shxa = conn.prepareStatement("select id from hold_30",
ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("FAIL opened statement with hold cursor attribute in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (PreparedStatement hold) " + sqle.getMessage());
}
try {
Statement shxa = conn.prepareCall("CALL XXX.TTT()",
ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY, ResultSet.HOLD_CURSORS_OVER_COMMIT);
System.out.println("FAIL opened statement with hold cursor attribute in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (CallableStatement hold) " + sqle.getMessage());
}
// check we cannot use a holdable statement set up in local mode.
System.out.println("STATEMENT HOLDABILITY " + (sh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
try {
sh.executeQuery("select id from hold_30");
System.out.println("FAIL used held statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local Statement hold) " + sqle.getMessage());
}
try {
sh.execute("select id from hold_30");
System.out.println("FAIL used held statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local Statement hold) " + sqle.getMessage());
}
System.out.println("PREPARED STATEMENT HOLDABILITY " + (psh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
try {
psh.executeQuery();
System.out.println("FAIL used held prepared statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local PreparedStatement hold) " + sqle.getMessage());
}
try {
psh.execute();
System.out.println("FAIL used held prepared statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local PreparedStatement hold) " + sqle.getMessage());
}
System.out.println("CALLABLE STATEMENT HOLDABILITY " + (csh.getResultSetHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
try {
csh.executeQuery();
System.out.println("FAIL used held callable statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local CallableStatement hold) " + sqle.getMessage());
}
try {
csh.execute();
System.out.println("FAIL used held callable statement in global transaction");
} catch (SQLException sqle) {
System.out.println("Expected SQLException (local CallableStatement hold) " + sqle.getMessage());
}
// but an update works
sh.executeUpdate("insert into hold_30 values(10, 'init10')");
xr.end(xid, XAResource.TMSUCCESS);
System.out.println("CONNECTION(held) HOLDABILITY " + (conn.getHoldability() == ResultSet.HOLD_CURSORS_OVER_COMMIT));
conn.close();
System.out.println("PASS XA HOLDABILITY TEST");
} catch (XAException xae) {
System.out.println("XAException error code " + xae.errorCode);
xae.printStackTrace(System.out);
Throwable t = xae.getCause();
if (t instanceof SQLException)
JDBCDisplayUtil.ShowSQLException(System.out, (SQLException) t);
} catch (SQLException sqle) {
JDBCDisplayUtil.ShowSQLException(System.out, sqle);
} catch (Throwable t) {
t.printStackTrace(System.out);
}
System.out.flush();
}
}