AI 助理
文档备案控制台
开发者社区 数据库 文章 正文

JDBC（常用类与接口、实现数据库的增删查改）

2023-08-08 368
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
RDS MySQL DuckDB 分析主实例，集群系列 4核8GB
RDS MySQL DuckDB 分析主实例，基础系列 4核8GB
RDS AI 助手，专业版
简介： 1.Connection接口常用方法、2.DriverMange类、3.Statement接口,4.实现表的数据更新（增、改、删）,5.实现数据查找（ResultSet接口），6.PreparedStatement 数据更新

1.Connection接口常用方法

用来与数据库连接的对象，只有获得了特定的数据库对象才能对数据库进行操作

方法 描述
createStatement() 创建一个 Statement 对象，用于执行 SQL 语句。
createStatement(int resultSetType,int resultSetConcurrency) 根据给定的结果集类型和并发性创建一个 Statement 对象，用于执行 SQL 语句。
prepareStatement() 创建一个 PreparedStatement 对象，用于执行带有参数的 SQL 语句。
isReadOnly() 返回一个布尔值，指示数据库连接是否为只读模式。
setReadOnly() 设置数据库连接的只读模式，以指示是否允许修改数据库。
commit() 提交当前事务中所有挂起的更改。
rollback() 回滚当前事务中的所有挂起的更改。
close() 关闭数据库连接。

2.DriverMange类

这个类主要包含和数据库的交互方法

方法
 描述
getConnection(String url, String user, String password) 获取与指定数据库的连接。传入数据库的URL、用户名和密码作为参数。
setLogonTimeout() 设置在尝试连接到数据库时等待的最长时间，超过该时间将引发异常。
println(String message) 打印消息到控制台或日志文件中。用于调试和记录信息。

案例代码：数据库的连接（基于MySQL）

数据库的连接与关闭

package com.company;
import java.sql.Connection;
import java.sql.DriverManager;
public class Main {
    public static void main(String[] args){
         final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
         final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
         final String DATABASE_USER ="mysql";
         final String DATABASE_PASSWORD ="xxxxxx";
        Connection conn = null;
         try {
//             通过反射加载mysql驱动
             Class.forName(DATABASE_DRIVER);
//             建立连接
              conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//             输出连接对象信息
             System.out.println(conn);
//             关闭连接
             conn.close();
         }catch (Exception e){
             e.printStackTrace();
         }
    }
}

image.gif

3.Statement接口

该接口是java执行数据库的重要操作，在建立完成数据库连接的基础上，向数据库发送需要执行的SQL的语句

方法 描述
execute(String sql) 执行给定的 SQL 语句，返回一个布尔值表示是否执行成功。
executeQuery(String sql) 执行给定的查询 SQL 语句，返回一个结果集 ResultSet 对象。
clearBatch() 清除该 Statement 对象当前设置的批处理命令。
addBatch(String sql) 将 SQL 语句添加到当前的批处理中。
close() 关闭 Statement 对象。任何打开的结果集也将关闭。

1.在案例操作前先确保建立好一个列表

这里通过Datadrip工具也可以用其他的工具比如DBeaver、Navica可以t快速根据需求自动生成sql脚本，也可以通过sql语句自行创建。

创建一个Person表，定义了姓名，年龄，身份证，名族。并且设置了身份证为唯一的主码并且是唯一的。

具体sql语句如下：

create table Person
(
  name varchar(4) not null comment '姓名',
  age int null comment '年龄',
  ID int null comment '身份证',
  nation varchar(4) null comment '民族'
);
create unique index Person_ID_uindex
  on Person (ID);
alter table Person
  add constraint Person_pk
    primary key (ID);

image.gif

4.实现表的数据更新（增、改、删）

案例实现：实现插入sql信息

插入信息

姓名：王二  年龄：18 身份id：001 民族：汉族

SQL代码案例：

insert into person(name, age, ID, nation) VALUE ('王二',18 ,001 ,'汉族');

image.gif那么搭配JDBC实现数据库中表的插入代码如下:

