0
0

不会吧不会吧，这博主居然用了1w+字来讲 JDBC 连接 MySQL，还花了好几个晚上写出来的

哈喽~大家好，这次我们来看看 JDBC 如何 连接 MySQL.

开头

  1.    首先如何下载安装 MySQL （链接），如何下载安装 SQLyog （链接），以及怎样下载 mysql-connector-java.jar（链接），可以看看这三位大佬的，这里操作数据库用的是  SQLyog  这款软件。
  1.    好了之后，我们用 idea 创建项目，记得要勾选 Web应用程序。

  1.     然后将 mysql-connector-java.jar 放入在 WEB - INF 里面的 lib 里面（如果没有就自己创建一个，记得要打包文件）

介绍

JDBC 的概念

  1.     JDBC 是 Java DataBase Connectivity (Java 数据连接)技术的简称，是一种可用于执行 SQL 语句的 Java API。它由一些 java 语言编写的类和接口组成；程序员通过使用 jdbc 可以方便地将 SQL 语句传送给几乎任何一种数据库。

JDBC 的功能

(1) 与数据库建立连接。
(2) 向数据库发送 SQL 语句并执行这些语句。
(3) 处理数据返回的结果。

JDBC 的常用接口和类

(1) Driver 接口:加载驱动程序。
(2) DriverManager 类:装人所需的 JDBC 驱动程序，编程时调用它的方法来创建连接。
(3) Connection 接口:编程时使用该类对象创建 Statement 对象。
(4) Statement 接口:编程时使用该类对象得到 ResultSet 对象。
(5) ResultSet 类:负责保存 Statement 执行后所产生的查询结果。

工作原理图

数据库的创建（MySQL）

右击 root@localhost 创建 db1 （注：基字符集一定要 uft8，别问为什么，本人因为这被折磨了半小时）输入名称 user

或者用 sql 语句创建

  1. CREATE DATABASE db1;
  3. USE db1;
  5. CREATE TABLE `user`(
  6.     `id` INT,
  7.     `name` VARCHAR(30)
  8. );
  10. INSERT INTO `user` VALUES (1,'张一'),(2,'张二'),(3,'张三'),(4,'张四'),(5,'张五');

连接 MySQL

1.注册驱动

  1. Class.forName("com.mysql.cj.jdbc.Driver");

2.获取连接

  1. Connection com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");

3.获取执行者连接

  1. Statement stat = com.createStatement();

4.执行 SQL 语句，并接受结果

  1. String sql = "SELECT * FROM user";
  2. ResultSet rs = stat.executeQuery(sql);

5.处理结果

  1. while (rs.next()){
  2.         System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
  3. }

6.释放资源

  1. com.close();
  2. stat.close();
  3. com.close();

代码连接起来

  1. package com.text.jdbc;
  3. import java.sql.*;
  5. public class jbdc {
  6.     public static void main(String[] args) throws Exception {
  8.         Class.forName("com.mysql.cj.jdbc.Driver");
  9.         Connection com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  10.         // DriverManager 注册驱动
  11.         // Connection 数据库连接对象  url（指定连接的路径 语法：“jdbc:mysql://ip地址:端口号/数据库名称”）
  12.         Statement stat = com.createStatement();
  13.         //执行 sql 语句的对象
  14.         String sql = "SELECT * FROM user";
  15.         ResultSet rs = stat.executeQuery(sql);
  16.         // 执行 增删改查 （DML）语句用 int executeUpdate(Sting sql);
  17.         // 执行 DQL 语句 ResultSet executeQuery(String sql);
  18.         // 对象释放 void close();
  19.         while (rs.next()){
  20.             System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
  21.         }
  23.         com.close();
  24.         stat.close();
  25.         com.close();
  26.     }
  27. }

这里有个小细节，在步骤一中，注册驱动那，如果忘了驱动名或者敲错了，可以在 lib -> mysql-connector-java.jar -> jdbc -> Driver 里面查看

点击运行，控制台读取数据库的数据，完成连接。

对 MySQL 进行增删改查

准备工作

  1.    首先我们创建好数据库(名为db1)数据表(名为student),并添加好数据 (这是我们的总表)，如图：

  1.    在前面我们用 jdbc 类 **打印出所有的数据表信息**，这里我们换一种方式，升级版
  3.    这里我们创建 controller包(里面有 StudentController 类)、dao包(里面有 StudentDao 接口、StudentDaoImpl 类)、daomian 包(里面有 Student 类)、service 包(里面有 StudentService 接口、StudentServiceImpl 类)，如图，并写入代码：

