JDBC概念及API详解-阿里云开发者社区

一、JDBC概念

JDBC就是使用Java语言操作关系型数据库的一套API

全称：(Java DataBase Connectivity) Java数据库连接

JDBC本质：

官方（sun公司）定义的一套操作所有关系型数据库的规则，即接口

各个数据库厂商去实现这套接口，提供数据库驱动jar包

我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类

JDBC好处：

各数据库厂商使用相同的接口，Java代码不需要针对不同数据库分别开发

可随时替代底层数据库，访问数据库的Java代码基本不变

二、JDBC快速入门步骤

0、创建工程，导入驱动jar包

1、注册驱动

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

2、获取连接

Connection conn = DriverManager.getConnection(url, username, password);

3、定义SQL语句

String sql = "SQL语句";

4、获取执行SQL对象

Statement stat = conn.createStatement();

5、执行SQL

stat.executeUpdate(sql);

6、处理返回结果

7、释放资源

代码示例：

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * JDBC快速入门
 */
public class JDBCDemo1he2 {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
            //1、注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
            String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
            String username = "root";
            String password = "199884lj";
            Connection conn = DriverManager.getConnection(url, username, password);
            //3、定义sql
            String sql = "update stu set math = 90 where age = 55";
            //4、获取执行sql的对象
            Statement stat = conn.createStatement();
            //5、执行sql
            int count = stat.executeUpdate(sql);//受影响的行数
            //6、处理结束
            System.out.println(count);
            //7、释放资源
            stat.close();
            conn.close();
    }
}

三、JDBC API详解

DriverManger（驱动管理类）

管理JDBC驱动程序的基本服务。

作用：1、注册驱动 2、获取数据库连接

一、注册驱动

有此Driver文件可自动读取文件在，自动注册驱动

二、获取数据库连接

static Connaction         getConnaction (String usl,String user,String password)

参数

1、url：连接路径

语法：

jdbc:mysql://地址(域名):端口号/数据库名称?参数键值对1&参数键值对2...

示例：

jdbc:mysql://127.0.0.1:3306/db1

细节：

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

2、user：用户名

3、password：密码

Connection（数据库连接对象）

与特定数据库连接（会话）。执行SQL语句并在连接的上下文中返回结果。

作用：1、获取执行SQL的对象 2、管理事务

1、获取执行SQL对象

普通执行SQL对象

Statement createStatement()

预编译SQL的执行SQL对象：防止SQL注入

PreparedStatement prepareStatement(sql)

执行存储过程的对象

CallableStatement prepareCall(sql)

2、事务管理

MySQL事务管理

开启事务：

BEGIN;/START  TRANSACTION;

提交事务：

COMMIT;

回滚事务：

ROLLBACK;

MySQL默认自动提交事务

JDBC事务管理：Connection接口中定义了3个对应的方法

开启事务：

setAutoCommit(boolean autoCommit)：true为自动提交事务；false为手动提交事务，即为开启事务

提交事务：

commit()

回滚事务：

rollback()

代码示例

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * JDBC API 详解：Connection
 */
public class JDBCDemo3_Connection {
    public static void main(String[] args) throws Exception {
        //1、注册驱动，在mysql的jar包下添加java.sql.Driver这个文件即可以省去手动注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql1 = "update stu set math = 300 where id = 1";
        String sql2 = "update stu set math = 300 where id = 2";
        //4、获取执行sql的对象
        Statement stat = conn.createStatement();
        try {
            //开启事务
            conn.setAutoCommit(false);
            //5、执行sql
            int count1 = stat.executeUpdate(sql1);//受影响的行数
            //6、处理结束
            System.out.println(count1);
            //5、执行sql
            int count2 = stat.executeUpdate(sql2);//受影响的行数
            //6、处理结束
            System.out.println(count2);
            //提交事务
            conn.commit();
        } catch (Exception e) {
            //回滚事务
            conn.rollback();
            e.printStackTrace();
        }
        //7、释放资源
        stat.close();
        conn.close();
    }
}

执行结果：

Statement（执行SQL语句）

用于执行静态SQL语句并返回其生成的结果的对象。

作用：执行SQL语句

int executeUpdate(sql)：执行DML、DDL语句

返回值：1、DML语句影响的行数 2、DDL语句执行后，执行成功也可能返回0

ResultSet executeQuery(sql)：执行DQL语句

返回值：ResultSet结果集对象

代码示例：

import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
/**
 * JDBC API 详解：Statement
 */
