ORM Architecture in Java JDBC
Program 1
package myconnection; import java.sql.*; public class MyCon { static Connection con=null; //Driver Load static { try { Class.forName("com.mysql.cj.jdbc.Driver"); System.out.println("Driver load"); } catch(ClassNotFoundException e) { System.out.println(e); } } //Connection done public static Connection getConnection() { try { con=DriverManager.getConnection("jdbc:mysql:/dataflair", "root","root@data"); System.out.println("Database connect "); } catch(SQLException e) { System.out.println(e); } return con; } }
Program 3
// Insert data in database package mydatabase; import java.sql.*; import java.util.*; public class TestjdbcMain { public static void main(String[] args) { Connection con=null; PreparedStatement ps=null; // Query Execution try { String sql; int rno,mn; String name; Scanner scan=new Scanner(System.in); System.out.println("Enter Roll No"); rno=scan.nextInt(); System.out.println("Enter Name"); name=scan.next(); System.out.println("Enter Mobile No"); mn=scan.nextInt(); sql="insert into student values(?,?,?)"; con=myconnection.MyCon.getConnection(); ps=con.prepareStatement(sql); int n=0; ps.setInt(1, rno); ps.setString(2, name); ps.setInt(3, mn); n=ps.executeUpdate(); if(n==1) System.out.println("Record inserted: " + n); } catch (SQLException e) { System.out.println(e); } } }
Program 4
// Delete by Primary key data in database package mydatabase; import java.sql.*; import java.util.*; public class TestDelete { public static void main(String[] args) { //Driver load Connection con=null; PreparedStatement ps=null; ResultSet rs=null; // Database Connection code try { // Query execute Scanner scan=new Scanner(System.in); int rno; System.out.println("Enter Roll no for delete: "); rno=scan.nextInt(); String sql; sql="select * from student where studid=?"; con=myconnection.MyCon.getConnection(); ps=con.prepareStatement(sql); ps.setInt(1, rno); rs=ps.executeQuery(); if(rs.next()) { System.out.println("Roll No Name MobileNo "); System.out.println("-------------------------------"); System.out.print(" "+rs.getInt(1)); System.out.print(" "+rs.getString(2)); System.out.println(" "+rs.getInt(3)); System.out.println("-------------------------------"); String s; System.out.println("Are your sure want to delete....(yes/no)"); s=scan.next(); if(s.toUpperCase().equals("YES")) { sql="delete from student where studid=?"; ps=con.prepareStatement(sql); ps.setInt(1, rno); if(ps.executeUpdate()>0) System.out.println("Record Deleted............."); } } else System.out.println("Record not found............."); // Connection close con.close(); } catch (SQLException e) { System.out.println(e); } } }
Program 5
package mydatabase; import java.sql.*; public class TestSearchAll { public static void main(String[] args) { Connection con=null; ResultSet rs=null; PreparedStatement ps=null; String sql; try { con=myconnection.MyCon.getConnection(); //Query execution..... sql="select * from student"; ps=con.prepareStatement(sql); rs=ps.executeQuery(); System.out.println("Roll No Name MobileNo "); System.out.println("-------------------------------"); int flag=0; while(rs.next()) { flag=1; System.out.print(" "+rs.getInt(1)); System.out.print(" "+rs.getString(2)); System.out.println(" "+rs.getInt(3)); } if(flag==0) System.out.println("**********Record not found***********"); System.out.println("-------------------------------"); // Connection close con.close(); } catch (SQLException e) { System.out.println(e); } } }
Program 6
// Update Record package mydatabase; import java.sql.*; import java.util.*; public class TestUpdate { public static void main(String[] args) { Connection con=null; PreparedStatement ps=null; ResultSet rs=null; String sql; // Driver Load Code // Database Connection Code try { con=myconnection.MyCon.getConnection(); // Query Execution Scanner scan=new Scanner(System.in); System.out.println("Enter Roll No for Update: "); int rno,mn; String name; rno=scan.nextInt(); sql="select * from student where studid=?"; ps=con.prepareStatement(sql); ps.setInt(1, rno); rs=ps.executeQuery(); System.out.println("Roll No Name Mobile No "); System.out.println("-----------------------------------"); if(rs.next()) { System.out.print(" "+ rs.getInt(1)); System.out.print(" "+ rs.getString(2)); System.out.println(" "+ rs.getInt(3)); System.out.println("Enter Name For Updation: "); name=scan.next(); System.out.println("Enter Mobile No For Updation: "); mn=scan.nextInt(); sql="update student set studname=?,mobile=? where studid=?"; ps=con.prepareStatement(sql); ps.setString(1, name); ps.setInt(2, mn); ps.setInt(3, rno); if(ps.executeUpdate()>0) System.out.println("Record Updated........."); } else System.out.println("*******Record Not Found**********"); System.out.println("-----------------------------------"); // Connection close con.close(); } catch (SQLException e) { System.out.println(e); } } }