JDBC上

JDBC实战--打通数据库

代码实现：

package com.imooc.db;

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

import com.imooc.model.Goddess;

public class DBUtil {

    private static final String URL = "jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8";
    private static final String USER = "root";
    private static final String PASSWORD = "123456";

    public static void main(String[] args) throws Exception {
        // 1.加载驱动程序
        Class.forName("com.mysql.jdbc.Driver");// 反射机制，通过一个类名去反向的将这个类加载到我们的环境中
        // 2.获得数据库的连接
        Connection conn = DriverManager.getConnection(URL, USER, PASSWORD);// DriverManager驱动类
        // 3.通过数据库的连接操作数据库，实现增删改查
        Statement stmt = conn.createStatement();
        // 执行查询，返回ResultSet对象
        ResultSet rs = stmt
                .executeQuery("select user_name,age from imooc_goddess");
        // rs.next()返回的是true，证明对象rs里面有数据
        while (rs.next()) {
            // 如果对象rs里面有数据，就会循环打印出来，如果没有，这个循环就不会走
            System.out.println(rs.getString("user_name") + ","
                    + rs.getInt("age"));
        }

    }
}

 数据库数据

imooc/imooc_goddess

运行结果：

测试数据库连接成功，能够从数据库读取到数据。

控制台输出

模型（三层架构）主要包括两个部分：对应数据库映射、对数据库映射的抽象方法（CRUD：增、删、改、查）

控制层：控制数据流通过程。把数据拼装起来，展示给视图层

视图层：对数据的展示

 模型层：数据处理，业务逻辑

把视图层的展示、业务逻辑、数据存储的过程分离开来，通过控制层来协调控制。

视图层：是用来数据展示用的，为了给用户展示出程序运行的结果

控制层（Controller）：更新模型层，更新视图层

 java基础——静态块：静态块执行的是最早的

 JDBC实战--搭建模型层（DAO层）

数据库对应的实体类

package com.imooc.model;

import java.util.Date;

public class Goddess {
//这些属性分别对应数据库的字段
    private Integer id;
    private String user_name;
    private Integer sex;
    private Integer age;
    private Date birthday;
    private String email;
    private String mobile;
    private String create_user;
    private String update_user;
    private Date create_date;
    private Date update_date;
    private Integer isdel;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUser_name() {
        return user_name;
    }

    public void setUser_name(String user_name) {
        this.user_name = user_name;
    }

    public Integer getSex() {
        return sex;
    }

    public void setSex(Integer sex) {
        this.sex = sex;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getMobile() {
        return mobile;
    }

    public void setMobile(String mobile) {
        this.mobile = mobile;
    }

    public String getCreate_user() {
        return create_user;
    }

    public void setCreate_user(String create_user) {
        this.create_user = create_user;
    }

    public String getUpdate_user() {
        return update_user;
    }

    public void setUpdate_user(String update_user) {
        this.update_user = update_user;
    }

    public Date getCreate_date() {
        return create_date;
    }

    public void setCreate_date(Date create_date) {
        this.create_date = create_date;
    }

    public Date getUpdate_date() {
        return update_date;
    }

    public void setUpdate_date(Date update_date) {
        this.update_date = update_date;
    }

    public Integer getIsdel() {
        return isdel;
    }

    public void setIsdel(Integer isdel) {
        this.isdel = isdel;
    }

    @Override
    public String toString() {
        return "Goddess [id=" + id + ", user_name=" + user_name + ", sex="
                + sex + ", age=" + age + ", birthday=" + birthday + ", email="
                + email + ", mobile=" + mobile + ", create_user=" + create_user
                + ", update_user=" + update_user + ", create_date="
                + create_date + ", update_date=" + update_date + ", isdel="
                + isdel + "]";
    }
}

模型层：CRUD（增、删、改、查）

控制层：接收视图层的参数，调用模型层，模型层把结果通知给控制层，控制层把结果更新给视图层，展示给用户，起着桥梁的作用

新的执行sql语句的方法：预编译sql语句

测试新增女神的方法：

 

测试结果：

数据库更新

