05.《JavaEE 学习笔记》JDBC-数据库论坛-技术分享-千百度社区

05.《JavaEE 学习笔记》JDBC

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

© 著作权归作者所有,转载或内容合作请联系作者

请登录后发表评论

    没有回复内容