yezhou

package ConnectionTest;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;

public class ContactTest {       
        private Connection conn = null;
       
        public void getConnection(){
                try{
                        String JDBC_URL = "jdbc:pointbase:server://localhost:9092/test";
                        String JDBC_DRIVER="com.pointbase.jdbc.jdbcUniversalDriver";                                       
                        String USER = "PBPUBLIC";
                        String PASSWORD = "PBPUBLIC";
                       
                        Class.forName(JDBC_DRIVER).newInstance();
                        conn = DriverManager.getConnection(JDBC_URL,USER,PASSWORD);
                        System.out.println("connection success");
                }catch(Exception e){
                        e.printStackTrace();
                }
        }
       
        public void excute(){
               
                try{
                        Statement stmt  = this.conn.createStatement();
                        String SQL = "select id ,name ,age ,address  from test";
                        ResultSet rs = stmt.executeQuery(SQL);

                        ResultSetMetaData ss = rs.getMetaData();
                               
                        int count = ss.getColumnCount();

                        for(int j = 1; j <= count; j++){
                                System.out.print(ss.getColumnName(j)+"        ");
                        }
                        System.out.println(" ");
                       
                        while(rs.next()){       
                                for (int i = 1; i <= count;i++){
                                        System.out.print(rs.getString(i)+" ");
                                }
                                System.out.println(" ");
                        }
                        rs.close();
                        stmt.close();
                        this.conn.close();                      
                }catch(Exception e){
                        e.printStackTrace();
                }
               
        }
       
        public static void main(String[] args)
        {
                ContactTest  ct = new ContactTest ();
                ct.getConnection();
                ct.excute();
        }
       
}