【JDBC】 API解析-6ren

【JDBC】 API解析

转载作者：知者更新时间：2024-03-13 07:30:27

一、DriverManager

1、注册驱动：

二、Connection

1、获取执sql对象

2、事务管理

mysql事务管理

演示jdbc的事务

三、Statement

1、执行sql语句

四、ResultSet

ResultSet案例

五、PreparedStatement

PreparedStatement作用：

SQL注入

演示普通登录：

sql注入演示：

PreparedStatement解决SQL注入

PrepareStatement原理

一、DriverManager

DriverManager(驱动管理类)作用：
1、注册驱动

2、获取数据库连接

1、注册驱动：

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

注册驱动的书写方法，表面上没有使用 DriverManager类，选中Driver，ctrl+b看源码可知

package com.mysql.jdbc;

import java.sql.DriverManager;
import java.sql.SQLException;

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
    public Driver() throws SQLException {
    }

    static {
        try {
            DriverManager.registerDriver(new Driver());
        } catch (SQLException var1) {
            throw new RuntimeException("Can't register driver!");
        }
    }
}

它使用了 DriverManager.registerDriver（）的方法

在MySQL5之后的驱动包，可以省略注册驱动的步骤

自动加载jar包中的META-INF/services/java.sql.Driver文件的驱动类

2、获取连接
static Connection getConnection(String url,String user,String password)

参数

1、url：连接路径
语法：jdbc:mysql://ip地址(域名):端口号/数据库名称？参数键值对1&参数键值对2....

举例：jdbc:mysql://127.0.0.1:3306/db1(本机127.0.0.1，本机域名：localhost)

细节：如果连接的是本机mysql服务器，并且mysql默认端口号是3306 ，则url可以简写为:jdbc:mysql://数据库名称？参数键值对如：jdbc:mysql:///db1

配置userSSL=false参数，禁用安全连接方式，解决警告提示

2、user:用户名

3、password：密码

解决警告提示：

?userSSL=false

String url="jdbc:mysql://127.0.0.1:3306/db1？useSSL=false";

二、Connection

Connection（数据库连接对象）作用：

1、获取执行SQL的对象

2、管理事务

1、获取执sql对象

普通执行SQL对象
Statement createStatement()
预编译SQL的执行SQL对象：防止SQL注入
PrepareStatement prepareStatement(sql)
执行存储过程对象
CallableStatement prepareCall(sql)

2、事务管理

mysql事务管理

开启事务：BEGIN；/START TRANSACTION(start transaction)

提交事务：COMMIT;

回滚事务：ROLLBACK;

(MySQL默认自动提交事务)

JDBC事务管理：

Connection接口中定义了3个对应的方法

开启事务:setAutoCommit(boolean autoCommit);true为自动提交事务，false为手动提交事务（开启事务）

提交事务：commit()

回滚事务：rollback()

演示jdbc的事务

复制前面弄过的类到包下

package com.jdbc;

import com.mysql.jdbc.Connection;

import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;

public class JDBCConnectionDemo {
    public static void main(String[] args) throws Exception {
        //1、注册驱动
        Class.forName("com.mysql.jdbc.Driver");
       //2、获取连接
         //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
        String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
        //username是你的mysql用户名
        String username="root";
        //password是你的mysql密码
        String password="123456";
        Connection conn= (Connection) DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql1="update emp set salary=6666 where ename='zhangsan'";
        String sql2="update emp set salary=6666 where ename='lisi'";
        //4、获取执行sql的Statement对象
        Statement stat=conn.createStatement();
         
      //选中要处理的异常部分，ctrl+alt+t快捷键生成
        try {
            //开启事务
           conn.setAutoCommit(false);
           //执行sql
            int count1=stat.executeUpdate(sql1);
            //处理结果
            System.out.println("影响的行数:"+count1);

            //执行时sql
            int count2=stat.executeUpdate(sql2);
            //处理结果
            System.out.println("影响的行数:"+count2);

            //提交事务
            conn.commit();
        } catch (Exception e) {
            e.printStackTrace();
            //回滚事务(回到开启事务之前，即什么也没处理前)
             conn.rollback();
        }finally {
            //7、释放资源(先开后释放)

            stat.close();
            conn.close();
        }

    }
}

运行之前数据库emp表：

运行结果：

运行之后数据库emp表：

try之中的发生了异常，就会被catch捕获，发生回滚，回滚到还没有开启事务之前，就是数据没有修改之前，若是没有用事务，就会导致可能一个成功一个失败，这是我们不愿意看到的。** 启用了事务，用了回滚事务，可以保证多个事务要么同时成功，要么同时失败。**

三、Statement

Statemen作用：

1、执行sql语句

int executeUpdate(sql): 执行DML(对数据的增删改)、**DDL(对表和库的增删改)**语句

返回值:(1)DML语句影响的行数（2）DDL语句执行后，执行成功也可能返回0

ResultSet executeQuery（sql）:执行**DQL(对数据的查询操作)**语句

返回值：ResultSet结果对象

四、ResultSet

ResultSet(结果集对象)作用：

1.封装了DQL查询语句的结果
ResultSet stmt.executeQuery(sql):执行DQL语句，返回ResultSet对象

获取查询结果

boolean next():（1）将光标从当前位置向前移动一行（2）判断当前行是否是有效行

返回值：当前行有数据返回true，当前没数据返回false。

xxx getXxx(参数)：获取数据

解释：xxx表示数据类型；如int getInt(参数)；String getString(参数)；

参数：对于int是列的编号，从1开始，对于String是列的名称。

使用步骤：

1、游标向下移动一行，并判断该行是否有数据：next()

2、获取数据：getXxx(参数)

示例：

while(rs.next()){
    rs.getXxx(参数);
}

实例：

package com.jdbc;

import com.mysql.jdbc.Connection;

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

public class JDBCDemo3_ResultSet {
    public static void main(String[] args) throws Exception {
        //1、注册驱动
        Class.forName("com.mysql.jdbc.Driver");
       //2、获取连接
         //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
        String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
        //username是你的mysql用户名
        String username="root";
        //password是你的mysql密码
        String password="123456";
        Connection conn= (Connection) DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql="select *from emp";
        //4、获取执行sql的Statement对象
        Statement stmt=conn.createStatement();
        //5、执行sql语句
        ResultSet rs=stmt.executeQuery(sql);
        //6处理结果
      while(rs.next()){
          //获取数据 getXxx();括号中可以写所在行，也可以写列名
          int id=rs.getInt(1);
          String ename=rs.getString(2);
          int salary=rs.getInt(3);
          //另一种写法：写行的名称
//          int id=rs.getInt("id");
//          String ename=rs.getString("ename");
//          int salary=rs.getInt("salary");
          System.out.println(id);
          System.out.println(ename);
          System.out.println(salary);
          System.out.println("-----------");
      }
        //7、释放资源(先开后释放)
        rs.close();
        stmt.close();
        conn.close();

    }
}

数据库中emp表

运行之后：

ResultSet案例

需求：查询account账户数据，封装为Account对象中，并且存储到ArrayList集合中

创建一个pojo包，用来存放对象的。

创建了一个类，提供getSet方法

package com.pojo;

public class Account {
    private int id;
    private String ename;
    private int salary;

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getEname() {
        return ename;
    }

    public void setEname(String ename) {
        this.ename = ename;
    }

    public int getSalary() {
        return salary;
    }

    public void setSalary(int salary) {
        this.salary = salary;
    }
    //为了更好的显示，重写toString()方法

    @Override
    public String toString() {
        return "Account{" +
                "id=" + id +
                ", ename='" + ename + '\'' +
                ", salary=" + salary +
                '}'+"\n";
    }
}

jdbc包下创建的类中

package com.jdbc;

import com.mysql.jdbc.Connection;
import com.pojo.Account;

import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;

public class JDBCDemo4_ResultSet {
    public static void main(String[] args) throws Exception {
        //1、注册驱动
        Class.forName("com.mysql.jdbc.Driver");
       //2、获取连接
         //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
        String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
        //username是你的mysql用户名
        String username="root";
        //password是你的mysql密码
        String password="123456";
        Connection conn= (Connection) DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql="select *from emp";
        //4、获取执行sql的Statement对象
        Statement stmt=conn.createStatement();
        //5、执行sql语句
        ResultSet rs=stmt.executeQuery(sql);
        //6处理结果
        //创建集合对象
        List<Account> list=new ArrayList<>();
      while(rs.next()){
          //创建Account对象
          Account account=new Account();
          //获取数据 getXxx();括号中可以写所在行，也可以写列名
          int id=rs.getInt(1);
          String ename=rs.getString(2);
          int salary=rs.getInt(3);
          //赋值数据
          account.setId(id);
          account.setEname(ename);
          account.setSalary(salary);
          list.add(account);
      }
        System.out.println(list);
        //7、释放资源(先开后释放)
        rs.close();
        stmt.close();
        conn.close();

    }
}

运行结果：

五、PreparedStatement

PreparedStatement作用：

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

SQL注入

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

演示普通登录：

首先数据录kc_db1下的emp表为：

package com.jdbc;

import com.mysql.jdbc.Connection;

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

public class JDBCDemo5_UserLogin {
    public static void main(String[] args) throws Exception {

       //2、获取连接
         //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
        String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
        //username是你的mysql用户名
        String username="root";
        //password是你的mysql密码
        String password="123456";
        Connection conn= (Connection) DriverManager.getConnection(url, username, password);
           String name="zhangsan";
           String pwd="1233";
        //3、定义sql
        String sql="select *from emp where ename='"+name+"'and password='"+pwd+"'" ;
        System.out.println("这条SQL语句是:"+sql);
        //4、获取执行sql的Statement对象
        Statement stat=conn.createStatement();
        //5、执行sql语句
        ResultSet rs = stat.executeQuery(sql);
        //6处理结果,rs有值说明查找成功
      if(rs.next()){
          System.out.println("登录成功");
      }else{
          System.out.println("登录失败");
      }
        //7、释放资源(先开后释放)
        rs.close();
        stat.close();
        conn.close();

    }
}

运行结果：

输入其他(不成功的原因是数据库中没有账号密码为这个的)：

sql注入演示：

对于这条sql语句来说不点在于密码，账号任意

String name="随便写的名";
 String pwd=" ' or '1'='1";

运行结果：

这条SQL语句是:select *from emp where ename='随便写的名'and password=' ' or '1'='1'

** sql注入的本质就是改变原有的SQL语句，加入or之后1=1恒为真，所以这条语句就是true**

PreparedStatement解决SQL注入

①获取PreparedStatement对象

//sql语句中的参数，使用？占位符代替
String sql="select *from user where username=? and password=?";
//通过Connection对象获取，并传入对应的sql语句
PreparedStatement  pstmt=conn.prepareStatement(sql);

②设置参数

PreparedStatement对象：setXxx(参数1，参数2)：表示给参数1(?的位置)赋值为参数2

Xxx：数据类型；任意setInt(参数1，参数2)

参数：

参数1：表示？的位置编号，从1开始
参数2：？的值

③执行sql

executeUpdate();/excuteQuery();括号内不需要传递sql。

创建类：

package com.jdbc;

import com.mysql.jdbc.Connection;

import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Scanner;

public class JDBCDemo5_UserLogin {
    public static void main(String[] args) throws Exception {

       //2、获取连接
         //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
        String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
        //username是你的mysql用户名
        String username="root";
        //password是你的mysql密码
        String password="123456";
        Connection conn= (Connection) DriverManager.getConnection(url, username, password);
           String name="随便写的名";
           String pwd=" ' or '1'='1";
        //3、定义sql
        String sql="select *from emp where ename=? and password=?" ;

        //4、获取的PreparedStatement对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //设置参数
        pstmt.setString(1, name);
        pstmt.setString(2, pwd);

        //5、执行sql语句
        ResultSet rs =pstmt.executeQuery();
        System.out.println("这条SQL语句是:"+sql);
        //6处理结果,rs有值说明查找成功
      if(rs.next()){
          System.out.println("登录成功");
      }else{
          System.out.println("登录失败");
      }
        //7、释放资源(先开后释放)
        rs.close();
       pstmt.close();
        conn.close();

    }
}

** 运行结果：**

这样就防止了sql注入，setXxx会对传入的参数会进行转义，不会拼接成字符串而是' or\ ' 1' = ' 1'

输入正确的：

PrepareStatement原理

PrepareStatement好处：
1、预编译SQL，性能更高

2、防止sql注入。

my.ini配置文件可以看到日志

log-output=FILE 
general-log=1
general_log_file="D:\mysql.log" 
slow-query-log=1
slow_query_log_file="D:\mysql_slow.log" 
long_query_time=2

预编译功能默认关闭

①：PreparedStatement预编译功能开启：userServerPrepStmts=true

在sql语句?之后书写参数

String url="jdbc:mysql://127.0.0.1:3306/kc_db01"?userServerPrepStmts=true;

开启就会要prepare预编译：

关闭之后就没有Prepare阶段

文章推荐： linux进程相关命令操作

文章推荐： SpringBoot—自定义Starter篇

文章推荐：技术如何拥有完美解决问题的能力

文章推荐：内网之工作组、域分析

