环境准备
- 安装Java开发工具包 (JDK) : 确保你的系统已安装JDK,并配置了环境变量,以便能够在命令行中运行
java
和javac
命令。 - 安装MySQL数据库: 在你的系统上安装MySQL服务器,并确保它正在运行。创建一个数据库以及一个拥有访问权限的用户。
- 下载MySQL JDBC驱动: JDBC是Java Database Connectivity的缩写,它是一种用于执行SQL语句的Java API。下载最新版本的MySQL JDBC驱动(通常是一个
.jar
文件),并将其添加到项目类路径中。
数据库连接步骤
-
加载JDBC驱动:
Class.forName("com.mysql.cj.jdbc.Driver");
-
建立连接:
String url = "jdbc:mysql://localhost:3306/yourDatabaseName?useSSL=false"; String user = "yourUsername"; String password = "yourPassword";try (Connection conn = DriverManager.getConnection(url, user, password)) {// 使用conn创建语句和执行查询} catch (SQLException e) {e.printStackTrace();}
-
执行SQL查询:
-
使用Statement或PreparedStatement对象来准备并执行SQL语句。
-
处理ResultSet结果集以获取数据。
6 关闭ResultSet、Statement对象及Connection连接。
示例代码
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;public class MySQLAccess {private Connection connect() throws SQLException {return DriverManager.getConnection("jdbc:mysql://localhost:3306/yourDatabaseName?useSSL=false", "yourUsername", "yourPassword");}public void readDataBase() throws SQLException {try (Connection connection = connect()) {PreparedStatement preparedStatement =connection.prepareStatement("SELECT * FROM yourTableName");ResultSet resultSet = preparedStatement.executeQuery();while(resultSet.next()) {// 处理结果集...int idColumnValue= resultSet.getInt("idColumnName");String stringColumnValue= resultSet.getString("stringColumnName");System.out.println(idColumnValue + ", "+ stringColumnValue);}// 清理环境资源resultSet.close();preparedStatement.close();} catch(SQLException e) { throw new RuntimeException(e);}}public static void main(String[] args) throws Exception{MySQLAccess dao=new MySQLAccess();dao.readDataBase(); }
}
确保替换上述代码中 localhost
, 3306
, youDatabaseName
, youTableName
, idColumnName
,stringColumnName
,youUsername
,youPassword
.