Java實現員工管理系統（資料庫儲存版）

阿新 • • 發佈：2019-01-21

需求詳見http://blog.csdn.net/hahaha_sxm/article/details/48169711
這次將儲存方式變為資料庫儲存，相較上文，添加了一個DBConnection類，TestEMD.java重寫（程式碼在下方貼出），另外父類Employee中添加了一個返回工資的方法（用於獲取計算後的工資存於資料庫）：

public Double getSalary(){
        return salary;
    }

先在SQLServer 2008 R2 中新建資料庫名為：“EmployeeManager”，在該資料庫下新建查詢建一個員工表：Employee，屬性為了方便些，都設為verchar(50)不推薦這麼幹,原諒我︿(￣︶￣)︿，順帶把把幾個操作語句也粘上，好久沒動資料庫了，基本的語句都忘了，憋了半天憋出來的。。原諒我︿(￣︶￣)︿。

create table Employee
(  
id varchar(50) primary key,  
name varchar(50) unique,  
position varchar(50),
holiday varchar(50),
salary varchar(50),)
insert into Employee(id,name,position,holiday,salary) values('1','張三','普通員工','3','6700.0')
insert into Employee(id,name,position,holiday,salary) values('2','李四' 
,'普通員工','3','6700.0')
delete from Employee where name='李四';
update Employee set id='1',name='李華',position='普通員工',holiday='3',salary='7555.0' where name='張三'

資料庫建完後第一步，專案中匯入SQLDrive的Jar包。右鍵專案-build path-Configure Build path 彈出的對話方塊選擇Libraries選項卡，點選右方的add External jar 然後選擇你的驅動包點選確定就行。

接下來專案中寫資料庫訪問類DBConnection.java

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

