首页 > 其他分享 >一.JDBC----(基础篇)

一.JDBC----(基础篇)

时间:2024-07-14 10:29:19浏览次数:22  
标签:语句 JDBC resultSet 数据库 基础 ---- preparedStatement emp SQL

一、引言

1.1 数据的存储

我们在开发Java程序时,数据都是存储在内存中,属于临时存储,当程序停止或重启时,内存中的数据就丢失了!我们为了解决数据的长期存储问题,有如下解决方案:

  1. 数据通过I/O流技术,存储在本地磁盘中,解决了持久化问题,但是没有结构和逻辑,不方便管理和维护。

  2. 通过关系型数据库,将数据按照特定的格式交由数据库管理系统维护。关系型数据库是通过库和表分隔不同的数据,表中数据存储的方式是行和列,区分相同格式不同值的数据。

1.2 数据的操作

数据存储在数据库,仅仅解决了我们数据存储的问题,但当我们程序运行时,需要读取数据,以及对数据做增删改的操作,那么我们如何通过Java程序对数据库中的数据做增删改查呢?

二、JDBC

2.1 JDBC的概念
  • JDBC:Java Database Connectivity,意为Java数据库连接。

  • JDBC是Java提供的一组独立于任何数据库管理系统的API。

  • Java提供接口规范,由各个数据库厂商提供接口的实现,厂商提供的实现类封装成jar文件,也就是我们俗称的数据库驱动jar包。

  • 学习JDBC,充分体现了面向接口编程的好处,程序员只关心标准和规范,而无需关注实现过程。

2.2 JDBC的核心组成
  • 接口规范:

    • 为了项目代码的可移植性,可维护性,SUN公司从最初就制定了Java程序连接各种数据库的统一接口规范。这样的话,不管是连接哪一种DBMS软件,Java代码可以保持一致性。

    • 接口存储在java.sql和javax.sql包下。

  • 实现规范:

    • 因为各个数据库厂商的DBMS软件各有不同,那么各自的内部如何通过SQL实现增、删、改、查等操作管理数据,只有这个数据库厂商自己更清楚,因此把接口规范的实现交给各个数据库厂商自己实现。

    • 厂商将实现内容和过程封装成jar文件,我们程序员只需要将jar文件引入到项目中集成即可,就可以开发调用实现过程操作数据库了。

三、JDBC快速入门

3.1 JDBC搭建步骤
  1. 准备数据库。

  2. 官网下载数据库连接驱动jar包。https://downloads.mysql.com/archives/c-j/

  3. 创建Java项目,在项目下创建lib文件夹,将下载的驱动jar包复制到文件夹里。

  4. 选中lib文件夹右键->Add as Library,与项目集成。

  5. 编写代码

3.2 代码实现
3.2.1 数据库
CREATE DATABASE atguigu;
​
use atguigu;
​
create table t_emp
(
    emp_id     int auto_increment comment '员工编号' primary key,
    emp_name   varchar(100)  not null comment '员工姓名',
    emp_salary double(10, 5) not null comment '员工薪资',
    emp_age    int           not null comment '员工年龄'
);
​
insert into t_emp (emp_name,emp_salary,emp_age)
values  ('andy', 777.77, 32),
        ('大风哥', 666.66, 41),
        ('康师傅',111, 23),
        ('Gavin',123, 26),
        ('小鱼儿', 123, 28);

3.2.2 Java代码
package com.atguigu;
​
import java.sql.*;
​
public class JdbcQuick {
    public static void main(String[] args) throws ClassNotFoundException, SQLException {
        //1.注册驱动
        Class.forName("com.mysql.cj.jdbc.Driver");
      
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root", "atguigu");
​
        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp");
​
        //4.编写SQL语句并执行,获取结果
        ResultSet resultSet = preparedStatement.executeQuery();
​
​
        //5.处理结果
        while (resultSet.next()) {
            int empId = resultSet.getInt("emp_id");
            String empName = resultSet.getString("emp_name");
            String empSalary = resultSet.getString("emp_salary");
            int empAge = resultSet.getInt("emp_age");
            System.out.println(empId + "\t" + empName + "\t" + empSalary + "\t" + empAge);
        }
​
        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
​
    }
}
​

3.3 步骤总结
  1. 注册驱动【依赖的驱动类,进行安装】

  2. 获取连接【Connection建立连接】

  3. 创建发送SQL语句对象【Connection创建发送SQL语句的Statement】

  4. 发送SQL语句,并获取返回结果【Statement 发送sql语句到数据库并且取得返回结果】

  5. 结果集解析【结果集解析,将查询结果解析出来】

  6. 资源关闭【释放ResultSet、Statement 、Connection】