StudentController 类：

  1. package com.inxzw.domain.controller;
  3. import com.inxzw.domain.domain.Student;
  4. import com.inxzw.domain.service.StudentService;
  5. import com.inxzw.domain.service.StudentServiceImpl;
  6. import org.testng.annotations.Test;
  8. import java.util.ArrayList;
  10. public class StudentController {
  12.     private StudentService service = new StudentServiceImpl();
  14.     @Test
  15.     public void findAll(){
  16.         ArrayList<Student> list = service.findAll();
  17.         for (Student stu : list){
  18.             System.out.println(stu);
  19.         }
  20.     }
  22.     public void findById(){
  24.     }
  26. }

** StudentDao 接口：**

  1. package com.inxzw.domain.dao;
  3. import com.inxzw.domain.domain.Student;
  5. import java.util.ArrayList;
  7. public interface StudentDao {
  9.     // 查询所有学生信息
  10.     public abstract ArrayList<Student> findAll();
  11.     //获取id
  12.     public abstract Student findById(Integer id);
  13. //    新增信息
  14.     public abstract int insert(Student stu);
  15. //    修改信息
  16.     public abstract int update(Student stu);
  17. //    删除信息
  18.     public abstract int delete(Integer id);
  20. }
  1. **StudentDaoImpl类：**
  1. package com.inxzw.domain.dao;
  3. import com.inxzw.domain.domain.Student;
  5. import java.sql.*;
  6. import java.util.ArrayList;
  7. import java.util.Date;
  9. public class StudentDaoImpl implements StudentDao{
  11.     @Override
  12.     public ArrayList<Student> findAll(){
  14.         Connection com = null;
  15.         Statement stat = null;
  16.         ResultSet rs = null;
  18.         ArrayList<Student> list = new ArrayList<>();
  19.         try {
  20.             Class.forName("com.mysql.cj.jdbc.Driver");
  21.             com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  22.             stat = com.createStatement();
  23.             String sql = "SELECT * FROM student";
  24.             rs = stat.executeQuery(sql);
  26.             while (rs.next()){
  27. //                System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
  29.                 Integer sid = rs.getInt("sid");
  30.                 String name = rs.getString("name");
  31.                 Integer age = rs.getInt("age");
  32.                 Date birthday = rs.getDate("birthday");
  34.                 Student stu = new Student(sid,name,age,birthday);
  35.                 list.add(stu);
  37.             }
  39.         }catch (Exception e){
  40.             e.printStackTrace();
  41.         }finally {
  42.             if (com != null)
  43.             {
  44.                 try {
  45.                     com.close();
  46.                 } catch (SQLException e) {
  47.                     e.printStackTrace();
  48.                 }
  49.             }
  51.             if (stat != null)
  52.             {
  53.                 try {
  54.                     stat.close();
  55.                 } catch (SQLException e) {
  56.                     e.printStackTrace();
  57.                 }
  58.             }
  60.             if (rs != null)
  61.             {
  62.                 try {
  63.                     rs.close();
  64.                 } catch (SQLException e) {
  65.                     e.printStackTrace();
  66.                 }
  67.             }
  68.         }
  69.         return list;
  70.     }
  72.     @Override
  73.     public Student findById(Integer id) {
  74.         return null;
  75.     }
  77.     @Override
  78.     public int insert(Student stu) {
  79.         return 0;
  80.     }
  82.     @Override
  83.     public int update(Student stu) {
  84.         return 0;
  85.     }
  87.     @Override
  88.     public int delete(Integer id) {
  89.         return 0;
  90.     }
  92. }
  1. **Student 类：**
  1. package com.inxzw.domain.domain;
  3. import java.util.Date;
  5. public class Student {
  6.     private Integer sid;
  7.     private String name;
  8.     private  Integer age;
  9.     private Date birthday;
  11.     public Student(Integer sid, String name, Integer age, Date birthday) {
  12.         this.sid = sid;
  13.         this.name = name;
  14.         this.age = age;
  15.         this.birthday = birthday;
  16.     }
  18.     public Integer getSid() {
  19.         return sid;
  20.     }
  22.     public void setSid(Integer sid) {
  23.         this.sid = sid;
  24.     }
  26.     public String getName() {
  27.         return name;
  28.     }
  30.     public void setName(String name) {
  31.         this.name = name;
  32.     }
  34.     public Integer getAge() {
  35.         return age;
  36.     }
  38.     public void setAge(Integer age) {
  39.         this.age = age;
  40.     }
  42.     public Date getBirthday() {
  43.         return birthday;
  44.     }
  46.     public void setBirthday(Date birthday) {
  47.         this.birthday = birthday;
  48.     }
  50.     @Override
  51.     public String toString() {//打印
  52.         return "Student{" +
  53.                 "sid=" + sid +
  54.                 ", name='" + name + '\'' +
  55.                 ", age=" + age +
  56.                 ", birthday=" + birthday +
  57.                 '}';
  58.     }
  59. }
  1. **StudentService 接口：**
  1. package com.inxzw.domain.service;
  3. import com.inxzw.domain.domain.Student;
  5. import java.util.ArrayList;
  7. public interface StudentService {
  9.     public abstract ArrayList<Student> findAll();
  11.     public abstract Student findById(Integer id);
  13.     public abstract int insert(String stu);
  15.     public abstract int update(Student stu);
  17.     public abstract int delete(Integer id);
  19. }
  1. **StudentServiceImpl 类：**
  1. package com.inxzw.domain.service;
  3. import com.inxzw.domain.dao.StudentDao;
  4. import com.inxzw.domain.dao.StudentDaoImpl;
  5. import com.inxzw.domain.domain.Student;
  7. import java.util.ArrayList;
  9. public class StudentServiceImpl implements StudentService{
  11.     private StudentDao dao = new StudentDaoImpl();
  13.     public ArrayList<Student> findAll(){
  14.         return dao.findAll();
  15.     }
  17.     public Student findById(Integer id){
  18.         return null;
  19.     }
  21.     @Override
  22.     public int insert(String stu) {
  23.         return 0;
  24.     }
  26.     @Override
  27.     public int update(Student stu) {
  28.         return 0;
  29.     }
  31.     @Override
  32.     public int delete(Integer id) {
  33.         return 0;
  34.     }
  36. }
  1.    在 StudentController 类(控制类) ，运行 findAll() ，记得要加 @Text ，点击运行。完成查询所有信息。

