Java数据库连接——JDBC基础知识（操作数据库：增删改查）

Posted 2020-07-03 ❤喵了个咪❤❤

一、JDBC简介

JDBC是连接java应用程序和数据库之间的桥梁。

什么是JDBC?

Java语言访问数据库的一种规范,是一套API。

JDBC (Java Database Connectivity) API，即Java数据库编程接口，是一组标准的Java语言中的接口和类，使用这些接口和类，Java客户端程序可以访问各种不同类型的数据库。比如建立数据库连接、执行SQL语句进行数据的存取操作。

JDBC代表Java数据库连接。

JDBC库中所包含的API任务通常与数据库使用：

• 连接到数据库

• 创建SQL或mysql语句

• 在数据库中执行SQL或MySQL查询

• 查看和修改记录

比如：

二、JDBC使用详解

1、打通数据库

先新建Java 工程，将jar包导进去：

然后新建相应的数据库和表。

编写DBUtil.java

 1 package com.study.db;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.ResultSet;
 6 import java.sql.Statement;
 7 
 8 public class DBUtil {
 9     
10     private static final String URL="jdbc:mysql://localhost:3306/demo_jdbc";
11     private static final String NAME="root";
12     private static final String PASSWORD="root";
13 
14     public static void main(String[] args) throws Exception{
15         
16         //1.加载驱动程序
17         Class.forName("com.mysql.jdbc.Driver");
18         //2.获得数据库的连接
19         Connection conn = DriverManager.getConnection(URL, NAME, PASSWORD);
20         //3.通过数据库的连接操作数据库，实现增删改查
21         Statement stmt = conn.createStatement();
22         ResultSet rs = stmt.executeQuery("select user_name,age from imooc_goddess");//选择import java.sql.ResultSet;
23         while(rs.next()){//如果对象中有数据，就会循环打印出来
24             System.out.println(rs.getString("user_name")+","+rs.getInt("age"));
25         }
26     }
27 }

2、搭建模型层

采用MVC三层架构：建议由下往上开发（DB->view,需求读懂以后，设计数据库，然后根据数据库映射模型，再写控制层，再写视图层）

• View视图层——展示数据，反馈用户行为
•  Control控制层——控制数据流通过程，协调视图层和数据层
•  Model模型层——与数据库建立映射，与数据进行交互
• （DB数据库）

先新增对应的model层：按照数据库表对应的字段编写实体类。

 1 package com.study.model;
 2 
 3 import java.util.Date;
 4 
 5 public class Goddess {
 6     private Integer id;
 7     private String userName;
 8     private Integer sex;
 9     private Integer age;
10     private Date birthday;
11     private String email;
12     private String mobile;
13     private String createUser;
14     private Date createDate;
15     private String updateUser;
16     private Date updateDate;
17     private Integer isDel;
18     public Integer getId() {
19         return id;
20     }
21     public void setId(Integer id) {
22         this.id = id;
23     }
24     public String getUserName() {
25         return userName;
26     }
27     public void setUserName(String userName) {
28         this.userName = userName;
29     }
30     public Integer getSex() {
31         return sex;
32     }
33     public void setSex(Integer sex) {
34         this.sex = sex;
35     }
36     public Integer getAge() {
37         return age;
38     }
39     public void setAge(Integer age) {
40         this.age = age;
41     }
42     public Date getBirthday() {
43         return birthday;
44     }
45     public void setBirthday(Date birthday) {
46         this.birthday = birthday;
47     }
48     public String getEmail() {
49         return email;
50     }
51     public void setEmail(String email) {
52         this.email = email;
53     }
54     public String getMobile() {
55         return mobile;
56     }
57     public void setMobile(String mobile) {
58         this.mobile = mobile;
59     }
60     public String getCreateUser() {
61         return createUser;
62     }
63     public void setCreateUser(String createUser) {
64         this.createUser = createUser;
65     }
66     public Date getCreateDate() {
67         return createDate;
68     }
69     public void setCreateDate(Date createDate) {
70         this.createDate = createDate;
71     }
72     public String getUpdateUser() {
73         return updateUser;
74     }
75     public void setUpdateUser(String updateUser) {
76         this.updateUser = updateUser;
77     }
78     public Date getUpdateDate() {
79         return updateDate;
80     }
81     public void setUpdateDate(Date updateDate) {
82         this.updateDate = updateDate;
83     }
84     public Integer getIsDel() {
85         return isDel;
86     }
87     public void setIsDel(Integer isDel) {
88         this.isDel = isDel;
89     }
90     
91 }

