JDBC基础
Posted Downtime
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了JDBC基础相关的知识，希望对你有一定的参考价值。
Java数据库连接——JDBC基础知识（操作数据库：增删改查）
转载自：原文链接
^_^在此感谢： ❤喵了个咪❤❤
一、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 }
注意：
ResultSet：完成了查询结果的存储功能，而且只能读去一次，不能够来回的滚动读取。 返回的是一个结果集，可以通过方法next()逐一获取从数据库取到的值。
Statement：来自java api用于执行静态 SQL 语句并返回它所生成结果的对象。在默认情况下，同一时间每个 Statement 对象在只能打开一个 ResultSet 对象。因此，如果读取一个 ResultSet 对象与读取另一个交叉，则这两个对象必须是由不同的 Statement 对象生成的。如果存在某个语句的打开的当前 ResultSet 对象，则 Statement 接口中的所有执行方法都会隐式关闭它。
1、Statement对象用于执行不带参数的简单SQL语句。
2、Prepared Statement 对象用于执行预编译SQL语句，prepareStatement这个方法会将SQL语句加载到驱动程序conn集成程序中，但是并不直接执行，而是当它调用execute()方法的时候才真正执行。
3、Callable statement对象用于执行对存储过程的调用。
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("xiaoxia@qq.com");
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类型以上是关于JDBC基础的主要内容，如果未能解决你的问题，请参考以下文章
mysql jdbc源码分析片段 和 Tomcat's JDBC Pool