 java.sql.Date是java.util.Date的子集

新增女神代码实现：

//新增女神
    public void addGoddess(Goddess g) throws Exception{
        Connection conn=DBUtil.getConnection();//1、获得数据库连接
        //编译sql语句，给sql语句传递参数
        //2、拼写sql语句，执行SQL语句
        String sql="" +
                "insert into imooc_goddess" +
                "(user_name,sex,age,birthday,email,mobile," +
                "create_user,create_date,update_user,update_date,isdel)" +
                "values(" +
                //参数用问号表示，相当于占位符，有几个参数就有几个问号，再给这些参数来进行赋值，到真正执行的时候，这些参数会加载到这个sql语句，把这个sql语句拼接完整，再去执行。这样就会减少对数据库操作
                //要是不用前台传递参数，可以在sql语句里面直接写入。例：current_date()
                "?,?,?,?,?,?,?,current_date(),?,current_date(),?)";
        //将sql语句加载到驱动程序的执行程序中，但是并不直接执行，而是当它调用execute方法的时候才真正执行
        //3、预编译
        PreparedStatement ptmt=conn.prepareStatement(sql);
            
        //4、传参给预编译符？去赋值
        //ptmt.setString(1,user_name);
        //传递参数，user_name这个值不能写死，应该通过方法来传进来，这样我们就可以在视图层插入数据
        //前台只需将值通过setter方法，就可以把数据集成的传递过来
        ptmt.setString(1, g.getUser_name());//传递第一个参数，设置第一个?占位符的值
        ptmt.setInt(2, g.getSex());
        ptmt.setInt(3, g.getAge());
        //ptmt.setDate(4, g.getBirthday());需要的参数是sql.Date类型的日期类型，但是传进来的值是java.util.Date，类型不符，需要转换
        ////定义一个java.sql.Date类型的data，new Date(date),然后将我们的值g.getBirthday().getTime()传进去
        //getTime() 方法可返回距 1970 年 1 月 1 日之间的毫秒数。
        ptmt.setDate(4, new Date(g.getBirthday().getTime()));
        ptmt.setString(5, g.getEmail());
        ptmt.setString(6, g.getMobile());
        ptmt.setString(7, g.getCreate_user());
        ptmt.setString(8, g.getUpdate_user());
        ptmt.setInt(9, g.getIsdel());
        //5、调用execute方法的时候才真正执行
        ptmt.execute();
    }

新增女神功能测试：

public static void main(String[] args) throws Exception {
        
        //1、测试新增女神功能
        GoddessDao g=new GoddessDao();
        
        //定义女神对象
        Goddess g1=new Goddess();
        
        g1.setUser_name("小夏");
        g1.setAge(22);
        g1.setSex(1);
        g1.setBirthday(new Date());
        g1.setEmail("xiaxia@imooc.com");
        g1.setMobile("18766888866");
        g1.setCreate_user("ADMIN");
        g1.setUpdate_user("ADMIN");
        g1.setIsdel(1);
        
        g.addGoddess(g1);
    }

运行结果：

数据库表格imooc_goddess数据更新：

JDBC实战--搭建视图层

课程总结

检验代码采用MVC三层架构模式

模型层：实体类+DAO层（封装了对数据库操作的代码），和数据库打交道

Control（控制层)：负责调用模型层

View（视图层）：调用控制层

这种方式将应用程序和数据库分开了，没有中间的过程，没有中间ODBC，厂商API，也没有中间服务器，是直接和数据库打交道，所有效率上会很高。

具体代码实现：

模型层：实体类+DAO层

package com.imooc.model;

import java.util.Date;
//模型层（实体类+DAO层：封装了对数据库操作的代码）
//实体类第一个字母一定要大写
public class Goddess {
//这些属性分别对应数据库的字段
    private Integer id;
    private String user_name;
    private Integer sex;
    private Integer age;
    private Date birthday;
    private String email;
    private String mobile;
    private String create_user;//创建人
    private String update_user;//更新人
    private Date create_date;//创建时间
    private Date update_date;//更新时间
    private Integer isdel;//是否删除的标记。setIsdel(1):不删除

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUser_name() {
        return user_name;
    }

