JDBC - 简书

一、概念

Java DataBase Connectivity Java数据库连接

JDBC本质

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

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

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

image

二、使用步骤

导入驱动jar包
- 复制mysql-connector-java-5.1.37-bin.jar到项目的libs目录下
- 右键-->Add As Library
注册驱动
获取数据库连接对象 Connection
定义sql
获取执行sql语句的对象 Statement
执行sql，接受返回结果
处理结果
释放资源

package cn.mouweng.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

public class JdbcDemo1 {
    public static void main(String[] args) throws Exception {
        // 1.导入驱动jar包【这边要更新成8.+版本的】
        // 2.注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
        // 3.获取数据库连接对象
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "weng13515774733");
        // 4.定义sql语句
        String sql = "update user set username = 123 where username = 789";
        // 5.获取执行sql的对象 Statement
        Statement stat = conn.createStatement();
        // 6.执行sql
        int count = stat.executeUpdate(sql);
        // 7.处理结果
        System.out.println(count);
        // 8.释放资源
        stat.close();
        conn.close();
    }
}

三、对象详解

1.DriverManager

驱动管理对象

1.注册驱动

static void registerDriver(Driver driver) :注册与给定的驱动程序 DriverManager 。

写代码使用： Class.forName("com.mysql.jdbc.Driver");

通过查看源码发现：在com.mysql.jdbc.Driver类中存在静态代码块

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

注意：mysql5之后的驱动jar包可以省略注册驱动的步骤。

2.获取数据库连接

Connection conn = DriverManager.getConnection(String url, String user, String password);
//栗子
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db3", "root", "weng13515774733");

url：指定连接的路径【jdbc:mysql://ip地址(域名):端口号/数据库名称】

user：用户名 password：密码

2.Connection

数据库连接对象

1.获取执行sql的对象

Statement createStatement()
PreparedStatement prepareStatement(String sql)

2.管理事务

开启事务：setAutoCommit(boolean autoCommit)
- 调用该方法设置参数为false，即开启事务
提交事务：commit()
回滚事务：rollback()

3.Statement

执行Sql对象

1.执行sql

boolean execute(String sql) ：可以执行任意的sql【不常用】
int executeUpdate(String sql) ：执行DML（insert、update、delete）语句、DDL(create，alter、drop)语句
- 返回值：影响的行数。返回值>0的则执行成功，反之，则失败。
ResultSet executeQuery(String sql) ：执行DQL（select)语句

2.练习

package cn.mouweng.jdbc;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * account表 添加一条语句
 */
public class JdbcDemo2 {
    public static void main(String[] args) throws SQLException {
        Connection conn = null;
        Statement stmt = null;
        try {
            // 1.注册驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 2.定义Sql
            String sql = "insert into user values('wyf', '3000')";
            // 3.获取Connection对象
            conn = DriverManager.getConnection("jdbc:mysql:///db3", "root", "weng13515774733");
            // 4.获取执行sql的对象Statement
            stmt = conn.createStatement();
            // 5.执行sql
            int count = stmt.executeUpdate(sql);
            // 6.影响的行数
            System.out.println(count);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            // 避免空指针yichang
            if (stmt != null) {
                stmt.close();
            }
            if (conn != null) {
                conn.close();
            }
        }
    }
}

4.ResultSet

结果集对象,封装查询结果

1.常用函数

boolean next(): 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true
getXxx(参数):获取数据
- Xxx：代表数据类型如： int getInt() , String getString()
- 参数
  - int：代表列的编号,从1开始如： getString(1)
  - String：代表列名称。如： getDouble("balance")

2.使用步骤

游标向下移动一行
判断是否有数据
获取数据

//循环判断游标是否是最后一行末尾。
while(rs.next()){
  //获取数据
  int id = rs.getInt(1);
  String name = rs.getString("name");
  double balance = rs.getDouble(3);
  System.out.println(id + "---" + name + "---" + balance);
}

5.PreparedStatement

执行sql对象

1.sql注入问题

出现原因：使用了静态sql，未经过预编译，在拼接sql时，有一些sql的特殊关键字参与字符串的拼接。会造成安全性问题。

栗子：输入用户随便，输入密码：a' or 'a' = 'a。此时sql：select * from user where username = 'fhdsjkf' and password = 'a' or 'a' = 'a' 。

解决方案：使用PreparedStatement对象来解决

