Java 建立数据库：从头到尾指南119

Java 是一种强大的编程语言，广泛用于开发各种应用程序，包括与数据库交互的应用程序。本文将指导您使用 Java 从头开始建立一个数据库，涵盖从连接到数据库到插入、更新和检索数据的各个步骤。

建立数据库连接

第一步是建立与数据库的连接。这可以通过 Java 的 JDBC (Java Database Connectivity) API 来实现。以下代码示例展示了如何使用 DriverManager 类建立一个到 MySQL 数据库的连接：import ;
import ;
import ;
public class DatabaseConnection {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 检查连接是否成功
if (connection != null) {
("连接数据库成功！");
} else {
("连接数据库失败！");
}
}
}

创建数据库和表

与数据库建立连接后，您可以创建数据库和表来存储数据。以下代码示例展示了如何使用 Statement 对象创建数据库和表：import ;
import ;
import ;
import ;
public class CreateDatabaseAndTable {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 创建 Statement 对象
Statement statement = ();

// 创建数据库
("CREATE DATABASE IF NOT EXISTS my_database");

// 在数据库中创建表
("CREATE TABLE IF NOT EXISTS my_table (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)");

// 关闭 Statement 对象和连接
();
();
}
}

插入数据

创建表后，您可以使用 PreparedStatement 对象向表中插入数据。使用 PreparedStatement 可以防止 SQL 注入攻击，因为它允许您将参数作为占位符传递，而不是立即拼接到 SQL 语句中。import ;
import ;
import ;
import ;
public class InsertData {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 创建 PreparedStatement 对象
String sql = "INSERT INTO my_table (name, age) VALUES (?, ?)";
PreparedStatement statement = (sql);

// 设置占位符值
(1, "John Doe");
(2, 30);

// 执行插入操作
int rowsInserted = ();

// 检查插入是否成功
if (rowsInserted > 0) {
("数据插入成功！");
} else {
("数据插入失败！");
}

// 关闭 PreparedStatement 对象和连接
();
();
}
}

更新数据

可以使用类似于插入数据的过程使用 PreparedStatement 来更新表中的数据。以下代码示例展示了如何使用 PreparedStatement 更新表中的一行数据：import ;
import ;
import ;
import ;
public class UpdateData {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 创建 PreparedStatement 对象
String sql = "UPDATE my_table SET name = ?, age = ? WHERE id = ?";
PreparedStatement statement = (sql);

// 设置占位符值
(1, "Jane Doe");
(2, 35);
(3, 1);

// 执行更新操作
int rowsUpdated = ();

// 检查更新是否成功
if (rowsUpdated > 0) {
("数据更新成功！");
} else {
("数据更新失败！");
}

// 关闭 PreparedStatement 对象和连接
();
();
}
}

检索数据

使用 Statement 或 PreparedStatement 对象可以从表中检索数据。可以使用 ResultSet 对象来迭代检索到的数据行。以下代码示例展示了如何使用 PreparedStatement 从表中检索数据：import ;
import ;
import ;
import ;
import ;
public class RetrieveData {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 创建 PreparedStatement 对象
String sql = "SELECT * FROM my_table WHERE name = ?";
PreparedStatement statement = (sql);

// 设置占位符值
(1, "John Doe");

// 执行查询并获取结果集
ResultSet resultSet = ();

// 迭代结果集并打印数据
while (()) {
("ID: " + ("id"));
("Name: " + ("name"));
("Age: " + ("age"));
}

// 关闭 ResultSet、PreparedStatement 对象和连接
();
();
();
}
}

关闭连接

与数据库交互完毕后，请务必关闭 ResultSet、Statement 和 Connection 对象，以释放系统资源。以下代码示例展示了如何关闭连接：import ;
import ;
import ;
import ;
import ;
public class CloseConnection {
public static void main(String[] args) throws SQLException {
// 数据库连接信息
String url = "jdbc:mysql://localhost:3306/my_database";
String username = "root";
String password = "password";

// 建立连接
Connection connection = (url, username, password);

// 创建 Statement 对象
Statement statement = ();

// 执行查询并获取结果集
ResultSet resultSet = ("SELECT * FROM my_table");

// 关闭 ResultSet 对象
();

// 关闭 Statement 对象
();

// 关闭连接
();
}
}