JDBC（一） —— 简介及各个类详解

一、JDBC

1. 概念：Java DataBase Connectivity  Java数据库连接，Java语言操作数据库。

2. 本质：其实是java官方SUN公司定义的一套操作所有关系型数据库的规则，即接口。各个数据库厂商去实现这套接口，提供数据库驱动jar包。我们可以使用这套接口（即JDBC接口）编程，真正执行的代码是驱动jar包中的实现类，当调用接口方法时真正执行的是驱动jar包中实现类对应的实现方法。

定义了操作所有关系型数据库的规则（接口）。（由SUN公司程序员编写，定义了一套接口。）每一个数据库厂商写了不同的实现类，不同的实现类来操作它们自己。每一个实现类都实现了相同的接口。实现类的名字叫数据库驱动。

 3. 快速入门：

（1）步骤：

　　第一步：导入驱动jar包。下载地址：https://dev.mysql.com/downloads/connector/j/，解压后，mysql-connector-java-5.1.49-bin.jar文件是驱动文件，导入到工程内，src文件是开源的源代码文件。

　　　　　　复制jar包到项目新建的libs文件夹目录下

　　　　　　右键 ----->add as library

　　第二步：编写代码，注册驱动

　　　　　　idea处理异常的快捷键 Alt+Enter

　　第三步：获取数据库的连接对象，Connection，就是本地java代码和数据库的桥梁对象。

　　　　　　idea返回函数生成值对象的快捷键 Ctrl+Alt+V

　　第四步：定义SQL

　　第五步：通过Connection对象，获取执行SQL语句的对象，Statement

　　第六步：执行SQL，接收返回结果

　　第七步：处理结果

　　　　　　System.out.println()在idea中的快捷键为sout回车。

　　第八步：释放资源

代码示例：

package cn.itcast.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;

/**
 * JDBC快速入门
 */
public class JDBCDemo1 {
    public static void main(String[] args) throws Exception {

        //1.导入驱动jar包

        //2.注册驱动
        Class.forName("com.mysql.jdbc.Driver");

        //3.获取数据库的连接对象 Connection
        Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2", "root", "root");

        //4.定义SQL语句
        String sql = "update account set balance = 1000 where id = 1 or id = 2";

        //5.获取执行SQL的对象 statement
        Statement stmt = conn.createStatement();

        //6.执行SQL
        int count = stmt.executeUpdate(sql);

        //7.处理结果
        System.out.println(count);

        //8.释放资源
        stmt.close();
        conn.close();

    }

}

 4.详解各个对象

　　（1）DriverManager：驱动管理对象

　　　　　　功能：

　　　　　　　　　功能一 ：注册驱动：告诉程序该使用哪一个数据库驱动jar包。因为都是面向接口编程，所以需要知道面向哪一个jar包的类，因此需要jar包。

　　　　　　　　　　　　　解释：在DriverManager中有方法为：static void registerDriver(Driver driver);  含义为注册与给定的驱动程序 DriverManager

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

　　　　　　　　　　　　　把类加载进内存，后期也没有用到Driver类，说明有的代码在加载的时候就被加载到了内存，存在静态代码块。

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

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

　　　　　　　　　　　　　在MySQL版本5后，在jar包中，有一个META-INF文件夹下面有一个services目录，下面有一个java.sql.Driver文件，文件中有一句话为com.mysql.jdbc.Driver。

　　　　　　　　　　　　　说明在此文件中已经帮助我们注册了MySQL的驱动类，所以不写注册驱动的代码也是可以的，会自动扫描该文件，将驱动注册上。

　　　　　　　　　功能二：获取数据库连接

　　　　　　　　　　　　　　方法：static Connection getConnection(String url, String user, String password);

　　　　　　　　　　　　　　参数：

　　　　　　　　　　　　　　　　url：指定连接的路径

　　　　　　　　　　　　　　　　　　 不同的数据库写法有差异，此处介绍MySQL

　　　　　　　　　　　　　　　　　　语法：jdbc:mysql://ip地址（域名）: 端口号/数据库名称

　　　　　　　　　　　　　　　　　　例子：jdbc:mysql://localhost:3306/db1

　　　　　　　　　　　　　　　　　　细节：如果连接的是本地MySQL服务器，并且MySQL服务器默认端口是3306，则url可以省略ip地址和端口号，具体简写为：jdbc:mysql:///数据库名称

