Dao与实体类的封装

一、jdbc工具类封装

package JDBC.Dao;

import java.sql.*;

public class JdbcUtil {
    
    private Connection conn = null;
    private PreparedStatement ps = null;

    static {
    
        try {
    
            //注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
        } catch (ClassNotFoundException e) {
    
            e.printStackTrace();
        }
    }

    //封装conn对象创建
    public Connection createCon() {
    
        try {
    
            conn = DriverManager.getConnection("jdbc:mysql://127.0.0.1:3306/csdb?serverTimezone=UTC", "root", "lh051920");
            System.out.println("conn对象创建成功！");
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
            System.out.println("conn对象创建失败！");
        }
        return conn;
    }

    //封装PreparedStatement对象
    public PreparedStatement createStatement(String sql) {
    
        Connection conn = createCon();
        try {
    
            ps = conn.prepareStatement(sql);
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        }
        return ps;
    }

    //封装销毁
    public void close(ResultSet rs) {
    
        try {
    
            if (rs != null)
                rs.close();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        }
    }

    public void close() {
    
        try {
    
            if (ps != null)
                ps.close();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        }
        try {
    
            if (conn != null)
                conn.close();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        }

    }

}

二、DeptDao的封装

package JDBC.Dao;

import JDBC.entity.Dept;

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

/** * 封装dept表的操作 */
public class DeptDao {
    
    private JdbcUtil util = new JdbcUtil();

    public int add(String deptno, String dname, String loc) {
    
        String sql = "insert into dept (deptno,dname,loc) values(?,?,?)";
        PreparedStatement ps = this.util.createStatement(sql);
        int result = 0;
        try {
    
            ps.setInt(1, Integer.valueOf(deptno));
            ps.setString(2, dname);
            ps.setString(3, loc);
            result = ps.executeUpdate();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        } finally {
    
            util.close();
        }
        return result;
    }

    public int delete(String deptno) {
    
        String sql = "delete from dept where deptno=?";
        PreparedStatement ps = this.util.createStatement(sql);
        int result = 0;
        try {
    
            ps.setInt(1, Integer.valueOf(deptno));
            result = ps.executeUpdate();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        } finally {
    
            util.close();
        }
        return result;
    }

    public int update(String deptno, String dname, String loc) {
    
        String sql = "update dept set dname=?,loc=? where deptno=?";
        PreparedStatement ps = this.util.createStatement(sql);
        int result = 0;
        try {
    
            ps.setString(1, dname);
            ps.setString(2, loc);
            ps.setInt(3, Integer.valueOf(deptno));
            result = ps.executeUpdate();
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        } finally {
    
            util.close();
        }
        return result;
    }

    public List select() {
    
        List list = new ArrayList();
        String sql = "select * from dept";
        ResultSet rs = null;
        PreparedStatement ps = this.util.createStatement(sql);
        try {
    
            rs = ps.executeQuery();
            while (rs.next()) {
    
                int deptno = rs.getInt("deptno");
                String dname = rs.getString("dname");
                String loc = rs.getString("loc");
                list.add(new Dept(deptno, dname, loc));
            }
        } catch (SQLException throwables) {
    
            throwables.printStackTrace();
        } finally {
    
            util.close(rs);
        }
        return list;
    }


}

三、Dept数据表的封装

package JDBC.entity;

//表实体
public class Dept {
    
    private int deptno;
    private String dname;
    private String loc;

    public Dept(int deptno, String dname, String loc) {
    
        this.deptno = deptno;
        this.dname = dname;
        this.loc = loc;
    }

    public Dept() {
    
    }

    public int getDeptno() {
    
        return deptno;
    }

    public void setDeptno(int deptno) {
    
        this.deptno = deptno;
    }

    public String getDname() {
    
        return dname;
    }

    public void setDname(String dname) {
    
        this.dname = dname;
    }

    public String getLoc() {
    
        return loc;
    }

    public void setLoc(String loc) {
    
        this.loc = loc;
    }


}

四、测试代码

package JDBC.Test;

import JDBC.Dao.DeptDao;
import JDBC.entity.Dept;

import java.util.List;
import java.util.Scanner;

public class 部门管理 {
    
    static Scanner in = new Scanner(System.in);

    public static void main(String[] args) {
    
        menu();

    }

    private static void menu() {
    
        int flag;
        String deptno = null;
        String dname = null;
        String loc = null;
        DeptDao dept = new DeptDao();
        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.print("请选择功能：");
        flag = in.nextInt();
        in.nextLine();
        int result = 0;
        switch (flag) {
    
            case 1:
                System.out.print("请输入部门号：");
                deptno = in.nextLine();
                System.out.print("请输入部门名称：");
                dname = in.nextLine();
                System.out.print("请输入地址：");
                loc = in.nextLine();
                result = dept.add(deptno, dname, loc);
                if (result == 1)
                    System.out.println("添加部门成功！");
                else
                    System.out.println("添加部门失败！");
                break;
            case 2:
                System.out.print("请输入部门号：");
                deptno = in.nextLine();
                result = dept.delete(deptno);
                if (result == 1)
                    System.out.println("删除部门成功！");
                else
                    System.out.println("删除部门失败！");
                break;
            case 3:
                System.out.print("请输入部门号：");
                deptno = in.nextLine();
                System.out.print("请输入部门名称：");
                dname = in.nextLine();
                System.out.print("请输入地址：");
                loc = in.nextLine();
                result = dept.update(deptno, dname, loc);
                if (result == 1)
                    System.out.println("修改部门成功！");
                else
                    System.out.println("修改部门失败！");
                break;
            case 4:
                System.out.println("部门编号\t\t部门名称\t\t部门地址");
                List<Dept> list = dept.select();
                for (Dept d : list) {
    
                    System.out.println(d.getDeptno() + "\t\t" + d.getDname() + "\t\t" + d.getLoc());
                }
            case 0:
                break;
        }


    }
}

五、运行结果

=====部门管理系统=====
===1.添加部门========
===2.删除部门========
===3.更新部门========
===4.查询所有部门=====
===0.退出系统========
  
请选择功能：4
部门编号	部门名称		部门地址
10		ACCOUNTING		NEW YORK
20		RESEARCH		DALLAS
30		SALES			CHICAGO
40		OPERATIONS		BOSTON
60		工程部				徐州