JDBC 实践操作

根据 id 获取信息

我们可以通过 id 来获取属性，eg：通过 id 为 5 来查询元组。代码如下：

StudentDaoImpl 类：

  1. public Student findById(Integer id) {
  3.         Student stu = new Student();
  4.         Connection com = null;
  5.         Statement stat = null;
  6.         ResultSet rs = null;
  8.         ArrayList<Student> list = new ArrayList<>();
  9.         try {
  10.             Class.forName("com.mysql.cj.jdbc.Driver");
  11.             com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  12.             stat = com.createStatement();
  13.             String sql = "SELECT * FROM student WHERE sid = '"+id+"' ";
  14.             rs = stat.executeQuery(sql);
  16.             while (rs.next()){
  17. //                System.out.println(rs.getInt("id") + "\t" + rs.getString("name"));
  19.                 Integer sid = rs.getInt("sid");
  20.                 String name = rs.getString("name");
  21.                 Integer age = rs.getInt("age");
  22.                 Date birthday = rs.getDate("birthday");
  24.                 stu.setSid(sid);
  25.                 stu.setName(name);
  26.                 stu.setAge(age);
  27.                 stu.setBirthday(birthday);
  28.             }
  30.         }catch (Exception e){
  31.             e.printStackTrace();
  32.         }finally {
  33.             if (com != null)
  34.             {
  35.                 try {
  36.                     com.close();
  37.                 } catch (SQLException e) {
  38.                     e.printStackTrace();
  39.                 }
  40.             }
  42.             if (stat != null)
  43.             {
  44.                 try {
  45.                     stat.close();
  46.                 } catch (SQLException e) {
  47.                     e.printStackTrace();
  48.                 }
  49.             }
  51.             if (rs != null)
  52.             {
  53.                 try {
  54.                     rs.close();
  55.                 } catch (SQLException e) {
  56.                     e.printStackTrace();
  57.                 }
  58.             }
  59.         }
  60.         return stu;
  61.     }
  1. **StudentServiceImpl 类：**
  1.     public Student findById(Integer id){
  2.         return dao.findById(id);
  3.     }
  1. **StudentController 类：**
  1.     public void findById(){
  2.         Student stu = service.findById(4);//查询3号记录
  3.         System.out.println(stu);
  4.     }
  1.     点击运行，完成查询。

添加信息