然后开始新增Dao层，并修改DBUtil.java

DBUtil.java代码如下：

 1 package com.study.db;
 2 
 3 import java.sql.Connection;
 4 import java.sql.DriverManager;
 5 import java.sql.ResultSet;
 6 import java.sql.SQLException;
 7 import java.sql.Statement;
 8 
 9 public class DBUtil {
10     
11     private static final String URL="jdbc:mysql://localhost:3306/demo_jdbc";
12     private static final String NAME="root";
13     private static final String PASSWORD="root";
14     
15     private static Connection conn=null;
16     //静态代码块（将加载驱动、连接数据库放入静态块中）
17     static{
18         try {
19             //1.加载驱动程序
20             Class.forName("com.mysql.jdbc.Driver");
21             //2.获得数据库的连接
22             conn = DriverManager.getConnection(URL, NAME, PASSWORD);
23         } catch (ClassNotFoundException e) {
24             e.printStackTrace();
25         } catch (SQLException e) {
26             e.printStackTrace();
27         }
28     }
29     //对外提供一个方法来获取数据库连接
30     public static Connection getConnection(){
31         return conn;
32     }
33     
34     public static void main(String[] args) throws Exception{
35         
36         //3.通过数据库的连接操作数据库，实现增删改查
37         Statement stmt = conn.createStatement();
38         ResultSet rs = stmt.executeQuery("select user_name,age from imooc_goddess");//选择import java.sql.ResultSet;
39         while(rs.next()){//如果对象中有数据，就会循环打印出来
40             System.out.println(rs.getString("user_name")+","+rs.getInt("age"));
41         }
42     }
43 }

goddessDao.java 代码如下：

 1 package com.study.dao;
 2 
 3 import java.sql.Connection;
 4 import java.sql.ResultSet;
 5 import java.sql.SQLException;
 6 import java.sql.Statement;
 7 import java.util.ArrayList;
 8 import java.util.List;
 9 
10 import com.study.db.DBUtil;
11 import com.study.model.Goddess;
12 
13 public class GoddessDao {
14 
15     public void addGoddess(){
16         
17     }
18     
19     public void updateGoddess(){
20              
21     }
22     public void delGoddess(){
23         
24     }
25     
26     public List<Goddess> query() throws Exception{
27         Connection con=DBUtil.getConnection();
28         Statement stmt=con.createStatement();
29         ResultSet rs=stmt.executeQuery("select user_name,age from imooc_goddess");
30         List<Goddess> gs=new ArrayList<Goddess>();
31         Goddess g=null;
32         while(rs.next()){//如果对象中有数据，就会循环打印出来
33             g=new Goddess();
34             g.setUserName(rs.getString("user_name"));
35             g.setAge(rs.getInt("age"));
36             gs.add(g);
37         }
38         return gs;
39     }
40     
41     //查询单个女神
42     public Goddess get(){
43         return null;
44     }
45 }

新增Controller层：GoddessAction.java

 1 package com.study.controller;
 2 
 3 import java.util.List;
 4 
 5 import com.study.dao.GoddessDao;
 6 import com.study.model.Goddess;
 7 
 8 public class GoddessAction {
 9 
10     public static void main(String[] args) throws Exception {
11         GoddessDao gd=new GoddessDao();
12         List<Goddess> gs=gd.query();
13         for (Goddess goddess : gs) {
14             System.out.println(goddess.getUserName()+","+goddess.getAge());
15         }
16 
17     }
18 
19 }