    public void setUser_name(String user_name) {
        this.user_name = user_name;
    }

    public Integer getSex() {
        return sex;
    }

    public void setSex(Integer sex) {
        this.sex = sex;
    }

    public Integer getAge() {
        return age;
    }

    public void setAge(Integer age) {
        this.age = age;
    }

    public Date getBirthday() {
        return birthday;
    }

    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    public String getMobile() {
        return mobile;
    }

    public void setMobile(String mobile) {
        this.mobile = mobile;
    }

    public String getCreate_user() {
        return create_user;
    }

    public void setCreate_user(String create_user) {
        this.create_user = create_user;
    }

    public String getUpdate_user() {
        return update_user;
    }

    public void setUpdate_user(String update_user) {
        this.update_user = update_user;
    }

    public Date getCreate_date() {
        return create_date;
    }

    public void setCreate_date(Date create_date) {
        this.create_date = create_date;
    }

    public Date getUpdate_date() {
        return update_date;
    }

    public void setUpdate_date(Date update_date) {
        this.update_date = update_date;
    }

    public Integer getIsdel() {
        return isdel;
    }

    public void setIsdel(Integer isdel) {
        this.isdel = isdel;
    }

    //重写一个toString方法
    @Override
    public String toString() {
        return "Goddess [id=" + id + ", user_name=" + user_name + ", sex="
                + sex + ", age=" + age + ", birthday=" + birthday + ", email="
                + email + ", mobile=" + mobile + ", create_user=" + create_user
                + ", update_user=" + update_user + ", create_date="
                + create_date + ", update_date=" + update_date + ", isdel="
                + isdel + "]";
    }
}

package com.imooc.dao;

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

