首页 开发百科文章正文

java连接数据库实现增删改查功能

开发百科 2025年11月17日 06:25 538 admin

Java连接数据库实现增删改查功能的详细指南

在Java开发中,与数据库的交互是常见的需求,无论是进行数据存储、查询还是修改,掌握如何在Java中连接数据库并执行增删改查操作是非常重要的,本文将详细介绍如何使用Java连接数据库,并实现基本的增删改查功能。

java连接数据库实现增删改查功能

准备工作

  1. 安装和配置JDBC驱动:需要确保你的项目中已经包含了相应的JDBC驱动,对于MySQL数据库,可以在Maven项目的pom.xml文件中添加以下依赖:
    <dependency>
     <groupId>mysql</groupId>
     <artifactId>mysql-connector-java</artifactId>
     <version>8.0.26</version>
    </dependency>

  2. 创建数据库和表:为了测试,可以创建一个名为testdb的数据库,并在其中创建一个名为user的表,包含字段id(主键)、nameage
    CREATE DATABASE testdb;
    USE testdb;
    CREATE TABLE user (
     id INT PRIMARY KEY AUTO_INCREMENT,
     name VARCHAR(50),
     age INT
    );

连接数据库

java连接数据库实现增删改查功能

  1. 加载JDBC驱动:在Java代码中,首先需要加载并注册JDBC驱动。
    Class.forName("com.mysql.cj.jdbc.Driver");

  2. 建立连接:使用DriverManager获取数据库连接。
    Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/testdb", "root", "password");

执行增删改查操作

  1. 插入数据:使用PreparedStatement执行SQL插入语句。
    String sql = "INSERT INTO user (name, age) VALUES (?, ?)";
    try (PreparedStatement pstmt = connection.prepareStatement(sql)) {
     pstmt.setString(1, "John Doe");
     pstmt.setInt(2, 25);
     pstmt.executeUpdate();
    } catch (SQLException e) {
     e.printStackTrace();
    }

  2. 查询数据:使用PreparedStatement执行SQL查询语句,并处理结果集。
    String sql = "SELECT * FROM user";
    try (PreparedStatement pstmt = connection.prepareStatement(sql);
      ResultSet rs = pstmt.executeQuery()) {
     while (rs.next()) {
         System.out.println("ID: " + rs.getInt("id") + ", Name: " + rs.getString("name") + ", Age: " + rs.getInt("age"));
     }
    } catch (SQLException e) {
     e.printStackTrace();
    }

  3. 更新数据:使用PreparedStatement执行SQL更新语句。
    String sql = "UPDATE user SET age = ? WHERE id = ?";
    try (PreparedStatement pstmt = connection.prepareStatement(sql)) {
     pstmt.setInt(1, 26);
     pstmt.setInt(2, 1);
     pstmt.executeUpdate();
    } catch (SQLException e) {
     e.printStackTrace();
    }

  4. 删除数据:使用PreparedStatement执行SQL删除语句。
    String sql = "DELETE FROM user WHERE id = ?";
    try (PreparedStatement pstmt = connection.prepareStatement(sql)) {
     pstmt.setInt(1, 1);
     pstmt.executeUpdate();
    } catch (SQLException e) {
     e.printStackTrace();
    }

关闭连接 在完成所有数据库操作后,不要忘记关闭ResultSet、PreparedStatement和Connection对象,以释放资源。

if (rs != null) try { rs.close(); } catch (SQLException se) { /* can't do anything */ }
if (pstmt != null) try { pstmt.close(); } catch (SQLException se) { /* can't do anything */ }
if (connection != null) try { connection.close(); } catch (SQLException se) { /* can't do anything */ }

通过以上步骤,你可以在Java中成功连接数据库,并执行基本的增删改查操作,希望这篇文章对你有所帮助!

标签: 数据库连接

丫丫技术百科 备案号:新ICP备2024010732号-62 网站地图