四、核心API理解

4.1 注册驱动
  • Class.forName("com.mysql.cj.jdbc.Driver");
  • 在 Java 中,当使用 JDBC(Java Database Connectivity)连接数据库时,需要加载数据库特定的驱动程序,以便与数据库进行通信。加载驱动程序的目的是为了注册驱动程序,使得 JDBC API 能够识别并与特定的数据库进行交互。

  • 从JDK6开始,不再需要显式地调用 Class.forName() 来加载 JDBC 驱动程序,只要在类路径中集成了对应的jar文件,会自动在初始化时注册驱动程序。

4.2 Connection
  • Connection接口是JDBC API的重要接口,用于建立与数据库的通信通道。换而言之,Connection对象不为空,则代表一次数据库连接。

  • 在建立连接时,需要指定数据库URL、用户名、密码参数。

    • URL:jdbc:mysql://localhost:3306/atguigu

      • jdbc:mysql://IP地址:端口号/数据库名称?参数键值对1&参数键值对2

  • Connection 接口还负责管理事务,Connection 接口提供了 commitrollback 方法,用于提交事务和回滚事务。

  • 可以创建 Statement 对象,用于执行 SQL 语句并与数据库进行交互。

  • 在使用JDBC技术时,必须要先获取Connection对象,在使用完毕后,要释放资源,避免资源占用浪费及泄漏。

4.3 Statement
  • Statement 接口用于执行 SQL 语句并与数据库进行交互。它是 JDBC API 中的一个重要接口。通过 Statement 对象,可以向数据库发送 SQL 语句并获取执行结果。

  • 结果可以是一个或多个结果。

    • 增删改:受影响行数单个结果。

    • 查询:单行单列、多行多列、单行多列等结果。

  • 但是Statement 接口在执行SQL语句时,会产生SQL注入攻击问题:

    • 当使用 Statement 执行动态构建的 SQL 查询时,往往需要将查询条件与 SQL 语句拼接在一起,直接将参数和SQL语句一并生成,让SQL的查询条件始终为true得到结果。

4.4 PreparedStatement
  • PreparedStatementStatement 接口的子接口,用于执行预编译的 SQL 查询,作用如下:

    • 预编译SQL语句:在创建PreparedStatement时,就会预编译SQL语句,也就是SQL语句已经固定。

    • 防止SQL注入:PreparedStatement 支持参数化查询,将数据作为参数传递到SQL语句中,采用?占位符的方式,将传入的参数用一对单引号包裹起来'',无论传递什么都作为值。有效防止传入关键字或值导致SQL注入问题。

    • 性能提升:PreparedStatement是预编译SQL语句,同一SQL语句多次执行的情况下,可以复用,不必每次重新编译和解析。

  • 后续的学习我们都是基于PreparedStatement进行实现,更安全、效率更高!

4.5 ResultSet
  • ResultSet是 JDBC API 中的一个接口,用于表示从数据库中执行查询语句所返回的结果集。它提供了一种用于遍历和访问查询结果的方式。

  • 遍历结果:ResultSet可以使用 next() 方法将游标移动到结果集的下一行,逐行遍历数据库查询的结果,返回值为boolean类型,true代表有下一行结果,false则代表没有。

  • 获取单列结果:可以通过getXxx的方法获取单列的数据,该方法为重载方法,支持索引和列名进行获取。

五、基于PreparedStatement实现CRUD

5.1 查询单行单列
    @Test
    public void querySingleRowAndColumn() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root","atguigu");
​
        //3.创建PreparedStatement对象,并预编译SQL语句
        PreparedStatement preparedStatement = connection.prepareStatement("select count(*) as count from t_emp");
​
        //4.执行SQL语句,获取结果
        ResultSet resultSet = preparedStatement.executeQuery();
​
        //5.处理结果
        while (resultSet.next()){
            int count = resultSet.getInt("count");
            System.out.println("count = " + count);
        }
​
        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
​
    }

5.2 查询单行多列
    @Test
    public void querySingleRow() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root","atguigu");
​
        //3.创建PreparedStatement对象,并预编译SQL语句,使用?占位符
        PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp where emp_id = ?");
​
        //4.为占位符赋值,索引从1开始,执行SQL语句,获取结果
        preparedStatement.setInt(1,1);
        ResultSet resultSet = preparedStatement.executeQuery();
