【JDBC】 API解析

转x33g5p2x  于2022-02-14 转载在 其他  
字(9.9k)|赞(0)|评价(0)|浏览(295)

一、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、注册驱动：

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

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

  1. package com.mysql.jdbc;
  3. import java.sql.DriverManager;
  4. import java.sql.SQLException;
  6. public class Driver extends NonRegisteringDriver implements java.sql.Driver {
  7.     public Driver() throws SQLException {
  8.     }
  10.     static {
  11.         try {
  12.             DriverManager.registerDriver(new Driver());
  13.         } catch (SQLException var1) {
  14.             throw new RuntimeException("Can't register driver!");
  15.         }
  16.     }
  17. }

它使用了 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

  1. 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的事务

复制前面弄过的类到包下

  1. package com.jdbc;
  3. import com.mysql.jdbc.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.SQLException;
  7. import java.sql.Statement;
  9. public class JDBCConnectionDemo {
  10.     public static void main(String[] args) throws Exception {
  11.         //1、注册驱动
  12.         Class.forName("com.mysql.jdbc.Driver");
  13.        //2、获取连接
  14.          //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
  15.         String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
  16.         //username是你的mysql用户名
  17.         String username="root";
  18.         //password是你的mysql密码
  19.         String password="123456";
  20.         Connection conn= (Connection) DriverManager.getConnection(url, username, password);
  21.         //3、定义sql
  22.         String sql1="update emp set salary=6666 where ename='zhangsan'";
  23.         String sql2="update emp set salary=6666 where ename='lisi'";
  24.         //4、获取执行sql的Statement对象
  25.         Statement stat=conn.createStatement();
  26.          
  27.       //选中要处理的异常部分，ctrl+alt+t快捷键生成
  28.         try {
  29.             //开启事务
  30.            conn.setAutoCommit(false);
  31.            //执行sql
  32.             int count1=stat.executeUpdate(sql1);
  33.             //处理结果
  34.             System.out.println("影响的行数:"+count1);
  36.             //执行时sql
  37.             int count2=stat.executeUpdate(sql2);
  38.             //处理结果
  39.             System.out.println("影响的行数:"+count2);
  41.             //提交事务
  42.             conn.commit();
  43.         } catch (Exception e) {
  44.             e.printStackTrace();
  45.             //回滚事务(回到开启事务之前，即什么也没处理前)
  46.              conn.rollback();
  47.         }finally {
  48.             //7、释放资源(先开后释放)
  50.             stat.close();
  51.             conn.close();
  52.         }
  54.     }
  55. }

运行之前数据库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(参数)

示例：

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

实例：

  1. package com.jdbc;
  3. import com.mysql.jdbc.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.ResultSet;
  7. import java.sql.Statement;
  9. public class JDBCDemo3_ResultSet {
  10.     public static void main(String[] args) throws Exception {
  11.         //1、注册驱动
  12.         Class.forName("com.mysql.jdbc.Driver");
  13.        //2、获取连接
  14.          //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
  15.         String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
  16.         //username是你的mysql用户名
  17.         String username="root";
  18.         //password是你的mysql密码
  19.         String password="123456";
  20.         Connection conn= (Connection) DriverManager.getConnection(url, username, password);
  21.         //3、定义sql
  22.         String sql="select *from emp";
  23.         //4、获取执行sql的Statement对象
  24.         Statement stmt=conn.createStatement();
  25.         //5、执行sql语句
  26.         ResultSet rs=stmt.executeQuery(sql);
  27.         //6处理结果
  28.       while(rs.next()){
  29.           //获取数据 getXxx();括号中可以写所在行，也可以写列名
  30.           int id=rs.getInt(1);
  31.           String ename=rs.getString(2);
  32.           int salary=rs.getInt(3);
  33.           //另一种写法：写行的名称
  34. //          int id=rs.getInt("id");
  35. //          String ename=rs.getString("ename");
  36. //          int salary=rs.getInt("salary");
  37.           System.out.println(id);
  38.           System.out.println(ename);
  39.           System.out.println(salary);
  40.           System.out.println("-----------");
  41.       }
  42.         //7、释放资源(先开后释放)
  43.         rs.close();
  44.         stmt.close();
  45.         conn.close();
  47.     }
  48. }

数据库中emp表

运行之后：

 ResultSet案例

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

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

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

  1. package com.pojo;
  3. public class Account {
  4.     private int id;
  5.     private String ename;
  6.     private int salary;
  8.     public int getId() {
  9.         return id;
  10.     }
  12.     public void setId(int id) {
  13.         this.id = id;
  14.     }
  16.     public String getEname() {
  17.         return ename;
  18.     }
  20.     public void setEname(String ename) {
  21.         this.ename = ename;
  22.     }
  24.     public int getSalary() {
  25.         return salary;
  26.     }
  28.     public void setSalary(int salary) {
  29.         this.salary = salary;
  30.     }
  31.     //为了更好的显示，重写toString()方法
  33.     @Override
  34.     public String toString() {
  35.         return "Account{" +
  36.                 "id=" + id +
  37.                 ", ename='" + ename + '\'' +
  38.                 ", salary=" + salary +
  39.                 '}'+"\n";
  40.     }
  41. }

