Skip to content

P
Postgres FD Implementation
Commit b562c62b authored by Peter Mount's avatar Peter Mount
Browse files
Options

Tue Mar 06 12:05:00 GMT 2001 peter@retep.org.uk 

        - Removed org.postgresql.xa.Test from the JDBC EE driver as it's an old
          test class and prevented it from compiling.
parent 3df52c0c
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 377 deletions
src/interfaces/jdbc/CHANGELOG
View file @ b562c62b
Tue Mar 06 12:05:00 GMT 2001 peter@retep.org.uk
- Removed org.postgresql.xa.Test from the JDBC EE driver as it's an old
test class and prevented it from compiling.
Fri Mar 02 10:00:00 GMT 2001 peter@retep.org.uk
- Fixed build.xml so that PGclob is not built in the JDBC1.2 driver
......
src/interfaces/jdbc/org/postgresql/xa/Test.java deleted 100644 → 0
View file @ 3df52c0c
package org.postgresql.xa;
import java.sql.*;
import javax.sql.*;
import javax.transaction.xa.*;
public class Test
{
public static void main( String args[] )
{
XADataSource xaDS;
java.io.PrintWriter log;
log = new java.io.PrintWriter( System.out );
try {
xaDS = new XADataSource();
xaDS.setDatabaseName( "test" );
xaDS.setUser( "arkin" );
xaDS.setPassword( "natasha" );
xaDS.setLogWriter( log );
Thread1 thread1;
thread1 = new Thread1();
thread1.xaConn = xaDS.getXAConnection();
thread1.xid1 = new XidImpl();
Thread2 thread2;
thread2 = new Thread2();
thread1.thread2 = thread2;
thread2.thread1 = thread1;
thread2.xaConn = xaDS.getXAConnection();
thread2.xid1 = thread1.xid1;
thread2.xid2 = new XidImpl();
thread1.start();
thread2.start();
} catch ( Exception except ) {
System.out.println( except );
except.printStackTrace();
}
log.flush();
}
}
class Thread1
extends Thread
{
public void run()
{
Connection conn;
XAResource xaRes;
Statement stmt;
ResultSet rs;
try {
conn = xaConn.getConnection();
xaRes = xaConn.getXAResource();
} catch ( Exception except ) {
System.out.println( except );
return;
}
// Initially the table should have no value.
try {
stmt = conn.createStatement();
stmt.executeUpdate( "update test set text='nothing' where id=1" );
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Begin a transaction on this connection.
// Perform an update on the table.
System.out.println( "[Thread1] Starting transaction" );
try {
xaRes.start( xid1, XAResource.TMNOFLAGS );
} catch ( XAException except ) {
System.out.println( except );
return;
}
System.out.println( "[Thread1] Updating table" );
try {
stmt = conn.createStatement();
stmt.executeUpdate( "update test set text='first' where id=1" );
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread2 will start a new transction and attempt
// to perform an update on the table and will lock.
System.out.println( "[Thread1] Waking up Thread2" );
thread2.interrupt();
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// Perform a select from the table just to prove
// that Thread2 failed in its update.
System.out.println( "[Thread1] Selecting from table" );
try {
stmt = conn.createStatement();
rs = stmt.executeQuery( "select text from test where id=1" );
rs.next();
System.out.println( "First = " + rs.getString( 1 ) );
rs.close();
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread2 will now attempt to join our transaction
// and perform an update on the table.
System.out.println( "[Thread1] Waking up Thread2" );
thread2.interrupt();
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// Perform a select from the table to prove that
// Thread2 managed to update it.
System.out.println( "[Thread1] Selecting from table" );
try {
stmt = conn.createStatement();
rs = stmt.executeQuery( "select text from test where id=1" );
rs.next();
System.out.println( "First = " + rs.getString( 1 ) );
rs.close();
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// We now end the transaction for this thread.
// We are no longer in the shared transaction.
// Perform an update on the table and the update
// will lock.
System.out.println( "[Thread1] Ending transaction" );
try {
xaRes.end( xid1, XAResource.TMSUCCESS );
} catch ( XAException except ) {
System.out.println( except );
return;
}
System.out.println( "[Thread1] Selecting from table" );
try {
stmt = conn.createStatement();
stmt.executeUpdate( "update test set text='first' where id=1" );
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread 2 will now end the transcation and commit it.
System.out.println( "[Thread1] Waking up Thread2" );
thread2.interrupt();
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// Perform a select on the table to prove that it
// was only updated inside the transaction.
System.out.println( "[Thread1] Selecting from table" );
try {
stmt = conn.createStatement();
rs = stmt.executeQuery( "select text from test where id=1" );
rs.next();
System.out.println( "First = " + rs.getString( 1 ) );
rs.close();
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
}
javax.sql.XAConnection xaConn;
Xid xid1;
Thread thread2;
}
class Thread2
extends Thread
{
public void run()
{
Connection conn;
XAResource xaRes;
Statement stmt;
ResultSet rs;
try {
conn = xaConn.getConnection();
xaRes = xaConn.getXAResource();
} catch ( Exception except ) {
System.out.println( except );
return;
}
// Thread2 immediately goes to sleep, waits
// for Thread1 to wake it up.
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// Begin a transaction on this connection.
// Perform an update on the table. This will
// lock since Thread1 is in a different transaction
// updating the same table.
System.out.println( "[Thread2] Starting transaction" );
try {
xaRes.start( xid2, XAResource.TMNOFLAGS );
} catch ( XAException except ) {
System.out.println( except );
return;
}
System.out.println( "[Thread2] Updating table" );
try {
stmt = conn.createStatement();
stmt.executeUpdate( "update test set text='second' where id=1" );
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread1 will now proof that it owns the
// transaction.
System.out.println( "[Thread2] Waking up Thread1" );
thread1.interrupt();
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// We will now join the transaction shared with
// Thread1 and try to update the table again.
System.out.println( "[Thread2] Dumping transaction" );
try {
xaRes.end( xid2, XAResource.TMFAIL );
// xaRes.rollback( xid2 );
xaRes.forget( xid2 );
} catch ( XAException except ) {
System.out.println( except );
return;
}
System.out.println( "[Thread2] Joining transaction of Thread1" );
try {
xaRes.start( xid1, XAResource.TMJOIN );
} catch ( XAException except ) {
System.out.println( except );
return;
}
System.out.println( "[Thread2] Updating table" );
try {
stmt = conn.createStatement();
stmt.executeUpdate( "update test set text='second' where id=1" );
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread1 will now proof that it could update
// the table.
System.out.println( "[Thread2] Waking up Thread1" );
thread1.interrupt();
try {
sleep( Integer.MAX_VALUE );
} catch ( InterruptedException except ) { }
// We will now end the transaction and commit it.
System.out.println( "[Thread2] Commiting transaction" );
try {
xaRes.end( xid1, XAResource.TMSUCCESS );
xaRes.prepare( xid1 );
xaRes.commit( xid1, false );
xaRes.forget( xid1 );
} catch ( XAException except ) {
System.out.println( except );
return;
}
// Perform a select on the table to prove that it
// was only updated inside the transaction.
System.out.println( "[Thread2] Selecting from table" );
try {
stmt = conn.createStatement();
rs = stmt.executeQuery( "select text from test where id=1" );
rs.next();
System.out.println( "First = " + rs.getString( 1 ) );
rs.close();
stmt.close();
} catch ( SQLException except ) {
System.out.println( except );
}
// Thread1 will now proof that the table was only
// updated inside the transaction. Thread 2 will die.
System.out.println( "[Thread2] Waking up Thread1" );
thread1.interrupt();
}
javax.sql.XAConnection xaConn;
Xid xid1;
Xid xid2;
Thread thread1;
}
class XidImpl
implements Xid
{
public byte[] getBranchQualifier()
{
return null;
}
public byte[] getGlobalTransactionId()
{
return null;
}
public int getFormatId()
{
return 0;
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment