💟💟前言

友友们大家好，我是你们的小王同学😗😗

今天给大家带来的是MYSQL——JBDC实现增删改查

希望能给大家带来有用的知识

觉得小王写的不错的话 麻烦动动小手 点赞👍 收藏⭐  评论📄

小王的主页：小王同学🚗

小王的gitee：小王同学🏩

小王的github：小王同学💦

 

目录🤶🏼

API概述🎅🏼

建立连接🎅🏼

新增（create）🎅🏼

代码附上：🎅🏼

 查询（select）🎅🏼

代码附上：🎅🏼

更新（update）🎅🏼

代码附上🎅🏼

 删除（delete）🎅🏼

代码附上🎅🏼

---

 小王同学先给大家简单的介绍下咱们的jdbc

Java数据库连接，（Java Database Connectivity，简称JDBC）是Java语言中用来规范客户端程序如何来访问数据库的应用程序接口，提供了诸如查询和更新数据库中数据的方法。JDBC也是Sun Microsystems的商标。我们通常说的JDBC是面向关系型数据库的。

API概述🎅🏼

JDBC API主要位于JDK中的java.sql包中（之后扩展的内容位于javax.sql包中），主要包括（斜体代表接口，需驱动程序提供者来具体实现）：

DriverManager：负责加载各种不同驱动程序（Driver），并根据不同的请求，向调用者返回相应的数据库连接（Connection）。Driver：驱动程序，会将自身加载到DriverManager中去，并处理相应的请求并返回相应的数据库连接（Connection）。Connection：数据库连接，负责与进行数据库间通讯，SQL执行以及事务处理都是在某个特定Connection环境中进行的。可以产生用以执行SQL的Statement。Statement：用以执行SQL查询和更新（针对静态SQL语句和单次执行）。PreparedStatement：用以执行包含动态参数的SQL查询和更新（在服务器端编译，允许重复执行以提高效率）。CallableStatement：用以调用数据库中的存储过程。SQLException：代表在数据库连接的建立和关闭和SQL语句的执行过程中发生了例外情况（即错误）。

数据类型的映射

建立连接🎅🏼

建立连接的五大步骤：

• 加载（注册）数据库
•  建立链接
•  执行SQL语句
•  处理结果集
• 关闭数据库

首先小王同学先去公共仓库去下载我们的jdbc driver jar包！~

👉🏼公共仓库的地址

 

在搜索栏搜索mysql~

 

 点第一个mysql connector

 

  里面有各种各样的版本 小王同学的mysql是8版本系列的所以也要下载同样版本系列的驱动包~

 

点击下载jar包 下载解压完 👉🏼 

 右键ctrl c 复制 我们的jar包

然后打开我们的IDEA

创建一个jdbc的项目

创建一个lib文件夹 右键ctrl v  

然后

 Add as Library 就把我们的jar 包导入进去了！~

接下来就是最精彩的CRUD辣~

 

 

我们先在任务管理器创建一个学生表

 接着在IDEA实现 往表里插入一行数据~

新增（create）🎅🏼

代码附上：🎅🏼

import com.mysql.cj.jdbc.MysqlDataSource;
 
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
 
public class JDBCInsert {
    public static void main(String[] args) throws SQLException {
        DataSource dataSource=new MysqlDataSource();
        // 1. 创建数据源对象. 数据源对象就描述了要访问的数据库是啥, 在哪.
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/wxz_03?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("root");
        // 2. 让代码和数据库服务器建立连接.
        Connection connection=dataSource.getConnection();
 
        // [用户输入] 通过用户输入的数据, 来确定插入的值.
        Scanner sc=new Scanner(System.in);
        System.out.println("请输入要查找的学号: ");
        int id=sc.nextInt();
        System.out.println("请输入要查找的姓名: ");
        String  name=sc.next();
 
        // 3. 构造要执行的 SQL 语句~~ [构造请求]
        String  sql="insert into  student  values(?,?)";
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1, id);
        statement.setString(2, name);
        System.out.println("statement: " + statement);
 
        // 4. 执行 SQL [发送请求 & 读取响应]
        //    执行方法, 有两个
        //    executeUpdate 对应插入删除修改语句. 返回值表示这次 SQL 操作影响到的行数.
        //    executeQuery  对应查询语句. 返回值则是返回的临时表数据.
        int n = statement.executeUpdate();
        System.out.println("n = " + n);
 
        // 5. 完成之后, 就需要关闭释放相关资源.
        statement.close();
        connection.close();
 
 
 
 
 
    }
}

插入成功 我们进入cmd 查看一下表里的数据吧~

 

成功辣~

接着是我们的查询

 查询（select）🎅🏼

代码附上：🎅🏼

import com.mysql.cj.jdbc.MysqlDataSource;
 
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
 
public class JDBCSelect {
    public static void main(String[] args) throws SQLException {
        // 1. 创建数据源
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/wxz_03?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("root");
 
        // 2. 建立连接
        Connection connection = dataSource.getConnection();
 
        // 3. 构造 SQL
        String sql = "select * from student where id = ?";
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1, 1);
 
        // 4. 执行 SQL
        //    查询语句要使用 executeQuery 来完成了.
        //    返回的结果是 ResultSet . 结果集. 里面是一个 "表" 这样的数据结构.
        //    一个表里有很多行, 每一行有很多列~~
        ResultSet resultSet = statement.executeQuery();
 
        // 5. 遍历结果集合
        while (resultSet.next()) {
            // 每次循环, 就能够获取到 resultSet 中的一行. 进一步的就可以拿到每一列!!
            // getXXX 也是有一系列方法的. 会根据要取的数据的类型, 来灵活决策.
            int id = resultSet.getInt(1);
            String name = resultSet.getString(2);
            System.out.println("id = " + id + ", name =" + name);
        }
 
        // 6. 释放资源
        resultSet.close();
        statement.close();
        connection.close();
    }
}

 我们在控制台成功的查询到了前面插入的一条数据~

 接着是更新数据

更新（update）🎅🏼

代码附上🎅🏼

import com.mysql.cj.jdbc.MysqlDataSource;
 
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
 
// 通过 JDBC 修改数据
public class JDBCUpdate {
    public static void main(String[] args) throws SQLException {
        // 1. 创建数据源
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource)dataSource).setURL("jdbc:mysql://127.0.0.1:3306/wxz_03?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource)dataSource).setUser("root");
        ((MysqlDataSource)dataSource).setPassword("root");
 
        // 2. 建立连接
        Connection connection = dataSource.getConnection();
 
        // 3. 构造 SQL
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入要修改的同学学号: ");
        int id = scanner.nextInt();
        System.out.println("请输入要修改的同学姓名: ");
        String name = scanner.next();
 
        String sql = "update student set name = ? where id = ?";
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setString(1, name);
        statement.setInt(2, id);
 
        // 4. 执行 SQL
        int n = statement.executeUpdate();
        System.out.println("n = " + n);
 
        // 5. 关闭释放资源
        statement.close();
        connection.close();
    }

 我们在控制台查询一下看看更新了没

果然更新了 我们的update 也成功了 接着是最后的一个delete环节~

 删除（delete）🎅🏼

代码附上🎅🏼

import com.mysql.cj.jdbc.MysqlDataSource;
 
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Scanner;
 
public class JDBCDelete {
    public static void main(String[] args) throws SQLException {
        // 1. 创建数据源
        DataSource dataSource = new MysqlDataSource();
        ((MysqlDataSource) dataSource).setURL("jdbc:mysql://127.0.0.1:3306/wxz_03?characterEncoding=utf8&useSSL=false");
        ((MysqlDataSource) dataSource).setUser("root");
        ((MysqlDataSource) dataSource).setPassword("root");
 
        // 2. 和数据库建立连接
        Connection connection = dataSource.getConnection();
 
        // 3. 构造 SQL 语句
        Scanner scanner = new Scanner(System.in);
        System.out.println("请输入要删除的学号: ");
        int id = scanner.nextInt();
 
        String sql = "delete from student where id = ?";
        PreparedStatement statement = connection.prepareStatement(sql);
        statement.setInt(1, id);
 
        // 4. 执行 SQL
        int n = statement.executeUpdate();
        System.out.println("n = " + n);
 
        // 5. 释放资源
        statement.close();
        connection.close();
    }
}

小王同学去控制台看看学号为1的同学删除了没有！

 

 成功辣~~

以上就是小王同学带给大家的通过jdbc连接IDEA来实现 CRUD 是不是很方便呢

如果觉得小王同学写的不错的话 麻烦动动小手给个三连（doge）

码字不易 感谢大家的支持！