server/DBInterface/DBMultipleInsertTest.java

import java.sql.*;

/**
 * A main method to test how to insert MULTIPLE rows to a mySQL
 * database table in a single transaction.  This is required so
 * that the id references may be inserted to multiple tables
 * using an autoincrement field.
 *
 * IMPORTANT: This method obtains the database user and database
 * connection password from the Password class.  As such, this
 * class may be safely placed in a public CVS repository.
 *
 * @author  $Author:  $
 * @version $Id:  $
 */
class DBMultipleInsertTest {

    public static void main(String[] args){

        // Create an instance of the mySQL driver.
        try{
            Class.forName("org.gjt.mm.mysql.Driver").newInstance(); 
        }
        catch(Exception e){
            e.printStackTrace();
        }

        try {
            // Use the connection string for our group database.
            Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/co600_10_db?user="+Password.mySQLUser+"&password="+Password.mySQLPassword);

            // Create a statement object.
            Statement stmt = conn.createStatement();

            // Do NOT commit after each statement.
            conn.setAutoCommit(false);

            // A couple of SQL statements to try out...            
            String sql1 = "INSERT INTO cpu (id, cpu_no, cpu_load) VALUES (3, 4, 5);";
            String sql2 = "INSERT INTO cpu (id, cpu_no, cpu_load) VALUES (7, 8, 9);";
            
            // Execute the insert statements.
            stmt.executeUpdate(sql1);
            stmt.executeUpdate(sql2);
            
            // Now commit the results.
            conn.commit();
            
            // Restore autocommit.
            conn.setAutoCommit(true); 
            
            // Close the statement and database connection.
            stmt.close();
            conn.close();
        }
        catch (SQLException e) {
            System.out.println("SQLException: " + e.getMessage());
            System.out.println("SQLState:     " + e.getSQLState());
            System.out.println("VendorError:  " + e.getErrorCode());
        }
    }
}   
Revision:	1.1
Committed:	Mon Dec 4 09:54:03 2000 UTC (23 years, 5 months ago) by pjm2
Branch:	MAIN
Log Message:	A class to test inserting multiple data into a mySQL table using a single transaction.
#	Content
1	import java.sql.*;
2
3	/**
4	* A main method to test how to insert MULTIPLE rows to a mySQL
5	* database table in a single transaction. This is required so
6	* that the id references may be inserted to multiple tables
7	* using an autoincrement field.
8	*
9	* IMPORTANT: This method obtains the database user and database
10	* connection password from the Password class. As such, this
11	* class may be safely placed in a public CVS repository.
12	*
13	* @author $Author: $
14	* @version $Id: $
15	*/
16	class DBMultipleInsertTest {
17
18	public static void main(String[] args){
19
20	// Create an instance of the mySQL driver.
21	try{
22	Class.forName("org.gjt.mm.mysql.Driver").newInstance();
23	}
24	catch(Exception e){
25	e.printStackTrace();
26	}
27
28	try {
29	// Use the connection string for our group database.
30	Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/co600_10_db?user="+Password.mySQLUser+"&password="+Password.mySQLPassword);
31
32	// Create a statement object.
33	Statement stmt = conn.createStatement();
34
35	// Do NOT commit after each statement.
36	conn.setAutoCommit(false);
37
38	// A couple of SQL statements to try out...
39	String sql1 = "INSERT INTO cpu (id, cpu_no, cpu_load) VALUES (3, 4, 5);";
40	String sql2 = "INSERT INTO cpu (id, cpu_no, cpu_load) VALUES (7, 8, 9);";
41
42	// Execute the insert statements.
43	stmt.executeUpdate(sql1);
44	stmt.executeUpdate(sql2);
45
46	// Now commit the results.
47	conn.commit();
48
49	// Restore autocommit.
50	conn.setAutoCommit(true);
51
52	// Close the statement and database connection.
53	stmt.close();
54	conn.close();
55	}
56	catch (SQLException e) {
57	System.out.println("SQLException: " + e.getMessage());
58	System.out.println("SQLState: " + e.getSQLState());
59	System.out.println("VendorError: " + e.getErrorCode());
60	}
61	}
62	}