RowSet_Update_Field1
  •   String sqlx = "UPDATE CUSTOMER1 SET sal= 1500.25 WHERE id = 101";
  • Rowset Absolute
Customer1 Table:

Update Code structure:

Complete Code: RowSet_Update_Field1.txt

package javatemplate1;

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;

/**
*
* @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 CUSTOMER1 SET sal= 1500.25 WHERE id = 101";
// connecting to db
try {
//replacing Class.forName("org.postgresql.Driver");
param.put("user",user); param.put("password",pwd);
c = DriverManager.getConnection(dbURL,user,pwd);
c.setAutoCommit(false);
st = c.createStatement(
ResultSet.TYPE_SCROLL_SENSITIVE,
ResultSet.CONCUR_UPDATABLE);
st.executeUpdate(sqlx);
c.setAutoCommit(true);

//creating RowSet);
JdbcRowSet rowSet = RowSetProvider.newFactory().createJdbcRowSet();
rowSet.setUrl(dbURL);
rowSet.setUsername(user);
rowSet.setPassword(pwd);
rowSet.setCommand(sql1);
rowSet.execute();
rowSet.absolute(0x0);//
//

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...");
}
}

Runt time displays with : rowSet.absolute(0x0);

String sqlx = "UPDATE CUSTOMER1 SET sal= 1500.25 WHERE id = 101";

Runt time displays with : rowSet.absolute(0x1);

String sqlx = "UPDATE CUSTOMER1 SET sal= 1500.25 WHERE id = 101";