JDBC之连接数据库
发布人:shili8
发布时间:2025-01-14 11:43
阅读次数:0
** JDBC 之连接数据库**
Java Database Connectivity(JDBC)是一种用于访问和操作关系型数据库的 Java API。它允许 Java 程序通过 JDBC 驱动程序与各种数据库管理系统进行交互,包括 MySQL、Oracle、SQL Server 等。
在本文中,我们将重点介绍如何使用 JDBC 连接到一个数据库,并执行一些基本的 CRUD(Create、Read、Update、Delete)操作。
### **1. 导入 JDBC 包**
首先,我们需要导入 JDBC 的包。JDBC 包分为两个部分:`java.sql` 和 `javax.sql`。我们需要导入这两个包中的相关类。
javaimport java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import javax.sql.DataSource;
### **2. 加载 JDBC 驱动程序**
下一步是加载 JDBC 驱动程序。不同的数据库管理系统有不同的驱动程序,我们需要根据实际情况选择合适的驱动程序。
java// MySQL 驱动程序Class.forName("com.mysql.cj.jdbc.Driver"); // Oracle 驱动程序// Class.forName("oracle.jdbc.driver.OracleDriver"); // SQL Server 驱动程序// Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");
### **3. 获取数据库连接**
接下来,我们需要获取一个数据库连接。我们可以使用 `DriverManager` 类来获取一个连接。
javaString url = "jdbc:mysql://localhost:3306/mydb"; String username = "root"; String password = "password"; Connection conn = DriverManager.getConnection(url, username, password);
### **4. 执行 CRUD 操作**
现在,我们可以使用 JDBC API 来执行一些基本的 CRUD 操作。
#### **4.1 Create**
要创建一个新记录,我们需要准备一个 `PreparedStatement` 对象,然后使用 `executeUpdate()` 方法来执行 SQL语句。
javaString sql = "INSERT INTO users (name, email) VALUES (?, ?)"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, "John Doe"); pstmt.setString(2, "john@example.com"); int rowsAffected = pstmt.executeUpdate(); System.out.println("Rows affected: " + rowsAffected);
#### **4.2 Read**
要读取一个记录,我们需要准备一个 `PreparedStatement` 对象,然后使用 `executeQuery()` 方法来执行 SQL语句。
javaString sql = "SELECT * FROM users WHERE id = ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1,1); ResultSet rs = pstmt.executeQuery(); while (rs.next()) { System.out.println("Name: " + rs.getString("name")); System.out.println("Email: " + rs.getString("email")); }
#### **4.3 Update**
要更新一个记录,我们需要准备一个 `PreparedStatement` 对象,然后使用 `executeUpdate()` 方法来执行 SQL语句。
javaString sql = "UPDATE users SET name = ? WHERE id = ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setString(1, "Jane Doe"); pstmt.setInt(2,1); int rowsAffected = pstmt.executeUpdate(); System.out.println("Rows affected: " + rowsAffected);
#### **4.4 Delete**
要删除一个记录,我们需要准备一个 `PreparedStatement` 对象,然后使用 `executeUpdate()` 方法来执行 SQL语句。
javaString sql = "DELETE FROM users WHERE id = ?"; PreparedStatement pstmt = conn.prepareStatement(sql); pstmt.setInt(1,1); int rowsAffected = pstmt.executeUpdate(); System.out.println("Rows affected: " + rowsAffected);
### **5. 关闭数据库连接**
最后,我们需要关闭数据库连接。
javaconn.close();
以上就是使用 JDBC 连接到一个数据库并执行一些基本的 CRUD 操作的步骤。