05.《JavaEE 学习笔记》JDBC

一直流浪

5个月前发布

05.《JavaEE 学习笔记》JDBC

参考链接：https://www.runoob.com/w3cnote/jdbc-use-guide.html https://blog.csdn.net/goldentec/article/details/105334686

1、JDBC 简述

JDBC API 允许用户访问任何形式的表格数据，尤其是存储在关系数据库中的数据。

执行流程：

连接数据源，如：数据库。
为数据库传递查询和更新指令。
处理数据库响应并返回的结果。

2、JDBC构架

分为双层架构和三层架构。

（1）双层

image.png

作用：此架构中，Java Applet 或应用直接访问数据源。这需要一个JDBC驱动程序，它可以与被访问的特定数据源进行通信。

条件：要求 Driver 能与访问的数据库交互。

机制：用户命令传给数据库或其他数据源，随之结果被返回。

部署：数据源可以在另一台机器上，用户通过网络连接，称为 C/S配置（可以是内联网或互联网）。用户的机器是客户机，容纳数据源的机器是服务器。网络可以是内部网，例如连接公司内部的员工，也可以是Internet。。

（2）三层

image.png

侧架构特殊之处在于，引入中间层服务。

流程：命令和结构都会经过该层。

吸引：可以增加企业数据的访问控制，以及多种类型的更新；另外，也可简化应用的部署，并在多数情况下有性能优势。

历史趋势：以往，因性能问题，中间层都用 C 或 C++ 编写，随着优化编译器（将 Java 字节码转为高效的特定机器码）和技术的发展，如EJB，Java 开始用于中间层的开发这也让 Java 的优势突显出现出来，使用 Java 作为服务器代码语言，JDBC随之被重视。

3、JDBC 连接数据库

（1）加载驱动程序（通过反射找到对应的re包）

// 加载Oracle“驱动类” SPI
Class.forName("oracle.jdbc.driver.OracleDriver");

//加载MySql驱动 SPI
Class.forName("com.mysql.jdbc.Driver")

image.png

（2）获取数据库连接：

// 创建“URL连接字符串”。格式：jdbc:oracle:thin:@ 主机名/IP : 端口号 ：服务名称
String url = "jdbc:oracle:thin:@localhost:1521:XE";

// 创建“用户名”
String username = "scott";

// 创建“密码”
String password = "123456";

// 初始化“数据库连接对象”
Connection conn = DriverManager.getConnection(url, username, password);

完整的数据库连接：

package com.company.project.util;

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

public class DBUtil {
    // 声明“数据库连接对象”，单例模式
    private static Connection conn;

    // 方法：获取“数据库连接对象”，单例模式。
    public static Connection getConnection() {
        // 判断“数据库连接对象”是否存在
        try {
            // 判断条件：连接对象不为空 并且 连接对象不是关闭的
            if (conn != null && !conn.isClosed()) {
                return conn;
                // 返回成功后，后面的代码将不会被执行。
            }

            // 加载“驱动类” SPI
            Class.forName("oracle.jdbc.driver.OracleDriver");
            // 创建“URL连接字符串”。格式：jdbc:oracle:thin:@ 主机名/IP : 端口号 ：服务名称
            String url = "jdbc:oracle:thin:@localhost:1521:XE";

            // 创建“用户名”
            String username = "scott";
            // 创建“密码”
            String password = "123456";

            // 初始化“数据库连接对象”
            conn = DriverManager.getConnection(url, username, password);
            if (conn != null) {
                System.out.println("[操作提示]恭喜您，数据库连接成功！");
            }

        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        }

        return conn;
    }
}

4、JDBC 对数据库操作

4.1 Connection接口

Connection是与特定数据库的链接对象，通过DriverManager类取得。通常使用链接对象获得语句对象，常用的语句对象有两种，所以有两个方法获得。

（1）createStatement() 返回Statement对象，否则抛出SQLException异常，必须捕捉。

Statement createStatement(  ) throws SQLException

（2）prepareStatement(String sql) 返回PrepareStatement对象，有可能抛异常，必须捕捉。参数sql是要执行的SQL语句。

PreparedStatement  prepareStatement(String sql)  throws SQLException

4.2 Statement 对象（对静态sql的执行）

Statement对象可以用来执行SQL语句，使用executeQuery执行查询语句，返回结果集，使用executeUpdate执行增删改，返回操作的行数。

常用方法：

（1）executeUpdate(String sql) 执行执行增删改语句，返回返回受影响的行数

int executeUpdate(String sql)  throws SQLException

（2）executeQuery(String sql) 执行查询语句，返回结果集

ResultSet executeQuery(String sql)  throws SQLException

例子：

Connection conn = DBUtil.getConnection();
String sql = "select * from books";
Statement statement = conn.createStatement();
ResultSet rs = statement.executeQuery(sql);

4.3 PreparedStatment 对象（对动态sql的执行）

如果要多次执行相似的SQL语句，可以使用PreparedStatemend（预编译语句对象）对象来执行，进行了预编译，效率较高；可以执行带？的SQL语句，？使用setX方法赋值。

常用方法：

（1）executeUpdate(String sql) 执行执行增删改语句，返回返回受影响的行数

int executeUpdate()  throws SQLException

（2）executeQuery(String sql) 执行查询语句，返回结果集

ResultSet executQuery()  throws SQLException

（3）setX(int parameterIndex, X x)

介绍：将parameterIndex指定的“?”位置指定为x的值，这里X可以指代任意数据类型， “?”的索引从1开始。

void setX(int parameterIndex, X x)  throws SQLException

例子：插入订单

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

        public boolean insert(OrderForm orderForm) {
        boolean flag = false;
        conn = DBUtil.getConnection();
        String sql = "insert into order_form (id,user_id,book_id) values (?,?,?)";      
        try {
            pstmt = conn.prepareStatement(sql);
            pstmt.setLong(1, orderForm.getId());
            pstmt.setLong(2, orderForm.getUser_id());
            pstmt.setLong(3, orderForm.getBook_id());
            
            int rs = pstmt.executeUpdate();
            if(rs > 0) {
                flag = true;
                System.out.println("成功插入" + rs + "条记录");
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return flag;
    }

4.4 ResultSet接口

ResultSet对象用来封装查询得到的结果集，常用的方法有next以及getXXX方法。注意：必须使用next()方法，才能处理结果集。

常用方法：

（1）next()

说明：将结果集游标往下移动一行，如果已经到达结果集最后，将会返回false，有可能抛异常，必须捕捉

boolean next()  throws SQLException

（2）getX(String columnName)

说明：获得某个字段的值，X是指具体的数据类型，视数据库表中字段的具体情况而定，该方法有一组，并且每个都有两种重载方法，一种是以字段名称为参数，另一种是以字段索引为参数（字段索引从1开始），有可能抛异常，必须捕捉。

X getX(int columnIndex)  throws SQLException

例子：查询所有商品

    public ArrayList<Goods> displayGoods(){
        ArrayList<Goods> goodsList = new ArrayList<>();
        conn = DbConnect.getconn();
        String sql = "select * from goods";
        try {
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            
            while(rs.next()) {
                int gid = rs.getInt("gid");
                String gname = rs.getString(2);
                double gprice = rs.getDouble("gprice");
                int gnum = rs.getInt(4);
                
                Goods goods = new Goods(gid, gname, gprice, gnum);
                goodsList.add(goods);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            DbClose.queryClose(pstmt, rs, conn);
        }
        return goodsList;
    }

评分

欢迎为Ta评分