package javatemplate1;
import java.sql.Connection;  
import java.sql.Date;
import java.sql.DriverManager;  
import java.sql.PreparedStatement;
import java.sql.ResultSet;  
import java.sql.SQLException;
import java.sql.Statement;  
import javax.sql.RowSetEvent;  
import javax.sql.RowSetListener;  
import javax.sql.rowset.JdbcRowSet;  
import javax.sql.rowset.RowSetProvider;  
/**
 *
 * @author Manas14
 */
public class JavaTemplate1 {
   
    public static void main(String[] args) {
         // TODO code application logic here
        System.out.println("main block executing ");
       Connection c = null;  
       String dbURL = "jdbc:postgresql://localhost:5432/pgsdemo1";
      String user = "postgres"; String pwd = "postgre_manas9";
      PreparedStatement ps= null; 
      String sql1 = "Select * from emp";
        // connecting to db
      try {
         c = DriverManager.getConnection(dbURL,user,pwd);
         System.out.println("Connected to  database successfully"); 
        JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet(); 
        rowSet.setUrl(dbURL);
        rowSet.setUsername(user);
        rowSet.setPassword(pwd);
        rowSet.setCommand(sql1);
        rowSet.execute();
       
        //
        while(rowSet.next())
          {
             int eno= rowSet.getInt("EMPNO");
             String name = rowSet.getString("ename");
             String job = rowSet.getString("JOB");
             int manager = rowSet.getInt("MGR");
             Date date = rowSet.getDate("HIREDATE"); 
             float salary = rowSet.getFloat("SAL");
             // double commision = rs.getInt("COMM");
             int deptno = rowSet.getInt("DEPTNO");
            System.out.println("deptno " + deptno + " eno " + eno+ " name "+
                       name + " JOB  " +  job +"   manager " + manager +
                     "  hired" + date + " sal " + salary  ); 
            
          }
        
        //
      } catch (SQLException ex) { ex.getErrorCode();
            String message = ex.getMessage();  
            System.out.println(message); 
      } finally {
          System.out.println("going through final block"); 
            try {
                 if (ps== null || ps.isClosed()) {
                } else {
                  ps.close();
              }
                if (c != null && !c.isClosed()) {
                    c.close(); }
            } catch (SQLException ex) { ex.getErrorCode();
                  ex.getMessage();              
            }
        }
      System.out.println("dis-Connected to  database successfully"); 
     // st.close(); con.commit();con.close();
    }
    
}