jdbc包下创建的类中

  1. package com.jdbc;
  3. import com.mysql.jdbc.Connection;
  4. import com.pojo.Account;
  6. import java.sql.DriverManager;
  7. import java.sql.ResultSet;
  8. import java.sql.Statement;
  9. import java.util.ArrayList;
  10. import java.util.List;
  12. public class JDBCDemo4_ResultSet {
  13.     public static void main(String[] args) throws Exception {
  14.         //1、注册驱动
  15.         Class.forName("com.mysql.jdbc.Driver");
  16.        //2、获取连接
  17.          //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
  18.         String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
  19.         //username是你的mysql用户名
  20.         String username="root";
  21.         //password是你的mysql密码
  22.         String password="123456";
  23.         Connection conn= (Connection) DriverManager.getConnection(url, username, password);
  24.         //3、定义sql
  25.         String sql="select *from emp";
  26.         //4、获取执行sql的Statement对象
  27.         Statement stmt=conn.createStatement();
  28.         //5、执行sql语句
  29.         ResultSet rs=stmt.executeQuery(sql);
  30.         //6处理结果
  31.         //创建集合对象
  32.         List<Account> list=new ArrayList<>();
  33.       while(rs.next()){
  34.           //创建Account对象
  35.           Account account=new Account();
  36.           //获取数据 getXxx();括号中可以写所在行，也可以写列名
  37.           int id=rs.getInt(1);
  38.           String ename=rs.getString(2);
  39.           int salary=rs.getInt(3);
  40.           //赋值数据
  41.           account.setId(id);
  42.           account.setEname(ename);
  43.           account.setSalary(salary);
  44.           list.add(account);
  45.       }
  46.         System.out.println(list);
  47.         //7、释放资源(先开后释放)
  48.         rs.close();
  49.         stmt.close();
  50.         conn.close();
  52.     }
  53. }

运行结果：

五、PreparedStatement

PreparedStatement作用：

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

SQL注入

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

演示普通登录：

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

  1. package com.jdbc;
  3. import com.mysql.jdbc.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.ResultSet;
  7. import java.sql.Statement;
  9. public class JDBCDemo5_UserLogin {
  10.     public static void main(String[] args) throws Exception {
  12.        //2、获取连接
  13.          //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
  14.         String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
  15.         //username是你的mysql用户名
  16.         String username="root";
  17.         //password是你的mysql密码
  18.         String password="123456";
  19.         Connection conn= (Connection) DriverManager.getConnection(url, username, password);
  20.            String name="zhangsan";
  21.            String pwd="1233";
  22.         //3、定义sql
  23.         String sql="select *from emp where ename='"+name+"'and password='"+pwd+"'" ;
  24.         System.out.println("这条SQL语句是:"+sql);
  25.         //4、获取执行sql的Statement对象
  26.         Statement stat=conn.createStatement();
  27.         //5、执行sql语句
  28.         ResultSet rs = stat.executeQuery(sql);
  29.         //6处理结果,rs有值说明查找成功
  30.       if(rs.next()){
  31.           System.out.println("登录成功");
  32.       }else{
  33.           System.out.println("登录失败");
  34.       }
  35.         //7、释放资源(先开后释放)
  36.         rs.close();
  37.         stat.close();
  38.         conn.close();
  40.     }
  41. }

运行结果：

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

 sql注入演示：

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

  1. String name="随便写的名";
  2.  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对象

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

②设置参数

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

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

参数：

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

③执行sql

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

创建类：

  1. package com.jdbc;
  3. import com.mysql.jdbc.Connection;
  5. import java.sql.DriverManager;
  6. import java.sql.PreparedStatement;
  7. import java.sql.ResultSet;
  8. import java.sql.Statement;
  9. import java.util.Scanner;
  11. public class JDBCDemo5_UserLogin {
  12.     public static void main(String[] args) throws Exception {
  14.        //2、获取连接
  15.          //url的格式是："jdbc:mysql://mysql的ip:端口号/操作的数据库"
  16.         String url="jdbc:mysql://127.0.0.1:3306/kc_db01";
  17.         //username是你的mysql用户名
  18.         String username="root";
  19.         //password是你的mysql密码
  20.         String password="123456";
  21.         Connection conn= (Connection) DriverManager.getConnection(url, username, password);
  22.            String name="随便写的名";
  23.            String pwd=" ' or '1'='1";
  24.         //3、定义sql
  25.         String sql="select *from emp where ename=? and password=?" ;
  27.         //4、获取的PreparedStatement对象
  28.         PreparedStatement pstmt = conn.prepareStatement(sql);
  29.         //设置参数
  30.         pstmt.setString(1, name);
  31.         pstmt.setString(2, pwd);
  33.         //5、执行sql语句
  34.         ResultSet rs =pstmt.executeQuery();
  35.         System.out.println("这条SQL语句是:"+sql);
  36.         //6处理结果,rs有值说明查找成功
  37.       if(rs.next()){
  38.           System.out.println("登录成功");
  39.       }else{
  40.           System.out.println("登录失败");
  41.       }
  42.         //7、释放资源(先开后释放)
  43.         rs.close();
  44.        pstmt.close();
  45.         conn.close();
  47.     }
  48. }

** 运行结果：**

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

输入正确的：

 PrepareStatement原理

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

2、防止sql注入。

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

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

预编译功能默认关闭

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

在sql语句?之后书写参数

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

开启就会要prepare预编译： 

关闭之后就没有Prepare阶段

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_60719453/article/details/122807813

内容来源于网络，如有侵权，请联系作者删除！

JavasqlmysqljdbcJDBC从初识到掌握

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com