​
        //5.处理结果
        while (resultSet.next()){
            int empId = resultSet.getInt("emp_id");
            String empName = resultSet.getString("emp_name");
            String empSalary = resultSet.getString("emp_salary");
            int empAge = resultSet.getInt("emp_age");
            System.out.println(empId+"\t"+empName+"\t"+empSalary+"\t"+empAge);
        }
​
        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
​
    }

5.3 查询多行多列
    @Test
    public void queryMoreRow() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root","atguigu");
​
        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("select emp_id,emp_name,emp_salary,emp_age from t_emp");
​
        //4.编写SQL语句并执行,获取结果
        ResultSet resultSet = preparedStatement.executeQuery();
​
​
        //5.处理结果
        while (resultSet.next()){
            int empId = resultSet.getInt("emp_id");
            String empName = resultSet.getString("emp_name");
            String empSalary = resultSet.getString("emp_salary");
            int empAge = resultSet.getInt("emp_age");
            System.out.println(empId+"\t"+empName+"\t"+empSalary+"\t"+empAge);
        }
​
        //6.释放资源(先开后关原则)
        resultSet.close();
        preparedStatement.close();
        connection.close();
​
    }

5.4 新增
    @Test
    public void insert() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu","root", "atguigu");
​
        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("insert into t_emp (emp_name,emp_salary,emp_age)values  (?, ?,?)");
​
        //4.为占位符赋值,索引从1开始,编写SQL语句并执行,获取结果
        preparedStatement.setString(1,"rose");
        preparedStatement.setDouble(2,666.66);
        preparedStatement.setDouble(3,28);
        int result = preparedStatement.executeUpdate();
​
        //5.处理结果
        if(result>0){
            System.out.println("添加成功");
        }else{
            System.out.println("添加失败");
        }
​
        //6.释放资源(先开后关原则)
        preparedStatement.close();
        connection.close();
​
    }

5.5 修改
    @Test
    public void update() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root", "atguigu");
​
        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("update t_emp set emp_salary = ? where emp_id = ?");
​
        //4.为占位符赋值,索引从1开始,编写SQL语句并执行,获取结果
        preparedStatement.setDouble(1,888.88);
        preparedStatement.setDouble(2,8);
        int result = preparedStatement.executeUpdate();
​
        //5.处理结果
        if(result>0){
            System.out.println("修改成功");
        }else{
            System.out.println("修改失败");
        }
​
        //6.释放资源(先开后关原则)
        preparedStatement.close();
        connection.close();
​
    }

5.6 删除
    @Test
    public void delete() throws SQLException {
        //1.注册驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
​
        //2.获取数据库连接
        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/atguigu", "root", "atguigu");
​
        //3.创建Statement对象
        PreparedStatement preparedStatement = connection.prepareStatement("delete from t_emp where emp_id = ?");
​
        //4.为占位符赋值,索引从1开始,编写SQL语句并执行,获取结果
        preparedStatement.setInt(1,8);
        int result = preparedStatement.executeUpdate();
​
        //5.处理结果
        if(result>0){
            System.out.println("删除成功");
        }else{
            System.out.println("删除失败");
        }
​
        //6.释放资源(先开后关原则)
        preparedStatement.close();
        connection.close();
​
    }

六、常见问题

6.1 资源的管理

在使用JDBC的相关资源时,比如Connection、PreparedStatement、ResultSet,使用完毕后,要及时关闭这些资源以释放数据库服务器资源和避免内存泄漏是很重要的。

6.2 SQL语句问题

java.sql.SQLSyntaxErrorException:SQL语句错误异常,一般有几种可能:

  1. SQL语句有错误,检查SQL语句!建议SQL语句在SQL工具中测试后再复制到Java程序中!

  2. 连接数据库的URL中,数据库名称编写错误,也会报该异常!

6.3 SQL语句未设置参数问题

java.sql.SQLException:No value specified for parameter 1

在使用预编译SQL语句时,如果有?占位符,要为每一个占位符赋值,否则报该错误!

6.4 用户名或密码错误问题

连接数据库时,如果用户名或密码输入错误,也会报SQLException,容易混淆!所以一定要看清楚异常后面的原因描述

6.5 通信异常

在连接数据库的URL中,如果IP或端口写错了,会报如下异常:

com.mysql.cj.jdbc.exceptions.CommunicationsException: Communications link failure