package JavaWeb02;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class javaDemo {
    public static void main(String[] args)throws Exception {
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxx";
        String sql = "insert into person(name, age, ID, nation) VALUE ('王二',18 ,001 ,'汉族')";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        建立连接
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据库操作对象
        Statement statement = conn.createStatement();
        int count = statement.executeUpdate(sql);
        System.out.println("更新行数"+count);
//      关闭数据库连接
        conn.close();
    }
}

image.gif在数据库中查询可以看到，确实是插入成功了

image.gif 已经会了插入就可以尝试其他操作，比如数据删除，数据修改等等只需要把sql内容改一下就行了

案例：数据修改

package JavaWeb03;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class javaDemo {
    public static void main(String[] args) throws Exception{
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxx";
        String sql = "update person set name='黄小龙',age=99 where name='王二'";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        建立连接
        Connection coon = null;
        coon = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据库操作对象
        Statement statement = coon.createStatement();
        System.out.println("更新的行数"+statement.executeUpdate(sql));
        coon.close();
    }
}

案例：数据删除

image.gif

package JavaWeb04;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class javaDemo {
    public static void main(String[] args) throws Exception{
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxxx";
//        想要执行的sql语句
        String sql ="delete from person where name='王二'";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        连接数据库
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据库操作对象
        Statement statement = conn.createStatement();
        statement.executeUpdate(sql);
//        关闭连接
        conn.close();
    }
}

image.gif

5.实现数据查找（ResultSet接口）

数据查询返回的值需要用ResultSet接口进行封装

image.gif 以下是接口ResultSet接口的常用方法：

方法名 描述
next() 将游标移动到结果集中的下一行，并返回是否还有更多行可用的布尔值。在循环中逐行处理结果集时使用。
getXxx(int columnIndex) 根据列的索引获取当前行指定列的数据。columnIndex是从1开始计数的列索引。getXxx代表具体的数据类型，如getInt、getString等。返回指定列的数据，可以进行类型转换。
getXxx(String columnLabel) 根据列的名称获取当前行指定列的数据。columnLabel是列的字符串形式名称。类似于getXxx(int columnIndex)方法，返回指定列的数据。
close() 关闭结果集，释放与结果集相关的资源。在不再需要访问结果集时，应该调用此方法来关闭结果集，以便及时释放资源。

数据查询案例：

数据库内容：

image.gif 案例代码：

package JavaWeb05;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class javaDemo {
    public static void main(String[] args)throws Exception {
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxxx";
        String sql = "select name, age, ID, nation from person";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        建立连接
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建操作对象,并且对象使用的是执行查找语句的方法
        Statement statement = conn.createStatement();
        ResultSet rs = statement.executeQuery(sql);
//        需要按照定义的类型进行接收
        while (rs.next()){
            String name = rs.getString("name");
            int age = rs.getInt("age");
            int id = rs.getInt("id");
            String nation = rs.getString("nation");
            System.out.println("name="+name+" age="+age+" id="+id+" nation="+nation);
        }
//        退出连接
        conn.close();
        rs.close();
    }
}

image.gif

6.PreparedStatement 数据更新

问题引入：如果要正常插入数据并且使用statement接口则代码会如下：

package JavaWeb06;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.Statement;
public class javaDemo {
    public static void main(String[] args)throws  Exception {
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxx";
        String name ="汪心";
        int id = 100;
        String nation = "汉族";
        int age = 32;
        String sql = "insert into person(name, age, ID, nation)VALUE("+name+","+age+","+id+","+nation+")";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        连接
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据操作对象
        Statement statement = conn.createStatement();
        statement.executeUpdate(sql);
//        关闭对象
        conn.close();
    }
}

image.gif可以看到，如果用statement接口，那么会需要一个完整的sql语句，而sql语句需要通过拼接起来，非常麻烦，所以引入了PreparedStatement

Preparedstatement的常用方法如下：

方法 描述
executeUpdate() 执行 INSERT、UPDATE 和 DELETE 等更新操作，并返回更新的行数。
executeQuery() 执行 SELECT 查询操作，并返回结果集。
setXxx(index, value) 通过索引设置参数值，其中 Xxx 表示数据类型，如 setInt、setString 等。
setXxx(parameterName, value) 通过参数名设置参数值，其中 Xxx 表示数据类型，如 setInt、setString 等。
setNull(index, dataType) 设置参数为空值。
getGeneratedKeys() 获取生成的键。