StudentDaoImpl 类：

  1.     @Override
  2.     public int insert(Student stu) {
  4.         Connection com = null;
  5.         Statement stat = null;
  6.         int result = 0;
  8.         try {
  9.             Class.forName("com.mysql.cj.jdbc.Driver");
  10.             com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  11.             stat = com.createStatement();
  13.             Date d = stu.getBirthday();
  14.             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  15.             String birthday = sdf.format(d);
  17.             String sql = "INSERT INTO student VALUES ('"+stu.getSid()+"','"+stu.getName()+"','"+stu.getAge()+"','"+birthday+"')";
  18.             result = stat.executeUpdate(sql);
  20.         }catch (Exception e){
  21.             e.printStackTrace();
  22.         }finally {
  23.             if (com != null)
  24.             {
  25.                 try {
  26.                     com.close();
  27.                 } catch (SQLException e) {
  28.                     e.printStackTrace();
  29.                 }
  30.             }
  32.             if (stat != null)
  33.             {
  34.                 try {
  35.                     stat.close();
  36.                 } catch (SQLException e) {
  37.                     e.printStackTrace();
  38.                 }
  39.             }
  40.         }
  41.         return result;
  42.     }

StudentServiceImpl 类：

  1.     public int insert(Student stu) {
  2.         return dao.insert(stu);
  3.     }
  1. **StudentController 类：**
  1.     public void insert(){
  2.         Student stu = new Student(9, "张九", 29, new Date());
  3.         int result = service.insert(stu);
  5.         if (result != 0){
  6.             System.out.println("添加成功");
  7.         }else {
  8.             System.out.println("添加失败");
  9.         }
  10.     }
  1.      点击运行，显示出添加成功，我们用 findAll() 来查看表信息，完成添加。

修改信息

StudentDaoImpl 类：

  1.     public int update(Student stu) {
  2.         Connection com = null;
  3.         Statement stat = null;
  4.         int result = 0;
  6.         try {
  7.             Class.forName("com.mysql.cj.jdbc.Driver");
  8.             com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  9.             stat = com.createStatement();
  11.             Date d = stu.getBirthday();
  12.             SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
  13.             String birthday = sdf.format(d);
  15.             String sql = "UPDATE student SET sid = '"+stu.getSid()+"', name = '"+stu.getName()+"', age = '"+stu.getAge()+"',birthday = '"+birthday+"' WHERE sid = '"+stu.getSid()+"'";
  16.             result = stat.executeUpdate(sql);
  18.         }catch (Exception e){
  19.             e.printStackTrace();
  20.         }finally {
  21.             if (com != null)
  22.             {
  23.                 try {
  24.                     com.close();
  25.                 } catch (SQLException e) {
  26.                     e.printStackTrace();
  27.                 }
  28.             }
  30.             if (stat != null)
  31.             {
  32.                 try {
  33.                     stat.close();
  34.                 } catch (SQLException e) {
  35.                     e.printStackTrace();
  36.                 }
  37.             }
  38.         }
  39.         return result;
  40.     }

StudentServiceImpl 类：

  1.     public int update(Student stu) {
  2.         return dao.update(stu);
  3.     }

StudentController 类：

  1.     @Test
  2.     public void update(){
  3.         Student stu = service.findById(5);
  5.         stu.setName("张五点五");
  7.         int result = service.update(stu);
  8.         if (result != 0){
  9.             System.out.println("修改成功");
  10.         }else {
  11.             System.out.println("修改失败");
  12.         }
  13.     }
  1.     点击运行，显示出修改成功，我们用 findAll() 来查看表信息，完成修改。

删除信息

StudentDaoImpl 类：

  1. public int delete(Integer id) {
  2.         Connection com = null;
  3.         Statement stat = null;
  4.         int result = 0;
  6.         try {
  7.             Class.forName("com.mysql.cj.jdbc.Driver");
  8.             com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");
  9.             stat = com.createStatement();
  11.             String sql = "DELETE FROM student WHERE sid = '"+id+"'";
  12.             result = stat.executeUpdate(sql);
  14.         }catch (Exception e){
  15.             e.printStackTrace();
  16.         }finally {
  17.             if (com != null)
  18.             {
  19.                 try {
  20.                     com.close();
  21.                 } catch (SQLException e) {
  22.                     e.printStackTrace();
  23.                 }
  24.             }
  26.             if (stat != null)
  27.             {
  28.                 try {
  29.                     stat.close();
  30.                 } catch (SQLException e) {
  31.                     e.printStackTrace();
  32.                 }
  33.             }
  34.         }
  35.         return result;
  36.     }

StudentServiceImpl 类：

  1.     public int delete(Integer id) {
  2.         return dao.delete(id);
  3.     }

StudentController 类：

  1.     @Test
  2.     public void delete(){
  3.         int result = service.delete(5);
  5.         if (result != 0){
  6.             System.out.println("删除成功");
  7.         }else {
  8.             System.out.println("删除失败");
  9.         }
  10.     }
  1.    点击运行，显示出删除成功，我们用 findAll() 来查看表信息，完成删除（我们删除了张五点五那一行信息）。

