JDBC - Rowset

RowSet: - It is an object that combines a set of rows from either JDBC result sets or tabular data sources.  It supports component-based development models such as JavaBeans, with a standard set of properties and an event notification mechanism.

Types of RowSets:-

• CachedRowSet

• JdbcRowSet

• WebRowSet

• FilteredRowSet

• JoinRowSet

Implementation classes are:-

•  com.sun.rowset.CachedRowSetImpl

• com.sun.rowset.JdbcRowSetImpl

• com.sun.rowset.WebRowSetImpl

• com.sun.rowset.FilteredRowSetImpl

• com.sun.rowset.JoinRowSetImpl

RowSets are divided into two categories:-

• Connected Rowset :- The connected rowset is connected to the db connection object like resultset. It is making the permanent connection and doesn’t terminate until the application is terminated.Example :-  JdbcRowSet.

• Disconnected RowSet: - A disconnected RowSet retrieves the data from DB whenever requires, it establishes the connection and closes it after finishing the required task. The data that is modified during disconnected state is updated after the connection is re-established. Example:- CachedRowSet, WebRowSet, FilteredRowSet, JoinRowSet.

RowSet Sample Code:-

package com.gaurav.jdbcexamples;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.ResultSet;

import java.sql.SQLException;

import javax.sql.RowSetEvent;

import javax.sql.RowSetListener;

import javax.sql.rowset.JdbcRowSet;

import com.sun.rowset.JdbcRowSetImpl;

public class JDBCRowSetDemo {

      private static JdbcRowSet jdbcRowSet = null;

      private static Connection con = null;

      public static Connection getMySqlConnection() throws Exception {

            String JDBC_DRIVER = "com.mysql.jdbc.Driver"; // MySQL Driver filename

            String USERNAME = "root";

            String PASSWORD = "root";

            String DATABASE_URL = "jdbc:mysql://localhost:3306/test";

            Class.forName(JDBC_DRIVER);

            Connection connection = DriverManager.getConnection(DATABASE_URL,

                        USERNAME, PASSWORD);

            return connection;

      }

      public static void main(String... args) {

            try {

                  con = getMySqlConnection();

                  System.out.println(" SUCCESSFULLY GOT THE CONNECTION ");

                  jdbcRowSet = new JdbcRowSetImpl(con);

                  jdbcRowSet.setType(ResultSet.TYPE_SCROLL_INSENSITIVE);

                  String query = "SELECT * FROM student";

                  jdbcRowSet.setCommand(query);

                  jdbcRowSet.execute();

                  jdbcRowSet.addRowSetListener(new TestListener());

                  System.out

                              .println("------------------- ROWSET IS MOVING FORWARD ------------------------------");

                  while (jdbcRowSet.next()) {

                        // cursor Movement event occurs here

                        System.out.println("STUDENT_ID - " + jdbcRowSet.getInt(1));

                        System.out.println("FIRSTNAME - " + jdbcRowSet.getString(2));

                  }

                  System.out

                              .println("------------------- ROWSET IS MOVING BACK ------------------------------");

                  while (jdbcRowSet.previous()) {

                        // cursor Movement event occurs here

                        System.out.println("STUDENT_ID - " + jdbcRowSet.getInt(1));

                        System.out.println("FIRSTNAME - " + jdbcRowSet.getString(2));

                  }

                  System.out

                              .println("------------------ ROWSET IS MOVING RANDOMLY -----------------------------");

                  boolean isAbsoulteRow = jdbcRowSet.absolute(2);

                  System.out.println("isAbsoulteRow->" + isAbsoulteRow);

            } catch (SQLException sqe) {

                  sqe.printStackTrace();

            } catch (Exception e) {

                  e.printStackTrace();

            } finally {

                  try {

                        if (jdbcRowSet != null)

                              jdbcRowSet.close();

                        if (con != null)

                              con.close();

                  } catch (Exception e) {

                        e.getMessage();

                  }

            }

      }

}

class TestListener implements RowSetListener {

      @Override

      public void cursorMoved(RowSetEvent event) {

            System.out.println("EVENT OCCURRED FOR CURSOR MOVEMENT");

      }

      @Override

      public void rowChanged(RowSetEvent event) {

            System.out.println("EVENT OCCURRED FOR CURSOR CHANGED");

      }

      @Override

      public void rowSetChanged(RowSetEvent event) {

            System.out.println("EVENT OCCURRED FOR ROWSET CHANGED");

      }

}

Note:- For Table data structure ref:-http://www.javatechtipssharedbygaurav.com/2013/04/jdbc-statement.html

Result:-