package javatemplate1;
// MYSQL table mysqlVisitor1C
import com.sun.rowset.FilteredRowSetImpl;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.*;
import java.util.Properties;
import java.util.function.Function;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.sql.RowSet;
import javax.sql.rowset.FilteredRowSet;
import javax.sql.rowset.Predicate;
import jdk.nashorn.internal.codegen.types.Range;

public class JavaTemplate1 {
    // example of 
       public static void main(String[] args) throws InterruptedException {
        // TODO code application logic here
        System.out.println("main block executing ::mysqlVisitor1C");
       Connection c = null; //manage copnnection
       Statement st = null;// query statement support
       ResultSet rs = null;// active connection database result
    
  String dbURL = "jdbc:mysql://localhost/test?"; 
  String user = "Manas9"; String pwd = "Manas9237";
   // 
      String sqlQuery  ="Select * from mysqlVisitor1C";
     //create table visitor11 ("id int,"  + "fname varchar(30)," + "lname varchar(30),"    + "age  int(2))";
     String strInsert0 ="INSERT INTO  mysqlVisitor1C values (105,'Nathn', 'Kane', 20)";
     String strInsert1="INSERT INTO  mysqlVisitor1C values(106,'Sally', 'Pit', 24)"; 
      String strInsert2 ="INSERT INTO  mysqlVisitor1C values(107,'Roy', 'Heinz', 49)"; 
      String strInsert3 ="INSERT INTO  mysqlVisitor1C values(108,'Vasker', 'De', 54)"; 
      String [] strInsert = new String[]{strInsert1, strInsert2, strInsert3, strInsert0}; 
      String strBuff = null; 
      // connecting to db
      try {
          // connection>>statement >> Resultset 
       c = DriverManager.getConnection(dbURL,user,pwd);
       // drop table if exists visitor1A;
      c.setAutoCommit(false);
      //Select * from mysqlVisitor1C
       st = c.createStatement();
       PreparedStatement ps=c.prepareStatement(strInsert0);
       ps.addBatch();
        ps.executeBatch();
       ps=c.prepareStatement(strInsert1);
        ps.addBatch();
         ps.executeBatch();
        ps=c.prepareStatement(strInsert2);
       ps.addBatch(); 
       ps.executeBatch();
        ps=c.prepareStatement(strInsert3);
       ps.addBatch();
       ps.executeBatch();
       //
       c.commit();
       rs = st.executeQuery(sqlQuery);
       ResultSetMetaData metaData = rs.getMetaData();
       int numberOfColumns = metaData.getColumnCount();  
       //int rownum = metaData.
// get name of the columuns 
         for ( int i = 1; i <= numberOfColumns; i++ )
         {
         System.out.printf( "%-4s\t", 
                 metaData.getColumnName( i ) );
         }
         System.out.println();
        //
      //Process.loaddata(rs, numberOfColumns);
       System.out.println( "Filtered Rowset");
         FilteredRowSet frs = new FilteredRowSetImpl();
         frs.populate(rs);
         Process.loadfrwset(frs, numberOfColumns);
         //
         AgeFilter filter = new AgeFilter(30, 41, 4);

        frs.beforeFirst();
        frs.setFilter((javax.sql.rowset.Predicate) filter);
        System.out.println("\nSetting state filter:");

      } 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"); 
    } 
      
}
class Process {
       //
public static void loadfrwset(FilteredRowSet x1 , int n2)
        throws SQLException
{ int size = 0; 
    while ( x1.next() ) 
         {
             size++; 
            for ( int i = 1; i <= n2; i++ )
                try {
          System.out.printf( "%-4s\t", x1.getObject( i ));
          } catch (SQLException ex) {
            Logger.getLogger(Process.class.getName()).
             log(Level.SEVERE, null, ex);
                }
            System.out.println();
         }
    //displayMap(list1); 
    System.out.println("processed rows :: "+ size);
}

}
//