📋 个人简介

  • 💖 作者简介：大家好，我是阿牛，全栈领域优质创作者。😜
  • 📝 个人主页：馆主阿牛🔥
  • 🎉 支持我：点赞👍+收藏⭐️+留言📝
  • 📣 系列专栏：java 小白到高手的蜕变🍁
  • 💬格言：要成为光，因为有怕黑的人！🔥
    请添加图片描述

目录

前言

一个项目肯定是离不开数据库的，每种语言都有涉及到操作数据库的内容，本节来看看java语言中如何使用JDBC如何操作数据库！

JDBC简介

就是使用java语言操作关系型数据库的一套API。
请添加图片描述

JDBC快速入们

主要有7步，当然在这之前肯定要先在当前项目或者模块中导入java操作mysql的jar包。对于这个jar包的下载不再总结！
在这里插入图片描述
如图，在模块中新建一个libs目录，将这个jar包放到里面。然后我们要让这个模块识别这个jar包：
在这里插入图片描述
在这里插入图片描述
我们选择模块有效就可以，然后就可以写代码了！
这7步我注视到代码里：

package JdbcDemo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class JDBCDemo {
    public static void main(String[] args){
        try {
            methods();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    public static void methods() throws Exception{
        // 1.注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 2.获取连接
        String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
        String name = "root";
        String password = "...";
        Connection conn = DriverManager.getConnection(url,name,password);
        // 3.定义sql
        String sql = "update spj set QTY = 400 where SNO = 'S1'";
        // 4.获取执行sql的对象Statement
        Statement stmt = conn.createStatement();
        // 5. 执行sql
        int count = stmt.executeUpdate(sql); //返回更新的数据条数
        // 6.输出执行结果
        System.out.println("受影响行数：" + count);
        // 7.释放资源
        stmt.close();  //关闭执行sql的对象
        conn.close(); //关闭连接
    }
}

在这里插入图片描述

JDBC API 详解

DriverManager

DriverManager （驱动管理类）作用：

  1. 注册驱动
  2. 获取数据库的连接

在这里插入图片描述
但是，我们上面的案例代码中，并没有使用registerDriver来注册驱动，而是使用反射的方式加载Driver类，这个类里面用到了这个方法，来看看源码：
在这里插入图片描述
当然，mysql 5.0之后的jar包，注册驱动的这行代码可以不用写了：

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

因为这个jar包中有文件记录了这个类名，会读取文件自动加载！
在这里插入图片描述

Connection

Connection的参数说明：
请添加图片描述
Connection（数据库连接对象）作用

  1. 获取执行sql的对象

请添加图片描述

  1. 管理事务

请添加图片描述

package Demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

/**
 * @Author：Aniu
 * @Date：2023/2/26 14:16
 * @description TODO
 */
public class Demo {
        public static void main(String[] args){
            try {
                methods();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        public static void methods() throws Exception{
            // 1.注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 2.获取连接
            String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
            String name = "root";
            String password = "...";
            Connection conn = DriverManager.getConnection(url,name,password);
            // 3.定义sql
            String sql1 = "update spj set QTY = 450 where SNO = 'S1'";
            String sql2 = "update spj set QTY = 250 where SNO = 'S2'";
            // 4.获取执行sql的对象Statement
            Statement stmt = conn.createStatement();

            try {
                // 开启事务
                conn.setAutoCommit(false);
                // 5. 执行sql
                int count1 = stmt.executeUpdate(sql1); //返回更新的数据条数
                // 6.输出执行结果
                System.out.println("受影响行数：" + count1);
                // 5. 执行sql
                int count2 = stmt.executeUpdate(sql2); //返回更新的数据条数
                // 6.输出执行结果
                System.out.println("受影响行数：" + count2);
                // 提交事务
                conn.commit();
            } catch (Exception e) {
                // 回滚事务
                conn.rollback();
                e.printStackTrace();
            }
            // 7.释放资源
            stmt.close();  //关闭执行sql的对象
            conn.close(); //关闭连接
        }
}

在这里插入图片描述
开启事务的目的就是当发生异常的时候回滚，让这几条sql操作都不执行，这里不再多说！

Statement

Statement 的作用

  • 执行sql操作
    请添加图片描述

ResultSet

ResultSet （结果集对象）作用
1.封装了DQL查询语句的结果

ResultSet stmt.execute(sql)  //执行DQL语句，返回ResultSet对象

在这里插入图片描述
请添加图片描述
例：

package Test;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 * @Author：Aniu
 * @Date：2023/2/26 14:50
 * @description ResultSet
 */
public class Test {
    public static void main(String[] args) throws Exception {
        // 1.注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 2.获取连接
        String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
        String name = "root";
        String password = "...";
        Connection conn = DriverManager.getConnection(url,name,password);
        // 3.定义sql
        String sql = "select * from spj";
        // 4.获取Statement对象
        Statement stmt = conn.createStatement();
        // 5.执行sql
        ResultSet rs = stmt.executeQuery(sql);
        // 6.处理结果，遍历rs中的所有数据
        while(rs.next()){
            String sno = rs.getString("SNO");
            String pno = rs.getString("PNO");
            String jno = rs.getString("JNO");
            int qty = rs.getInt("QTY");
            System.out.println(sno);
            System.out.println(pno);
            System.out.println(jno);
            System.out.println(qty);
            System.out.println("------------");
        }
        // 7.释放资源
        rs.close();
        stmt.close();  //关闭执行sql的对象
        conn.close(); //关闭连接
    }
}

在这里插入图片描述

PreparedStatement - SQL注入演示

PreparedStatement 作用：

  • 预编译SQL语句并执行：预防SQL注入问题

SQL注入

  • SQL注入是通过操作输入来修改事先定义的SQL语句，用以达到执行代码对服务器进行攻击的方法。

进行这个案例，我们要先创建一张用户表：

CREATE TABLE `user` (
  `uid` bigint NOT NULL AUTO_INCREMENT COMMENT '用户uid', 
  `login_name` varchar(20) NOT NULL COMMENT '登录用户名',
  `login_pwd` varchar(32) NOT NULL COMMENT '登录密码',
   PRIMARY KEY (`uid`)
)

在这里插入图片描述

package Login;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

/**
 * @Author：Aniu
 * @Date：2023/2/26 15:36
 * @description TODO
 */
public class UserLogin {
    public static void main(String[] args) throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
        String name = "root";
        String password = "...";
        Connection conn = DriverManager.getConnection(url,name,password);
        // 模拟用户输入的值
        String login_name = "aniu";
        String login_pwd = "123456";

        String sql = "select * from user where login_name = '" + login_name + "' and login_pwd = '" + login_pwd + "'";
        System.out.println(sql);

        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        // 判断是否登录成功
        if(rs.next()){
            System.out.println("登录成功！");
        }else{
            System.out.println("登录失败！");
        }
    }
}

在这里插入图片描述
现在我们模拟sql注入，即使密码错误也可以登录成功！

public static void main(String[] args) throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
        String name = "root";
        String password = "...";
        Connection conn = DriverManager.getConnection(url,name,password);
        // 模拟用户输入的值(演示sql注入，用户名和密码随便写）
        String login_name = "aniu666";
        String login_pwd = "' or '1' = '1";

        String sql = "select * from user where login_name = '" + login_name + "' and login_pwd = '" + login_pwd + "'";
        System.out.println(sql);

        Statement stmt = conn.createStatement();
        ResultSet rs = stmt.executeQuery(sql);
        // 判断是否登录成功
        if(rs.next()){
            System.out.println("登录成功！");
        }else{
            System.out.println("登录失败！");
        }
        // 释放资源
        rs.close();
        stmt.close();  //关闭执行sql的对象
        conn.close(); //关闭连接
    }

在这里插入图片描述
即使用户明和密码错误我们也可以登录，这是因为这个sql是恒等式所导致的！

那么怎么避免这个问题呢？就是通过这个PreparedStatement来解决！

请添加图片描述

public class UserLogin {
    public static void main(String[] args) throws Exception {
        Class.forName("com.mysql.cj.jdbc.Driver");
        String url = "jdbc:mysql://127.0.0.1:3306/myclasswork";
        String name = "root";
        String password = "...";
        Connection conn = DriverManager.getConnection(url,name,password);
        // 模拟用户输入的值(演示sql注入，用户名和密码随便写）
        String login_name = "aniu666";
        String login_pwd = "' or '1' = '1";

        String sql = "select * from user where login_name = ? and login_pwd = ?";

        PreparedStatement pstmt = conn.prepareStatement(sql);
        // 设置？的值
        pstmt.setString(1,login_name);
        pstmt.setString(2,login_pwd);

        ResultSet rs = pstmt.executeQuery();
        // 判断是否登录成功
        if(rs.next()){
            System.out.println("登录成功！");
        }else{
            System.out.println("登录失败！");
        }
        // 7.释放资源
        rs.close();
        pstmt.close();  //关闭执行sql的对象
        conn.close(); //关闭连接
    }
}

在这里插入图片描述
此时则显示登陆失败，避免了sql注入！本质上就是将sql中单引号进行了转义
’ \’ '，使用prepareStatement预编译sql性能更高！当然你要开启预编译，给Connection的url加参数：

String url = "jdbc:mysql://127.0.0.1:3306/myclasswork?useServerPrepStmts=true";

结语

如果你觉得博主写的还不错的话，可以关注一下当前专栏，博主会更完这个系列的哦！也欢迎订阅博主的其他好的专栏。

🏰系列专栏
👉软磨 css
👉硬泡 javascript
👉flask框架快速入门

# java # 数据库
Logo
腾讯云开发者社区

腾讯云面向开发者汇聚海量精品云计算使用和开发经验，营造开放的云计算技术生态圈。

更多推荐

cover

基于《2023腾讯云容器和函数计算技术实践精选集》—探索腾讯云TKE的Docker容器、Serverless和微服务优势

avatar 腾讯云开发者社区
cover

一站式加速、安全防护，EdgeOne为金融行业数字化升级保驾护航

avatar 腾讯云开发者社区
cover

全球安全加速一站式底座，EdgeOne以极致玩家体验撬动游戏行业增长

avatar 腾讯云开发者社区