利用 Java 连接和操作数据库26

在现实世界的应用程序中，通常需要与数据库交互以存储、检索和管理数据。Java 作为一种流行的编程语言，提供了丰富的工具和库，使开发者能够轻松连接和操作各种数据库。

连接到数据库

要连接到数据库，可以使用 Java Database Connectivity (JDBC) 框架。JDBC 定义了一组接口和类，允许 Java 程序访问不同的数据库管理系统 (DBMS) 的统一接口。以下代码段展示了如何使用 JDBC 连接到 MySQL 数据库：```java
import .*;
public class DatabaseConnection {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "your_password";
try {
// 建立连接
Connection connection = (url, username, password);
("数据库连接成功！");
// 关闭连接
();
} catch (SQLException e) {
();
}
}
}
```

执行 SQL 查询

连接到数据库后，就可以执行 SQL 查询来检索或修改数据。使用 JDBC 可以创建语句对象，该对象允许您执行 SQL 查询或更新。```java
import .*;
public class DatabaseQuery {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "your_password";
try {
// 建立连接
Connection connection = (url, username, password);
// 创建语句对象
Statement statement = ();
// 执行 SQL 查询
ResultSet resultSet = ("SELECT * FROM users");
// 遍历结果集
while (()) {
(("id") + " " + ("name"));
}
// 关闭资源
();
();
();
} catch (SQLException e) {
();
}
}
}
```

执行 SQL 更新

除了查询数据外，还可以使用 JDBC 执行 SQL 更新，例如插入、更新或删除记录。使用 PreparedStatement 类的优点是可以防止 SQL 注入攻击，并提高性能。```java
import .*;
public class DatabaseUpdate {
public static void main(String[] args) {
// 数据库连接参数
String url = "jdbc:mysql://localhost:3306/database_name";
String username = "root";
String password = "your_password";
try {
// 建立连接
Connection connection = (url, username, password);
// 创建预编译语句
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
PreparedStatement statement = (sql);
// 设置参数
(1, "John Doe");
(2, "@");
// 执行更新
int affectedRows = ();
// 关闭资源
();
();
("已插入 " + affectedRows + " 条记录");
} catch (SQLException e) {
();
}
}
}
```

使用 Java 持久化 API (JPA)

除了 JDBC，Java 还提供了 Java 持久化 API (JPA)，它提供了一种更高层的、面向对象的方式来与数据库交互。JPA 使用实体类来表示数据库表，并使用注解或 XML 配置文件来定义实体与表之间的映射。```java
import .*;
@Entity
@Table(name = "users")
public class User {
@Id
@GeneratedValue
private Long id;
@Column(nullable = false)
private String name;
@Column(nullable = false, unique = true)
private String email;
//省略 getter 和 setter 方法
}
```
```java
import ;
import ;
import ;
public class DatabaseJPA {
public static void main(String[] args) {
// 创建实体管理器工厂
EntityManagerFactory emf = ("persistence-unit-name");
// 创建实体管理器
EntityManager em = ();
// 开始事务
().begin();
// 创建实体对象
User user = new User();
("John Doe");
("@");
// 将实体对象保存到数据库
(user);
// 提交事务
().commit();
// 关闭实体管理器和实体管理器工厂
();
();
}
}
```