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

JDBC中数据库的增删改查操作

2022-05-10 120
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 笔记

一、数据库编程一般过程

3.png

图为数据库编程的一般过程，其中查询（Read）过程最多需要7个步骤，修改（C插入、U 更新、D删除）过程最多需要5个步骤。这个过程采用了预编译语句对象进行数据操作，所以有可能进 行绑定参数。


在编程之前先交代一下config.properties文件：

driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/JAVA
user=root
password=199911
useSSL=false
verifyServerCertificate=false

准备好的数据库

image.png


二、数据查询操作

（1）有条件查询

代码如下：

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
/**
 * @author : 蔡政洁
 * @email :caizhengjie888@icloud.com
 * @date : 2020/3/2
 * @time : 3:48 下午
 */
//不使用自动资源管理
public class CRUDSample1 {
//    连接数据库
    static String url;
//    创建properties对象
    static Properties info = new Properties();
//    1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
    static {
//            获得属性文件输入流
        InputStream inputStream = CRUDSample1.class.getClassLoader().getResourceAsStream("config.properties");
        try {
//            加载属性文件内容到Properties对象
            info.load(inputStream);
//            从属性文件中读取URL
            url = info.getProperty("url");
//            从属性文件中读取driver
            String driverClassname = info.getProperty("driver");
//            驱动程序加载
            Class.forName(driverClassname);
            System.out.println("驱动程序加载成功");
        } catch (IOException e) {
            System.out.println("加载属性文件失败");
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序加载失败");
            e.printStackTrace();
        }
    }
//主函数
    public static void main(String[] args) {
//        查询数据
        read();
    }
//    数据查询操作
    public static void read(){
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
//            2.创建数据库连接
            conn = DriverManager.getConnection(url,info);
            System.out.println("数据库连接成功");
//            3.创建语句对象,返回PreparedStatement对象
//            这里查询的是数据库中id大于2的人的姓名和年龄
            pstmt = conn.prepareStatement("select name,age from xinxi_tb where id > ? order by id");
//            4.绑定参数
            /**
             * 绑定参数时需要注意两个问题：绑定参数顺序 和 绑定参数的类型
             * 绑定参数索引是 从1开始的，而不是从0开始的。
             * 根据绑定参数的类型不同选择对应的set方法。
             */
            pstmt.setInt(1,3);
//            5.执行查询
            rs =  pstmt.executeQuery();
//            6.遍历结果集
            while (rs.next()){
                /**注意点：列名对应的数据类型，rs.getX就对应什么，例如（name: %s，rs.getString("name"或者为 1 )）
                 *rs.getX(可以设置为columnindex = （查找的列的索引，从1开始索引），或columnLabel = "列名")
                 */
                System.out.printf("name: %s,age: %d\n",rs.getString(1),rs.getInt("age"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
//            7.释放资源，这里也可以选择自动资源管理
        }finally {
            if (rs != null){
                try {
                    rs.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (pstmt != null){
                try {
                    pstmt.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null){
                try {
                    conn.close();
                }catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

运行结果：

驱动程序加载成功
数据库连接成功
name: 雷军,age: 43
name: 马云,age: 56
name: 马化腾,age: 49


（2）无条件查询

代码如下：

import java.io.IOException;
import java.io.InputStream;
import java.sql.*;
import java.util.Properties;
/**
 * @author : 蔡政洁
 * @email :caizhengjie888@icloud.com
 * @date : 2020/3/2
 * @time : 6:01 下午
 */
//使用自动资源管理系统
public class CRUDSample2 {
    //    连接数据库
    static String url;
    //    创建properties对象
    static Properties info = new Properties();
    //    1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
    static {
//            获得属性文件输入流
        InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
        try {
//            加载属性文件内容到Properties对象
            info.load(inputStream);
//            从属性文件中读取URL
            url = info.getProperty("url");
//            从属性文件中读取driver
            String driverClassname = info.getProperty("driver");
//            驱动程序加载
            Class.forName(driverClassname);
            System.out.println("驱动程序加载成功");
        } catch (IOException e) {
            System.out.println("加载属性文件失败");
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序加载失败");
            e.printStackTrace();
        }
    }
    //主函数
    public static void main(String[] args) {
//        查询最大的用户id
        System.out.println(readMaxUserID());
    }
//    查询最大的用户id
    public  static int readMaxUserID(){
        int maxid = 0;
        try (
//            2.创建数据库连接
            Connection conn = DriverManager.getConnection(url,info);
//            3.创建语句对象
            PreparedStatement pstmt = conn.prepareStatement("select max(id) from xinxi_tb");
//             4。执行查询
            ResultSet rs = pstmt.executeQuery()
            ){
//            打印数据库连接信息
            System.out.println("数据库连接成功");
//            5.遍历结果集
            if (rs.next()){
                maxid = rs.getInt(1);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return maxid;
    }
}

运行结果：

驱动程序加载成功
数据库连接成功
6


三、数据插入

代码如下：

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Properties;
/**
 * @author : 蔡政洁
 * @email :caizhengjie888@icloud.com
 * @date : 2020/3/2
 * @time : 6:15 下午
 */
//使用自动资源管理系统
        public class CRUDSample3 {
            //    连接数据库
            static String url;
            //    创建properties对象
            static Properties info = new Properties();
            //    1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
            static {
//            获得属性文件输入流
                InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
                try {
//            加载属性文件内容到Properties对象
            info.load(inputStream);
//            从属性文件中读取URL
            url = info.getProperty("url");
//            从属性文件中读取driver
            String driverClassname = info.getProperty("driver");
//            驱动程序加载
            Class.forName(driverClassname);
            System.out.println("驱动程序加载成功");
        } catch (IOException e) {
            System.out.println("加载属性文件失败");
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序加载失败");
            e.printStackTrace();
        }
    }
    //主函数
    public static void main(String[] args) {
//        数据插入操作
        create();
    }
    public static void create(){
        try (
//            2.创建数据库连接
                Connection conn = DriverManager.getConnection(url,info);
//            3.创建语句对象
                PreparedStatement pstmt = conn.prepareStatement("insert into xinxi_tb (id, name, age) values (?,?,?)");
                ){
//            打印数据库连接信息
            System.out.println("数据库连接成功");
//            4.绑定参数
            pstmt.setInt(1,6);
            pstmt.setString(2,"马化腾");
            pstmt.setInt(3,49);
//            5.执行修改
//            行executeUpdate()方法执行SQL语句，该 方法与查询方法executeQuery()不同。executeUpdate()方法返回的是整数，成功影响的记录数， 即成功插入记录数。
            int affectedRows = pstmt.executeUpdate();
            System.out.printf("成功插入%d条数据\n",affectedRows);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

这里要根据自己数据库的实际情况来修改代码，才能运行


四、数据更新

代码如下：

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Properties;
/**
 * @author : 蔡政洁
 * @email :caizhengjie888@icloud.com
 * @date : 2020/3/2
 * @time : 6:40 下午
 */
//使用自动资源管理系统
public class CRUDSample4 {
    //    连接数据库
    static String url;
    //    创建properties对象
    static Properties info = new Properties();
    //    1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
    static {
//            获得属性文件输入流
        InputStream inputStream = CRUDSample4.class.getClassLoader().getResourceAsStream("config.properties");
        try {
//            加载属性文件内容到Properties对象
            info.load(inputStream);
//            从属性文件中读取URL
            url = info.getProperty("url");
//            从属性文件中读取driver
            String driverClassname = info.getProperty("driver");
//            驱动程序加载
            Class.forName(driverClassname);
            System.out.println("驱动程序加载成功");
        } catch (IOException e) {
            System.out.println("加载属性文件失败");
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序加载失败");
            e.printStackTrace();
        }
    }
    //主函数
    public static void main(String[] args) {
//        数据更新操作
        update();
    }
    public static void update(){
        try (
//            2.创建数据库连接
                Connection conn = DriverManager.getConnection(url,info);
//            3.创建语句对象
                PreparedStatement pstmt = conn.prepareStatement("update xinxi_tb set name = ? where id = ?");
                ){
//            打印数据库连接信息
            System.out.println("数据库连接成功");
//            4.绑定参数
            pstmt.setString(1,"雷军");
            pstmt.setInt(2,4);
//            5.执行修改
            int affectedRows = pstmt.executeUpdate();
            System.out.printf("成功更新%d条数据\n",affectedRows);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

这里要根据自己数据库的实际情况来修改代码，才能运行


五、数据删除

代码如下：

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Properties;
/**
 * @author : 蔡政洁
 * @email :caizhengjie888@icloud.com
 * @date : 2020/3/2
 * @time : 6:49 下午
 */
//使用自动资源管理系统
public class CRUDSample5 {
    //    连接数据库
    static String url;
    //    创建properties对象
    static Properties info = new Properties();
    //    1.驱动程序加载，放在静态代码块中，在静态代码块中读取属性文件内容到Properties对象和加载驱动程序，这两个操作只需执行一次
    static {
//            获得属性文件输入流
        InputStream inputStream = CRUDSample2.class.getClassLoader().getResourceAsStream("config.properties");
        try {
//            加载属性文件内容到Properties对象
            info.load(inputStream);
//            从属性文件中读取URL
            url = info.getProperty("url");
//            从属性文件中读取driver
            String driverClassname = info.getProperty("driver");
//            驱动程序加载
            Class.forName(driverClassname);
            System.out.println("驱动程序加载成功");
        } catch (IOException e) {
            System.out.println("加载属性文件失败");
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动程序加载失败");
            e.printStackTrace();
        }
    }
    //主函数
    public static void main(String[] args) {
//        数据删除操作
        delete();
    }
    public static void delete(){
        try (
//            2.创建数据库连接
                Connection conn = DriverManager.getConnection(url,info);
//            3.创建语句对象
                PreparedStatement pstmt = conn.prepareStatement("delete from xinxi_tb where id = ?");
                ){
//            打印数据库连接信息
            System.out.println("数据库连接成功");
//            4.绑定参数
            pstmt.setInt(1, 3);
//            5.执行修改
            int affectedRows = pstmt.executeUpdate();
            System.out.printf("成功删除%d条数据\n",affectedRows);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}

这里要根据自己数据库的实际情况来修改代码，才能运行


文章标签：
资源管理
Java
数据库
数据库连接
关键词：
数据库增删改查
数据库jdbc
数据库操作
jdbc操作
jdbc增删改查
游客wkxim4agoo6le
目录
相关文章
东方睿赢
|
3月前
|
Java 关系型数据库 数据库连接
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
JDBC：Java与数据库的“黄金搭档”，为何它如此重要？
东方睿赢
48 8
iamzfh
|
1月前
|
前端开发 Java 数据库连接
javamvc配置，增删改查，文件上传下载。
【10月更文挑战第4天】javamvc配置，增删改查，文件上传下载。
iamzfh
38 1
qa浪涛
|
1月前
|
存储 NoSQL API
使用Py2neo进行Neo4j图数据库的增删改查操作
使用Py2neo进行Neo4j图数据库的增删改查操作
qa浪涛
66 5
diygwcom
|
1月前
|
数据可视化 API PHP
低代码开发工具-学生管理系统-老师管理增删改查实现
低代码开发工具-学生管理系统-老师管理增删改查实现
diygwcom
33 5
nanshaws
|
1月前
|
SQL Java 数据库
Springboot+spring-boot-starter-data-jdbc实现数据库的操作
本文介绍了如何使用Spring Boot的spring-boot-starter-data-jdbc依赖来操作数据库，包括添加依赖、配置数据库信息和编写基于JdbcTemplate的数据访问代码。
nanshaws
62 2
程序员小海绵
|
2月前
|
SQL 关系型数据库 MySQL
学成在线笔记+踩坑（3）——【内容模块】课程分类查询、课程增改删、课程计划增删改查，统一异常处理+JSR303校验
课程分类查询、课程新增、统一异常处理、统一封装结果类、JSR303校验、修改课程、查询课程计划、新增/修改课程计划
程序员小海绵
94 1
学成在线笔记+踩坑（3）——【内容模块】课程分类查询、课程增改删、课程计划增删改查，统一异常处理+JSR303校验
快乐就是哈哈哈
|
29天前
|
JavaScript 前端开发 测试技术
[新手入门]todolist增删改查：vue3+ts版本！
【10月更文挑战第15天】[新手入门]todolist增删改查：vue3+ts版本！
快乐就是哈哈哈
23 0
杀死一只知更鸟debug
|
2月前
|
SQL 关系型数据库 MySQL
ThinkPHP6 连接使用数据库，增删改查，find，select，save，insert，insertAll，insertGetId，delete，update方法的用法
本文介绍了在ThinkPHP6框架中如何连接和使用数据库进行增删改查操作。内容包括配置数据库连接信息、使用Db类进行原生MySQL查询、find方法查询单个数据、select方法查询数据集、save方法添加数据、insertAll方法批量添加数据、insertGetId方法添加数据并返回自增主键、delete方法删除数据和update方法更新数据。此外，还说明了如何通过数据库配置文件进行数据库连接信息的配置，并强调了在使用Db类时需要先将其引入。
杀死一只知更鸟debug
95 0
ThinkPHP6 连接使用数据库，增删改查，find，select，save，insert，insertAll，insertGetId，delete，update方法的用法
派大鑫的工作室
|
1月前
|
Java API 数据库
Data jpa 增删改查的方法分别有哪些
Data jpa 增删改查的方法分别有哪些
派大鑫的工作室
108 0
Codelinghu
|
1月前
|
SQL druid Java
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
JDBC和数据库连接池-两个工具类-JDBCUtilsByDruid和BasicDAO
Codelinghu
32 0

热门文章

最新文章

  • 1
    RDS入门——Excel文件转存到RDS数据库实践
  • 2
    SQLServer数据库日志清理 清除sqlserver2005日志 - sk
  • 3
    MySQL数据库管理深度解析：创建新数据库的完全指南
  • 4
    C语言连接MySQL数据库
  • 5
    数据库被注入daxia123原因及解决办法
  • 6
    ChatGPT 引爆向量数据库赛道
  • 7
    创建逻辑stand by数据库
  • 8
    Mysql数据库主从不同步解决案例
  • 9
    Android 数据库ORM框架GreenDao学习心得及使用总结<二>
  • 10
    SQLite数据库版本升级的管理实现
  • 1
    Java面试题：什么是JDBC以及如何在Java中使用它进行数据库操作？
    53
  • 2
    Java面试题：描述JDBC的工作原理，包括连接数据库、执行SQL语句等步骤。
    66
  • 3
    【Java】已解决com.mysql.cj.jdbc.exceptions.CommunicationsException异常
    1155
  • 4
    【Java】已解决Java中的com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException异常
    246
  • 5
    【Java】已解决com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException异常
    392
  • 6
    [已解决]com.mysql.cj.jdbc.exceptions. PacketTooBigException: Packet for query is too large (3,456,888
    61
  • 7
    Java中的JDBC编程详解
    51
  • 8
    使用MySQL JDBC连接数据库
    440
  • 9
    JDBC的路径讲解？
    99
  • 10
    使用MySQL JDBC连接数据库
    82

    • 相关课程

    更多
  • 从传统数据库到云数据库演进
  • 数据库常见问题排查
  • JDBC数据库开发入门
  • 数据库及SQL/MySQL基础
  • JDBC数据库开发进阶
  • 高校精品课-西安交通大学 -数据库理论与技术

    • 相关电子书

    更多
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》
  • 阿里云瑶池数据库精要2022版
  • 2022 DTCC-阿里云一站式数据库上云最佳实践

    • 相关实验场景

    更多
  • 使用DAS实现数据库SQL优化
  • 自建数据库迁移到云数据库
  • PolarDB for AI：在数据库中通过SQL实现AI能力
  • 云原生HTAP数据库，让你的交易和分析一库搞定
  • 快速体验PolarDB开源数据库
  • SQLServer数据库的创建
    • 下一篇
    无影云桌面