当前位置：首页 > Java

java如何连接mysql

2026-02-04 11:11:16Java

连接MySQL的基本步骤

确保已安装MySQL数据库和Java开发环境（JDK）。需要下载MySQL Connector/J驱动，并将其添加到项目的类路径中。

添加MySQL驱动依赖

在Maven项目中，可以在pom.xml文件中添加以下依赖：

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.28</version>
</dependency>

如果使用Gradle，则在build.gradle中添加：

implementation 'mysql:mysql-connector-java:8.0.28'

编写Java连接代码

使用java.sql包中的类来连接MySQL数据库。以下是一个完整的示例代码：

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

public class MySQLConnection {
    public static void main(String[] args) {
        // 数据库连接信息
        String url = "jdbc:mysql://localhost:3306/数据库名";
        String username = "用户名";
        String password = "密码";

        try {
            // 加载驱动
            Class.forName("com.mysql.cj.jdbc.Driver");

            // 建立连接
            Connection connection = DriverManager.getConnection(url, username, password);
            System.out.println("数据库连接成功");

            // 关闭连接
            connection.close();
        } catch (ClassNotFoundException e) {
            System.out.println("驱动加载失败");
            e.printStackTrace();
        } catch (SQLException e) {
            System.out.println("数据库连接失败");
            e.printStackTrace();
        }
    }
}

处理连接异常

确保捕获并处理ClassNotFoundException和SQLException异常。常见的连接问题包括：

驱动未正确加载
数据库URL、用户名或密码错误
数据库服务未启动

使用连接池优化性能

在高并发场景下，可以使用连接池管理数据库连接，例如HikariCP：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;

public class ConnectionPoolExample {
    public static void main(String[] args) {
        HikariConfig config = new HikariConfig();
        config.setJdbcUrl("jdbc:mysql://localhost:3306/数据库名");
        config.setUsername("用户名");
        config.setPassword("密码");

        try (HikariDataSource dataSource = new HikariDataSource(config)) {
            System.out.println("连接池创建成功");
        }
    }
}

执行SQL查询

成功连接后，可以使用Statement或PreparedStatement执行SQL查询：

java如何连接mysql

Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM 表名");
while (resultSet.next()) {
    System.out.println(resultSet.getString("列名"));
}