1. 导入 JDBC 驱动:
首先,确保已经下载了 MySQL Connector/J 驱动,然后将其导入项目中。
<!-- Maven 依赖 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.23</version> <!-- 根据实际版本选择 -->
</dependency>
2. 加载 JDBC 驱动:
在代码中加载 MySQL 的 JDBC 驱动。
try {
Class.forName("com.mysql.cj.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
}
注:在较新的 MySQL Connector/J 版本中,驱动的加载通常是自动的,无需显式调用 Class.forName()。
3. 建立数据库连接:
使用 DriverManager.getConnection() 方法建立与数据库的连接。
String url = "jdbc:mysql://localhost:3306/your_database";
String username = "your_username";
String password = "your_password";
try (Connection connection = DriverManager.getConnection(url, username, password)) {
// 连接已建立,执行数据库操作
} catch (SQLException e) {
e.printStackTrace();
}
在 url 中,jdbc:mysql://localhost:3306/your_database 部分表示连接到本地 MySQL 服务器,端口为 3306,数据库名为 your_database。根据实际情况修改主机名、端口和数据库名。
4. 执行 SQL 查询:
通过 Connection 对象创建 Statement 对象,然后使用 executeQuery() 方法执行 SQL 查询。
try (Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement()) {
String query = "SELECT * FROM your_table";
ResultSet resultSet = statement.executeQuery(query);
while (resultSet.next()) {
// 处理查询结果
String column1 = resultSet.getString("column1");
int column2 = resultSet.getInt("column2");
// ...
}
} catch (SQLException e) {
e.printStackTrace();
}
5. 执行 SQL 更新:
如果要执行更新操作(如插入、更新、删除),可以使用 executeUpdate() 方法。
try (Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement()) {
String updateQuery = "UPDATE your_table SET column1 = 'new_value' WHERE id = 1";
int rowsAffected = statement.executeUpdate(updateQuery);
System.out.println(rowsAffected + " rows updated.");
} catch (SQLException e) {
e.printStackTrace();
}
6. 关闭连接:
在完成数据库操作后,务必关闭数据库连接,以释放资源。
try (Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement()) {
// 执行数据库操作
} catch (SQLException e) {
e.printStackTrace();
}
这是连接 MySQL 数据库的基本步骤。在实际应用中,为了提高安全性和性能,通常会使用连接池技术(例如 HikariCP、Apache DBCP)来管理数据库连接。
转载请注明出处:http://www.zyzy.cn/article/detail/13505/Java