JAVA MySQL Create Read Update Delete CRUD Project

 I have shown how to create a Java Project which can do Create Read Update Delete Operations.

First create a new database ‘crud’ in Mysql. Then create a table ‘user’

1. CREATE TABLE `user` (
   	`sl_no` INT(5) NULL DEFAULT NULL,
   	`name` VARCHAR(100) NULL DEFAULT NULL,
   	`email` VARCHAR(100) NULL DEFAULT NULL
   )
   COLLATE='latin1_swedish_ci'
   ENGINE=InnoDB
   ;
   

2. Project Structure in Eclipse IDE

3. Connection Class to get connection with MySql
   DB_Connection.java

   package CRUD;
   import java.sql.Connection;
   import java.sql.DriverManager;
   public class DB_Connection {
   public static void main(String[] args) {
     DB_Connection obj_DB_Connection=new DB_Connection();
     System.out.println(obj_DB_Connection.get_connection());
   }
   public Connection get_connection(){
    Connection connection=null;
   try {
     Class.forName("com.mysql.jdbc.Driver");              
     connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/crud","root", "root");
   } catch (Exception e) {
     System.out.println(e);
   }
     return connection;
   }
   }
   

4. CRUD_Test.java

   package CRUD;
   import java.sql.Connection;
   import java.sql.PreparedStatement;
   import java.sql.ResultSet;
   public class CRUD_Test {
   
   public static void main(String[] args) {
   	CRUD_Test objTest=new CRUD_Test();
           //insert data
   	objTest.create_data("1", "jinu", "jinu@gmail.com");
   	objTest.create_data("2", "jawad", "jawad@gmail.com");
           //read data
   	objTest.read_data("2");
           //update data
   	objTest.update_data("2", "22", "jawad2", "jawad2@gmail");
           //delete data
   	objTest.delete_data("1");
   }
   
   public void create_data(String sl_no,String name,String email){
   	DB_Connection obj_DB_Connection=new DB_Connection();
   	Connection connection=obj_DB_Connection.get_connection();
   	PreparedStatement ps=null;
   	try {
   		String query="insert into user(sl_no,name,email) values (?,?,?)";
   		ps=connection.prepareStatement(query);
   		ps.setString(1, sl_no);
   		ps.setString(2, name);
   		ps.setString(3, email);
   		System.out.println(ps);
   		ps.executeUpdate();
   	} catch (Exception e) {
   		System.out.println(e);
   	}
   }
   
   public void read_data(String sl_no){
   	DB_Connection obj_DB_Connection=new DB_Connection();
   	Connection connection=obj_DB_Connection.get_connection();
   	PreparedStatement ps=null;
   	ResultSet rs=null;
   	try {
   		String query="select * from user";
   		ps=connection.prepareStatement(query);
   		//ps.setString(1, sl_no);
   		System.out.println(ps);
   		rs=ps.executeQuery();
   		while(rs.next()){
   		System.out.println("Sl no -"+rs.getString("sl_no"));
   		System.out.println("name -"+rs.getString("name"));
   		System.out.println("email -"+rs.getString("email"));
   		System.out.println("---------------");
   		}
   	} catch (Exception e) {
   		System.out.println(e);
   	}
   }
   
   public void update_data(String sl_no,String new_sl_no,String name,String email){
   	DB_Connection obj_DB_Connection=new DB_Connection();
   	Connection connection=obj_DB_Connection.get_connection();
   	PreparedStatement ps=null;
   	try {
   		String query="update user set sl_no=?,name=?,email=? where sl_no=?";
   		ps=connection.prepareStatement(query);
   		ps.setString(1, new_sl_no);
   		ps.setString(2, name);
   		ps.setString(3, email);
   		ps.setString(4, sl_no);
   		System.out.println(ps);
   		ps.executeUpdate();
   	} catch (Exception e) {
   		System.out.println(e);
   	}
   }
   
   public void delete_data(String sl_no){
   	DB_Connection obj_DB_Connection=new DB_Connection();
   	Connection connection=obj_DB_Connection.get_connection();
   	PreparedStatement ps=null;
   	try {
   		String query="delete from user where sl_no=?";
   		ps=connection.prepareStatement(query);
   		ps.setString(1, sl_no);
   		System.out.println(ps);
   		ps.executeUpdate();
   	} catch (Exception e) {
   		System.out.println(e);
   	}
   
   }
   }