　　　　　　　　　　　　　　　　user：用户名

　　　　　　　　　　　　　　　　password：密码

　　（2）Connection：数据库连接对象 —— 代表了当前代码和数据库连接的桥梁

　　　　　　功能：

　　　　　　　　功能一：获取执行SQL的对象

　　　　　　　　　　　　Statement   createStatement()

　　　　　　　　　　　　PreparedStatement  prepareStatement(String sql)

　　　　　　　　功能二：管理事务

　　　　　　　　　　　　开启事务：void setAutoCommit(boolean autoCommit) :  调用该方法设置参数为false，即开启事务

　　　　　　　　　　　　提交事务：void commit()

　　　　　　　　　　　　回滚事务：void rollback()

　　（3）Statement：执行SQL的对象

　　　　　　功能：执行SQL

　　　　　　　　boolean execute(String sql) ： 可以执行任意的SQL 了解

　　　　　　　　int executeUpdate(String sql)：执行DML(insert、update、delete)语句、DDL(create、alter、drop)语句。一般executeUpdate来执行DML语句

　　　　　　　　　　返回值：影响的行数，可以通过这个影响的行数判断DML语句是否执行成功。

　　　　　　　　ResultSet executeQuery(String sql) ：执行DQL语句（select语句）

　　　　　　案例：JDBC增删改表中数据

　　　　　　　　添加一条记录：

package cn.itcast.jdbc;

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

/**
 * accout表 添加一条记录 insert语句
 */
