DropCreateTable_RowSet1
  • import javax.sql.RowSetEvent;
    import javax.sql.RowSetListener;
  • Drop Table IF EXISTS Table_Name:
    param.put("user",user); param.put("password",pwd);
  • Driver manager
    c = DriverManager.getConnection(dbURL,user,pwd);
  • Initialize Statement
    st = c.createStatement();
    System.out.println("Connected to database successfully");
  • Drop table syntax and execute
    String sql2 = "DROP TABLE IF EXISTS CUSTOMER1 ";
    st.executeUpdate(sql2);
    st.executeUpdate("DROP TABLE IF EXISTS CUSTOMER1;");
  • Create Table with statement
    st.executeUpdate("create table CUSTOMER1 (id int,fname varchar,lname varchar, SAL float);");
  • Inserting data with executeUpdate
    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)");
  • import javax.sql.rowset.JdbcRowSet;
    JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
    rowSet.setUrl(dbURL);
    rowSet.setUsername(user);
    rowSet.setPassword(pwd);
    rowSet.setCommand(sql1);
    rowSet.execute();
Code Structure:

Data Added from RowSet to a List (a collection object)

Code : Cursor Event Listner

CODE : DropCreateTable_RowSet1.txt

/*
* 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)");
//creating RowSet);
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");
// 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<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...");
}
}

Display result: