Database Table
CREATE TABLE employeeList(empid int not null primary key auto_increment, empname varchar(255), salary double);
Bean Class
package com.javadb2.mugil.employee; public class bean { private int empId; private String empName; private double empSalary; public int getEmpId() { return empId; } public void setEmpId(int empId) { this.empId = empId; } public String getEmpName() { return empName; } public void setEmpName(String empName) { this.empName = empName; } public double getEmpSalary() { return empSalary; } public void setEmpSalary(double empSalary) { this.empSalary = empSalary; } }
Crud Operation with Bean Class
package com.javadb2.mugil.employee; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import com.javadb2.mugil.db.display; import com.mysql.jdbc.PreparedStatement; import com.mysql.jdbc.Statement; public class insert { public static void main(String[] args) { bean objBean = new bean(); objBean.setEmpName(display.getInput("Enter the Employee Name")); objBean.setEmpSalary(Integer.parseInt(display.getInput("Enter Salary"))); boolean result = getInsertedKey(objBean); if(result) { System.out.println("The Last Inserted Primary Key is "+objBean.getEmpId()); } } public static boolean getInsertedKey(bean objBean) { ResultSet keys = null; String strSQL = "INSERT INTO employeeList(empname, salary)VALUES(?,?)"; try { Connection conn = getConnection(); PreparedStatement stmt = (PreparedStatement) conn.prepareStatement(strSQL, Statement.RETURN_GENERATED_KEYS); stmt.setString(1, objBean.getEmpName()); stmt.setDouble(2, objBean.getEmpSalary()); int affected = stmt.executeUpdate(); if(affected == 1) { keys = stmt.getGeneratedKeys(); keys.next(); int newkey = keys.getInt(1); objBean.setEmpId(newkey); } else { System.err.println("Unable to Update Values"); return false; } } catch (SQLException e) { processException(e); System.err.println("Error in Establishing Connection"); } return true; } public static Connection getConnection() throws SQLException { Connection conn = DriverManager.getConnection("jdbc:mysql://localhost/test", "root", "pass"); return conn; } public static void processException(SQLException e) { System.err.println("Error Message "+e.getMessage()); System.err.println("Error Code"+e.getErrorCode()); System.err.println("SQL State"+e.getSQLState()); } }