Java 连接 SQL Server 数据库：分步指南135

需要将 Java 应用程序连接到 SQL Server 数据库吗？本文将详细介绍连接过程的各个方面，从建立连接到执行查询和管理事务。通过遵循这些步骤，您可以轻松地从 Java 应用程序中访问 SQL Server 数据。

建立连接

首先，您需要建立到 SQL Server 数据库的连接。为此，可以使用 JDBC（Java 数据库连接）API。
import ;
import ;
public class JdbcConnection {
public static void main(String[] args) {
try {
// 设置连接参数
String url = "jdbc:sqlserver://localhost:1433;databaseName=dbName";
String user = "user";
String password = "password";
// 建立连接
Connection connection = (url, user, password);
("连接成功！");
} catch (Exception e) {
("连接失败：" + ());
}
}
}

使用 () 方法可以建立连接。它需要三个参数：连接 URL、用户名和密码。连接 URL 指定了数据库的地址、端口号和数据库名称。

执行查询

连接建立后，您可以执行查询以检索数据库中的数据。
import ;
import ;
public class JdbcQuery {
public static void main(String[] args) {
try {
// 获取连接
Connection connection = ();
// 创建 Statement
Statement statement = ();
// 执行查询
ResultSet resultSet = ("SELECT * FROM table_name");
// 处理结果集
while (()) {
int id = ("id");
String name = ("name");
(id + " " + name);
}
// 关闭 Statement 和连接
();
();
} catch (Exception e) {
("查询失败：" + ());
}
}
}

使用 Statement 接口可以执行查询。首先，创建一个 Statement 对象，然后使用 executeQuery() 方法执行查询。查询结果存储在 ResultSet 对象中，您可以从中检索数据。

更新数据

您还可以使用 JDBC 更新 SQL Server 数据库中的数据。
import ;
public class JdbcUpdate {
public static void main(String[] args) {
try {
// 获取连接
Connection connection = ();
// 创建 PreparedStatement
PreparedStatement preparedStatement = ("UPDATE table_name SET name = ? WHERE id = ?");
// 设置参数
(1, "newName");
(2, 1);
// 执行更新
int affectedRows = ();
("更新成功！受影响行数：" + affectedRows);
// 关闭 PreparedStatement 和连接
();
();
} catch (Exception e) {
("更新失败：" + ());
}
}
}

使用 PreparedStatement 接口可以更新数据。首先，创建一个 PreparedStatement 对象，然后设置 SQL 语句和参数。最后，使用 executeUpdate() 方法执行更新。返回的受影响行数指示更新了多少行。

管理事务

在某些情况下，可能需要将多个操作组合成一个事务。事务确保操作要么同时全部完成，要么全部回滚。
import ;
public class JdbcTransaction {
public static void main(String[] args) {
try {
// 获取连接
Connection connection = ();
// 设置自动提交为 false
(false);
// 创建 Savepoint
Savepoint savepoint = ("mySavepoint");
// 执行更新
PreparedStatement preparedStatement = ("UPDATE table_name SET name = ? WHERE id = ?");
(1, "newName");
(2, 1);
();
// 回滚到 Savepoint
(savepoint);
// 提交事务
();
// 关闭连接
();
} catch (Exception e) {
("事务失败：" + ());
}
}
}