JDBC

• Java DataBase Connectivity
• 一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。
• 我们可以使用这套接口（JDBC）编程，真正执行的代码是驱动jar包中的实现类。

使用

//1. 导入驱动jar包
//2.注册驱动
Class.forName("com.mysql.jdbc.Driver");
//3.获取数据库连接对象
Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "root");
//4.定义sql语句
String sql = "update account set balance = 500 where id = 1";
//5.获取执行sql的对象 Statement
Statement stmt = conn.createStatement();
//6.执行sql
int count = stmt.executeUpdate(sql);
//7.处理结果
System.out.println(count);
//8.释放资源
stmt.close();
conn.close();

为什么执行Class.forName()之后，通过DriverManager.getConnection,就可以获取相关数据库的连接Connection的实现呢？

1. Class.forName()的作用要求JVM查找并加载指定的类
2. 查看com.mysql.jdbc.Driver类的源码，有如下代码

public class Driver extends NonRegisteringDriver implements java.sql.Driver {
    public Driver() throws SQLException {
    }
    // JVM会执行该类的静态代码块
    // 这是JDBC规范中要求每个数据库厂家的实现类Driver都必须向DriverManager注册自己，才可以用DriverManager获取Connection对象
    static {
        try {
            DriverManager.registerDriver(new Driver());
        } catch (SQLException var1) {
            throw new RuntimeException("Can't register 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!");
     }
}

• Connection：数据库连接对象

static Connection getConnection(String url, String user, String password) 
参数：
url：指定连接的路径
user：用户名
password：密码 

• Statement：执行sql的对象

Statement createStatement()

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

boolean execute(String sql）; 可以执行任意的sql语句 
int executeUpdate(String sql) 
执行DML（insert、update、delete）语句、DDL(create，alter、drop)语句
返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功 返回值>0的则执行成功，反之，则失败。
ResultSet executeQuery(String sql);执行DQL（select)语句

• PreparedStatement：执行sql的对象

1. 使用PreparedStatement对象来解决sql注入问题
2. 预编译的SQL：参数使用?作为占位符

1.定义sql
String sql = "select * from user where username = ? and password = ?";
2.获取执行sql的对象
pstmt = conn.prepareStatement(sql);
3. 给?赋值
pstmt.setString(1,username);
pstmt.setString(2,password);

• ResultSet：结果集对象,封装查询结果

# 常用方法
boolean next(); 游标向下移动一行，判断当前行是否是最后一行末尾(是否有数据)，如果是，则返回false，如果不是则返回true
getXxx(参数); 获取数据

while(rs.next()){
    //获取数据
    int id = rs.getInt(1);
    String name = rs.getString("name");
    double balance = rs.getDouble(3);
    System.out.println(id + "---" + name + "---" + balance);
}

封装JDBCUtils

jdbc.properties

url=jdbc:mysql:///test
user=root
password=
driver=com.mysql.jdbc.Driver

import java.io.FileReader;
import java.net.URL;
import java.sql.*;
import java.util.Properties;

public class JDBCUtils {

    private static String url;
    private static String username;
    private static String password;
    private static String driver;

    // 读取配置文件，只需要读取一次，使用静态代码块
    static {
        try {
            // 1. 获取配置文件路径
            ClassLoader classLoader = JDBCUtils.class.getClassLoader();
            URL res = classLoader.getResource("jdbc.properties");
            String path = res.getPath();
            //2. 创建Properties集合类
            Properties properties = new Properties();
            properties.load(new FileReader(path));
            url = properties.getProperty("url");
            username = properties.getProperty("username");
            password = properties.getProperty("password");
            driver = properties.getProperty("driver");
            //3.注册驱动
            Class.forName(driver);
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    /**
     * 获取连接
     * @return
     * @throws SQLException
     */
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(url, username, password);
    }

    /**
     * 释放资源
     * @param stmt
     * @param conn
     */
    public static void close(Statement stmt, Connection conn){
        if( stmt != null){
            try {
                stmt.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }

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

    /**
     * 释放资源
     * @param rs
     * @param stmt
     * @param 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();
            }
        }
    }
}

数据库连接池

• Druid

数据库连接池实现技术，阿里巴巴出品

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.1.16</version>
    </dependency>

druid.properties

driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql:///test
username=root
password=root
# 初始化连接数量
initialSize=5
# 最大连接数
maxActive=10
# 最大等待时间
maxWait=3000

JDBCUtils.class

import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class JDBCUtils {

    private static DataSource ds;

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

    /**
     * 获取资源
     * @return
     */
    public static DataSource getDataSource(){
        return ds;
    }

    /**
     * 获取连接
     * @return
     * @throws SQLException
     */
    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();
            }
        }
    }
}

JDBCTemplate

Spring框架对JDBC的简单封装，提供了一个JDBCTemplate对象简化JDBC的开发。

# 创建JdbcTemplate对象, 依赖于数据源DataSource
JdbcTemplate template = new JdbcTemplate(ds);

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