package javatemplate1;

import com.sun.rowset.JdbcRowSetImpl;
import java.sql.Connection;
//import java.sql.Date;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
//import java.sql.ResultSet; // for result set
import javax.sql.rowset.JdbcRowSet;  
import javax.sql.rowset.RowSetProvider;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.*;
import java.util.function.Function;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.sql.RowSetEvent;  
import javax.sql.RowSetListener;  
import javax.sql.rowset.CachedRowSet;
import com.sun.rowset.CachedRowSetImpl;

public class JavaTemplate1 {
    // example of 
       public static void main(String[] args) {
        // TODO code application logic here
        System.out.println("main block executing ");
       Connection c = null; //manage copnnection
       Statement st = null;// query statement support
       ResultSet rs = null;// active connection database result
     
     String dbURL = "jdbc:postgresql://localhost:5432/pgsdemo1";
     String user = "postgres"; String pwd = "postgre_manas9";
     // String dbURL = "jdbc:mysql://localhost/test?"; 
     //String user = "Manas9"; String pwd = "Manas9237";
       String sql1 = "Select *  from pgsvisitor1b";
      // connecting to db
      try {
          // connection>>statement >> Resultset 
       c = DriverManager.getConnection(dbURL,user,pwd);
       st = c.createStatement(); 
       rs = st.executeQuery(sql1);
       ResultSetMetaData metaData = rs.getMetaData();
       int numberOfColumns = metaData.getColumnCount();  
             // get name of the columuns with Result set
         for ( int i = 1; i <= numberOfColumns; i++ ){
         System.out.printf( "%-8s\t", 
                 metaData.getColumnName( i ) );
         }
             System.out.println();
        //
         Process.loaddata(rs, numberOfColumns);
         //Note the difference 
          JdbcRowSet rset; 
           rset = new JdbcRowSetImpl();
           rset.setUsername(user);
           rset.setPassword(pwd);
           rset.setUrl(dbURL);
            rset.setCommand(sql1);
           rset.execute();
        Process.loadrset(rset, numberOfColumns);
            // Process.loaddata(rs, numberOfColumns);
             //CachedRowSet rset ;
            //rset = new CachedRowSetImpl();
            //rset.populate(rs);
        //rs.close();
         System.out.println("rs closed" );
         
      } catch (SQLException ex) { ex.getErrorCode();
            String message = ex.getMessage();  
            System.out.println(message); 
      } finally {
          System.out.println("going through final block"); 
            try {
                 if (st== null || st.isClosed()) {
                } else {
                  st.close();
              }
                if (c != null && !c.isClosed()) {
                    c.close(); }
            } catch (SQLException ex) { ex.getErrorCode();
                  ex.getMessage();              
            }
        }
      
      System.out.println("dis-Connected to  database successfully"); 

    } 
      
}
class Process {
   //private int empno;  private String empname; 
   // private String empjob; private float empsal; 
    //
public static void loaddata(ResultSet x1 , int n2)
        throws SQLException
{ int size = 0; 
    while ( x1.next() ) 
         {
             size++; 
            for ( int i = 1; i <= n2; i++ )
                try {
          System.out.printf( "%-8s\t", x1.getObject( i ));
          } catch (SQLException ex) {
            Logger.getLogger(Process.class.getName()).
             log(Level.SEVERE, null, ex);
                }
            System.out.println();
         }
    //displayMap(list1); 
    System.out.println("processed rows :: "+ size);
}
public static void loadrset( JdbcRowSet x1 , int n2)
        throws SQLException
{ int size = 0; 
    while ( x1.next() ) 
         {
             size++; 
            for ( int i = 1; i <= n2; i++ )
                try {
          System.out.printf( "%-8s\t", x1.getObject( i ));
          } catch (SQLException ex) {
            Logger.getLogger(Process.class.getName()).
             log(Level.SEVERE, null, ex);
                }
            System.out.println();
         }
    //displayMap(list1); 
    System.out.println("processed rows :: "+ size);
}
}