标签:语句,JDBC,resultSet,数据库,基础,----,preparedStatement,emp,SQL
From: https://blog.csdn.net/mmmmazhiyuan/article/details/140413140

相关文章

  • Java进阶之路66问 | 什么是幂等性?如何保证接口的冥等性?
    API设计中的幂等性什么是幂等性幂等性是指无论一个操作执行多少次,最终的结果都是一样的。也就是说,重复执行同一个操作不会改变系统的状态或产生不同的结果。想象你在一栋大楼里等电梯。你按下电梯按钮的5楼按钮键,电梯开始向5楼的位置移动。后面即使你再按几次5楼按钮键,......
  • Java优雅使用线程池连接SFTP进行文件上传下载 解决请求量大问题
    Java优雅使用线程池连接SFTP进行文件上传下载解决请求量大问题使用FTP连接池降低资源消耗,提高响应速率为什么要使用线程池连接SFTP呢?在Java中使用线程池来连接SFTP(SecureFileTransferProtocol)工具的原因主要与性能、资源管理和效率有关。以下是一些关键原因:资源管......
  • 花几千上万学习Java,真没必要!(四)
    1、关系运算符:packagetest.com;publicclassRelationalArithmetic{ /*关系运算符用于比较两个值之间的关系,关系运算符的结果是一个布尔值,即true或false。 Java提供了6种关系运算符: >:大于 <:小于 >=:大于等于 <=:小于等于 ==:等于 !=:不等于*/publicstaticvoi......
  • 怎样才能将MP4转换成RMVB格式?这五种视频格式转换法一定要知道
    在当今数字化时代,视频格式转换已成为许多人的日常需求。特别是将MP4格式的视频转换为RMVB格式,这在某些特定的播放环境或设备中显得尤为重要。本文将详细介绍几种将MP4转换成RMVB格式的方法,帮助读者轻松应对视频格式转换的问题。方法一:使用【汇帮视频格式转换器】操作步骤如下......
  • UML/SysML建模工具更新情况(2024年7月)(1)
    DDD领域驱动设计批评文集做强化自测题获得“软件方法建模师”称号《软件方法》各章合集工具最新版本:EnterpriseArchitect17.0BETA更新时间:2024年7月2日工具简介性价比很高,目前最流行的UML建模工具。还包含需求管理、项目估算、测试支持。团队建模支持。平台:Window......
  • 启发式优化算法合集
    遗传算法(GeneticAlgorithm)模拟退火(SimulatedAnnealing)粒子群优化(ParticleSwarmOptimization)蚁群算法(AntColonyOptimization)差分进化(DifferentialEvolution)禁忌搜索(TabuSearch)局部搜索(LocalSearch)邻域搜索(NeighborhoodSearch)蝙蝠......
  • OpenFlow 是一个网络通信协议,它允许网络管理员通过中央控制器(如 OpenFlow 控制器)来编
    OpenFlow是一个网络通信协议,它允许网络管理员通过中央控制器(如OpenFlow控制器)来编程定义网络中的数据包转发行为。OpenFlow协议通常用于软件定义网络(SDN)架构中,其中网络控制平面与数据转发平面是分离的。在Python中,直接编写与OpenFlow交换机交互的代码通常涉及使用......
  • Windows11系统System.Runtime.Serialization.dll文件丢失问题
    其实很多用户玩单机游戏或者安装软件的时候就出现过这种问题,如果是新手第一时间会认为是软件或游戏出错了,其实并不是这样,其主要原因就是你电脑系统的该dll文件丢失了或没有安装一些系统软件平台所需要的动态链接库,这时你可以下载这个System.Runtime.Serialization.dll文件(挑选......
  • Windows11系统System.Resources.Writer.dll文件丢失问题
    其实很多用户玩单机游戏或者安装软件的时候就出现过这种问题,如果是新手第一时间会认为是软件或游戏出错了,其实并不是这样,其主要原因就是你电脑系统的该dll文件丢失了或没有安装一些系统软件平台所需要的动态链接库,这时你可以下载这个System.Resources.Writer.dll文件(挑选合适......
  • Java计算机毕业设计个人健康管理系统的设计与实现(开题报告+源码+论文)
    本系统(程序+源码)带文档lw万字以上 文末可获取一份本项目的java源码和数据库参考。系统程序文件列表开题报告内容研究背景随着生活节奏的加快和健康意识的增强,个人健康管理成为了现代社会的重要议题。传统医疗模式下,人们往往只在出现症状时才寻求医生的帮助,这种“被动医疗......