JAVA對數據庫進行操作，實現數據庫中數據的插入，查詢，更改，刪除操作

（—）通過mysql workbench 創建一個數據庫，在這里命名為company，然后建一個tb_employee表

（二）以下是java代碼對表tb_employee的操作

1 創建一個Employee類，包括員工的一些信息，如  id  name age sex

2創建DatabaseConnection類，用於數據庫的連接

3創建一個EmployeeOperation類，用於操作數據庫，它里面包括了 以下方法

（1）getInstance()   //返回EmployeeOperation類實例的靜態方法

（2）saveEmployee(Employee emp)   //向數據庫中加入數據

（3）selectEmployee()        //從數據庫中查詢所需數據

（4）updateEmployee(Employee emp)  //根據員工的編號更改員工的年齡信息

（5）deleteEmployeeById(Employee emp)  //根據員工id刪除員工

4創建測試類

 

各個類的代碼如下

package 數據庫_向數據庫插入數據;
//盡量將屬性定義為私有的，寫出對應的setXXX和getXXX的方法
public class Employee {
    private int empId;
    private String empName;
    private int empAge;
    private String empSex;
    
    public Employee(){}
    
    public int getEmpId() {
        return this.empId;
    }
    public void setEmpId(int id) {
        this.empId = id;
    }
    
    public String getEmpName() {
        return this.empName;
    }
    public void setEmpName(String name) {
        this.empName = name;
    }
    
    public int getEmpAge() {
        return this.empAge; 
    }
    public void setEmpAge(int age) {
        this.empAge = age;
    }
    
    public String getEmpSex() {
        return this.empSex;
    }
    public void setEmpSex(String sex) {
        this.empSex = sex;
    }

}

 

 

package 數據庫_向數據庫插入數據;

import java.sql.Connection;
import java.sql.DriverManager;

public class DatabaseConnection {
    private static Connection conn = null;
    public static Connection getCon() {
        try {
            Class.forName("com.mysql.jdbc.Driver"); //加載數據庫連接驅動
            String user = "root";
            String psw = "XXX";  //XXX為自己的數據庫的密碼
            String url = "jdbc:mysql://localhost:3306/ZZZ";                   //ZZZ為連接的名字
            conn = DriverManager.getConnection(url, user, psw);  //獲取連接
        } catch (Exception e) {
            System.out.println("連接數據庫失敗");
            e.printStackTrace();
        }
        return conn;
    }

}

 

package 數據庫_向數據庫插入數據;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

//EmployeeOperation類用於操作數據庫，單例模式。
public class EmployeeOperation {
    private static  EmployeeOperation instance = new EmployeeOperation();
    
