在Java程序中连接MySQL数据库需要使用JDBC API(Java Database Connectivity)。
下面是一个简单的Java程序连接MySQL数据库的示例:
import java.sql.*;
public class MySQLConnectionTest {
static final String DB_URL = "jdbc:mysql://localhost:3306/test";
static final String USER = "root";
static final String PASS = "password";
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
try {
// 注册JDBC驱动
Class.forName("com.mysql.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 user";
ResultSet rs = stmt.executeQuery(sql);
// 处理结果集
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.print("ID: " + id);
System.out.print(", Name: " + name);
System.out.println(", Age: " + age);
}
// 关闭资源
rs.close();
stmt.close();
conn.close();
} catch(SQLException se) {
// 处理JDBC异常
se.printStackTrace();
} catch(Exception e) {
// 处理Class.forName异常
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!");
}
}
该程序会连接到MySQL数据库的test数据库,查询user表中的数据,并打印出来。
需要注意的是,在运行该程序之前,需要先下载并安装MySQL Connector/J驱动,将其添加到classpath中。另外,需要替换DB_URL、USER和PASS为实际的连接信息。
在该程序中,主要使用了以下步骤来连接MySQL数据库:
注册JDBC驱动:
Class.forName("com.mysql.jdbc.Driver");
打开连接:
conn = DriverManager.getConnection(DB_URL,USER,PASS);
执行查询:
stmt = conn.createStatement();
String sql;
sql = "SELECT id, name, age FROM user";
ResultSet rs = stmt.executeQuery(sql);
处理结果集:
while(rs.next()){
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.print("ID: " + id);
System.out.print(", Name: " + name);
System.out.println(", Age: " + age);
}
关闭资源:
rs.close();
stmt.close();
conn.close();
总的来说,连接MySQL数据库的步骤并不复杂,但是需要了解一些基本的JDBC知识和MySQL连接参数的设置。