import com.imooc.db.DBUtil;
import com.imooc.model.Goddess;
//模型层（实体类+DAO层：封装了对数据库操作的代码）
//执行业务方法
public class GoddessDao {
//新增女神
    public void addGoddess(Goddess g) throws Exception{
        Connection conn=DBUtil.getConnection();//1、获得数据库连接
        //编译sql语句，给sql语句传递参数
        //2、拼写sql语句，执行SQL语句
        String sql="" +
                "insert into imooc_goddess" +
                "(user_name,sex,age,birthday,email,mobile," +
                "create_user,create_date,update_user,update_date,isdel)" +
                "values(" +
                //参数用问号表示，相当于占位符，有几个参数就有几个问号，再给这些参数来进行赋值，到真正执行的时候，这些参数会加载到这个sql语句，把这个sql语句拼接完整，再去执行。这样就会减少对数据库操作
                //要是不用前台传递参数，可以在sql语句里面直接写入。例：current_date()
                "?,?,?,?,?,?,?,current_date(),?,current_date(),?)";
        //将sql语句加载到驱动程序的执行程序中，但是并不直接执行，而是当它调用execute方法的时候才真正执行
        //3、预编译
        PreparedStatement ptmt=conn.prepareStatement(sql);
            
        //4、传参给预编译符？去赋值
        
        //ptmt.setString(1,user_name);
        //传递参数，user_name这个值不能写死，应该通过方法来传进来，这样我们就可以在视图层插入数据
        //前台只需将值通过setter方法，就可以把数据集成的传递过来
        ptmt.setString(1, g.getUser_name());//传递第一个参数，设置第一个?占位符的值
        ptmt.setInt(2, g.getSex());
        ptmt.setInt(3, g.getAge());
        //ptmt.setDate(4, g.getBirthday());需要的参数是sql.Date类型的日期类型，但是传进来的值是java.util.Date，类型不符，需要转换
        ////定义一个java.sql.Date类型的data，new Date(date),然后将我们的值g.getBirthday().getTime()传进去
        //getTime() 方法可返回距 1970 年 1 月 1 日之间的毫秒数。
        ptmt.setDate(4, new Date(g.getBirthday().getTime()));
        ptmt.setString(5, g.getEmail());
        ptmt.setString(6, g.getMobile());
        ptmt.setString(7, g.getCreate_user());
        ptmt.setString(8, g.getUpdate_user());
        ptmt.setInt(9, g.getIsdel());
        //5、调用execute方法的时候才真正执行
        ptmt.execute();
    }
    //修改女神
    public void updateGoddess(Goddess g) throws SQLException{//参数通过对象的形式Goddess g传进来
        Connection conn=DBUtil.getConnection();
        //sql语句之间加上空格，因为等到执行的时候会变成一行，如果不加空格的话，前后的字符就会在一起，这样就会报sql错误
        String sql="" +
                //更新女神表
                " update imooc_goddess " +
                //设置用户名···等于新的值
                " set user_name=?,sex=?,age=?,birthday=?,email=?,mobile=?, " +
                //更新人，更新时间，是否删除
                " update_user=?,update_date=current_date(),isdel=? " +
                //通过where条件更新其中一条记录，而不是更新所有记录即整个女神表
                " where id=? ";
        PreparedStatement ptmt=conn.prepareStatement(sql);
        
        ptmt.setString(1, g.getUser_name());
        ptmt.setInt(2, g.getSex());
        ptmt.setInt(3, g.getAge());
        ptmt.setDate(4, new Date(g.getBirthday().getTime()));
        ptmt.setString(5, g.getEmail());
        ptmt.setString(6, g.getMobile());
        ptmt.setString(7, g.getUpdate_user());
        ptmt.setInt(8, g.getIsdel());
        ptmt.setInt(9, g.getId());
        ptmt.execute();
    }
    //删除女神
    public void delGoddess(Integer id) throws SQLException{//参数不用传递对象，只需要传递一个id进来就可以了
        Connection conn=DBUtil.getConnection();
        
        String sql="" +
                " delete from imooc_goddess " +
                //根据主键id来删
                " where id=? ";
        PreparedStatement ptmt=conn.prepareStatement(sql);
        //需要一个参数id就可以了
        ptmt.setInt(1, id);
        ptmt.execute();
    }
    //查询女神，相当于全部查询，不管这张表里面有对少条记录我们都会查询出来，没有加过滤条件
    public List<Goddess> query() throws Exception{
        List<Goddess> result=new ArrayList<Goddess>();
        
        Connection conn=DBUtil.getConnection();
        StringBuilder sb=new StringBuilder();
        sb.append("select id,user_name,age from imooc_goddess  ");//没有加过滤条件
        
        PreparedStatement ptmt=conn.prepareStatement(sb.toString());
        //执行查询，返回ResultSet对象
        ResultSet rs=ptmt.executeQuery();
        
        Goddess g=null;
        //rs.next()返回的是true，证明对象rs里面有数据
        while(rs.next()){
            g=new Goddess();
            g.setId(rs.getInt("id"));
            g.setUser_name(rs.getString("user_name"));
            g.setAge(rs.getInt("age"));
            result.add(g);
        }
        return result;
    }
    
    //优化的查询方法，加一个查询参数：女神姓名
    //查询女神，相当于全部查询，不管这张表里面有对少条记录我们都会查询出来，没有加过滤条件
        public List<Goddess> query(String name) throws Exception{
            List<Goddess> result=new ArrayList<Goddess>();
            
            Connection conn=DBUtil.getConnection();
            StringBuilder sb=new StringBuilder();
            sb.append("select * from imooc_goddess  ");
            
            sb.append(" where user_name=? ");
            //预编译sql语句
            PreparedStatement ptmt=conn.prepareStatement(sb.toString());
            //把参数传入
            ptmt.setString(1, name);
            //将sql语句打印出来
            System.out.println(sb.toString());
            //执行查询
            ResultSet rs=ptmt.executeQuery();
            
            Goddess g=null;
            //rs.next()返回的是true，证明对象rs里面有数据
            //遍历结果集
            while(rs.next()){
                g=new Goddess();
                g.setId(rs.getInt("id"));
                g.setUser_name(rs.getString("user_name"));
                g.setAge(rs.getInt("age"));
                g.setSex(rs.getInt("sex"));
                g.setBirthday(rs.getDate("birthday"));
                g.setEmail(rs.getString("email"));
                g.setMobile(rs.getString("mobile"));
                g.setCreate_date(rs.getDate("create_date"));
                g.setCreate_user(rs.getString("create_user"));
                g.setUpdate_date(rs.getDate("update_date"));
                g.setUpdate_user(rs.getString("update_user"));
                g.setIsdel(rs.getInt("isdel"));
                
                result.add(g);
            }
            return result;
        }
        
