Rule to Read Database Table

import org.apache.log4j.Level;
import org.apache.log4j.Logger;import sailpoint.plugin.PluginBaseHelper;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

    Logger log = Logger.getLogger("sailpoint.rules.ReadDBTable");
    log.setLevel(Level.DEBUG);
    log.debug("-----------------------------------");

    Connection connection = PluginBaseHelper.getConnection();
    log.debug("Connection established to DB: " + connection.getCatalog());
    ResultSet resultSet = null;
    PreparedStatement preparedStatement = null;
    try{

        String selectQuery = "SELECT COLUMN_NAME FROM TABLE_NAME; ";
        preparedStatement = connection.prepareStatement(selectQuery);
        log.debug("Executing the query: " +selectQuery);
        resultSet = preparedStatement.executeQuery();

        while(resultSet.next()){
            String column_value = resultSet.getString("COLUMN_NAME");
            log.debug(column_value);
        }

    } catch(Exception e){
        log.error("Exception occurred: " +e);
    }
    connection.close();