/* * To change this license header, choose License Headers in Project Properties. * To change this template file, choose Tools | Templates * and open the template in the editor. */ 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; /** * * @author Manas9 */ 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 CUSTOMER1"; String sqlx = "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"); String sql2 = "DROP TABLE IF EXISTS CUSTOMER1 "; st.executeUpdate(sql2); st.executeUpdate("DROP TABLE IF EXISTS CUSTOMER1;"); st.executeUpdate("create table CUSTOMER1 (id int,fname varchar,lname varchar, SAL float);"); st.executeUpdate("insert into CUSTOMER1 (id,fname,lname,SAL ) values (101,'John','Smith',1500.25)"); st.executeUpdate("insert into CUSTOMER1 (id,fname,lname,SAL ) values (102,'Peter', 'Pan', 2000.36)"); st.executeUpdate("insert into CUSTOMER1 (id,fname,lname,SAL ) values (103,'Daniel', 'Boone', 3500.45)"); //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("id"); String fname = rowSet.getString("fname"); String lname = rowSet.getString("lname"); float salary = rowSet.getFloat("SAL"); //rowSet.updateFloat(sql2, salary); // adding to list list.add(eno); //Process.loaddata(list); list.add(fname);//Process.loaddata(list);Process list.add(lname); 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 x1 ) { List list1; list1 = new ArrayList(); list1.add(x1); displayMap(list1); } public static void displayMap(List 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..."); } }