Java Database Connectivity (JDBC)是一个Java API，用于与数据库进行连接和操作。通过JDBC，Java程序可以与各种关系型数据库进行通信，执行SQL查询、更新数据等操作。
一、Java连接数据库两种方式
二、Java中提供的方法
三、连接数据库的步骤
|
3.1 数据库实现
3.1.1 连接数据库
打开DataGrip，点击左上角“+”标志，选择对应数据库进行连接：
3.1.2 创建book表：
| -- 创建一个book表，表中存入book相关的内容，包括id，书名，作者，价格 create table book( bookid int primary key auto_increment, bookname varchar(50) not null, bookauthor varchar(50), bookprice double not null
); |
3.1.3 在数据库中插入数据：
| -- 向表中插入一些数据 insert into book (bookname, bookauthor, bookprice) values ('活着', '余华', 29.90), ('百年孤独', '加西亚·马尔克斯', 39.90), ('挪威的森林', '村上春树', 49.90), ('围城', '钱钟书', 39.00), ('小王子', '安东尼·德·圣埃克苏佩里', 25.00), ('红与黑', '司汤达', 35.00), ('简·爱', '夏洛蒂·勃朗特', 30.00), ('傲慢与偏见', '简·奥斯汀', 28.50), ('海边的卡夫卡', '村上春树', 45.00), ('时间简史', '斯蒂芬·霍金', 50.00), ('解忧杂货店', '东野圭吾', 38.00), ('追风筝的人', '卡勒德·胡赛尼', 32.00), ('平凡的世界', '路遥', 27.00), ('月亮和六便士', '毛姆', 34.00), ('茶花女', '小仲马', 22.00), ('动物农场', '乔治·奥威尔', 26.00), ('福尔摩斯探案集', '阿瑟·柯南·道尔', 31.00), ('人类简史', '尤瓦尔·赫拉利', 48.00), ('白夜行', '东野圭吾', 36.00), ('盗墓笔记', '南派三叔', 40.00); |
查看表中数据：
3.2 JDBC连接数据库
3.2.1 创建对应的Java项目
在idea的空项目中创建一个java项目，创建好后将自动生成的Main类删除
3.2.2 导入对应Jar包
在创建完项目后，右键点击bookstore，创建目录，创建一个名为lib的目录，将附件中的lib文件夹中的问价导入到项目中的lib目录下
3.2.3 添加为库
选中所有jar包，将其添加为库
成功添加后会带有索引箭头
3.2.4 创建JDBC连接 (详细代码请查看项目文件)
在src目录下创建一个java类，名为dao.BaseDao
| package dao; import java.sql.*; /** * @program: Book * @ClassName BaseDao * @description: * @author: 苏芮溪 * @create: 2024−11-18 17:25 * @Version 1.0 **/ public class BaseDao { public static final String DRIVERCLASSNAME = "com.mysql.cj.jdbc.Driver"; public static final String URL = "jdbc:mysql://localhost:3306/bookstore?sslMode=REQUIRED&characterEncoding=UTF-8&connectionTimeZone=GMT%2B8&forceConnectionTimeZoneToSession=true"; public static final String USER = "root"; public static final String PASS = "admin"; /** * 获取数据库连接 */ public Connection getConnection() { Connection conn = null; try { //装载驱动.3 Class.forName(DRIVERCLASSNAME); //连接数据库 conn = DriverManager.getConnection(URL, USER, PASS); System.out.println(conn); } catch (Exception e) { e.printStackTrace(); } return conn; } protected void closedAll(Connection conn, PreparedStatement ps, ResultSet rs) { if (rs != null) { try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if (ps != null) { try { ps.close(); } catch (SQLException e) { e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { e.printStackTrace(); } } } } |
3.3 Java代码实现
3.3.1创建对应层的软件包目录
按如下图片创建对应的软件包：
3.3.2创建entity的实体类
创建的实体类中的属性要与数据库中的实体类的属性一一对应（个数和类型要对应）（可以选择实现Serializable接口）
自动生成对应的get，set方法以及有参构造无参构造（ALT+INSERT）
| package entity; import java.io.Serializable; /** * @program: Book * @ClassName Book * @description: * @author: 苏芮溪 * @create: 2024−11-18 17:45 * @Version 1.0 **/ public class Book implements Serializable { int id; String name; String author; double price; public Book() { } public Book(int id, String name, String author, double price) { this.id = id; this.name = name; this.author = author; this.price = price; } public Book(String name, String author, double price) { this.name = name; this.author = author; this.price = price; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getAuthor() { return author; } public void setAuthor(String author) { this.author = author; } public double getPrice() { return price; } public void setPrice(double price) { this.price = price; } @Override public String toString() { return "Book{" + "id=" + id + ", name='" + name + '\'' + ", author='" + author + '\'' + ", price=" + price + '}'; } } |
3.3.3创建dao层接口和实现类
创建BookDao接口，在接口中声明方法
| package dao; import entity.Book; import java.util.List; /** * @program: Book * @ClassName BookDao * @description: * @author: 苏芮溪 * @create: 2024−11-18 17:48 * @Version 1.0 **/ public interface BookDao { //查询所有书籍 List<Book> findAll(); //添加书籍 boolean addBook(Book book); //通过书的id更新书籍 boolean updateBook(Book book,int id); //删除书籍 boolean deleteBook(Book book); List<Book> findLike(String name); } |
创建BookDaoImpl实现类，继承BaseDao类实现BookDao接口，在BookDaoImpl中实现对应方法（查阅代码文件）
| package dao.impl; import dao.BaseDao; import dao.BookDao; import entity.Book; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.Collections; import java.util.List; /** @program: Book @ClassName BookDaoImpl @description: @author: 苏芮溪 @create: 2024−11-18 17:53 @Version 1.0 **/ public class BookDaoImpl extends BaseDao implements BookDao { //创建连接引用 Connection conn = null; //创建操作引用 PreparedStatement ps = null; //创捷接收引用 ResultSet rs = null; @Override public List<Book> findAll() { List<Book> books = new ArrayList<Book>(); //SQL操作语句 String sql = "select * from book"; try { //进行数据库连接（调用BaseDao中的方法） conn = getConnection(); //创建操作对象 ps = conn.prepareStatement(sql); //接受处理结果 rs = ps.executeQuery(); while (rs.next()) { //根据返回结果创建book对象 Book book = new Book(rs.getInt("bookid"),rs.getString("bookname"), rs.getString("bookauthor"), rs.getDouble("bookprice")); //将对象加入到列表中 books.add(book); } } catch (SQLException e) { e.printStackTrace(); }finally { closedAll(conn, ps, rs); } return books; } @Override public boolean addBook(Book book) { //SQL操作语句 String sql = "insert into book(bookname,bookauthor,bookprice) values(?,?,?)"; try { //进行数据库连接（调用BaseDao中的方法） conn = getConnection(); //创建操作对象 ps = conn.prepareStatement(sql); //处理sql操作参数 ps.setString(1,book.getName()); ps.setString(2,book.getAuthor()); ps.setDouble(3,book.getPrice()); //执行 插入 修改 删除 都执行此语句 int i = ps.executeUpdate(); if (i > 0) { return true; } } catch (SQLException e) { e.printStackTrace(); }finally { closedAll(conn, ps, null); } return false; } @Override public boolean updateBook(Book book, int id) { //SQL操作语句 String sql = "update book set bookname=?,bookauthor=?,bookprice=? where bookid=?"; try { //进行数据库连接（调用BaseDao中的方法） conn = getConnection(); //创建操作对象 ps = conn.prepareStatement(sql); //处理sql操作参数 ps.setString(1,book.getName()); ps.setString(2,book.getAuthor()); ps.setDouble(3,book.getPrice()); ps.setInt(4,id); //执行 插入 修改 删除 都执行此语句 int i = ps.executeUpdate(); if (i > 0) { return true; } } catch (SQLException e) { e.printStackTrace(); }finally { closedAll(conn, ps, null); } return false; } @Override public boolean deleteBook(Book book) { //SQL操作语句 String sql = "delete from book where bookname=?"; try { //进行数据库连接（调用BaseDao中的方法） conn = getConnection(); //创建操作对象 ps = conn.prepareStatement(sql); //处理sql操作参数 ps.setString(1,book.getName()); //执行 插入 修改 删除 都执行此语句 int i = ps.executeUpdate(); if (i > 0) { return true; } } catch (SQLException e) { e.printStackTrace(); }finally { closedAll(conn, ps, null); } return false; } @Override public List<Book> findLike(String name) { List<Book> books = new ArrayList<Book>(); //SQL操作语句 String sql = "select * from book where bookname like ?"; try { //进行数据库连接（调用BaseDao中的方法） conn = getConnection(); //创建操作对象 ps = conn.prepareStatement(sql); ps.setString(1,"%"+name+"%"); //接受处理结果 rs = ps.executeQuery(); while (rs.next()) { //根据返回结果创建book对象 Book book = new Book(rs.getInt("bookid"),rs.getString("bookname"), rs.getString("bookauthor"), rs.getDouble("bookprice")); //将对象加入到列表中 books.add(book); } } catch (SQLException e) { e.printStackTrace(); }finally { closedAll(conn, ps, rs); } return books; } } |
3.3.4创建service层接口和实现类
| package service; import entity.Book; import java.util.List; /** * @program: Book * @ClassName BookService * @description: * @author: 苏芮溪 * @create: 2024−11-18 18:09 * @Version 1.0 **/ public interface BookService { //查询所有书籍 List<Book> findAll(); //添加书籍 boolean addBook(Book book); //通过书的id更新书籍 boolean updateBook(Book book,int id); //删除书籍 boolean deleteBook(Book book); //模糊查询 List<Book> findLike(String name); } |
| package service.impl; import dao.BookDao; import dao.impl.BookDaoImpl; import entity.Book; import service.BookService; import java.util.Collections; import java.util.List; /** * @program: Book * @ClassName BookServiceImpl * @description: * @author: 苏芮溪 * @create: 2024−11-18 18:10 * @Version 1.0 **/ public class BookServiceImpl implements BookService { //面向接口变成 BookDao bookDao; //构造函数 public BookServiceImpl() { bookDao = new BookDaoImpl(); } @Override public List<Book> findAll() { return bookDao.findAll(); } @Override public boolean addBook(Book book) { return bookDao.addBook(book); } @Override public boolean updateBook(Book book, int id) { return bookDao.updateBook(book, id); } @Override public boolean deleteBook(Book book) { return bookDao.deleteBook(book); } @Override public List<Book> findLike(String name) { return bookDao.findLike(name); } } |
3.5创建test类运行程序
3.5.1总查询：
先运行一下一下代码，查询一下所有的书籍，同时也是检测一下数据库的连接是否正确：
我们可以清晰看到数据库连接地址以及书籍信息
3.5.2模糊查询：
查询书名中带有“的”的书籍
3.5.3添加书籍：
添加一本书，并使用模糊查询查找到它
3.5.4删除书籍：
3.5.5更新书籍
四、注意事项总结
在使用JDBC进行数据库连接时，数据库的名称url，用户名密码一定要正确，不然无法正确连接数据库；同时，数据库连接时，一定要记得加载驱动，以及将Jar包导入类库。
在Dao层中，实现sql查询时，sql中的属性是数据库中表的属性，而在下面返回到的resultset中转为我们的Book类时，取值取得是数据库中的属性的值， 构造出来的是我们的实体类Book。
查询中可以根据作者查询，可以查询价格区间，在更新和删除
总之，记住JDBC的总体结构，熟悉SQL语句，掌握Java代码编写，再加以练习就可以很好地掌握这部分内容。
![[Realtek sdk-3.4.14b] RTL8197FH-VG新增jffs2分区操作说明](https://i-blog.csdnimg.cn/direct/fb877ef307724527b8c9e8a1e1b4759d.png)
