package testsuite;

/*
   
 * Transaction.java
   
 *
   
 * Created on May 24, 2000, 10:02 PM
   
 */
import java.sql.*;


/**
 * Tests declared transaction capability.
 * 
 * @version $Id: Transaction.java,v 1.2 2002/04/25 01:13:01 mark_matthews Exp $
 * @author mmatthew
 */
public class Transaction
    extends Object
{
    //~ Instance/static variables .............................................

    static String DBUrl = "jdbc:mysql:///test";

    //~ Constructors ..........................................................

    /**
     * Creates a new Transaction object.
     * 
     * @throws Exception DOCUMENT ME!
     */
    public Transaction()
                throws Exception
    {
        Connection Conn = null;
        Statement Stmt = null;

        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            Conn = DriverManager.getConnection(DBUrl);
            Conn.setAutoCommit(true);
            Stmt = Conn.createStatement();

            try {
                Stmt.executeUpdate("DROP TABLE trans_test");
            } catch (SQLException sqlEx) { /* ignore */
            }

            Stmt.executeUpdate("CREATE TABLE trans_test (id int not null primary key, decdata double) type=BDB");
            Conn.setAutoCommit(false);
            Stmt.executeUpdate("INSERT INTO trans_test (id, decdata) VALUES (1, 1.0)");
            Conn.rollback();

            ResultSet RS = Stmt.executeQuery("SELECT * from trans_test");

            if (!RS.next()) {
                System.out.println("Ok");
            } else {
                System.out.println("Rollback failed");
            }

            Stmt.executeUpdate("INSERT INTO trans_test (id, decdata) VALUES (2, 23.485115)");
            Conn.commit();
            RS = Stmt.executeQuery("SELECT * from trans_test where id=2");

            if (RS.next()) {
                System.out.println(RS.getDouble(2));
                System.out.println("Ok");
            } else {
                System.out.println("Rollback failed");
            }
        } catch (Exception ex) {
            throw ex;
        } finally {
            if (Stmt != null) {
                try {
                    Stmt.close();
                } catch (SQLException SQLEx) { /* ignore */
                }
            }
            if (Conn != null) {
                try {
                    Conn.close();
                } catch (SQLException SQLEx) { /* ignore */
                }
            }
        }
    }
    //~ Methods ...............................................................

    /**
     * DOCUMENT ME!
     * 
     * @param args DOCUMENT ME!
     * @throws Exception DOCUMENT ME!
     */
    public static void main(String[] args)
                     throws Exception
    {
        new Transaction();
    }
}