2.使用步骤

导入驱动jar包 mysql-connector-java-5.1.37-bin.jar
注册驱动
获取数据库连接对象 Connection
注意：sql的参数使用问号【？】作为占位符。如：select * from user where username = ? and password = ?;
获取执行sql语句的对象 PreparedStatement Connection.prepareStatement(String sql)
给【？】赋值
- 方法： setXxx(参数1,参数2)
  - 参数1：【？】的位置编号从1 开始
  - 参数2：【？】的值
执行sql，接受返回结果，不需要传递sql语句
处理结果
释放资源

四、JDBC工具类

目的：简化书写

抽取注册驱动
抽取一个方法获取连接对象
- 需求：不想传递参数，还得保证工具类的通用性
- 解决：通过配置文件来解决【Jdbc.properties】
抽取一个方法释放资源

JDBCUtils.java

package cn.mouweng.utils;

import java.io.FileInputStream;
import java.io.IOException;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {
    private  static String url;
    private static String user;
    private static String password;
    private static String driver;

    static{
        // 读取资源文件，获取值.
        try {
            // 创建properties集合类
            Properties pro = new Properties();

            ClassLoader classLoader = JDBCUtils.class.getClassLoader();
            URL res = classLoader.getResource("jdbc.properties");
            String path = res.getPath();
            System.out.println(path);

            // 加载文件
            pro.load(new FileInputStream(path));
            url = pro.getProperty("url");
            user = pro.getProperty("user");
            password = pro.getProperty("password");
            driver = pro.getProperty("driver");
            try {
                Class.forName("com.mysql.cj.jdbc.Driver");
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static Connection getConnection() throws SQLException {

        /**
         * 获取连接的工具方法，返回连接对象
         */
        return DriverManager.getConnection(url, user, password);
    }

    public static void close(Statement stat, Connection conn) {
        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void close(ResultSet res, Statement stat, Connection conn) {
        if(stat != null) {
            try {
                stat.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
        if (res != null) {
            try {
                res.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

jdbc.properties文件【在src目录下】

url=jdbc:mysql://localhost:3306/db3
user=root
password=weng13515774733
driver=com.mysql.cj.jdbc.Driver

五、JDBC控制事务

1.操作

开启事务：setAutoCommit(boolean autoCommit) ：调用该方法设置参数为false，即开启事务
- 在执行sql之前开启事务
提交事务：commit()
- 当所有sql都执行完提交事务
回滚事务：rollback()
- 在catch中回滚事务

package cn.mouweng.jdbc;

import cn.mouweng.utils.JDBCUtils;
import com.mysql.cj.xdevapi.PreparableStatement;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class JdbcDemo10 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstat1 = null;
        PreparedStatement pstat2 = null;
        try {
            // 1.获取连接
            conn = JDBCUtils.getConnection();

            conn.setAutoCommit(false);

            // 2.定义sql
            String sql1 = "update account set balance = balance - ? where id = ?";
            String sql2 = "update account set balance = balance + ? where id = ?";
            // 3.获取执行sql对象
            pstat1 = conn.prepareStatement(sql1);
            pstat2 = conn.prepareStatement(sql2);

            // 4.设置参数
            pstat1.setInt(1,500);
            pstat1.setInt(2,1);

            pstat2.setInt(1,500);
            pstat2.setInt(2,2);

            // 5.执行sql语句
            pstat1.executeUpdate();

            // 制造异常 
            int i = 3/0;

            pstat2.executeUpdate();

            conn.commit();

        } catch (Exception e) {
            // 事务的回滚
            try {
                if (conn != null)
                    conn.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        } finally {
            JDBCUtils.close(pstat1, conn);
            JDBCUtils.close(pstat2, null);
        }

    }
}

六、数据库连接池

1.概念

其实就是一个容器(集合)，存放数据库连接的容器。

不会每一次调用数据库都创建数据库连接，而是系统初始化时提前创建好存放数据库连接的容器，需要用的时候从连接池中取出连接使用，用完了放回到池子里面去。

image

2.优点

节约资源
用户访问高效

3.实现

1.标准接口

在DataSource javax.sql包下的

2.方法

获取连接：getConnection()
归还连接：Connection.close()。如果连接对象Connection是从连接池中获取的，那么调用Connection.close()方法，则不会再关闭连接了。而是归还连接

3.注意

一般我们不去实现它，由数据库厂商来实现。例如：
- C3P0：数据库连接池技术
- Druid：数据库连接池实现技术，由阿里巴巴提供的

4.C3P0

1.使用步骤

导入jar包 (两个) c3p0-0.9.5.2.jar mchange-commons-java-0.2.12.jar
- 还有一个数据库的驱动jar包也要导入！
定义配置文件
- 名称： c3p0.properties 或者 c3p0-config.xml
- 路径：直接将文件放在src目录下即可。
创建核心对象数据库连接池对象 ComboPooledDataSource
获取连接： getConnection

2.代码

//1.创建数据库连接池对象
//什么都不传，获取默认配置，可以指定名称配置
DataSource ds  = new ComboPooledDataSource();
//2. 获取连接对象
Connection conn = ds.getConnection();

5.Druid

1.使用步骤

导入jar包 druid-1.0.9.jar
定义配置文件：
- 是properties形式的
- 可以叫任意名称，可以放在任意目录下
加载配置文件。Properties
获取数据库连接池对象：通过工厂来来获取 DruidDataSourceFactory
获取连接：getConnection

2.代码

//3.加载配置文件
Properties pro = new Properties();
InputStream is = DruidDemo.class.getClassLoader().getResourceAsStream("druid.properties");
pro.load(is);
//4.获取连接池对象
DataSource ds = DruidDataSourceFactory.createDataSource(pro);
//5.获取连接
Connection conn = ds.getConnection();

3.定义工具类

定义一个类 JDBCUtils
提供静态代码块加载配置文件，初始化连接池对象
提供方法
- 获取连接方法：通过数据库连接池获取提供方法连接
- 释放资源
- 获取连接池的方法

public class JDBCUtils {

  //1.定义成员变量 DataSource
  private static DataSource ds ;

  static{
    try {
      //1.加载配置文件
      Properties pro = new Properties();
      pro.load(JDBCUtils.class.getClassLoader().getResourceAsStream("druid.properties"));
      //2.获取DataSource
      ds = DruidDataSourceFactory.createDataSource(pro);
    } catch (IOException e) {
      e.printStackTrace();
    } catch (Exception e) {
      e.printStackTrace();
    }
  }

  /**
     * 获取连接
     */
  public static Connection getConnection() throws SQLException {
    return ds.getConnection();
  }

  /**
     * 释放资源
     */
  public static void close(Statement stmt,Connection conn){
    close(null,stmt,conn);
  }


  public static void close(ResultSet rs , Statement stmt, Connection conn){

    if(rs != null){
      try {
        rs.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }

    if(stmt != null){
      try {
        stmt.close();
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }

    if(conn != null){
      try {
        conn.close();//归还连接
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
  }

  /**
    * 获取连接池方法
    */

  public static DataSource getDataSource(){
    return  ds;
  }
}

七、Spring JDBC

Spring框架对JDBC的简单封装。提供了一个JDBCTemplate对象简化JDBC的开发.其还是需要依赖于数据库连接池对象DataSource。

1.使用步骤

导入jar包
创建JdbcTemplate对象。依赖于数据源DataSource
- JdbcTemplate template = new JdbcTemplate(ds);
调用JdbcTemplate的方法来完成CRUD的操作

public class JDBCTempleteDemo1 {
    public static void main(String[] args) {
        // 1.导入jar包
        // 2.创建JDBCTemplete对象
        JdbcTemplate templete = new JdbcTemplate(JDBCDruidUtils.getDataSource());
        // 3.调用方法
        String sql = "update account set balance = 5000 where id = ?";
        int count = templete.update(sql, 3);
        System.out.println(count);
    }
}

2.JDBCTemplete的CRUD操作

update():执行DML语句。增、删、改语句
queryForMap():查询结果将结果集封装为map集合，将列名作为key，将值作为value 将这条记录封装为一个map集合
- 注意：这个方法查询的结果集长度只能是1
queryForList():查询结果将结果集封装为list集合
- 注意：将每一条记录封装为一个Map集合，再将Map集合装载到List集合中
query():查询结果，将结果封装为JavaBean对象
- query的参数：RowMapper
  - new BeanPropertyRowMapper<类型>(类型.class)
  - 一般我们使用BeanPropertyRowMapper实现类。可以完成数据到JavaBean的自动封装
queryForObject：查询结果，将结果封装为对象
- 一般用于聚合函数的查询