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

本文涉及的产品
云数据库 RDS MySQL Serverless,0.5-2RCU 50GB
云数据库 RDS MySQL Serverless,价值2615元额度,1个月
简介: 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 表示数据类型,如 setIntsetString 等。
setXxx(parameterName, value) 通过参数名设置参数值,其中 Xxx 表示数据类型,如 setIntsetString 等。
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

相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
6天前
|
SQL druid Java
JDBC&数据库连接池
JDBC&数据库连接池
|
7天前
|
SQL Java 数据库连接
Java从入门到精通:2.3.1数据库编程——学习JDBC技术,掌握Java与数据库的交互
ava从入门到精通:2.3.1数据库编程——学习JDBC技术,掌握Java与数据库的交互
|
28天前
|
SQL Java 数据库连接
使用JDBC进行数据库操作:Java Web开发的数据库连接
【4月更文挑战第3天】Java Web开发中,JDBC是与数据库交互的关键,提供统一访问关系型数据库的规范。核心组件包括DriverManager、Connection、Statement和ResultSet。使用流程涉及加载驱动、建立连接、创建Statement、执行SQL及处理结果,最后关闭资源。最佳实践包括使用try-with-resources、PreparedStatement、事务管理等。在Web开发中,JDBC用于用户认证、数据持久化、检索和事务管理。虽然有ORM工具,但掌握JDBC基础仍然重要。
|
2月前
|
安全 Java 数据库连接
jdbc实现批量给多个表中更新数据(解析Excel表数据插入到数据库中)
jdbc实现批量给多个表中更新数据(解析Excel表数据插入到数据库中)
155 0
|
2月前
|
JavaScript Java 关系型数据库
基于vue的MOBA类游戏攻略分享平台23(程序+数据库+论文)可帮忙远程调试
基于vue的MOBA类游戏攻略分享平台23(程序+数据库+论文)可帮忙远程调试
|
2月前
|
存储 关系型数据库 MySQL
解释一下如何使用Python的数据库接口库进行数据库操作。
【2月更文挑战第12天】【2月更文挑战第33篇】解释一下如何使用Python的数据库接口库进行数据库操作。
|
3月前
|
SQL druid Java
JDBC技术【分页查询、数据库连接池、应用程序分层、封装通用的BaseDao】(四)-全面详解(学习总结---从入门到深化)
JDBC技术【分页查询、数据库连接池、应用程序分层、封装通用的BaseDao】(四)-全面详解(学习总结---从入门到深化)
30 0
|
4月前
|
SQL Java 关系型数据库
MySQL之JDBC(二)
MySQL之JDBC(二)
34 0
|
4月前
|
关系型数据库 MySQL Java
MySQL之JDBC(一)
MySQL之JDBC
35 0
|
6天前
|
SQL 关系型数据库 MySQL
Spring_jdbc数据连接池(mysql实现增、删、改、查)
Spring_jdbc数据连接池(mysql实现增、删、改、查)
15 0