java连接mysql数据库实现代码,建立demo类
时间: 2024-09-28 07:11:33 浏览: 32
在Java中,我们可以使用JDBC (Java Database Connectivity) 来连接MySQL数据库。下面是一个简单的Demo类示例,展示如何连接、查询数据以及关闭连接:
```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
public class MysqlDemo {
private static final String DB_URL = "jdbc:mysql://localhost:3306/test_db";
private static final String USER = "root";
private static final String PASS = "password";
// 连接数据库的静态方法
public static Connection getConnection() throws SQLException {
return DriverManager.getConnection(DB_URL, USER, PASS);
}
// 查询操作的示例方法
public static void queryData(Connection conn) {
try {
String sql = "SELECT * FROM users WHERE id = ?";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, 1); // 设置SQL占位符的值
ResultSet rs = pstmt.executeQuery();
if (rs.next()) {
System.out.println("Name: " + rs.getString("name"));
System.out.println("Email: " + rs.getString("email"));
} else {
System.out.println("No data found.");
}
} catch (SQLException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
Connection conn = null;
try {
// 获取连接
conn = getConnection();
// 执行查询操作
queryData(conn);
// 关闭连接,释放资源
conn.close();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 确保即使在异常情况下也关闭连接
try {
if (conn != null && !conn.isClosed()) {
conn.close();
}
} catch (SQLException ex) {
ex.printStackTrace();
}
}
}
}
```
在这个例子中,我们首先导入必要的库,然后创建一个`getConnection`方法来获取到数据库连接。`queryData`方法则用于执行一条SQL查询,并打印结果。在`main`函数里,我们尝试连接数据库、执行查询并确保在完成后安全地关闭连接。
阅读全文