一文搞定Java连接SQL Server，轻轻松松玩转数据

后端

2023-07-15 19:36:39

JDBC技术详解：建立Java与SQL Server之间的连接

摘要：

Java开发人员经常需要操作存储在SQL Server数据库中的数据。本文将全面解析JDBC技术，一步步指导您建立Java与SQL Server之间的连接，涵盖查询、插入、更新和删除操作，以及事务和连接池的使用技巧。

一、构建连接基础：准备工作

1. SQL Server安装与数据库创建

安装SQL Server数据库，为您提供数据存储平台。
通过SQL Server Management Studio创建数据库，用于存储和管理您的数据。

2. JDBC驱动程序下载与安装

从微软官方网站下载JDBC驱动程序，它是Java连接SQL Server的桥梁。
将驱动程序添加到您的Java项目中，使Java具备连接SQL Server的能力。

二、建立Java与SQL Server之间的连接

// 加载JDBC驱动程序
Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");

// 获取连接字符串
String connectionString = "jdbc:sqlserver://localhost:1433;databaseName=test;user=sa;password=password";

// 创建连接
Connection connection = DriverManager.getConnection(connectionString);

代码示例： 本代码通过加载JDBC驱动程序并提供连接字符串来建立Java与SQL Server的连接。

三、操作数据库：执行查询、插入、更新和删除

查询操作：

// 创建Statement对象
Statement statement = connection.createStatement();

// 执行查询
ResultSet resultSet = statement.executeQuery("SELECT * FROM table");

// 遍历结果集
while (resultSet.next()) {
    // 获取数据
    int id = resultSet.getInt("id");
    String name = resultSet.getString("name");
    // ...

    // 使用数据
    // ...
}

// 关闭Statement对象
statement.close();

插入操作：

// 创建PreparedStatement对象
PreparedStatement statement = connection.prepareStatement("INSERT INTO table (name, age) VALUES (?, ?)");

// 设置参数
statement.setString(1, "John Doe");
statement.setInt(2, 20);

// 执行插入操作
int rowCount = statement.executeUpdate();

// 打印受影响的行数
System.out.println("受影响的行数：" + rowCount);

// 关闭PreparedStatement对象
statement.close();

更新操作：

// 创建PreparedStatement对象
PreparedStatement statement = connection.prepareStatement("UPDATE table SET name = ? WHERE id = ?");

// 设置参数
statement.setString(1, "John Smith");
statement.setInt(2, 1);

// 执行更新操作
int rowCount = statement.executeUpdate();

// 打印受影响的行数
System.out.println("受影响的行数：" + rowCount);

// 关闭PreparedStatement对象
statement.close();

删除操作：

// 创建PreparedStatement对象
PreparedStatement statement = connection.prepareStatement("DELETE FROM table WHERE id = ?");

// 设置参数
statement.setInt(1, 1);

// 执行删除操作
int rowCount = statement.executeUpdate();

// 打印受影响的行数
System.out.println("受影响的行数：" + rowCount);

// 关闭PreparedStatement对象
statement.close();

四、保证数据完整性：使用事务

事务是一种确保数据完整性的机制，通过组合多个操作为一个原子性单元，即使一个操作失败，其他操作也会回滚。

使用示例：

try {
    // 开始事务
    connection.setAutoCommit(false);

    // 执行多个操作
    // ...

    // 提交事务
    connection.commit();

    // 关闭连接
    connection.close();
} catch (SQLException e) {
    // 回滚事务
    connection.rollback();

    e.printStackTrace();
}

五、提高性能：使用连接池

连接池管理数据库连接，帮助您提高数据库访问性能，减少建立和断开连接的开销。

使用示例：

// 创建连接池
ConnectionPool connectionPool = new ConnectionPool();

// 从连接池中获取连接
Connection connection = connectionPool.getConnection();

// 使用连接执行查询、插入、更新和删除操作
// ...

// 将连接归还给连接池
connectionPool.releaseConnection(connection);