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 (24 years ago) by pjm2
Branch:	MAIN
Log Message:	A class to test inserting multiple data into a mySQL table using a single transaction.
#	User	Rev	Content
1	pjm2	1.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			}