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);
        }
    
    }
    
}