public class JDBCDemo4_Statement {
    /**
     * 执行DML语句
     *
     * @throws Exception
     */
    @Test
    public void testDML() throws Exception {
        //1、注册驱动，在mysql的jar包下添加java.sql.Driver这个文件即可以省去手动注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql = "update stu set math = 90 where id=1";
        //4、获取执行sql的对象
        Statement stat = conn.createStatement();
        //5、执行sql
        int count = stat.executeUpdate(sql);//执行完DML语句，受影响的行数
        //6、处理结束
        //System.out.println(count);
        if (count > 0) {
            System.out.println("修改成功");
        } else {
            System.out.println("修改失败");
        }
        //7、释放资源
        stat.close();
        conn.close();
    }
    /**
     * 执行DDL语句
     * @throws Exception
     */
    @Test
    public void testDDDL() throws Exception {
        //1、注册驱动，在mysql的jar包下添加java.sql.Driver这个文件即可以省去手动注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql = "drop database db2";
        //4、获取执行sql的对象
        Statement stat = conn.createStatement();
        //5、执行sql
        int count = stat.executeUpdate(sql);//执行完DDL语句，可能是0
        //6、释放资源
        stat.close();
        conn.close();
    }
}

运行结果：

ResultSet（结果集对象）

ResultSet作用：

1、封装了DQL查询语句的结果

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

获取查询结果

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

返回值：

1、true：有效行，当前行有数据

2、false：无效行，当前行没有数据

xxx getXxx(参数)：获取数据