Preparedstatement与Statement相比在编写sql语句的时候可以用"?"进行占位符的设计，在通过conn.prepareStatement(sql语句)创建对象时候，将sql作为参数传入进去，对于每一位的？占位符都可以通过对象.set类型(第几个占位符,类型值)

以下案例代码实现通过Preparedstatement向数据库插入一条数据

插入案例代码：

package JavaWeb07;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class javaDemo {
    public static void main(String[] args)throws Exception {
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxx";
        String name ="汪心";
        int id = 100;
        String nation = "汉族";
        int age = 32;
        String sql ="insert into person(name, age, ID, nation)VALUES"+"(?,?,?,?)";
//        加载驱动
        Class.forName(DATABASE_DRIVER);
//        建立连接
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据操作对象
        PreparedStatement preparedStatement = conn.prepareStatement(sql);
        preparedStatement.setString(1,name);
        preparedStatement.setInt(2,age);
        preparedStatement.setInt(3,id);
        preparedStatement.setString(4,nation);
        int count = preparedStatement.executeUpdate();
        System.out.println("本次更新的行数"+count);
//        关闭连接
        conn.close();
    }
}

image.gifimage.gif案例 数据查询：

package JavaWeb08;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class javaDemo {
    public static void main(String[] args)throws  Exception {
        final String DATABASE_DRIVER = "com.mysql.cj.jdbc.Driver";
        final String DATABASE_URL="jdbc:mysql://localhost:3306/mysqltest";
        final String DATABASE_USER ="mysql";
        final String DATABASE_PASSWORD ="xxxxxxx";
        String sql ="select name, age, ID, nation from person";
        //        加载驱动
        Class.forName(DATABASE_DRIVER);
//        建立连接
        Connection conn = null;
        conn = DriverManager.getConnection(DATABASE_URL,DATABASE_USER,DATABASE_PASSWORD);
//        创建数据操作对象
        PreparedStatement preparedStatement = conn.prepareStatement(sql);
        ResultSet rs = preparedStatement.executeQuery();
        while (rs.next()){
//            ResultSet通过占位符的位置获取信息
            String name = rs.getString(1);
            int age  = rs.getInt(2);
            int id = rs.getInt(3);
            String nation = rs.getString(4);
            System.out.println("name="+name+" age="+age+" id="+id+" nation="+nation);
        }
//        关闭连接
        conn.close();
        rs.close();
    }
}

image.gif

