Class

Class Process :

Event Listener:

package javatemplate1;

import java.sql.Connection;
//import java.sql.Date;
import java.sql.DriverManager;
//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;
// ResultSet rs = null; // result set object
//String dbURL = "jdbc:mysql://localhost/test?";
String dbURL = "jdbc:postgresql://localhost:5432/pgsdemo1";
// String user = "Manas9"; String pwd = "Manas9237";
String user = "postgres"; String pwd = "postgre_manas9";
//String user = "manas237"; String password = "pwmanas237";
Process ps = new Process();
Properties param = new Properties();
List list = new ArrayList();
String sql1 = "Select * from emp";
String sql2 = "UPDATE emp SET sal= ? WHERE EMPNO = ?";
// connecting to db
try {
//replacing Class.forName("org.postgresql.Driver");
param.put("user",user); param.put("password",pwd);
c = DriverManager.getConnection(dbURL,user,pwd);
st = c.createStatement();
System.out.println("Connected to database successfully");
c.setAutoCommit(false);
//ResultSet rs = st.executeQuery("SELECT * FROM emp;");
JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
rowSet.setUrl(dbURL);
rowSet.setUsername(user);
rowSet.setPassword(pwd);
rowSet.setCommand(sql1);
rowSet.execute();
//
rowSet.addRowSetListener(new CursorListener());
while(rowSet.next())
{ int eno= rowSet.getInt("EMPNO");
String name = rowSet.getString("ename");
String job = rowSet.getString("JOB");
float salary = rowSet.getFloat("SAL");
//rowSet.updateFloat(sql2, salary);
// 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...");
}
}