import java.sql.*;
import com.mysql.jdbc.jdbc2.optional.*;
import java.util.*;
import java.io.*;

public class bug11563 {

   private static final String server   = "localhost";
   private static final String database = "test";
   private static final String username = "root";
   private static final String password = "";

   private Statement stmt;

   public static void main (String [ ] args)
   {
      try
      {  System.err.println ("Initialize datasource");
         MysqlDataSource ds = new MysqlDataSource();
         ds.setServerName (server);
         ds.setDatabaseName (database);
         ds.setUser (username);
         ds.setPassword (password);
         ds.setUseNewIo (true);

         System.err.println ("Setup database connection\n");
         Connection conn = ds.getConnection();

         test (conn);
      }
      catch (Exception e)
      {  e.printStackTrace (System.err);
         System.exit (1);
      }
   }

   private static void test (Connection conn) throws Exception
   {
      Statement stmt = conn.createStatement();
      try {
         stmt.executeUpdate ("DROP TABLE IF EXISTS test");
         stmt.executeUpdate ("CREATE TABLE test (field1 integer, field2 integer)");
         stmt.executeUpdate ("INSERT INTO test (field1,field2) VALUES (NULL,NULL)");

         PreparedStatement ps = conn.prepareStatement ("SELECT * FROM test");
         ResultSet rs = ps.executeQuery();
      	if (rs.next())
      	{	Integer i = (Integer) rs.getObject ("field1");
            System.out.println ("field1: " + i);
            i = (Integer) rs.getObject ("field2");
            System.out.println ("field2: " + i + "\n");
        }
	ps.close();
      }
      finally {
         stmt.executeUpdate ("DROP TABLE IF EXISTS test");
      }
   }
}