    //通过一个参数一个参数传进来
    //查询女神，参数：姓名、手机号、邮箱，按照女神的姓名、手机号、邮箱来查询
    public List<Goddess> query(String name,String mobile,String email) throws Exception{
        List<Goddess> result=new ArrayList<Goddess>();
        
        Connection conn=DBUtil.getConnection();
        StringBuilder sb=new StringBuilder();
        sb.append("select * from imooc_goddess  ");//全部查询，没有过滤条件
        //加上查询参数
        sb.append(" where user_name like ? and mobile like ? and email like ?");
        
        PreparedStatement ptmt=conn.prepareStatement(sb.toString());
        //这边的查询参数是写死的，但可以通过集合方式传进来，更加便捷
        ptmt.setString(1, "%"+name+"%");//%通配符
        ptmt.setString(2, "%"+mobile+"%");
        ptmt.setString(3, "%"+email+"%");
        System.out.println(sb.toString());
        ResultSet rs=ptmt.executeQuery();
        
        Goddess g=null;
        while(rs.next()){
            g=new Goddess();
            g.setId(rs.getInt("id"));
            g.setUser_name(rs.getString("user_name"));
            g.setAge(rs.getInt("age"));
            g.setSex(rs.getInt("sex"));
            g.setBirthday(rs.getDate("birthday"));
            g.setEmail(rs.getString("email"));
            g.setMobile(rs.getString("mobile"));
            g.setCreate_date(rs.getDate("create_date"));
            g.setCreate_user(rs.getString("create_user"));
            g.setUpdate_date(rs.getDate("update_date"));
            g.setUpdate_user(rs.getString("update_user"));
            g.setIsdel(rs.getInt("isdel"));
            //循环放到集合里面，返回集合
            result.add(g);
        }
        return result;
    }
    //不通过一个参数一个参数传进来，传递一个集合，通过集合的方式List ，把这些参数放到集合里面，然后再传进来，查询的条件也可以通过集合方式Map<String, Object>传进来，这种方式更便捷
    //查询参数通过集合传过来params
    public List<Goddess> query(List<Map<String, Object>> params) throws Exception{
        List<Goddess> result=new ArrayList<Goddess>();
        
        Connection conn=DBUtil.getConnection();
        StringBuilder sb=new StringBuilder();
        //1=1永远成立，后面再追加and就没问题了,where后面不能直接加and
        sb.append("select * from imooc_goddess where 1=1 ");
        //判断集合是否为空
        if(params!=null&&params.size()>0){
            //遍历集合
            for (int i = 0; i < params.size(); i++) {
                Map<String, Object> map=params.get(i);
                //拼装sql语句，查询变量name，查询关系rela（例：=），变量的值value
                //就不会像sb.append(" where user_name like ? and mobile like ? and email like ?");把查询条件写死
                //这里可以改变查询参数
                //如果把and去掉，第一条参数可以，第二条就没有and来连接了，所以可以在前面的sql语句加上where 1=1
                //name:要查询的字段，rela：查询的关系（=,>,<,like），value:要传输查询参数的值
                sb.append("  and "+map.get("name")+" "+map.get("rela")+" "+map.get("value")+" ");
                
            }
        }
        
        PreparedStatement ptmt=conn.prepareStatement(sb.toString());
        
        System.out.println(sb.toString());//打印sql语句
        ResultSet rs=ptmt.executeQuery();
        
        Goddess g=null;
        while(rs.next()){
            g=new Goddess();
            g.setId(rs.getInt("id"));
            g.setUser_name(rs.getString("user_name"));
            g.setAge(rs.getInt("age"));
            g.setSex(rs.getInt("sex"));
            g.setBirthday(rs.getDate("birthday"));
            g.setEmail(rs.getString("email"));
            g.setMobile(rs.getString("mobile"));
            g.setCreate_date(rs.getDate("create_date"));
            g.setCreate_user(rs.getString("create_user"));
            g.setUpdate_date(rs.getDate("update_date"));
            g.setUpdate_user(rs.getString("update_user"));
            g.setIsdel(rs.getInt("isdel"));
            
            result.add(g);
        }
        return result;
    }
    //查询一个女神，得到其中一个女神的详细信息
    public Goddess get(Integer id) throws SQLException{//根据id来查
        Goddess g=null;
        Connection conn=DBUtil.getConnection();
        String sql="" +
                " select * from imooc_goddess " +
                " where id=? ";
        //预编译sql语句
        PreparedStatement ptmt=conn.prepareStatement(sql);
        //传入参数
        ptmt.setInt(1, id);
        //execute()方法用来执行更改数据库的操作，包括新增、修改、删除。
        //executeQuery()方法：查询
        ResultSet rs=ptmt.executeQuery();//执行查询，返回结果集rs
        //遍历结果集
        while(rs.next()){
            g=new Goddess();
            g.setId(rs.getInt("id"));
            g.setUser_name(rs.getString("user_name"));
            g.setAge(rs.getInt("age"));
            g.setSex(rs.getInt("sex"));
            //g.setBirthday:java.util.Date
            //rs.getDate:java.sql.Date
            //注意：这里的java.sql.Date不需要转成java.util.Date，因为java.sql.Date是java.util.Date的子集
            g.setBirthday(rs.getDate("birthday"));
            g.setEmail(rs.getString("email"));
            g.setMobile(rs.getString("mobile"));
            g.setCreate_date(rs.getDate("create_date"));
            g.setCreate_user(rs.getString("create_user"));
            g.setUpdate_date(rs.getDate("update_date"));
            g.setUpdate_user(rs.getString("update_user"));
            g.setIsdel(rs.getInt("isdel"));
        }
        return g;//返回女神对象
    }
}