PS：CRUD：增加(Create)、读取(Retrieve)（重新得到数据-->高级应用：报表、分页）、更新(Update)和删除(Delete)

3、搭建模型层——CRUD操作

新增create操作：

 1 //添加女神
 2     public void addGoddess(Goddess g) throws Exception{
 3         Connection con=DBUtil.getConnection();//首先拿到数据库的连接
 4         String sql="" + 
 5                 "insert into imooc_goddess"+
 6                 "(user_name,sex,age,birthday,email,mobile,"+
 7                 "create_user,create_date,update_user,update_date,isdel) "+
 8                 "values("+
 9                 "?,?,?,?,?,?,?,current_date(),?,current_date(),?)";//参数用?表示，相当于占位符;用mysql的日期函数current_date()来获取当前日期
10         //预编译sql语句
11         PreparedStatement psmt = con.prepareStatement(sql);
12         //先对应SQL语句，给SQL语句传递参数
13         psmt.setString(1, g.getUserName());
14         psmt.setInt(2, g.getSex());
15         psmt.setInt(3, g.getAge());
16         //注意：setDate()函数第二个参数需要的是java.sql.Date类型，我们传进来的是java.util.Date，类型不符，需要做一下转换
17         psmt.setDate(4, new Date(g.getBirthday().getTime()));
18         psmt.setString(5, g.getEmail());
19         psmt.setString(6, g.getMobile());
20         psmt.setString(7, g.getCreateUser());
21         psmt.setString(8, g.getUpdateUser());
22         psmt.setInt(9, g.getIsDel());
23         //执行SQL语句
24         psmt.execute();
25         /**
26          * prepareStatement这个方法会将SQL语句加载到驱动程序conn集成程序中，但是并不直接执行
27          * 而是当它调用execute()方法的时候才真正执行；
28          * 
29          * 上面SQL中的参数用?表示，相当于占位符，然后在对参数进行赋值。
30          * 当真正执行时，这些参数会加载在SQL语句中，把SQL语句拼接完整才去执行。
31          * 这样就会减少对数据库的操作
32          */
33     }

测试：

package com.study.controller;

import java.util.Date;
import java.util.List;

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

public class GoddessAction {

    public static void main(String[] args) throws Exception {
        GoddessDao gd=new GoddessDao();
        Goddess g1=new Goddess();
        g1.setUserName("小夏");
        g1.setAge(22);
        g1.setSex(1);
        g1.setBirthday(new Date());
        g1.setEmail("[email protected]");
        g1.setMobile("123456789");
        g1.setCreateUser("admin");
        g1.setUpdateUser("admin");
        g1.setIsDel(1);
        //添加女神
        gd.addGoddess(g1);
    }

}

