batchretrievetest.java

高质量Java程序设计 源代码

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

public class BatchRetrieveTest extends Object {
	private static final int FETCH_SIZE = 1;
	public BatchRetrieveTest() {
	}
	public static void main(String[] args) {
		BatchRetrieveTest batchRetrieveTest = new BatchRetrieveTest();
		batchRetrieveTest.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();
			stmt1.setFetchSize(1);
			ResultSet rs1 =
				stmt1.executeQuery("select id,name,description from test_table");
			while (rs1.next()) {
				;
			}
			rs1.close();
			stopWatch.stop();
			stmt1.close();
			System.out.println(
				"Time elapsed of batch retrieve with cache 1: "
					+ stopWatch.getTimeElapsed());
			stmt2 = conn.createStatement();
			stmt2.setFetchSize(FETCH_SIZE);
			stopWatch.start();
			ResultSet rs2 =
				stmt2.executeQuery("select id,name,description from test_table");
			while (rs2.next()) {
				;
			}
			rs2.close();
			stopWatch.stop();
			stmt2.close();
			System.out.println(
				"Time elapsed of batch retrieve with cache 2: "
					+ stopWatch.getTimeElapsed());
			conn.close();
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			try {
				stmt1.close();
				stmt2.close();
				conn.close();
			} catch (Exception e) {
			}
		}
	}
}