JAVAclass类调用数据库
时间: 2023-09-04 20:06:46 浏览: 83
JAVA调用存储过程
可以通过 JDBC API 来实现。具体来说,需要进行以下步骤:
1. 导入 JDBC 驱动程序。
2. 载入驱动程序并建立数据库连接。
3. 创建用于执行 SQL 语句的 Statement 对象。
4. 执行 SQL 语句并处理结果。
5. 关闭数据库连接。
以下是一个示例代码:
```
import java.sql.*;
public class MyClass {
public static void main(String[] args) {
// JDBC driver name and database URL
String JDBC_DRIVER = "com.mysql.jdbc.Driver";//这里以使用 MySQL 数据库为例
String DB_URL = "jdbc:mysql://localhost/EMP";
// Database credentials
String USER = "username";
String PASS = "password";
Connection conn = null;
Statement stmt = null;
try {
// Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");
// Open a connection
conn = DriverManager.getConnection(DB_URL, USER, PASS);
// Execute a query
stmt = conn.createStatement();
String sql = "SELECT id, name, age FROM Employees";
ResultSet rs = stmt.executeQuery(sql);
// Extract data from result set
while (rs.next()) {
// Retrieve by column name
int id = rs.getInt("id");
String name = rs.getString("name");
int age = rs.getInt("age");
// Display values
System.out.print("ID: " + id);
System.out.print(", Name: " + name);
System.out.println(", Age: " + age);
}
// Clean-up environment
rs.close();
stmt.close();
conn.close();
} catch (SQLException se) {
// Handle errors for JDBC
se.printStackTrace();
} catch (Exception e) {
// Handle errors for 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();
}
}
}
}
```
在这个示例中,首先定义了一个字符串变量 JDBC_DRIVER,它包含了 JDBC 驱动程序的名称;另外一个字符串变量 DB_URL 描述了数据库的 URL 地址。然后定义了用户名和密码,这是为了访问数据库而设置的身份验证信息。
接下来,代码通过 Class.forName() 来加载 JDBC 驱动程序,这样就能够开始使用 JDBC API。然后,代码通过 DriverManager.getConnection() 来获得数据库连接。接着,代码创建了一个 Statement 对象,它用于执行 SQL 语句。使用 stmt.executeQuery() 方法来执行查询操作。在 while 循环中,使用 ResultSet 对象来处理查询结果,并显示到控制台。
最后,代码释放了资源,关闭了数据库连接和 Statement 对象。
阅读全文