Java基础学习笔记二十八 管家婆综合项目

package cn.itcast.gjp.tools;
/*
 *  使用DBCP实现数据库的连接池
 *  连接池配置,自定义类,
 *  最基本四项完整
 *  对于数据库连接池其他配置,自定义
 */

import org.apache.commons.dbcp.BasicDataSource;
import javax.sql.DataSource;

public class JDBCUtils {
    //创建出BasicDataSource类对象
    private static BasicDataSource datasource = new BasicDataSource();

    //静态代码块,对象BasicDataSource对象中的配置,自定义
    static {
        //数据库连接信息,必须的
        datasource.setDriverClassName("com.mysql.jdbc.Driver");
        datasource.setUrl("jdbc:mysql://localhost:3306/gjp");
        datasource.setUsername("root");
        datasource.setPassword("123456");
        //对象连接池中的连接数量配置,可选的
        datasource.setInitialSize(10);//初始化的连接数
        datasource.setMaxActive(8);//最大连接数量
        datasource.setMaxIdle(5);//最大空闲数
        datasource.setMinIdle(1);//最小空闲
    }

    //定义静态方法,返回BasicDataSource类的对象
    public static DataSource getDataSource() {
        return datasource;
    }
}

package cn.itcast.gjp.app;

/**
 * 程序入口
 */
public class MainApp {
    public static void main(String[] args) {
        
    }
}

package cn.itcast.gjp.domain;

public class ZhangWu {
    private int  zwid;
    private String flname;
    private double  money;
    private String zhanghu;
    private String createtime;
    private String description;

    public ZhangWu(int zwid, String flname, double money, String zhanghu, String createtime, String description) {
        this.zwid = zwid;
        this.flname = flname;
        this.money = money;
        this.zhanghu = zhanghu;
        this.createtime = createtime;
        this.description = description;
    }
    public ZhangWu() {

    }
    @Override
    public String toString() {
        return "Zhangwu [zwid=" + zwid + ", flname=" + flname + ", money=" + money + ", zhanghu=" + zhanghu
                + ", createtime=" + createtime + ", description=" + description + "]";
    }
    public int getZwid() {
        return zwid;
    }
    public void setZwid(int zwid) {
        this.zwid = zwid;
    }
    public String getFlname() {
        return flname;
    }
    public void setFlname(String flname) {
        this.flname = flname;
    }
    public double getMoney() {
        return money;
    }
    public void setMoney(double money) {
        this.money = money;
    }
    public String getZhanghu() {
        return zhanghu;
    }
    public void setZhanghu(String zhanghu) {
        this.zhanghu = zhanghu;
    }
    public String getCreatetime() {
        return createtime;
    }
    public void setCreatetime(String createtime) {
        this.createtime = createtime;
    }
    public String getDescription() {
        return description;
    }
    public void setDescription(String description) {
        this.description = description;
    }
}

package cn.itcast.gjp.dao;

import cn.itcast.gjp.tools.JDBCUtils;
import org.apache.commons.dbutils.QueryRunner;

/**
 *  实现对数据表 gjp_zhangwu 数据增删改查操作
 *  dbuils工具类完成,类成员创建QueryRunner对象,指定数据源
 **/
public class ZhangWuDao {
    private QueryRunner qr = new QueryRunner(JDBCUtils.getDataSource());
}

package cn.itcast.gjp.service;

import cn.itcast.gjp.dao.ZhangWuDao;

/**
 *  业务层类
 *  接收上一层,控制层controller的数据
 *  经过计算,传递给dao层,操作数据库
 *  调用dao层中的类,类成员位置,创建Dao类的对象
 */
public class ZhangWuService {
    private ZhangWuDao dao = new ZhangWuDao();
}

package cn.itcast.gjp.view;

import cn.itcast.gjp.service.ZhangWuService;

/*
 *  视图层,用户看到和操作的界面
 */
public class MainView {
    private ZhangWuService service = new ZhangWuService();
}

/*
     *  实现界面效果
     *  接收用户的输入
     *  根据数据,调用不同的功能方法
     */
    public void run(){
        //创建Scanner类对象,反复键盘输入
        Scanner sc = new Scanner(System.in);
        while(true){
            System.out.println("---------------管家婆家庭记账软件---------------");
            System.out.println("1.添加账务　2.编辑账务　3.删除账务　4.查询账务　5.退出系统");
            System.out.println("请输入要操作的功能序号[1-5]:");
            //接收用户的菜单选择
            int choose = sc.nextInt();
            //对选择的菜单判断,调用不同的功能
            switch(choose){
            case 1:
               // 选择添加账务,调用添加账务的方法
                addZhangWu();
                break;
            case 2:
                // 选择的编辑账务,调用编辑账务方法
                editZhangWu();
                break;
            case 3:
                // 选择的删除账务,调用删除账务方法
                deleteZhangWu();
                break;
            case 4:
                // 选择的是查询账务,调用查询方法
                selectZhangWu();
                break;
            case 5:
                System.exit(0);
                break;
            }
        }
    }