    public static EmployeeOperation getInstance() { 20         return instance;
    }
    
　　　　 private EmployeeOperation() {
        }
    public boolean saveEmployee(Employee emp) {   //向數據庫中加入數據
        boolean result = false;
        Connection conn = null;
        try {
            
        conn = DatabaseConnection.getCon();  //建立數據庫連接
        String sqlInset = "insert into company.tb_employee(empId, empName, empAge, empSex) values(?, ?, ?, ?)";
        PreparedStatement stmt = conn.prepareStatement(sqlInset);   //會拋出異常
        
        stmt.setInt(1, emp.getEmpId());         //設置SQL語句第一個“？”的值
        stmt.setString(2, emp.getEmpName());    //設置SQL語句第二個“？”的值
        stmt.setInt(3, emp.getEmpAge());        //設置SQL語句第三個“？”的值
        stmt.setString(4, emp.getEmpSex());     //設置SQL語句第四個“？”的值
        int i = stmt.executeUpdate();            //執行插入數據操作，返回影響的行數
        if (i == 1) {
            result = true;
        }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } finally { //finally的用處是不管程序是否出現異常，都要執行finally語句，所以在此處關閉連接
            try {
                conn.close(); //打開一個Connection連接后，最后一定要調用它的close（）方法關閉連接，以釋放系統資源及數據庫資源
            } catch(SQLException e) {
                e.printStackTrace();
            }
        }
        
        return result;
        
    }
    
    
    public List<Employee> selectEmployee() {       //從數據庫中查詢所需數據
        List<Employee> empList = new ArrayList<Employee>();
        Connection conn = null;
        try {
            conn = DatabaseConnection.getCon();
            Statement stmt = conn.createStatement();
            ResultSet rs = stmt.executeQuery("select * from company.tb_employee");//執行SQL並返回結果集
            while (rs.next()) {
                Employee emp = new Employee();
                emp.setEmpId(rs.getInt("empId"));   //從結果集rs中獲取內容時，若為字符串類型的，用rs.getString("string")方法
                emp.setEmpName(rs.getString("empName"));   //其中str為想要從    數據庫的    表    中獲取的信息
                emp.setEmpAge(rs.getInt("empAge"));  //若為int類型，用rs.getInt(number);
                emp.setEmpSex(rs.getString("empSex"));
                empList.add(emp);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();                                         //關閉連接
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return empList;                                             //返回結果
    }
    
    
    public boolean updateEmployee(Employee emp) { //根據員工的編號更改員工的年齡信息
        boolean result = false;
        Connection conn = null;
        try {
            conn = DatabaseConnection.getCon();
            String sql = "update company.tb_employee set empAge=? where empId=?";  //update語句
            PreparedStatement stmt = conn.prepareStatement(sql);
            stmt.setInt(1, emp.getEmpAge());                //設置SQL語句第一個"?"的參數值
            stmt.setInt(2, emp.getEmpId());                    //設置SQL語句第二個"?"的參數值    
            int flag = stmt.executeUpdate();                //執行修改操作，返回影響的行數
            if (flag == 1) {                                //修改成功返回true
                result = true;
            }
        } catch(Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return result;
    }
    
    public boolean deleteEmployeeById(Employee emp) {
        boolean result = false;
        Connection conn = null;
        try {
            conn = DatabaseConnection.getCon();
            String sql = "delete from company.tb_employee where empId = ?";
            PreparedStatement stmt = conn.prepareStatement(sql);
            stmt.setInt(1, emp.getEmpId());
            int i = stmt.executeUpdate();
            if (i == 1) {
                result = true;
            } 
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                conn.close();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
        return result;
    }

}

 

package 數據庫_向數據庫插入數據;

public class MainTest {
    public static void main(String[] args) {    //測試向數據庫的表中插入元素的方法
        Employee emp = new Employee();
        emp.setEmpId(2);
        emp.setEmpName("LILEI");
        emp.setEmpAge(33);
        emp.setEmpSex("male");
        boolean res = EmployeeOperation.getInstance().saveEmployee(emp);
        if (res == true) {
            System.out.println("向company.tb_employee表中插入數據成功");
        } else {
            System.out.println("向company.tb_employee表中插入數據失敗");
        }
    }

}

 

package 數據庫_向數據庫插入數據;

import java.util.List;

public class SelectMainTest {     //測試從數據庫中獲取數據的方法
    public static void main(String[] args) {
        List<Employee> empList = EmployeeOperation.getInstance().selectEmployee();
        System.out.println("員工ID\t員工姓名\t員工年齡\t員工性別");
        for (Employee emp : empList) {
            System.out.print(emp.getEmpId() + "\t" + emp.getEmpName() + "\t" + emp.getEmpAge() + "\t" + emp.getEmpSex());
            System.out.println();
        }
    }

}

 

 

package 數據庫_向數據庫插入數據;

import java.util.List;

public class UpdateMainTest {    //根據員工的id修改員工年齡的方法
    public static void main(String[] args) {
        List<Employee> empList = EmployeeOperation.getInstance().selectEmployee();
        System.out.println("員工ID");
        for (Employee emp : empList) {
            System.out.println(emp.getEmpId());
        }
        Employee emp = new Employee();
        emp.setEmpId(2);
        emp.setEmpAge(50);
        boolean res = EmployeeOperation.getInstance().updateEmployee(emp);
        if (res) {
            System.out.println("編號為2的員工的年齡修改成功");
        } else {
            System.out.println("編號為2的員工的年齡修改失敗");
        }
        
    }

}

 

package 數據庫_向數據庫插入數據;

public class DeleteMainTest {
    public static void main(String[] args) {   //測試刪除對應id的員工的方法
        Employee emp = new Employee();
        emp.setEmpId(1);
        boolean res = EmployeeOperation.getInstance().deleteEmployeeById(emp);
        if (res) {
            System.out.println("成功刪除id為1的員工");
        } else {
            System.out.println("未能成功刪除id為1的員工");
        }
    }

}

 

以上代碼經個人親測，想要運行上述代碼的同學注意一下

1 DatabaseConnection類中用戶名和密碼要改一下，

2 在數據庫中建立的表的名字 以及表的各個列的名字需要一致

3 在JAVA工程中要引入 mysql-connector-java-5.1.34-bin.jar，如下圖所示