public class DBConnection {
    private static Connection conn = null;
    private static final String classname="com.microsoft.sqlserver.jdbc.SQLServerDriver";
    private static final String url="jdbc:sqlserver://localhost:1433;DatabaseName=EmployeeManager;user=sa;password=123";
    public static Connection getConnection(){
        try {
            Class.forName(classname);
        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        try {
            conn = DriverManager.getConnection(url);
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return conn;
    }
    public static void close(){
        try {
            conn.close();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

接下來就是進入操作類TestEMD.java的編寫了，程式碼如下：

package EmployeeGuanli;

import java.io.IOException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;

public class TestEMD {
    static Scanner sc = new Scanner(System.in);

    public static void caoZuo() {
        System.out.println("----     工資管理系統                  ----");
        System.out.println("-------------------------------");
        System.out.println("---        1     增加                        ---");
        System.out.println("---        2     刪除                        ---");
        System.out.println("---        3     修改                        ---");
        System.out.println("---        4     查詢                        ---");
        System.out.println("---        0     退出                        ---");
        System.out.println("-------------------------------");
        System.out.println("請輸入你要選擇的操作：");
        String s = sc.next();
        switch (s) {
        case "1":
            try {
                try {
                    addEmployee();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            } catch (IOException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            break;
        case "2":
            try {
                try {
                    delEmployee();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            break;
        case "3":
            try {
                try {
                    updateEmployee();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            break;
        case "4":
            try {
                queryEmployee();
            } catch (SQLException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            break;
        case "0":
            System.out.println("謝謝使用O(∩_∩)O");
            break;
        default:
            System.out.println("指令錯誤請重新輸入！");
            caoZuo();
            break;
        }

    }

    public static void addEmployee() throws IOException, SQLException {
        Connection conn=DBConnection.getConnection();
        String sql="insert into Employee(id,name,position,holiday,salary) values(?,?,?,?,?)";
        PreparedStatement ps=null;
        ps=conn.prepareStatement(sql);
        System.out.println("------增加員工------");
        System.out.println("請輸入相關資訊：");
        System.out.print("ID：");
        String id = sc.next();
        System.out.print("姓名:");
        String name = sc.next();
        System.out.print("職務:");
        String position = sc.next();
        System.out.print("請假天數:");
        int holiday = sc.nextInt();
        System.out.print("基本工資:");
        double salary = sc.nextInt();
        switch (position) {
        case "普通員工":
            Employee a = new CommonEmployee();
            a.ID = id;
            a.name = name;
            a.position = "普通員工";
            a.holiday = holiday;
            a.salary = salary;
            a.sumSalary();
            ps.setString(1,""+id);
            ps.setString(2, name);
            ps.setString(3, position);
            ps.setString(4, ""+holiday);
            ps.setString(5, ""+a.getSalary());
            ps.executeUpdate();
            ps.close();
            conn.close();
            System.out.println("新增成功");
            break;
        case "經理":
            Employee b = new Manager();
            b.ID = id;
            b.name = name;
            b.position = "經理";
            b.holiday = holiday;
            b.salary = salary;
            b.sumSalary();
            ps.setString(1,""+id);
            ps.setString(2, name);
            ps.setString(3, position);
            ps.setString(4, ""+holiday);
            ps.setString(5, ""+b.getSalary());
            ps.executeUpdate();
            ps.close();
            conn.close();
            System.out.println("新增成功！");
            break;
        case "董事長":
            Employee c = new Director();
            c.ID = id;
            c.name = name;
            c.position = "董事長";
            c.holiday = holiday;
            c.salary = salary;
            c.sumSalary();
            ps.setString(1,""+id);
            ps.setString(2, name);
            ps.setString(3, position);
            ps.setString(4, ""+holiday);
            ps.setString(5, ""+c.getSalary());
            ps.executeUpdate();
            ps.close();
            conn.close();
            System.out.println("新增成功！");
            break;
        default:
            System.out.println("不存在此職務，請重新輸入！");
            ps.close();
            conn.close();
            addEmployee();
            break;
        }
        caoZuo();
    }

    public static void delEmployee() throws IOException, SQLException {
        System.out.println("----------刪除員工---------");
        System.out.println("請輸入員工姓名：");
        String n = sc.next();
        Connection conn=DBConnection.getConnection();
        String sql="select * from Employee";
        PreparedStatement ps=conn.prepareStatement(sql);
        ResultSet rs=ps.executeQuery();
        Boolean flag=false;
        while(rs.next()){
            String s=rs.getString("name");
            if(n.equals(s)){
                System.out.println("你要刪除的是:");
                System.out.println(rs.getString(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3)+"\t\t"+rs.getString(4)+"\t"+rs.getString(5));
                flag=true;
                System.out.println("你確定要刪除嗎？\n [Y]確定，[N]取消");
            }
        }
        if(!flag){
            System.out.println("你輸入的使用者名稱不存在！請重新輸入！");
            rs.close();
            ps.close();
            conn.close();
            delEmployee();
        }
        String shifou=sc.next();
        if(shifou.equals("y")){
            rs.close();
            ps.close();;
            String sql2="delete from Employee where name=?";
            PreparedStatement ps2=conn.prepareStatement(sql2);
            ps2.setString(1, n);
            Boolean bo=ps2.execute();
            if(!bo){
                System.out.println("刪除成功！");
            }else{
                System.out.println("刪除失敗！");
            }
            ps2.close();
            conn.close();
            caoZuo();
        }else if(shifou.equals("n")){
            System.out.println("已取消刪除！");
            rs.close();
            ps.close();
            conn.close();
            caoZuo();
        }
    }

    public static void updateEmployee() throws IOException, SQLException {
        System.out.println("--------------修改員工資料-------------");
        System.out.println("請輸入你要修改的姓名：");
        String s = sc.next();
        Connection conn=DBConnection.getConnection();
        String sql="select * from Employee";
        PreparedStatement ps=conn.prepareStatement(sql);
        ResultSet rs=ps.executeQuery();
        Boolean flag=false;
        while(rs.next()){
            String nn=rs.getString("name");
            if(nn.equals(s)){
                System.out.println("你要修改的是:");
                System.out.println(rs.getString(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3)+"\t\t"+rs.getString(4)+"\t"+rs.getString(5));
                flag=true;
            }
        }
        if(!flag){
            System.out.println("你輸入的使用者名稱不存在！請重新輸入！");
            rs.close();
            ps.close();
            conn.close();
            delEmployee();
        }
        rs.close();
        ps.close();
        String sql2="update Employee set id=?,name=?,position=?,holiday=?,salary=? where name=?";
        PreparedStatement ps2=conn.prepareStatement(sql2);
        System.out.println("請重新輸入相關資訊：");
        System.out.print("ID：");
        String id = sc.next();
        System.out.print("姓名:");
        String name = sc.next();
        System.out.print("職務:");
        String position = sc.next();
        System.out.print("請假天數:");
        int holiday = sc.nextInt();
        System.out.print("基本工資:");
        double salary = sc.nextDouble();
        switch (position) {
        case "普通員工":
                Employee a = new CommonEmployee();
                a.ID = id;
                a.name = name;
                a.position = "普通員工";
                a.holiday = holiday;
                a.salary = salary;
                a.sumSalary();
                ps2.setString(1, id);
                ps2.setString(2, name);
                ps2.setString(3, position);
                ps2.setString(4, ""+holiday);
                ps2.setString(5, ""+a.getSalary());
                ps2.setString(6, s);
                ps2.executeUpdate();
                ps2.close();
                conn.close();
                System.out.println("修改成功！");
                a.display();
                caoZuo();
            break;
        case "經理":
                Employee b = new Manager();
                b.ID = id;
                b.name = name;
                b.position = "經理";
                b.holiday = holiday;
                b.salary = salary;
                b.sumSalary();
                ps2.setString(1, id);
                ps2.setString(2, name);
                ps2.setString(3, position);
                ps2.setString(4, ""+holiday);
                ps2.setString(5, ""+b.getSalary());
                ps2.setString(6, s);
                ps2.executeUpdate();
                ps2.close();
                conn.close();
                System.out.println("修改成功！");
                b.display();
                caoZuo();
            break;
        case "董事長":
                Employee c = new Director();
                c.ID = id;
                c.name = name;
                c.position = "董事長";
                c.holiday = holiday;
                c.salary = salary;
                c.sumSalary();
                ps2.setString(1, id);
                ps2.setString(2, name);
                ps2.setString(3, position);
                ps2.setString(4, ""+holiday);
                ps2.setString(5, ""+c.getSalary());
                ps2.setString(6, s);
                ps2.executeUpdate();
                ps2.close();
                conn.close();
                System.out.println("新增成功！");
                c.display();
                 caoZuo();
            break;
        default:
            System.out.println("不存在此職務，請重新輸入！");
            ps2.close();
            conn.close();
            updateEmployee();
            break;
        }
    }

    public static void queryEmployee() throws SQLException {
        System.out.println("--------------所有員工資訊---------------");
        Connection conn=DBConnection.getConnection();
        String sql="select * from Employee";
        PreparedStatement ps=conn.prepareStatement(sql);
        ResultSet rs=ps.executeQuery();
        while(rs.next()){
            System.out.println(rs.getString(1)+"\t"+rs.getString(2)+"\t"+rs.getString(3)+"\t\t"+rs.getString(4)+"\t"+rs.getString(5));
        }
        rs.close();
        ps.close();
        conn.close();
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        caoZuo();
    }

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        TestEMD.caoZuo();
    }

}

Java實現員工管理系統（資料庫儲存版）

Java實現員工管理系統（資料庫儲存版）

基於JAVA的圖書管理系統（jsp+mysql+tomcat）

linux專案 -- 圖書管理系統（連結串列版）

學生成績管理系統（簡易本地版）

學生管理系統（SSM簡易版）總結

資料結構課程設計【學生資訊管理系統（煙大版）】

利用C語言簡單的實現庫存管理系統（本地檔案生成形式儲存）

[java原始碼] Java Web 文章管理系統（Jsp+Ajax+JDBC+MySql實現）

使用集合（ArrayList，HashMap等做對比）實現員工管理系統案例

JAVA語言實現簡單的學生成績管理系統（總分+平均分+排名）

基於JavaEE（SSH）實現員工管理系統案例

Java swing實現圖書管理系統（高階版）

java構建學生管理系統（一）

利用nodejs實現商品管理系統（二）

如何寫一個完整課堂管理系統（資料庫增刪改查）

linux專案 --- 圖書管理系統（資料庫版）

java+SQL做學生資訊管理系統（增刪改查）學生新作

基於java的圖書管理系統（英文）

學生管理系統（資料庫版本）（sqlite3版本）；淺析資料庫的基礎用法及實際操作

員工管理系統（C 語言）——伺服器解析

Java實現員工管理系統（資料庫儲存版）

相關推薦