/*
     * 定义方法 selectZhangWu()
     * 显示查询的方式 1 所有查询   2 条件查询
     * 接收用户的选择
     */
     public void selectZhangWu(){
         System.out.println("1. 查询所有    2. 条件查询");
         Scanner sc = new Scanner(System.in);
         int selectChooser = sc.nextInt();
         //判断根据用户的选择,调用不同的功能
         switch(selectChooser){
         case 1:
             //选择的查询所有,调用查询所有的方法
             selectAll();
             break;
         case 2:
             //选的条件查询,调用带有查询条件的方法
             select();
             break;
         }
     }

 /*
     * 定义方法,实现查询所有的账务数据
     */
    public void selectAll(){
        //调用控制层中的方法,查询所有的账务数据
        List<ZhangWu> list = service.selectAll();
        if(list.size()!=0)
            print(list);
        else
            System.out.println("没有查询到数据");
    }

    //输出账务数据方法,接收List集合,遍历集合,输出表格
    private void print(List<ZhangWu> list) {
        //输出表头
        System.out.println("ID\t\t类别\t\t账户\t\t金额\t\t时间\t\t说明");
        //遍历集合,结果输出控制台
        for(ZhangWu zw : list){
            System.out.println(zw.getZwid()+"\t\t"+zw.getFlname()+"\t\t"+zw.getZhanghu()+"\t\t"+
                    zw.getMoney()+"\t\t"+zw.getCreatetime()+"\t"+zw.getDescription());
        }
    }

/*
     *  定义方法,实现查询所有的账务数据
     *  此方法,由控制层调用, 去调用dao层的方法
     *  返回存储ZhangWu对象的List集合
     */
    public List<ZhangWu> selectAll(){
        return dao.selectAll();
    }

/*
     * 定义方法,查询数据库,获取所有的账务数据
     * 方法,由业务层调用
     * 结果集,将所有的账务数据,存储到Bean对象中,存储到集合中
     */
    public List<ZhangWu> selectAll(){
        try{
            //查询账务数据的SQL语句
            String sql = "SELECT * FROM gjp_zhangwu";
            //调用qr对象的方法,query方法,结果集BeanListHandler
            List<ZhangWu> list = qr.query(sql, new BeanListHandler<>(ZhangWu.class));
            return list;
        }catch(SQLException ex){
            System.out.println(ex);
            throw new RuntimeException("查询所有账务失败");
        }
    }

 /*
     * 定义方法,实现条件查询账务数据
     * 提供用户的输入日期,开始日期结束日期
     * 就2个日期,传递到controller层
     * 调用controller的方法,传递2个日期参数
     * 获取到controller查询的结果集,打印出来
     */
    public void select(){
        System.out.println("选择条件查询,输入日期格式XXXX-XX-XX");
        Scanner sc = new Scanner(System.in);
        System.out.print("请输入开始日期:");
        String startDate = sc.nextLine();
        System.out.print("请输入结果日期:");
        String endDate = sc.nextLine();
        //调用controller层的方法,传递日期,获取查询结果集
        List<ZhangWu> list = service.select(startDate, endDate);
        if(list.size()!=0)
            print(list);
        else
            System.out.println("没有查询到数据");
    }

/*
     * 定义方法,实现条件查询账务
     * 方法由控制层调用,传递2个日期字符串
     * 调用dao层的方法,传递2个日期字符串
     * 获取到查询结果集
     */
    public List<ZhangWu> select(String startDate,String endDate){
        return dao.select(startDate, endDate);
    }

/*
     * 定义方法,查询数据库,带有条件去查询账务表
     * 由业务层调用,查询结果集存储到Bean对象,存储到List集合
     * 调用者传递2个日期字符串
     */
    public List<ZhangWu> select(String startDate,String endDate){
        try{
            //拼写条件查询的SQL语句
            String sql = "SELECT * FROM gjp_zhangwu WHERE createtime BETWEEN ? AND ?";
            //定义对象数组,存储?占位符
            Object[] params = {startDate,endDate};
            //调用qr对象的方法query查询数据表,获取结果集
            return qr.query(sql, new BeanListHandler<>(ZhangWu.class),params);
        }catch(SQLException ex){
            System.out.println(ex);
            throw new RuntimeException("条件查询失败");
        }
    }

/*
     * 定义方法addZhangWu
     * 添加账务的方法，用户在界面中选择菜单1的时候调用、
     * 实现思想：
     *       接收键盘输入，5项输入，调用controller层方法
     */
    public void addZhangWu() {
        System.out.println("选择的添加账务功能，请输入以下内容");
        Scanner sc = new Scanner(System.in);
        System.out.println("输入分类名称");
        String flname = sc.next();
        System.out.println("输入金额");
        double money = sc.nextDouble();
        System.out.println("输入账户");
        String zhanghu = sc.next();
        System.out.println("输入日期：格式XXXX-XX-xx");
        String createtime = sc.next();
        System.out.println("输入具体描述");
        String description = sc.next();
        //将接收到的数据，调用controller层的方法，传递参数，实现数据添加
        //将用户输入的所有参数，封装成ZhangWu对象
        ZhangWu zw = new ZhangWu(0, flname, money, zhanghu, createtime, description);
        controller.addZhangWu(zw);
        System.out.println("恭喜添加账务成功");
    }