控制层

package com.imooc.action;
//控制层
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import com.imooc.dao.GoddessDao;
import com.imooc.model.Goddess;

public class GoddessAction {

    public void add(Goddess goddess) throws Exception{
        GoddessDao dao=new GoddessDao();
        goddess.setSex(1);
        goddess.setCreate_user("ADMIN");
        goddess.setUpdate_user("ADMIN");
        goddess.setIsdel(0);
        dao.addGoddess(goddess);
    }
    
    public Goddess get(Integer id) throws SQLException{
        GoddessDao dao=new GoddessDao();
        return dao.get(id);
    }
    
    public void edit(Goddess goddess) throws Exception{
        GoddessDao dao=new GoddessDao();
        dao.updateGoddess(goddess);
    }
    public void del(Integer id) throws SQLException{
        GoddessDao dao=new GoddessDao();
        dao.delGoddess(id);
    }
    
    public List<Goddess>  query() throws Exception{
        GoddessDao dao=new GoddessDao();
        return dao.query();
    }
    public List<Goddess> query(List<Map<String, Object>> params) throws Exception{
        GoddessDao dao=new GoddessDao();
        return dao.query(params);
    }
    
    public static void main(String[] args) throws Exception {
        
//        //1、测试新增女神功能
//        GoddessDao g=new GoddessDao();
//        
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小夏");
//        g1.setAge(22);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18766888866");
//        g1.setCreate_user("ADMIN");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
//        
//        g.addGoddess(g1);
/**************************************************************************/        
//        //1-1、测试新增女神功能
//        GoddessDao g=new GoddessDao();
//        
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小美");
//        g1.setAge(22);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18766888866");
//        g1.setCreate_user("ADMIN");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
//        
//        g.addGoddess(g1);
/**************************************************************************/        
//        //2、测试更新女神功能
//        GoddessDao g=new GoddessDao();
//        
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小夏");
//        g1.setAge(21);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18712345678");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
//        
//        g1.setId(7);
//        
//        g.updateGoddess(g1);
    
/**************************************************************************/    
//        //3、测试删除女神功能
//        GoddessDao g=new GoddessDao();
//        
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小夏");
//        g1.setAge(21);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18712345678");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
//        
//        g1.setId(7);
//        
//        g.delGoddess(7);
        
/**************************************************************************/    
//        //4、测试查询单个女神的信息
//        GoddessDao g=new GoddessDao();
//        
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小夏");
//        g1.setAge(21);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18712345678");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
//        
//        g1.setId(7);
//        
//        //返回一个女神对象
//        Goddess g2=g.get(9);
//        //把查询到的女神信息打印到控制台
//        System.out.println(g2.toString());
        
/**************************************************************************/    
//        //5、测试查询女神的信息
//        GoddessDao g=new GoddessDao();
//        //查询小美的信息
//        List<Goddess> result=g.query("小夏");
//        //遍历结果集
//        for (int i = 0; i < result.size(); i++) {
//            //将信息打印到控制台上面
//            System.out.println(result.get(i).toString());
//        }
//        //定义女神对象
//        Goddess g1=new Goddess();
//        
//        g1.setUser_name("小美");
//        g1.setAge(22);
//        g1.setSex(1);
//        g1.setBirthday(new Date());
//        g1.setEmail("xiaxia@imooc.com");
//        g1.setMobile("18766888866");
//        g1.setCreate_user("ADMIN");
//        g1.setUpdate_user("ADMIN");
//        g1.setIsdel(1);
        
/**************************************************************************/    
        //6、测试通过集合方式查询女神的信息
        GoddessDao g=new GoddessDao();
        
        List<Map<String, Object>> params=new ArrayList<Map<String,Object>>();
        Map<String,Object> param=new HashMap<String,Object>();
        param.put("name", "user_name");
//        param.put("rela", "=");
//        param.put("value", "'小夏'");
        
        param.put("rela", "like");
        param.put("value", "'%小美%'");
        //把参数放到集合里面去
        params.add(param);//这一句一定要加，否则会被后面的覆盖
/**************************************************************************/    
        //加入查询条件：按手机号查询
        param=new HashMap<String,Object>();
        param.put("name", "mobile");
//        param.put("rela", "=");
//        param.put("value", "'18712345678'");
        
        param.put("rela", "like");
        param.put("value", "'%18712345678%'");
        //把参数放到集合里面去
        params.add(param);
/**************************************************************************/        
        param=new HashMap<String,Object>();
        param.put("name", "email");
        param.put("rela", "=");
        param.put("value", "'xiaxia@imooc.com'");
        //把参数放到集合里面去
        params.add(param);
/**************************************************************************/            
        
        
        List<Goddess> result=g.query(params);
        //遍历结果集
        for (int i = 0; i < result.size(); i++) {
            //将信息打印到控制台上面
            System.out.println(result.get(i).toString());
        }
//               定义女神对象
        Goddess g1=new Goddess();
        
        g1.setUser_name("小美");
        g1.setAge(22);
        g1.setSex(1);
        g1.setBirthday(new Date());
        g1.setEmail("xiaxia@imooc.com");
        g1.setMobile("18766888866");
        g1.setCreate_user("ADMIN");
        g1.setUpdate_user("ADMIN");
        g1.setIsdel(1);
    }
        
}
    