xxx：数据类型；如:int getInt(参数);String getString(参数

参数

int：列的编号，从1开始

String：列的名称

代码示例：

import com.itheima.pojo.Account;
import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
/**
 * JDBC API 详解：Result
 */
public class JDBCDemo5_ResultSet {
    /**
     * 执行DQl语句
     * @throws Exception
     */
    @Test
    public void testResultSet() throws Exception {
        //1、注册驱动，在mysql的jar包下添加java.sql.Driver这个文件即可以省去手动注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql = "select * from stu";
        //4、获取statement对象
        Statement stmt = conn.createStatement();
        //5、执行sql
        ResultSet rs = stmt.executeQuery(sql);
        //处理结果，遍历rs中的所有数值
        //6.1 光标向下移动一行，并且判断当前行是否有数据
//        while(rs.next()){
//            //6.2 获取数据 getXxx()
//            int id = rs.getInt(1);
//            String name = rs.getString(2);
//
//            System.out.println(id);
//            System.out.println(name);
//
//            System.out.println("---------------");
//        }
        while(rs.next()){
            //6.2 获取数据 getXxx()
            int id = rs.getInt("id");
            String name = rs.getString("name");
            System.out.println(id);
            System.out.println(name);
            System.out.println("---------------");
        }
        //7、释放资源
        rs.close();
        stmt.close();
        conn.close();
    }
    /**
     * 查看account账户表数据，封装为Account对象中，并且存储到ArrayList集合中
     * 1、定义实体类Account
     * 2、查询数据，封装到Account对象中
     * 3、将Account对象存入ArrayList集合中
     *
     *
     * @throws Exception
     */
    @Test
    public void testResultSet2() throws Exception {
        //1、注册驱动，在mysql的jar包下添加java.sql.Driver这个文件即可以省去手动注册驱动
//            Class.forName("com.mysql.jdbc.Driver");
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //3、定义sql
        String sql = "select * from account";
        //4、获取statement对象
        Statement stmt = conn.createStatement();
        //5、执行sql
        ResultSet rs = stmt.executeQuery(sql);
        //创建集合
        List<Account> list = new ArrayList<>();
        while(rs.next()){
            Account account = new Account();
            //6.2 获取数据 getXxx()
            int id = rs.getInt("id");
            String name = rs.getString("name");
            int money = rs.getInt("money");
            //赋值
            account.setId(id);
            account.setName(name);
            account.setMoney(money);
            //存入集合
            list.add(account);
        }
        System.out.println(list);
        //7、释放资源
        rs.close();
        stmt.close();
        conn.close();
    }
}

运行结果：

PreparedStatement（预编译SQL语句的对象）

作用：预编译SQL语句并执行，预防SQL注入问题

SQL注入

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

SQL注入演示：

import com.itheima.pojo.Account;
import org.junit.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
/**
 * 用户登录
 */
public class JDBCDemo6_UserLogin {
    @Test
    public void testResultSet() throws Exception {
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "199884lj";
        Connection conn = DriverManager.getConnection(url, username, password);
        //接收用户输入 用户名和密码
        String name = "zhangsan";
        String pwd = "2";
        String sql = "select * from tb_user where username = '" + name + "' and password = '" + pwd + "'";
        //获取stmt对象
        Statement stmt = conn.createStatement();
        //执行sql
        ResultSet rs = stmt.executeQuery(sql);
        //判断登录是否成功
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        //7、释放资源
        rs.close();
        stmt.close();
        conn.close();
    }
    /**
     * 演示SQL注入
     * @throws Exception
     */
    @Test
    public void testLogin_Inject() throws Exception {
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "199884lj";
        Connection conn = DriverManager.getConnection(url, username, password);
        //接收用户输入 用户名和密码
        String name = "sdbabasdga";
        String pwd = "'or'1'='1";
        String sql = "select * from tb_user where username = '" + name + "' and password = '" + pwd + "'";
        System.out.println(sql);
        //获取stmt对象
        Statement stmt = conn.createStatement();
        //执行sql
        ResultSet rs = stmt.executeQuery(sql);
        //判断登录是否成功
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        //7、释放资源
        rs.close();
        stmt.close();
        conn.close();
    }
}

运行结果：

sql注入语句

select * from tb_user where username 'sdbabasdga' and password = ' ' or '1' = '1'

1、获取PreparedStatement对象

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

2、设置参数值

PreparedStatement对象：setXxx(参数1，参数2)：给？赋值

Xxx：数据类型：如setInt(参数1，参数2)

参数：

参数1：？的位置编号，从1开始

参数2：？的值

3、执行SQL

executeUpdate();/executeQuery();：不需要再传递sql

PreparedStatement好处：

1、预编译SQL，性能更高

2、防止SQL注入：将敏感字符进行转义

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

②配置MySQL执行日志(重启mysql服务后生效)

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

PrepareStatement原理：

1、在获取PreparedStatement对象时，将sql语句发送给mysql服务检查，编译（这些步骤很耗时）

2、执行时就不用再进行这些步骤，速度更快

3、如果sql模板一样，则只需要进行一次检查、编译

代码示例：

import org.junit.Test;
import java.sql.*;
/**
 * API详解 PreparedStatement
 */
public class JDBCDemo7_PreparedStatement {
    @Test
    public void testPreparedStatement() throws Exception {
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //接收用户输入 用户名和密码
        String name = "zhangsan";
        String pwd = "123";
        //定义sql
        String sql = "select * from tb_user where username = ? and password = ?";
        //获取stmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //设置？的值
        pstmt.setString(1,name);
        pstmt.setString(2,pwd);
        //执行sql
        ResultSet rs = pstmt.executeQuery();
        //判断登录是否成功
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        //7、释放资源
        rs.close();
        pstmt.close();
        conn.close();
    }
    /**
     * PreparedStatement原理
     * @throws Exception
     */
    @Test
    public void testPreparedStatement2() throws Exception {
        //2、获取连接:如果连接的是本机mysql并且端口是默认的3306，可以简化书写
        String url = "jdbc:mysql:///db1?useUnicode=true&characterEncoding=utf8";
        String username = "root";
        String password = "xxxxxxx";
        Connection conn = DriverManager.getConnection(url, username, password);
        //接收用户输入 用户名和密码
        String name = "zhangsan";
        String pwd = "'or'1'='1";
        //定义sql
        String sql = "select * from tb_user where username = ? and password = ?";
        //获取stmt对象
        PreparedStatement pstmt = conn.prepareStatement(sql);
        //设置？的值
        pstmt.setString(1,name);
        pstmt.setString(2,pwd);
        ResultSet rs = null;
        //执行sql
        rs = pstmt.executeQuery();
        //设置？的值
        pstmt.setString(1,"aaa");
        pstmt.setString(2,"bbb");
        //执行sql
        rs = pstmt.executeQuery();
        //判断登录是否成功
        if (rs.next()) {
            System.out.println("登录成功");
        } else {
            System.out.println("登录失败");
        }
        //7、释放资源
        rs.close();
        pstmt.close();
        conn.close();
    }
}

运行结果：

JDBC概念及API详解

一、JDBC概念

JDBC本质：

JDBC好处：

二、JDBC快速入门步骤

三、JDBC API详解

DriverManger（驱动管理类）

Connection（数据库连接对象）

Statement（执行SQL语句）

ResultSet（结果集对象）

PreparedStatement（预编译SQL语句的对象）

热门文章

最新文章

相关课程

相关电子书

相关实验场景

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

JDBC概念及API详解

一、JDBC概念

JDBC本质：

JDBC好处：

二、JDBC快速入门步骤

三、JDBC API详解

DriverManger（驱动管理类）

Connection（数据库连接对象）

Statement（执行SQL语句）

ResultSet（结果集对象）

PreparedStatement（预编译SQL语句的对象）

热门文章

最新文章

相关课程

相关电子书

相关实验场景