/*
     * 定义方法，实现添加账务
     * 是由控制层调用，传递ZhangWu对象
     */
    public void addZhangWu(ZhangWu zw) {
        dao.addZhangWu(zw);
    }

 /*
     * 定义方法，实现添加账务功能
     * 由业务层调用，传递ZhangWu对象
     * 将ZhangWu对象中的数据，添加到数据库
     */
    public void addZhangWu(ZhangWu zw) {
        try{
            //拼接添加数据的sql
            String sql = "INSERT INTO gjp_zhangwu (flname,money,zhanghu,createtime,description) VALUES(?,?,?,?,?)";
            //创建对象数组，处处5个占位符的实际参数
            //实际参数来源是传递过来的对象ZhangWu
            Object[] params = {zw.getFlname(),zw.getMoney(),zw.getZhanghu(),zw.getCreatetime(),zw.getDescription()};
            //调用qr对象中的方法update执行添加
            qr.update(sql, params);
        }catch(SQLException ex) {
            System.out.println(ex);
            throw new RuntimeException("账务添加失败");
        }
    }

/*
     * 定义方法，实现对账务的编辑功能
     * 实现思想：
     *     接收用户的输入的信息
     *  封装成ZhangWu对象
     *  调用控制层的方法，传递ZhangWu对象，实现编辑
     * 
     */
    public void editZhangWu() {
        //调用查询所有账务数据的功能，显示出来
        //看到所有数据，从中选择一项，进行修改
        selectAll();
        System.out.println("选择的是编辑功能，请输入数据");
        Scanner sc = new Scanner(System.in);
        System.out.print("请输入ID");
        int zwid = sc.nextInt();
        System.out.println("输入分类名称");
        String flname = sc.next();
        System.out.println("输入金额");
        double money = sc.nextDouble();
        System.out.println("输入账户");
        String zhanghu = sc.next();
        System.out.println("输入日期：格式XXXX-XX-xx");
        String createtime = sc.next();
        System.out.println("输入具体描述");
        String description = sc.next();
        //将用户输入的数据，封装到ZhangWu对象中
        //用户输入的ID，必须封装到到对象中
        ZhangWu zw = new ZhangWu(zwid, flname, money, zhanghu, createtime, description);
        //调用controller层中的方法，实现编辑账务
        controller.editZhangWu(zw);
        System.out.println("账务编辑成功");
    }

/*
     * 定义方法，实现编辑账务
     * 由控制层调用，传递ZhangWu对象
     * 调用dao层的方法，传递ZhangWu对象
     */
    public void editZhangWu(ZhangWu zw) {
        dao.editZhangWu(zw);
    }

/*
     * 定义方法，实现编辑功能
     * 由业务层调用，传递ZhangWu对象
     * 将对象中的数据，更新到数据表
     */
    public void editZhangWu(ZhangWu zw) {
        try {
            //更新数据的SQL
            String sql = "UPDATE gjp_zhangwu SET flname=?,money=?,zhanghu=?,createtime=?,description=? WHERE zwid=?";
            //定义对象数组，封装所有数据
            Object[] params = {zw.getFlname(),zw.getMoney(),zw.getZhanghu(),zw.getCreatetime(),zw.getDescription(),zw.getZwid()};
            //调用qr对象方法update执行更新
            qr.update(sql, params);
        } catch (SQLException ex) {
            System.out.println(ex);
            throw new RuntimeException("编辑账务失败");
        }
        
    }

/*
     * 定义方法，实现账务删除
     * 实现思想：
     *     接收用户的输入，输入一个主键数据
     *  调用控制层方法，传递一个主键
     */
    public void deleteZhangWu() {
        //调用查询所有账务数据的功能，显示出来
        //看到所有数据，从中选择一项，进行修改
        selectAll();
        System.out.println("选择的是删除功能，请输入序号即可");
        int zwid = new Scanner(System.in).nextInt();
        //调用控制层方法，传递主键id即可
        controller.deleteZhangWu(zwid);
        System.out.println("删除账务成功");
    }

/*
     * 定义方法，实现删除账务功能
     * 由控制层调用，传递主键id
     * 调用dao层方法，传递主键id
     */
    public void deleteZhangWu(int zwid) {
        dao.deleteZhangWu(zwid);
    }

 /*
     * 定义方法，实现删除业务
     * 业务层调用，传递主键id
     */
    public void deleteZhangWu(int zwid) {
        try {
            //拼写删除数据SQL
            String sql = "DELETE FROM gjp_zhangwu WHERE zwid=?";
            qr.update(sql, zwid);
        } catch (SQLException ex) {
            System.out.println(ex);
            throw new RuntimeException("删除账务失败");
        }
    }