RecorstSet_To_List1
  • load a list from
main block :

Code : RecordSet_To_List1.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;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.*;

/**
*
* @author Manas14
*/
public class JavaTemplate1 {
// private static String dbURL;

/**
* @param args the command line arguments
*/
public static void main(String[] args) {
// TODO code application logic here
// 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";
Properties param = new Properties();
List list = new ArrayList();
// 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");
c.setAutoCommit(false);
ResultSet rs = st.executeQuery("SELECT * FROM emp;");

// rs = st.execute();
while(rs.next())
{
//int dept = rs.getInt("EMPNO");
int eno= rs.getInt("EMPNO");
String name = rs.getString("ename");
String job = rs.getString("JOB");
int manager = rs.getInt("MGR");
Date date = rs.getDate("HIREDATE");
float salary = rs.getFloat("SAL");
// double commision = rs.getInt("COMM");
int deptno = rs.getInt("DEPTNO");
//
list.add(eno); //Process.loaddata(list);
list.add(name);//Process.loaddata(list);
list.add(job);//Process.loaddata(list);
list.add(salary);
Process.loaddata(list);
list.clear();
//
/*
System.out.println("deptno " + deptno + " eno " + eno+ " name "+
name + " JOB " + job +" manager " + manager +
" hired" + date + " sal " + salary );
*/

}
//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> list;
list = new ArrayList();
list.add(x1);
display(list);
}
public static void display(List<Object> str1){
str1.stream().forEach((obj1) -> {
System.out.print(" " +obj1 );
}
//System.out.println();
);
System.out.println();
//str1.stream().map((x) -> x).forEach(System.out::println);
}
}