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