在IntelliJ IDEA中使用Java连接MySQL数据库的方法详解

下面我将详细讲解在IntelliJ IDEA中使用Java连接MySQL数据库的方法：

环境搭建

1. 下载MySQL Community Server以及MySQL的JDBC驱动（可以在官网上下载）。

2. 安装MySQL Community Server，并配置好用户名和密码。

3. 将下载好的JDBC驱动放到IntelliJ IDEA的classpath中。具体操作可以在File -> Project Structure -> Modules 中添加jar包，或者将其放到项目的lib目录下。

连接MySQL数据库

在Java中连接MySQL数据库需要使用到JDBC API，我们需要使用Java代码来进行连接。

import java.sql.*;

public class ConnectMySQL {
    public static void main(String[] args) {
        Connection conn = null;
        String url = "jdbc:mysql://localhost:3306/test";
        String user = "root";
        String password = "password";

        try {
            // 加载MySQL JDBC驱动
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 建立MySQL数据库连接
            conn = DriverManager.getConnection(url, user, password);
            // 输出连接成功信息
            System.out.println("MySQL数据库连接已经建立！");
        } catch (ClassNotFoundException ex) {
            // 捕获驱动加载失败异常
            System.out.println("驱动加载失败！");
        } catch (SQLException ex) {
            // 捕获数据库连接失败异常
            System.out.println("连接MySQL数据库失败！");
        } finally {
            if (conn != null) {
                try {
                    // 关闭数据库连接
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

以上代码使用了JDBC API中的一些类和方法，这些类和方法需要进行导入。这部分代码主要实现了JDBC API的核心功能：加载驱动、建立连接、关闭连接等。

示例

除了上述的示例代码，下面给出两个使用Java连接MySQL数据库的示例代码：

示例1

import java.sql.*;

public class JDBCExample {
  static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
  static final String DB_URL = "jdbc:mysql://localhost/EMP";
  static final String USER = "username";
  static final String PASS = "password";

  public static void main(String[] args) {
    Connection conn = null;
    Statement stmt = null;
    try {
      Class.forName(JDBC_DRIVER);

      System.out.println("Connecting to database...");
      conn = DriverManager.getConnection(DB_URL, USER, PASS);

      System.out.println("Creating statement...");
      stmt = conn.createStatement();
      String sql;
      sql = "SELECT id, name, age FROM Employees";
      ResultSet rs = stmt.executeQuery(sql);

      while (rs.next()) {
        int id = rs.getInt("id");
        int age = rs.getInt("age");
        String name = rs.getString("name");

        System.out.print("ID: " + id);
        System.out.print(", Age: " + age);
        System.out.println(", Name: " + name);
      }

      rs.close();
      stmt.close();
      conn.close();
    } catch (SQLException se) {
      se.printStackTrace();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        if (stmt != null) {
          stmt.close();
        }
      } catch (SQLException se2) {
      }

      try {
        if (conn != null) {
          conn.close();
        }
      } catch (SQLException se) {
        se.printStackTrace();
      }
    }
    System.out.println("Goodbye!");
  }
}

通过上述Java代码实现了连接MySQL数据库、查询数据等基础操作，可供参考。

示例2

import java.sql.*;

public class Example {
  public static void main(String[] args) {
    Connection conn = null;
    try {
      String dbName = "mydb";
      String userName = "myuser";
      String password = "mypassword";

      Class.forName("com.mysql.cj.jdbc.Driver");
      conn = DriverManager.getConnection(
          "jdbc:mysql://localhost/" + dbName + "?user=" + userName + "&password=" + password);

      Statement stmt = conn.createStatement();
      String sql = "CREATE TABLE REGISTRATION " + "(id INTEGER not NULL, " + " username VARCHAR(255), "
          + " email VARCHAR(255), " + " PRIMARY KEY ( id ))";
      stmt.executeUpdate(sql);
      System.out.println("Created table in given database...");

      sql = "INSERT INTO REGISTRATION " + "VALUES (100, 'Zara', '[e-mail]')";
      stmt.executeUpdate(sql);
      sql = "INSERT INTO REGISTRATION " + "VALUES (101, 'Mahnaz', '[e-mail]')";
      stmt.executeUpdate(sql);
      System.out.println("Inserted records into the table...");

      stmt.close();
      conn.close();
    } catch (SQLException se) {
      se.printStackTrace();
    } catch (Exception e) {
      e.printStackTrace();
    } finally {
      try {
        if (conn != null)
          conn.close();
      } catch (SQLException se) {
        se.printStackTrace();
      }
    }
    System.out.println("Goodbye!");
  }
}

以上的两个示例分别实现了数据库的建表和数据的插入操作。

希望以上内容能够帮助你在IntelliJ IDEA中使用Java连接MySQL数据库，如有任何问题请留言或者私信我，我会尽快回复。