JDBC简介

JDBC（Java Data Base Connectivity,java数据库连接）是一种用于执行SQL语句的Java API，可以为多种关系数据库提供统一访问，它由一组用Java语言编写的类和接口组成。JDBC提供了一种基准，据此可以构建更高级的工具和接口，使数据库开发人员能够编写数据库应用程序。通过JDBC，我们可以使用相同的API访问不同的数据库服务。

JDBC的基本使用要熟悉，因为所有的ORM框架底层都是调用JDBC

JDBC接口

• Driver：Driver接口由数据库厂家提供，作为java开发人员，只需要使用Driver接口就可以了。
• Connection：与数据库的连接（会话），在连接上下文中执行sql语句并返回结果。

常用方法：

createStatement()：创建向数据库发送sql的statement对象。

prepareStatement(sql) ：创建向数据库发送预编译sql的PrepareSatement对象。

prepareCall(sql)：创建执行存储过程的callableStatement对象。

setAutoCommit(boolean autoCommit)：设置事务是否自动提交。

commit() ：在链接上提交事务。

rollback() ：在此链接上回滚事务。

• Statement

分类：

Statement：由createStatement创建，用于发送简单的SQL语句。

PreparedStatement ：继承自Statement接口，由preparedStatement创建，用于发送含有一个或多个参数的SQL语句。PreparedStatement对象比Statement对象的效率更高，并且可以防止SQL注入，所以我们一般都使用PreparedStatement。

CallableStatement：继承自PreparedStatement接口，由方法prepareCall创建，用于调用存储过程。

常用方法：

execute(String sql):运行语句，返回是否有结果集

executeQuery(String sql)：运行select语句，返回ResultSet结果集。

executeUpdate(String sql)：运行insert/update/delete操作，返回更新的行数。

addBatch(String sql) ：把多条sql语句放到一个批处理中。

executeBatch()：向数据库发送一批sql语句执行。

• ResultSet：查询结果

常用方法：

getString(int index)、getString(String columnName)：获得在数据库里是varchar、char等类型的数据对象。

getFloat(int index)、getFloat(String columnName)：获得在数据库里是Float类型的数据对象。

getDate(int index)、getDate(String columnName)：获得在数据库里是Date类型的数据。

getBoolean(int index)、getBoolean(String columnName)：获得在数据库里是Boolean类型的数据。

getObject(int index)、getObject(String columnName)：获取在数据库里任意类型的数据。

JDBC简单实例

JDBC操作数据库的步骤：

• 注册驱动（Driver）
• 获取数据库连接（Connection）
• 获取 statement/preparedStateMent
• 执行sql并获取结果
• 解析结果
• 关闭连接： ResultSet → Statement → Connection

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * @Author: jimmy
 * @Date: 2021/9/9 11:04
 * @Description:
 *  JDBC连接数据库操作
 */
public class JdbcDemo {

    static final String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    static final String DB_URL = "jdbc:mysql://localhost:3306/ybconvet?useUnicode=true&characterEncoding=utf8&allowMultiQueries=true";
    static final String USER = "root";
    static final String PASS = "root";


    public static void main(String[] args) {
        JdbcDemo demo = new JdbcDemo();
        demo.queryWithStatement();
        demo.QueryPreparedStatement();
    }

    public void queryWithStatement(){
        System.out.println("----  queryWithStatement ----");
        Connection conn = null;
        Statement stmt = null;

        try {
            // 1、注册mysql的驱动
            Class.forName(JDBC_DRIVER);

            // 2、获取连接
            conn = DriverManager.getConnection(DB_URL, USER, PASS);

            // 3、创建 statement
            stmt = conn.createStatement();
            String id = "20";
            String sql = "select count(1) from oms_ser_table_check where id < " + id;

            // 4、通过statement执行sql并获取结果
            System.out.println("--------------通过statement执行sql并获取结果----------------");
            ResultSet rs = stmt.executeQuery(sql);
            int count = 0;
            while (rs.next()) {
               count = rs.getInt(1);
            }

            System.out.println(count);
            // 关闭连接
            rs.close();
            stmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            // finally block used to close resources
            try {
                if (stmt != null){
                    stmt.close();
                }

            } catch (SQLException se2) {
            }// nothing we can do
            try {
                if (conn != null){
                    conn.close();
                }
            } catch (SQLException se) {
                se.printStackTrace();
            }
        }
    }

    public void QueryPreparedStatement(){
        System.out.println("----  QueryPreparedStatement ----");
        Connection conn = null;
        PreparedStatement pstmt = null;

        try {
            // 1、注册mysql的驱动
            Class.forName(JDBC_DRIVER);

            // 2、获取连接
            conn = DriverManager.getConnection(DB_URL, USER, PASS);

            // 3、创建 PreparedStatement
            String sql = "select count(1) from oms_ser_table_check where id < ?" ;
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, 20);


            // 4、通过statement执行sql并获取结果
            System.out.println("--------------通过PreparedStatement执行sql并获取结果----------------");
            ResultSet rs = pstmt.executeQuery();
            int count = 0;
            while (rs.next()) {
                count = rs.getInt(1);
            }

            System.out.println(count);
            // 关闭连接
            rs.close();
            pstmt.close();
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            // finally block used to close resources
            try {
                if (pstmt != null){
                    pstmt.close();
                }

            } catch (SQLException se2) {
            }// nothing we can do
            try {
                if (conn != null){
                    conn.close();
                }
            } catch (SQLException se) {
                se.printStackTrace();
            }
        }
    }
}
// 输出结果：
----  queryWithStatement ----
--------------通过statement执行sql并获取结果----------------
19
----  QueryPreparedStatement ----
--------------通过PreparedStatement执行sql并获取结果----------------
19

绅士们，拿走吧，不用客气（图片如有侵权，联系删除）