JDBC分析按部门查询员工功能

本篇博客主要是观察其接口和类的组织方式和套路；然后分析JDBC的第3，第4，第5步骤；

首先：创建HumanResourceApplication类；作为入口类；

这个类作为入口类，接受键盘输入，然后根据输入去调用其他类中定义的方法；

    package com.imooc.jdbc.hrapp;
 
    import com.imooc.jdbc.command.Command;
    import com.imooc.jdbc.command.QueryCommand;
 
    import java.util.Scanner;
 
    public class HumanResourceApplication {
        public static void main(String[] args) {
            System.out.println("1-查询部门员工");
            Scanner in = new Scanner(System.in);
            Integer cmd = in.nextInt();
            switch (cmd){
                case 1: //查询部门员工
                    Command command = new QueryCommand();
                    command.execute();
            }
        }
    }

然后，定义一个Command接口；注意这种使用接口的编程的组织方式和套路；

    package com.imooc.jdbc.command;
 
    public interface Command {
        public void execute();
    }

最后，编写接口的实现类：QueryCommand类，去具体实现接口的功能

    package com.imooc.jdbc.command;
 
    import java.sql.*;
    import java.util.Scanner;
 
    public class QueryCommand implements Command {
 
        @Override
        public void execute() {
            System.out.println("请输入部门名称");
            Scanner sc = new Scanner(System.in);
            String pdname = sc.next();
            // 将这三个对象拿到外边，扩大其生命周期；同时这三个对象都内置了close()方法；
            Connection conn = null;
            Statement stmt = null;
            ResultSet rs = null;
            try {
                // 1.加载并注册JDBC驱动
                Class.forName("com.mysql.cj.jdbc.Driver");
                // 2.创建数据库连接
                conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/imooc?useSSL=false&useUincode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true", "root", "12345");
                // 3.创建Statement对象
                stmt = conn.createStatement();
                // 结果集
                rs = stmt.executeQuery("select  * from employee where dname='"+pdname+"'");
                // 4.遍历查询结果
                // next()方法返回一个Boolean值，代表是否存在下一条记录；这个结果集有点迭代器的赶脚；
                // 如果有，返回true，同时结果集提取下一条记录
                // 如果没有，返回false，循环就会停止；
                // 默认，在开始执行下面的循环之前，结果集定位在第一条记录之前；；当循环时，就会尝试获取第一条记录，如果有返回true，
                // 就会把第一条记录提取出来，然后在循环体中进行读取；如果没有直接跳出。
                while (rs.next()) {
                    Integer eno = rs.getInt(1);
                    String ename = rs.getString("ename");
                    Float salary = rs.getFloat("salary");
                    String dname = rs.getString("dname");
                    System.out.println(dname + "-" + eno + "-" + ename + "-" + salary);
                }
 
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }finally {
                // 5.关闭连接，释放资源
                // 这儿演示了对所有资源的完整释放，以后在实际开发中，只写【conn.close();】是没问题的，因为物理连接一旦断开，所有的资源一定会被自动的释放；
                // 这儿之所以三个都写出来了，主要目的是要明白这背后的完全体是什么样子的；
                // 下面三个关闭都可能抛出SQLException，分别使用try块对其进行了处理；
                try {
                    if (rs != null) {  // 如果rs != null，代表rs被实例化了，所以这儿需要关闭一下，进行释放；
                        rs.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                try {
                    if (stmt != null) {  // 如果rs != null，代表stmt被实例化了，所以这儿需要关闭一下，进行释放；
                        stmt.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
                try {
                    if (conn != null && conn.isClosed() == false) {  // conn.isClosed()==false代表这个连接还没有关闭，还正在使用中；
                        conn.close();
                    }
                } catch (SQLException e) {
                    e.printStackTrace();
                }
 
            }
        }
    }