public class JDBCDemo2 {
    public static void main(String[] args){
        //提升Connection和Statement作用域
        Connection conn = null;
        Statement stmt = null;
        //1. 添加jar包
        //2. 注册驱动
        try {
            Class.forName("com.mysql.jdbc.Driver");
            //3. 定义SQL
            String sql = "insert into account values(3,'王五',3000)";
            //4.获取数据库连接对象：Connection对象
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2", "root", "root");
            //5.获取执行SQL的对象：Statement对象
            stmt = conn.createStatement();
            //6.执行SQL语句
            int count = stmt.executeUpdate(sql);//返回值为影响的行数
            //7.处理结果
            System.out.println(count);
            if(count == 1){
                System.out.println("操作成功");
            } else{
                System.out.println("操作失败");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //8.释放资源：倒着释放，因为statement是由connection获取的。
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

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

    }
}

　　　　　　　　修改一条记录：

package cn.itcast.jdbc;

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

public class JDBCDemo3 {
    public static void main(String[] args) {

        Connection conn = null;
        Statement stmt = null;

        //1.添加jar包


        try {
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.定义sql
            String sql = "update account set balance = 1500 where name = '王五'";
            //4.获取数据库连接对象Connection
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2","root","root");
            //5.获取执行SQL对象 Statement
            stmt = conn.createStatement();
            //6.执行SQL
            int count = stmt.executeUpdate(sql);
            //7.处理结果
            System.out.println(count);
            if (count == 1){
                System.out.println("操作成功");
            } else {
                System.out.println("操作失败");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //8.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

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

　　　　　　　　删除一条记录：

package cn.itcast.jdbc;

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

/**
 * account表删除一套记录
 */
public class JDBCDemo4 {
    public static void main(String[] args) {

        Connection conn = null;
        Statement stmt = null;

        //1.导入jar包

        try {
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.获取数据库连接对象Connection
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2","root","root");
            //4.获取执行SQL对象 Statement
            stmt = conn.createStatement();
            //5.定义SQL
            String sql = "delete from account where id = 3";
            //6.执行SQL
            int count = stmt.executeUpdate(sql);
            //7.处理结果
            System.out.println(count);
            if(count == 1){
                System.out.println("删除操作成功");
            } else {
                System.out.println("删除操作失败");
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //8.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

　　　　DDL语句：

package cn.itcast.jdbc;

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

/**
 * 执行DDL语句
 */
public class JDBCDemo5 {
    public static void main(String[] args) {

        Connection conn = null;
        Statement stmt = null;

        //1.导入jar包

        try {
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.获取数据库连接对象Connection
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2","root","root");
            //4.获取执行SQL对象 Statement
            stmt = conn.createStatement();
            //5.定义SQL
            String sql = "create table student(id int,name varchar(20))";
            //6.执行SQL
            int count = stmt.executeUpdate(sql);
            //7.处理结果
            System.out.println(count);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //8.释放资源
            if(stmt != null){
                try {
                    stmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if(conn != null){
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }

    }
}

　　（4）ResultSet：结果集对象，封装查询结果

　　　　　　方法：

　　　　　　　　boolean next()：游标向下移动一行，判断当前行是否是最后一行末尾（是否有数据），如果是则返回false，如果不是则返回true。

　　　　　　　　getXXX(参数)：获取数据，XXX代表数据类型，如getInt()，getString()，getDouble()等，参数有两种情况，第一种情况接收int类型的值，代表列的编号，如getString(2)，编号从1开始。第二种情况接收String类型的值，列的名称，如getDouble("balance")

案例1

package cn.itcast.jdbc;

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

/**
 * 练习ResultSet
 */
public class JDBCDemo6 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        //1.导入jar包

        try {
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.获取数据库连接对象Connection
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2","root","root");
            //4.获取执行SQL对象Statement
            stmt = conn.createStatement();
            //5.定义SQL
            String sql = "select * from account";
            //6.执行SQL
            rs = stmt.executeQuery(sql);
            //7.处理结果
            rs.next();
            int id = rs.getInt(1);
            String name = rs.getString("name");
            double balance = rs.getDouble("balance");
            System.out.println(id +"  " + name + "  " + balance);
            rs.next();
            id = rs.getInt(1);
            name = rs.getString("name");
            balance = rs.getDouble("balance");
            System.out.println(id +"  " + name + "  " + balance);
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            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();
                }
            }
        }

    }
}

注意：使用步骤，第一步游标向下移动一行，第二步判断是否有数据，第三步获取数据。

案例2

package cn.itcast.jdbc;

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

/**
 * 练习ResultSet
 */
public class JDBCDemo7 {
    public static void main(String[] args) {
        Connection conn = null;
        Statement stmt = null;
        ResultSet rs = null;
        //1.导入jar包

        try {
            //2.注册驱动
            Class.forName("com.mysql.jdbc.Driver");
            //3.获取数据库连接对象Connection
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/db2","root","root");
            //4.获取执行SQL对象Statement
            stmt = conn.createStatement();
            //5.定义SQL
            String sql = "select * from account";
            //6.执行SQL
            rs = stmt.executeQuery(sql);
            //7.处理结果
            while(rs.next()){//next()如果返回true则表示仍有数据。
                int id = rs.getInt(1);
                String name = rs.getString("name");
                double balance = rs.getDouble("balance");
                System.out.println(id +"  " + name + "  " + balance);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            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();
                }
            }
        }

    }
}

　　（5）PreparedStatement：执行SQL的对象

 　　　　SQL注入问题，表现为随便输入用户名，密码为：a' or  'a' = 'a  。 SQL为：select * from user where username = 'fhdshkkjfd' and password = 'a' or 'a' = 'a'

　　　　 在拼接SQL时，有一些SQL的特殊关键字参与字符串的拼接，会造成安全性问题。

　　　　 解决SQL注入的问题：使用preparedStatement对象来解决

　　　　 预编译的SQL：参数使用？作为占位符

　　　　步骤：

　　　　　　1）导入驱动jar包

　　　　　　2）注册驱动

　　　　　　3）获取数据库连接对象Connection

　　　　　　4）定义SQL：主语SQL的参数使用？作为占位符。如：select * from user where username = ? password = ?;

　　　　　　5）获取执行SQL语句的对象PreparedStatement   connection.prepareStatement(String sql)

　　　　　　6）给？赋值：方法为——setXxx(参数1，参数2);  参数1为？的位置编号，从1开始；参数2为？的值

　　　　　　7）执行SQL，接收返回结果，不需要传递SQL语句

　　　　　　8）处理结果

　　　　　　9）释放资源

示例代码

package cn.itcast.jdbc;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;


import cn.itcast.util.JDBCUtil;

public class JDBCDemo9 {
    public static void main(String[] args) {
        Scanner sc = new Scanner(System.in);
        System.out.println("请输入用户名");
        String username = sc.nextLine();
        System.out.println("请输入密码");
        String password = sc.nextLine();

        boolean flag = new JDBCDemo9().login(username, password);
        if (flag) {
            System.out.println("登录成功");
        } else {
            System.out.println("用户名密码错误");
        }

    }

    public boolean login(String username, String password){
        if(username == null || password == null){
            return false;
        }

        Connection conn = null;
        PreparedStatement preStmt = null;
        ResultSet rs = null;

        try {
            //1.注册驱动并获取连接
            conn = JDBCUtil.getConnection();
            //2.定义SQL
            String sql = "select * from user where name = ? and password = ?";
            //3.获取执行SQL的对象 PreparedStatement
            preStmt = conn.prepareStatement(sql);
            preStmt.setString(1,username);
            preStmt.setString(2,password);
            //4.执行查询，不需要传递SQL的方法
            rs = preStmt.executeQuery();
            return rs.next();//如果有下一行则返回true

        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            JDBCUtil.close(rs,preStmt,conn);
        }
        return false;
    }
}

5.抽取JDBC工具类  JDBCUtils

目的：简化书写

分析

　　抽取一个方法获取连接

　　　　需求：不想传递参数，还需要保证工具类的通用性。

　　　　解决方案：配置文件

　　　　　　定义jdbc.properties配置文件，将来只需要读取配置文件就可以拿到参数。

　　抽取一个方法释放资源

实例代码

package cn.itcast.util;

import java.io.FileReader;
import java.io.IOException;
import java.net.URL;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

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

    /**
     * 文件的读取，只需要读取一次即可拿到这些值。使用静态代码块
     */
    static {
        //读取资源文件，并获值

        try {
            //1.创建Properties集合类
            Properties pro = new Properties();
            //获取src路径下的文件的方式 --> ClassLoader类加载器
            ClassLoader classLoader = JDBCUtil.class.getClassLoader();
            //URL 统一资源定位符
            URL res = classLoader.getResource("jdbc.properties");//传一个文件名，可以获得它的资源，以src为根目录
            String path = res.getPath();

            //2.加载文件
            pro.load(new FileReader(path));
            //3.获取数据，赋值
            url = pro.getProperty("url");
            user = pro.getProperty("user");
            password  = pro.getProperty("password");
            driver = pro.getProperty("driver");

            //4.注册驱动
            Class.forName(driver);
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }
    }

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

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

    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();
            }
        }
    }
}

 6.JDBC控制事务

　　事务：一个包含多个步骤的业务操作。如果这个业务操作被事务管理，则这多个步骤要么同时成功，要么同时失败

　　操作：开启事务，提交事务，回滚事务。

　　使用Connection对象来管理事务

　　　　开启事务：setAutoCommit(boolean autoCommit)：调用该方法设置参数为false，即开启事务

　　　　　　　　在执行SQL之前开启事务

　　　　提交事务：commit()

　　　　　　　　在所有SQL都执行完提交事务

　　　　回滚事务：rollback()

　　　　　　　　在catch中回滚事务

示例代码

package cn.itcast.jdbc;

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

import cn.itcast.util.JDBCUtil;

/**
 * 事务操作
 */
public class JDBCDemo10 {
    public static void main(String[] args) {

        Connection conn = null;
        PreparedStatement pstmt1 = null;
        PreparedStatement pstmt2 = null;
        try {
            //1.获取数据库连接
            conn = JDBCUtil.getConnection();

            //开启事务
            conn.setAutoCommit(false);


            //2.定义SQL
            //2.1 张三减去500
            String sql1 = "update account set balance = balance - ? where id = ?";
            //2.2 李四加上500
            String sql2 = "update account set balance = balance + ? where id = ?";
            //3.获取SQL执行对象
            pstmt1 = conn.prepareStatement(sql1);
            pstmt2 = conn.prepareStatement(sql2);
            //4.设置参数
            pstmt1.setDouble(1,500);
            pstmt1.setInt(2,1);

            pstmt2.setDouble(1,500);
            pstmt2.setInt(2,2);
            //5.执行SQL
            pstmt1.executeUpdate();

            //手动制造异常
            int i = 3/0;
            pstmt2.executeUpdate();

            //提交事务
            conn.commit();
        } catch (Exception e) {
            //事务的回滚
            try {
                if(conn !=null)
                    conn.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        } finally{
            if(pstmt1 != null){
                try {
                    pstmt1.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            JDBCUtil.close(pstmt2,conn);
        }
    }
}