文章标签：
云数据库 RDS MySQL 版
Java
SQL
关系型数据库
索引
数据安全/隐私保护
MySQL
数据库
数据库连接
关键词：
数据库jdbc
数据库增删查改
数据库接口
类数据库
jdbc类
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。   相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情: https://www.aliyun.com/product/rds/mysql 
Alphamilk
目录
相关文章
34789737
|
5月前
|
SQL Java 数据库连接
除了JDBC，还有哪些常见的数据库访问技术？
除了JDBC，还有哪些常见的数据库访问技术？
34789737
493 2
游客kufrkwrbkmpsa
|
PHP 数据库
【YashanDB知识库】PHP使用OCI接口使用数据库绑定参数功能异常
【YashanDB知识库】PHP使用OCI接口使用数据库绑定参数功能异常
游客kufrkwrbkmpsa
239 6
潜意识Java
|
SQL Java 关系型数据库
使用 JDBC 实现 Java 数据库操作
JDBC（Java Database Connectivity）是 Java 提供的数据库访问技术，允许通过 SQL 语句与数据库交互。本文详细介绍了 JDBC 的使用方法，包括环境准备、编程步骤和完整示例。
潜意识Java
1142 7
游客kufrkwrbkmpsa
|
SQL Java 数据库连接
【YashanDB数据库】由于网络带宽不足导致的jdbc向yashandb插入数据慢
由于网络带宽不足导致的jdbc向yashandb插入数据慢
游客kufrkwrbkmpsa
184 0
三三是该溜子
|
SQL 存储 关系型数据库
数据库的创建和增删查改使用操作（超详细）
本文主要带新手小白理解上手mysql的增删查改等操作
三三是该溜子
618 3
三三是该溜子
|
SQL Java 数据库连接
JDBC编程安装———通过代码操控数据库
本文，教你从0开始学习JBCD，包括驱动包的下载安装调试设置，以及java是如何通过JBDC实现对数据库的操作，以及代码的分析，超级详细
三三是该溜子
229 0
游客54bz4h3flp7ai
|
SQL 存储 BI
gbase 8a 数据库 SQL合并类优化——不同数据统计周期合并为一条SQL语句
gbase 8a 数据库 SQL合并类优化——不同数据统计周期合并为一条SQL语句
游客54bz4h3flp7ai
244 1
顾翔
|
6月前
|
缓存 关系型数据库 BI
使用MYSQL Report分析数据库性能（下）
使用MYSQL Report分析数据库性能
顾翔
470 158
翼龙云TG_yilongcloud
|
6月前
|
关系型数据库 MySQL 数据库
自建数据库如何迁移至RDS MySQL实例
数据库迁移是一项复杂且耗时的工程，需考虑数据安全、完整性及业务中断影响。使用阿里云数据传输服务DTS，可快速、平滑完成迁移任务，将应用停机时间降至分钟级。您还可通过全量备份自建数据库并恢复至RDS MySQL实例，实现间接迁移上云。
翼龙云TG_yilongcloud
210 1
游客vphb4ae2je2zi
|
6月前
|
关系型数据库 MySQL 数据库
阿里云数据库RDS费用价格：MySQL、SQL Server、PostgreSQL和MariaDB引擎收费标准
阿里云RDS数据库支持MySQL、SQL Server、PostgreSQL、MariaDB，多种引擎优惠上线！MySQL倚天版88元/年，SQL Server 2核4G仅299元/年，PostgreSQL 227元/年起。高可用、可弹性伸缩，安全稳定。详情见官网活动页。
游客vphb4ae2je2zi
1118 152

热门文章

最新文章

  • 1
    cloudera-scm-server启动出现Error creating bean with name 'entityManagerFactoryBean'与HHH010003: JDBC Driver class not found: com.mysql.jdbc.Driver错误解决办法（图文
  • 2
    实践真知：解决 Jdbc 连接 Oracle 12c 时快时慢的问题
  • 3
    实时计算 Flink版操作报错之报错：Caused by: oracle.jdbc.OracleDatabaseException: ORA-01291如何解决
  • 4
    报错org.springframework.jdbc.UncategorizedSQLException: Error attempting to get column ‘xxx‘ from resu
  • 5
    SSH代理连接JDBC数据库
  • 6
    spring jdbc JdbcTemplate入门
  • 7
    Java EE WEB工程师培训-JDBC+Servlet+JSP整合开发之13.Form表单处理(1)
  • 8
    实时计算 Flink版操作报错合集之flink jdbc写入数据时，长时间没写入后报错，是什么原因导致的
  • 9
    【图文并茂】源码解析MyBatis Sharding-Jdbc SQL语句执行流程详解
  • 10
    各个版本的sqlite-jdbc jar下载链接
  • 1
    现代化实时数仓 SelectDB 再次登顶 ClickBench 全球数据库分析性能排行榜！
    861
  • 2
    Python 操作 MySQL 数据库
    341
  • 3
    为什么数据库字符编码不一致会导致索引失效
    533
  • 4
    关系型数据库考虑索引的选择性
    376
  • 5
    关系型数据库选择正确的索引类型
    477
  • 6
    关系型数据库识别常查询字段
    400
  • 7
    SQL DB - 关系型数据库是如何工作的
    197
  • 8
    认识常见的一些数据库分类
    1660
  • 9
    关系型数据库中对索引的数目
    370
  • 10
    关系型数据库针对常查询的字段建立索引
    258

    • 相关课程

    更多
  • 数据库的前世今生
  • 数据库核心概念
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • 数据库及SQL/MySQL基础
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • 开源数据库工作室推广计划
  • 国产数据库研制人才培养实践
  • 阿里云&信通院《Serverless数据库技术研究报告》
    • 下一篇
    云安全中心：病毒查杀