当前位置：首页 > 后端开发 > 正文

java中怎么连接数据库

admin
后端开发
2025-09-01
10

Java中连接数据库通常使用JDBC（Java Database Connectivity），首先加载数据库驱动，然后通过 DriverManager.getConnection()方法获取数据库连接。

Java中连接数据库是一项常见的任务,通常通过JDBC（Java Database Connectivity）来实现，JDBC是Java提供的一套API，用于执行SQL语句并处理数据库操作，以下是详细的步骤和示例代码，帮助你理解如何在Java中连接数据库。

准备工作

1 安装JDK

确保你的系统已经安装了Java Development Kit (JDK)，你可以在Oracle官网下载最新版本的JDK。

2 安装数据库

你需要一个数据库来连接,常见的数据库包括MySQL、PostgreSQL、Oracle等，本文以MySQL为例。

3 安装数据库驱动

为了在Java中连接数据库,你需要相应的数据库驱动，对于MySQL，你可以从MySQL官网下载MySQL Connector/J。

配置项目

1 创建Java项目

使用你喜欢的IDE（如IntelliJ IDEA、Eclipse等）创建一个新的Java项目。

2 添加数据库驱动到项目

将下载的MySQL Connector/J JAR文件添加到项目的类路径中，在IntelliJ IDEA中，你可以通过以下步骤添加：

右键点击项目 -> Open Module Settings
选择Libraries -> 点击+按钮 -> 选择Java库 -> 选择下载的JAR文件

编写代码连接数据库

1 导入必要的包

在Java代码中,你需要导入java.sql包中的类。

java中怎么连接数据库第1张

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;

2 加载数据库驱动

虽然在JDBC 4.0及更高版本中，驱动会自动加载，但显式加载驱动仍然是一个好习惯。

try {
    Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {
    e.printStackTrace();
}

3 建立连接

使用DriverManager.getConnection()方法建立与数据库的连接。

String url = "jdbc:mysql://localhost:3306/mydatabase";
String user = "root";
String password = "password";
try (Connection connection = DriverManager.getConnection(url, user, password)) {
    System.out.println("Connected to the database!");
} catch (SQLException e) {
    e.printStackTrace();
}

执行SQL查询

1 创建Statement对象

使用Connection.createStatement()方法创建一个Statement对象，用于执行SQL语句。

try (Statement statement = connection.createStatement()) {
    // Execute SQL query
}

2 执行查询

使用Statement.executeQuery()方法执行SQL查询，并返回一个ResultSet对象。

String query = "SELECT  FROM users";
try (ResultSet resultSet = statement.executeQuery(query)) {
    while (resultSet.next()) {
        int id = resultSet.getInt("id");
        String name = resultSet.getString("name");
        System.out.println("ID: " + id + ", Name: " + name);
    }
}

处理异常

在数据库操作中,可能会遇到各种异常，如SQLException，确保在代码中捕获并处理这些异常。

try {
    // Database operations
} catch (SQLException e) {
    e.printStackTrace();
} finally {
    // Close resources
}

关闭资源

在使用完数据库资源后,确保关闭Connection、Statement和ResultSet对象，以释放资源。

try {
    if (resultSet != null) resultSet.close();
    if (statement != null) statement.close();
    if (connection != null) connection.close();
} catch (SQLException e) {
    e.printStackTrace();
}

完整示例代码

以下是一个完整的示例代码,展示了如何在Java中连接MySQL数据库并执行查询。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.SQLException;
public class DatabaseConnectionExample {
    public static void main(String[] args) {
        String url = "jdbc:mysql://localhost:3306/mydatabase";
        String user = "root";
        String password = "password";
        Connection connection = null;
        Statement statement = null;
        ResultSet resultSet = null;
        try {
            // Load the MySQL driver
            Class.forName("com.mysql.cj.jdbc.Driver");
            // Establish the connection
            connection = DriverManager.getConnection(url, user, password);
            System.out.println("Connected to the database!");
            // Create a statement
            statement = connection.createStatement();
            // Execute a query
            String query = "SELECT  FROM users";
            resultSet = statement.executeQuery(query);
            // Process the result set
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("name");
                System.out.println("ID: " + id + ", Name: " + name);
            }
        } catch (ClassNotFoundException e) {
            System.out.println("MySQL Driver not found!");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("Error executing SQL query!");
            e.printStackTrace();
        } finally {
            // Close resources
            try {
                if (resultSet != null) resultSet.close();
                if (statement != null) statement.close();
                if (connection != null) connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}