1 import java.util.*;
2 import java.io.*;
3 import java.sql.*;
4 
5 public class AutoCommitTest extends PgpoolTest{
6     public String sql = "select * from autocommit where a = ?";
7 
main(String[] args)8     public static void main(String[] args) throws SQLException {
9 	AutoCommitTest test = new AutoCommitTest();
10 	test.do_test();
11     }
12 
do_test()13     public void do_test() throws SQLException
14     {
15         connection.setAutoCommit(true);
16 
17         PreparedStatement stmt = null;
18         ResultSet rs = null;
19 
20         try {
21             for(int i = 0; i < 10; i++) {
22                 stmt = connection.prepareStatement(sql);
23                 try {
24                     stmt.setInt(1, i + 1);
25                     rs = stmt.executeQuery();
26 
27                     while(rs.next()){
28                         logwriter.print(rs.getInt(1) + " ");
29                     }
30                     logwriter.println();
31                 } finally {
32                     if(rs != null) rs.close();
33                     if(stmt != null) stmt.close();
34                 }
35             }
36         } finally {
37             connection.close();
38 	    logwriter.close();
39         }
40     }
41 
getTestName()42     public String getTestName() {
43 	return "autocommit";
44     }
45 }
46