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.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 javax.sql.RowSetEvent;
import javax.sql.RowSetListener;

public class JavaTemplate1 {
public static void main(String[] args) {
// TODO code application logic here
System.out.println("main block executing ");
Connection c = null; Statement st = null;
String dbURL = "jdbc:postgresql://localhost:5432/pgsdemo1";
String user = "postgres"; String pwd = "postgre_manas9";
String sql1 = "Select * from emp";
List list = new ArrayList();
// connecting to db
try {
// statement >> Resultset >> RoowSet
c = DriverManager.getConnection(dbURL,user,pwd);

JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
// JdbcRowSet rowSet = new JdbcRowSetImpl(rs);
rowSet.setUrl(dbURL);
rowSet.setUsername(user);
rowSet.setPassword(pwd);
rowSet.setCommand(sql1);
rowSet.execute();
rowSet.afterLast();
// last to first
while(rowSet.previous())
{ int eno= rowSet.getInt("EMPNO");
String name = rowSet.getString("ename");
String job = rowSet.getString("JOB");
float salary = rowSet.getFloat("SAL");
// adding to list
list.add(eno); //Process.loaddata(list);
list.add(name);//Process.loaddata(list);Process
list.add(job);//Process.loaddata(list);
list.add(salary);
Process.loaddata(list);
list.clear();
}
//Process.loaddata(list (x->x));
} 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");

// st.close(); con.commit();con.close();
}

}
class Process {

//
public static void loaddata(List<Object> x1 )
{
List<Object> list1;
list1 = new ArrayList();
list1.add(x1);
displayMap(list1);
}
public static void displayMap(List<Object> str1){
//System.out.println();
str1.stream().forEach((obj1) -> {
System.out.print(" " +obj1 ); });
System.out.println();
}
}// end of process class
//
class CursorListener implements RowSetListener {
@Override
public void cursorMoved(RowSetEvent event) {
System.out.println ("Cursor Moved...");
}
@Override
public void rowChanged(RowSetEvent event) {
System.out.println("Cursor Changed...");
}
@Override
public void rowSetChanged(RowSetEvent event) {
System.out.println("RowSet changed...");
}
}