代码优化

  1.    在这里我们完成了对数据表进行了增删改查操作，最后来看 StudentDaoImpl 类中发现我们已经写了 300 多行代码，而且我们还写了，非常多的重复代码，效率非常的底，所以为了减少代码量，这里我们需要优化。

  1.    我们创建一个新的包名叫 utils ，新建类 JDBCutils，然后创建配置文件 config.properties

  1.        在 JDBCutils 类里面：“构造私有方法、声明所需要的配置变量、注册驱动、获取数据库连接方法、释放资源方法” ，代码如下：
  1.     private JDBCutils(){}
  3.     // 声明所需要的配置变量
  4.     private static String driverClass;
  5.     private static String url;
  6.     private static String username;
  7.     private static String password;
  8.     private static Connection con;
  10.     //提供静态代码块，读取配置文件信息为变量赋值，注册驱动
  11.     static {
  12.         try {
  13.             InputStream is = JDBCutils.class.getClassLoader().getResourceAsStream("config.properties");
  14.             Properties prop = new Properties();
  15.             prop.load(is);
  17.             driverClass = prop.getProperty("driverClass");
  18.             url = prop.getProperty("url");
  19.             username = prop.getProperty("username");
  20.             password = prop.getProperty("password");
  21.         } catch (IOException e) {
  22.             e.printStackTrace();
  23.         }
  24.     }
  26.     // 获取数据库连接方法
  27.     public static Connection getConecction(){
  28.         try {
  29.             con = DriverManager.getConnection(url,username,password);
  30.         } catch (SQLException e) {
  31.             e.printStackTrace();
  32.         }
  33.         return con;
  34.     }
  36.     //释放资源方法
  37.     public static void close(Connection con, Statement stat, ResultSet rs){
  38.         if (con != null){
  39.             try {
  40.                 con.close();
  41.             } catch (SQLException e) {
  42.                 e.printStackTrace();
  43.             }
  44.         }
  46.         if (stat != null){
  47.             try {
  48.                 stat.close();
  49.             } catch (SQLException e) {
  50.                 e.printStackTrace();
  51.             }
  52.         }
  53.     }
  55.     public static void close(Connection con, Statement stat){
  56.         if (con != null){
  57.             try {
  58.                 con.close();
  59.             } catch (SQLException e) {
  60.                 e.printStackTrace();
  61.             }
  62.         }
  64.     }

** config.properties ：**

  1. driverClass = com.mysql.cj.jdbc.Driver
  2. url = jdbc:mysql://10.16.158.90:3306/db1
  3. username = root
  4. password = 123456

我们已经创建好了准备工作，下面来看看 findAll() 是如何优化的

首先，这两步是可以替换掉的

之前：

  1. Class.forName("com.mysql.cj.jdbc.Driver");
  2. com = DriverManager.getConnection("jdbc:mysql://10.16.158.90:3306/db1", "root", "123456");

** 之后：**

  1. com = JDBCutils.getConecction();

之前：

  1.             if (com != null)
  2.             {
  3.                 try {
  4.                     com.close();
  5.                 } catch (SQLException e) {
  6.                     e.printStackTrace();
  7.                 }
  8.             }
  10.             if (stat != null)
  11.             {
  12.                 try {
  13.                     stat.close();
  14.                 } catch (SQLException e) {
  15.                     e.printStackTrace();
  16.                 }
  17.             }
  19.             if (rs != null)
  20.             {
  21.                 try {
  22.                     rs.close();
  23.                 } catch (SQLException e) {
  24.                     e.printStackTrace();
  25.                 }
  26.             }

** 之后：**

  1. JDBCutils.close(com, stat, rs);

现在看是不是感觉很爽？是不是省去了很多代码？点击运行，看看是否能跑起来。

ok，运行没问题，优化成功。

然后，findById()、insert()、update()、delete() 方法操作都一样，这里就不一一显示了。

小结：大家在 **StudentDaoImpl **类中有一个小细节，在 DriverManager.getConnection 中设置（“jdbc:mysql://ip地址:端口号/数据库名称”）ip 地址这里，在换地方写代码时，一定要记得改，我debug 了一小时才发现，我一直在想为什么上午下午在图书馆里面有用，晚上在寝室就没用了？血淋淋的痛啊~ 亲们，一定要记得改！

（求关注）持续更新中……

标签： java intellij-idea 前端
本文转载自: https://blog.csdn.net/aasd23/article/details/124218870
版权归原作者 一个名叫追的程序猿 所有， 如有侵权，请联系我们删除。
登录后发布评论

“不会吧不会吧，这博主居然用了1w+字来讲 JDBC 连接 MySQL，还花了好几个晚上写出来的”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？