git.8kb.co.uk Git - pgpool-ii/pgpool-ii_2.2.5/blob - test/jdbc/ColumnTest.java

   1 import java.sql.Connection;
   2 import java.sql.DriverManager;
   3 import java.sql.ResultSet;
   4 import java.sql.SQLException;
   5 import java.sql.Statement;
   6
   7 public class ColumnTest extends PgpoolTest {
   8     public static String sql =
   9             "SELECT"
  10             +" columntest.v1 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz001,"
  11             +" columntest.v2 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz002,"
  12             +" columntest.v3 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz003,"
  13             +" columntest.v4 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz004,"
  14             +" columntest.v5 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz005,"
  15             +" columntest.v6 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz006,"
  16             +" columntest.v7 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz007,"
  17             +" columntest.v8 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz008,"
  18             +" columntest.v9 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz009,"
  19             +" columntest.v10 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz010,"
  20             +" columntest.v11 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz011,"
  21             +" columntest.v12 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz012,"
  22             +" columntest.v13 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz013,"
  23             +" columntest.v14 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz014,"
  24             +" columntest.v15 as abcdefghijklmnopqrstuvwxyzabcdefghijklmnopqrstuvwxyz015"
  25             +" FROM columntest";
  26     static String url = "jdbc:postgresql://localhost:9999/test";
  27     static String user = "y-asaba";
  28     static String password = "postgres";
  29     static final int COUNT = 100;
  30
  31     public void do_test() throws SQLException {
  32         connection.setAutoCommit(false);
  33
  34         Statement stmt = null;
  35         ResultSet rs = null;
  36
  37         try {
  38             for (int i = 0; i < COUNT; i++) {
  39                 try {
  40                     stmt = connection.createStatement();
  41                     rs = stmt.executeQuery(sql);
  42
  43                     while(rs.next()){
  44                         logwriter.println(rs.getInt(1));
  45                     }
  46                 } finally {
  47                     if(rs != null) rs.close();
  48                     if(stmt != null) stmt.close();
  49                 }
  50             }
  51         } finally {
  52             connection.close();
  53             logwriter.close();
  54         }
  55     }
  56
  57     public String getTestName() {
  58         return "column";
  59     }
  60 }