视图层

package com.imooc.view;

import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Scanner;

import com.imooc.action.GoddessAction;
import com.imooc.model.Goddess;

public class View {
    //提示语
    private static final String CONTEXT="欢迎来到女神禁区：
" +
            "下面是女神禁区的功能列表：
" +
            "[MAIN/M]:主菜单
" +
            "[QUERY/Q]:查看全部女神的信息
" +
            "[GET/G]:查看某位女神的详细信息
" +
            "[ADD/A]:添加女神信息
" +
            "[UPDATE/U]:更新女神信息
" +
            "[DELETE/D]:删除女神信息
" +
            "[SEARCH/S]:查询女神信息(根据姓名、手机号来查询)
" +
            "[EXIT/E]:退出女神禁区
" +
            "[BREAK/B]:退出当前功能，返回主菜单";
    //操作标记
    private static final String OPERATION_MAIN="MAIN";//访问主菜单（功能列表）
    private static final String OPERATION_QUERY="QUERY";
    private static final String OPERATION_GET="GET";
    private static final String OPERATION_ADD="ADD";
    private static final String OPERATION_UPDATE="UPDATE";
    private static final String OPERATION_DELETE="DELETE";
    private static final String OPERATION_SEARCH="SEARCH";
    private static final String OPERATION_EXIT="EXIT";
    private static final String OPERATION_BREAK="BREAK";

