batchupdatetest.java

高质量Java程序设计 源代码

package net.betterjava.performance.database;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.DriverManager;
import net.betterjava.performance.StopWatch;

public class BatchUpdateTest extends Object {
	private static final int REC_NUMBER = 1000;
	public BatchUpdateTest() {
	}
	public static void main(String[] args) {
		BatchUpdateTest batchUpdateTest = new BatchUpdateTest();
		batchUpdateTest.test();
	}
	void test() {
		Connection conn = null;
		Statement stmt1 = null;
		Statement stmt2 = null;
		StopWatch stopWatch = new StopWatch();
		int i = 0;
		try {
			Class.forName("oracle.jdbc.driver.OracleDriver");
			conn =
				DriverManager.getConnection(
					"jdbc:oracle:thin:@iptidev:1521:iptidev",
					"dssowner",
					"prdowner");
			stmt1 = conn.createStatement();
			stopWatch.start();
			for (i = 0; i < REC_NUMBER; i++) {
				stmt1.execute(
					"insert into test_table(id,name,description) values("
						+ i
						+ ",'test','a small test')");
			}
			stmt1.close();
			stopWatch.stop();
			System.out.println("Time elapsed of Statement:" + stopWatch.getTimeElapsed());
			stmt2 = conn.createStatement();
			stopWatch.start();
			int endNumber = REC_NUMBER + REC_NUMBER;
			for (i = REC_NUMBER; i < endNumber; i++) {
				stmt2.addBatch(
					"insert into test_table(id,name,description) values("
						+ i
						+ ",'test','a small test')");
			}
			stmt2.executeBatch();
			stmt2.close();
			stopWatch.stop();
			System.out.println(
				"Time elapsed of batch update:" + stopWatch.getTimeElapsed());
			conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				stmt1.close();
				stmt2.close();
				conn.close();
			} catch (Exception e) {
			}
		}
	}
}