修改、删除、查询(根据id)操作：

 1 //更新女神
 2     public void updateGoddess(Goddess g) throws SQLException{
 3         Connection con=DBUtil.getConnection();//首先拿到数据库的连接
 4         String sql="" + 
 5                 "update imooc_goddess "+
 6                 "set user_name=?,sex=?,age=?,birthday=?,email=?,mobile=?,"+
 7                 "update_user=?,update_date=current_date(),isdel=?) "+
 8                 "where id=?";//参数用?表示，相当于占位符;用mysql的日期函数current_date()来获取当前日期
 9         //预编译sql语句
10         PreparedStatement psmt = con.prepareStatement(sql);
11         //先对应SQL语句，给SQL语句传递参数
12         psmt.setString(1, g.getUserName());
13         psmt.setInt(2, g.getSex());
14         psmt.setInt(3, g.getAge());
15         //注意：setDate()函数第二个参数需要的是java.sql.Date类型，我们传进来的是java.util.Date，类型不符，需要做一下转换
16         psmt.setDate(4, new Date(g.getBirthday().getTime()));
17         psmt.setString(5, g.getEmail());
18         psmt.setString(6, g.getMobile());
19         psmt.setString(7, g.getUpdateUser());
20         psmt.setInt(8, g.getIsDel());
21         psmt.setInt(9, g.getId());
22         //执行SQL语句
23         psmt.execute();    
24     }
25 
26 //删除女神
27     public void delGoddess(Integer id) throws SQLException{
28         Connection con=DBUtil.getConnection();//首先拿到数据库的连接
29         String sql="" + 
30                 "delete from imooc_goddess "+
31                 "where id=?";//参数用?表示，相当于占位符;用mysql的日期函数current_date()来获取当前日期
32         //预编译sql语句
33         PreparedStatement psmt = con.prepareStatement(sql);
34         //先对应SQL语句，给SQL语句传递参数
35         psmt.setInt(1, id);
36         //执行SQL语句
37         psmt.execute();    
38     }
39 
40 //查询单个女神(根据id去查询)
41     public Goddess get(Integer id) throws SQLException{
42         Goddess g=null;
43         Connection con=DBUtil.getConnection();//首先拿到数据库的连接
44         String sql="" + 
45                 "select * from imooc_goddess "+
46                 "where id=?";//参数用?表示，相当于占位符;用mysql的日期函数current_date()来获取当前日期
47         //预编译sql语句
48         PreparedStatement psmt = con.prepareStatement(sql);
49         //先对应SQL语句，给SQL语句传递参数
50         psmt.setInt(1, id);
51         //执行SQL语句
52         /*psmt.execute();*///execute()方法是执行更改数据库操作（包括新增、修改、删除）;executeQuery()是执行查询操作
53         ResultSet rs = psmt.executeQuery();//返回一个结果集
54         //遍历结果集
55         while(rs.next()){
56             g=new Goddess();
57             g.setId(rs.getInt("id"));
58             g.setUserName(rs.getString("user_name"));
59             g.setAge(rs.getInt("age"));
60             g.setSex(rs.getInt("sex"));
61             //rs.getDate("birthday")获得的是java.sql.Date类型。注意：java.sql.Date类型是java.util.Date类型的子集，所以这里不需要进行转换了。
62             g.setBirthday(rs.getDate("birthday"));
63             g.setEmail(rs.getString("email"));
64             g.setMobile(rs.getString("mobile"));
65             g.setCreateUser(rs.getString("create_user"));
66             g.setCreateDate(rs.getDate("create_date"));
67             g.setUpdateUser(rs.getString("update_user"));
68             g.setUpdateDate(rs.getDate("update_date"));
69             g.setIsDel(rs.getInt("isdel"));
70         }
71         return g;
72     }

 查询（根据name\mobile等）操作

 1 //查询单个女神(根据姓名等信息去查询)
 2         public List<Goddess> get(String name,String mobile) throws SQLException{
 3             List<Goddess> result=new ArrayList<Goddess>();
 4             Connection con=DBUtil.getConnection();//首先拿到数据库的连接
 5             StringBuffer sb=new StringBuffer();
 6             sb.append("select * from imooc_goddess ");
 7             sb.append("where user_name like ? and mobile like ?");
 8             //预编译sql语句
 9             PreparedStatement psmt = con.prepareStatement(sb.toString());
10             //先对应SQL语句，给SQL语句传递参数
11             psmt.setString(1, "%"+name+"%");
12             psmt.setString(2, "%"+mobile+"%");    
13             System.out.println(sb.toString());
14             //执行SQL语句
15             /*psmt.execute();*///execute()方法是执行更改数据库操作（包括新增、修改、删除）;executeQuery()是执行查询操作
16             ResultSet rs = psmt.executeQuery();//返回一个结果集
17             Goddess g=null;
18             //遍历结果集
19             while(rs.next()){
20                 g=new Goddess();
21                 g.setId(rs.getInt("id"));
22                 g.setUserName(rs.getString("user_name"));
23                 g.setAge(rs.getInt("age"));
24                 g.setSex(rs.getInt("sex"));
25                 //rs.getDate("birthday")获得的是java.sql.Date类型。注意：java.sql.Date类型是java.util.Date类型的子集，所以这里不需要进行转换了。
26                 g.setBirthday(rs.getDate("birthday"));
27                 g.setEmail(rs.getString("email"));
28                 g.setMobile(rs.getString("mobile"));
29                 g.setCreateUser(rs.getString("create_user"));
30                 g.setCreateDate(rs.getDate("create_date"));
31                 g.setUpdateUser(rs.getString("update_user"));
32                 g.setUpdateDate(rs.getDate("update_date"));
33                 g.setIsDel(rs.getInt("isdel"));
34                 
35                 result.add(g);//将结果封装到对象中
36             }
37             return result;
38         }