javascript - 控制台错误 - 解析 AJAX JSON 解析
我一直在使用 AJAX 从我正在创建的网络服务中解析 JSON 数组时遇到问题。我的前端是一个简单的 ajax 和 jquery 组合，用于显示从我正在创建的网络服务返回的结果。尽管知道我的数据库查
xml - Json 解析 vs xml 解析？
很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈，无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开，visit the help center . 关闭 1
android - java.lang.NoClassDefFoundError : com. 解析。解析
我在尝试运行 Android 应用程序时遇到问题并收到以下错误 java.lang.NoClassDefFoundError: com.parse.Parse 当我尝试运行该应用时。最佳答案在这
python - 解析 HTML 内容时防止 etree 解析 HTML 实体
有什么办法可以防止etree在解析HTML内容时解析HTML实体吗？ html = etree.HTML('&') html.find('.//body').text 这给了我 '&' 但我想
javascript - 使用 JSON 解析/解析 js 对象时，返回方法中的函数范围会丢失
我有一个有点疯狂的例子，但对于那些 JavaScript 函数作用域专家来说，它看起来是一个很好的练习: (function (global) { // our module number one
java - 使用 Java 解析 HTML 数据(DOM 解析)
关闭。此题需要details or clarity 。目前不接受答案。想要改进这个问题吗？通过 editing this post 添加详细信息并澄清问题. 已关闭 8 年前。 Improve th
php - 在服务器上用 PHP 解析 HTML 还是在最终用户端用 JavaScript 解析 HTML 会更好？
我需要编写一个脚本来获取链接并解析链接页面的 HTML 以提取标题和其他一些数据，例如可能是简短的描述，就像您链接到 Facebook 上的内容一样。当用户向站点添加链接时将调用它，因此在客户端启动
node.js - 为什么 npm 包从/AppData 解析，而不是从 local/node_modules 解析？
在 VS Code 中本地开发时，包解析为 C:/Users//AppData/Local/Microsoft/TypeScript/3.5/node_modules/@types//index而不是
php - 解析 json 错误 : SyntaxError: JSON. 解析:JSON 数据的第 1 行第 2 列出现意外字符
我在将 json 从 php 解析为 javascript 时遇到问题这是我的示例代码: //function MethodAjax = function (wsFile, param) {
php - 解析 json 错误 : SyntaxError: JSON. 解析:JSON 数据的第 1 行第 2 列出现意外字符
我在将 json 从 php 解析为 javascript 时遇到问题这是我的示例代码: //function MethodAjax = function (wsFile, param) {
解析，在哪里可以了解
我被赋予了将一种语言“翻译”成另一种语言的工作。对于使用正则表达式的简单逐行方法来说，源代码过于灵活(复杂)。我在哪里可以了解更多关于词法分析和解析器的信息？最佳答案如果你想对这个主题产生“情绪化
正则表达式 {} 解析
您好，我在解析此文本时遇到问题 { { { {[system1];1;1;0.612509325}; {[system2];1;
JavaScript 解析？
我正在为 adobe after effects 在 extendscript 中编写一些代码，最终变成了 javascript。我有一个数组，我想只搜索单词“assemble”并返回整个 jc3_
JavaScript 解析
我有这段代码: $(document).ready(function() { // }); 问题:FB_RequireFeatures block 外部的代码先于其内部的代码执行。因此 who
解析.netcore项目中IStartupFilter使用教程
背景： netcore项目中有些服务是在通过中间件来通信的，比如orleans组件。它里面服务和客户端会指定网关和端口，我们只需要开放客户端给外界，服务端关闭端口。相当于去掉host，这样省掉了些
解析:继承ViewGroup后的子类如何重写onMeasure方法
1.首先贴上我试验成功的代码复制代码代码如下: protected void onMeasure(int widthMeasureSpec, int heightMeasureSpec)
Python如何对XML 解析
什么是 XML？ XML 指可扩展标记语言（eXtensible Markup Language），标准通用标记语言的子集，是一种用于标记电子文件使其具有结构性的标记语言。你可以通过本站学习 X
解析:php调用MsSQL存储过程使用内置RETVAL获取过程中的return值
【PHP代码】复制代码代码如下: $stmt = mssql_init('P__Global_Test', $conn) or die("initialize sto
解析:清除SQL被注入恶意病毒代码的语句
在SQL查询分析器执行以下代码就可以了。复制代码代码如下: declare @t varchar(255),@c varchar(255) declare table_cursor curs
【JavaScript】前端算法题40道题+解析
前言最近练习了一些前端算法题，现在做个总结，以下题目都是个人写法，并不是标准答案，如有错误欢迎指出，有对某道题有新的想法的友友也可以在评论区发表想法，互相学习🤭 题目题目一: 二维数组中的

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

【JDBC】 API解析

一、DriverManager

1、注册驱动：

二、Connection

1、获取执sql对象

2、事务管理

mysql事务管理

演示jdbc的事务

三、Statement

1、执行sql语句

四、ResultSet

ResultSet案例

五、PreparedStatement

PreparedStatement作用：

SQL注入

演示普通登录：

sql注入演示：

PreparedStatement解决SQL注入

PrepareStatement原理