用java写一个mysql数据库连接查询
时间: 2024-05-05 22:17:18 浏览: 120
以下是一个Java程序,它连接到MySQL数据库并查询数据:
```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
public class MySQLConnection {
public static void main(String[] args) {
Connection conn = null;
Statement stmt = null;
ResultSet rs = null;
try {
// 加载MySQL驱动
Class.forName("com.mysql.jdbc.Driver");
// 建立数据库连接
conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "password");
// 创建SQL语句
String sql = "SELECT * FROM users";
// 创建执行SQL语句的Statement对象
stmt = conn.createStatement();
// 执行查询并获取结果集
rs = stmt.executeQuery(sql);
// 处理查询结果
while (rs.next()) {
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
System.out.println("ID: " + id + ", Name: " + name + ", Age: " + age);
}
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
} finally {
// 关闭数据库连接
try {
if (rs != null) {
rs.close();
}
if (stmt != null) {
stmt.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
```
说明:
- 首先,我们加载MySQL驱动程序,使用`Class.forName("com.mysql.jdbc.Driver")`方法来加载驱动。
- 然后,我们建立数据库连接,使用`DriverManager.getConnection()`方法来获取连接。在这个例子中,我们连接到本地MySQL数据库,并使用用户名“root”和密码“password”。
- 接下来,我们创建一个SQL语句,`SELECT * FROM users`,它将返回“users”表中的所有记录。
- 然后我们创建Statement对象,使用`conn.createStatement()`方法,用于执行SQL语句。
- 执行查询,使用`stmt.executeQuery()`方法来执行SQL语句并获取结果集。
- 最后,我们处理结果集,使用`rs.next()`方法来遍历结果集中的每一行数据,并使用`rs.getInt()`和`rs.getString()`方法来获取每个字段的值。
- 最后,我们关闭ResultSet、Statement和Connection对象,使用`rs.close()`, `stmt.close()`和`conn.close()`方法。
注意:在实际开发中,我们应该使用连接池来管理数据库连接,以避免频繁地打开和关闭数据库连接。