java调用数据库的方法

开发百科 2025年11月19日 20:58 241 admin

Java调用数据库的全面指南

在Java开发中,调用数据库是常见的需求，无论是进行数据查询、插入、更新还是删除操作，都需要通过JDBC（Java Database Connectivity）来实现，本文将详细介绍如何在Java中调用数据库，包括连接数据库、执行SQL语句以及处理结果集等步骤。

需要确保项目中已经添加了JDBC驱动的依赖,对于MySQL数据库，可以在Maven项目的pom.xml文件中添加以下依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.26</version>
</dependency>
创建一个数据库连接,可以使用DriverManager类来获取数据库连接对象，以下是一个简单的示例代码：
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
public class DatabaseUtils {
    private static final String URL = "jdbc:mysql://localhost:3306/your_database";
    private static final String USER = "your_username";
    private static final String PASSWORD = "your_password";
    public static Connection getConnection() throws SQLException {
        return DriverManager.getConnection(URL, USER, PASSWORD);
    }
}
使用Statement或PreparedStatement对象来执行SQL语句,以下是使用Statement对象的示例代码：

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class QueryExample {
    public void queryData() {
        String sql = "SELECT * FROM your_table";
        try (Connection connection = DatabaseUtils.getConnection();
             Statement statement = connection.createStatement();
             ResultSet resultSet = statement.executeQuery(sql)) {
            while (resultSet.next()) {
                // 处理结果集中的数据
                System.out.println("Column1: " + resultSet.getString("column1"));
                System.out.println("Column2: " + resultSet.getInt("column2"));
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
如果需要执行参数化查询,可以使用PreparedStatement对象，以下是使用PreparedStatement对象的示例代码：

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class PreparedStatementExample {
    public void executePreparedStatement() {
        String sql = "INSERT INTO your_table (column1, column2) VALUES (?, ?)";
        try (Connection connection = DatabaseUtils.getConnection();
             PreparedStatement preparedStatement = connection.prepareStatement(sql)) {
            preparedStatement.setString(1, "value1");
            preparedStatement.setInt(2, 123);
            int affectedRows = preparedStatement.executeUpdate();
            System.out.println("Affected rows: " + affectedRows);
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
}
不要忘记关闭ResultSet和Statement对象,以避免资源泄漏。