    public static void main(String[] args) {
        
        System.out.println(CONTEXT);
        //怎么保持程序一直运行，永真循环 while(true){}
        
        //接收控制台输入参数
        Scanner scan=new Scanner(System.in);
        Goddess goddess=new Goddess();
        GoddessAction action=new GoddessAction();
        String prenious=null;//记忆变量，记忆上一次请求的是哪一个分支哪一个模块
        Integer step=1;//标记步骤
        while(scan.hasNext()){//有输入值的时候才循环
            String in=scan.next().toString();
            if(OPERATION_EXIT.equals(in.toUpperCase())
                    //OPERATION_EXIT.substring(0, 1)截取E,toUpperCase()转换成大写
                    ||OPERATION_EXIT.substring(0, 1).equals(in.toUpperCase())){
                System.out.println("您已成功退出女神禁区。");
                break;
            }else if(OPERATION_QUERY.equals(in.toUpperCase())
                    ||OPERATION_QUERY.substring(0, 1).equals(in.toUpperCase())){
                try {
                    List<Goddess> list=action.query();
                    for (Goddess go : list) {
                        System.out.println(go.getId()+",姓名："+go.getUser_name());
                    }
                } catch (Exception e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                
                
            }else if(OPERATION_ADD.equals(in.toUpperCase())
                    ||OPERATION_ADD.substring(0, 1).equals(in.toUpperCase())
                    ||OPERATION_ADD.equals(prenious)){
                prenious=OPERATION_ADD;
                //新增女神
                
                if(1==step){
                    System.out.println("请输入女神的［姓名］");
                }else if(2==step){
                    goddess.setUser_name(in);
                    System.out.println("请输入女神的［年龄］");
                }else if(3==step){
                    goddess.setAge(Integer.valueOf(in));
                    System.out.println("请输入女神的［生日］，格式如：yyyy-MM-dd");
                }else if(4==step){
                    SimpleDateFormat sf=new SimpleDateFormat("yyyy-MM-dd");
                    Date birthday=null;
                    try {
                        birthday = sf.parse(in);
                        goddess.setBirthday(birthday);
                        System.out.println("请输入女神的［邮箱］");
                    } catch (ParseException e) {
                        e.printStackTrace();
                        System.out.println("您输入的格式有误，请重新输入");
                        step=3;
                    }
                }else if(5==step){
                    goddess.setEmail(in);
                    System.out.println("请输入女神的［手机号］");
                }else if(6==step){
                    goddess.setMobile(in);
                    
                    try {
                        action.add(goddess);
                        System.out.println("新增女神成功");
                    } catch (Exception e) {
                        e.printStackTrace();
                        System.out.println("新增女神失败");
                    }
                }
                if(OPERATION_ADD.equals(prenious)){
                    step++;                    
                }
            }else{
                System.out.println("您输入的值为:"+in);                
            }
            
        }
    }
}

数据库

package com.imooc.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
//获得数据库连接
public class DBUtil {

    private static final String URL="jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8";
    private static final String USER="root";
    private static final String PASSWORD="123456";
    
    private static Connection conn=null;
    
    static {
        try {
            //1.加载驱动程序
            Class.forName("com.mysql.jdbc.Driver");
            //2.获得数据库的连接
            conn=DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    //对外提供一个方法来获得数据库连接
    public static Connection getConnection(){
        return conn;
    }

}