测试：

 1 package com.study.controller;
 2 
 3 import java.util.Date;
 4 import java.util.List;
 5 
 6 import com.study.dao.GoddessDao;
 7 import com.study.model.Goddess;
 8 
 9 public class GoddessAction {
10 
11     public static void main(String[] args) throws Exception {
12         GoddessDao gd=new GoddessDao();
13         /*//查询所有女神
14         List<Goddess> gs=gd.query();
15         for (Goddess goddess : gs) {
16             System.out.println(goddess.getUserName()+","+goddess.getAge());
17         }*/
18         
19         Goddess g1=new Goddess();
20         g1.setUserName("小夏");
21         g1.setAge(22);
22         g1.setSex(1);
23         g1.setBirthday(new Date());
24         g1.setEmail("[email protected]");
25         g1.setMobile("123456789");
26         g1.setCreateUser("admin");
27         g1.setUpdateUser("admin");
28         g1.setIsDel(1);
29         //添加女神
30 //        gd.addGoddess(g1);
31         
32         //查询单个女神（根据id）
33         /*Goddess g2 = gd.get(4);
34         System.out.println(g2.toString());*/
35         
36         //查询单个女神（根据姓名等信息）
37         List<Goddess> list = gd.get("小溪", "139");
38         //遍历结果集
39         for(int i=0;i<list.size();i++){
40             System.out.println(list.get(i).toString());
41         }
42     }
43 
44 }

运行结果：

select * from imooc_goddess where user_name like ? and mobile like ?
Goddess [id=1, userName=小溪, sex=1, age=22, birthday=2000-12-12, [email protected], mobile=13911111111, createUser=ADMIN, createDate=2015-01-08, updateUser=ADMIN, updateDate=2015-01-08, isDel=0]

 查询操作的进一步完善：

 1 //查询单个女神(根据姓名等信息去查询)----->使用Map存储条件信息；防止条件为空可加一条where 1=1
 2                 public List<Goddess> get(List<Map<String, Object>> params) throws SQLException{
 3                     List<Goddess> result=new ArrayList<Goddess>();
 4                     Connection con=DBUtil.getConnection();//首先拿到数据库的连接
 5                     StringBuffer sb=new StringBuffer();
 6                     sb.append("select * from imooc_goddess where 1=1 ");//注意where 1=1 的小技巧
 7                     if(params !=null && params.size()>0){//先判断集合是否为空
 8                         //遍历集合
 9                         for(int i=0;i<params.size();i++){
10                             Map<String, Object> map=params.get(i);
11                             sb.append("and "+map.get("name")+" " +map.get("rela")+" "+map.get("value")+" ");//查询什么？关系是什么？以及值是什么，我们都可以通过参数传进来。
12                         }
13                         
14                     }
15                     //预编译sql语句
16                     PreparedStatement psmt = con.prepareStatement(sb.toString());
17                     System.out.println(sb.toString());
18                     //执行SQL语句
19                     /*psmt.execute();*///execute()方法是执行更改数据库操作（包括新增、修改、删除）;executeQuery()是执行查询操作
20                     ResultSet rs = psmt.executeQuery();//返回一个结果集
21                     Goddess g=null;
22                     //遍历结果集
23                     while(rs.next()){
24                         g=new Goddess();
25                         g.setId(rs.getInt("id"));
26                         g.setUserName(rs.getString("user_name"));
27                         g.setAge(rs.getInt("age"));
28