Java数据库操作：从基础到安全防护

### Java 数据库操作：从基础到安全防护 #### 1. 数据库操作基础 在 Java 应用程序中进行数据库操作时，有一些基本的操作步骤和概念需要了解。首先，几乎每个数据库任务都遵循相同的基本代码格式： 1. **获取数据库连接**：与数据库建立通信通道。 2. **从连接创建语句**：用于执行 SQL 语句。 3. **使用语句执行数据库任务**：如查询、插入、更新或删除操作。 4. **处理数据库任务的结果**：例如显示查询结果。 5. **关闭语句和数据库连接**：释放资源。 使用 JDBC 执行查询和 DML（数据操作语言）操作的主要区别在于，需要根据要执行的操作在 `Statement` 对象上调用不同的方法。执行查询时，调用 `Statement` 的 `executeQuery()` 方法；执行插入、更新和删除等 DML 任务时，调用 `executeUpdate()` 方法。 以下是具体的 CRUD（创建、读取、更新、删除）操作示例： - **插入操作**： ```java // 假设存在 performCreate 方法 private static void performCreate() { String sql = "INSERT INTO TABLE_NAME VALUES (value1, value2, ...)"; try (Statement stmt = conn.createStatement()) { int rowsInserted = stmt.executeUpdate(sql); if (rowsInserted > 0) { System.out.println(rowsInserted + " rows inserted."); } } catch (SQLException e) { e.printStackTrace(); } } ``` - **查询操作**： ```java // 假设存在 performRead 方法 private static void performRead() { String sql = "SELECT * FROM TABLE_NAME"; try (Statement stmt = conn.createStatement(); ResultSet rs = stmt.executeQuery(sql)) { while (rs.next()) { // 处理结果集 System.out.println(rs.getString(1)); } } catch (SQLException e) { e.printStackTrace(); } } ``` - **更新操作**： ```java // 假设存在 performUpdate 方法 private static void performUpdate() { String sql = "UPDATE TABLE_NAME SET column1 = value1 WHERE condition"; try (Statement stmt = conn.createStatement()) { int rowsUpdated = stmt.executeUpdate(sql); if (rowsUpdated > 0) { System.out.println(rowsUpdated + " rows updated."); } } catch (SQLException e) { e.printStackTrace(); } } ``` - **删除操作**： ```java // 假设存在 performDelete 方法 private static void performDelete() { String sql = "DELETE FROM TABLE_NAME WHERE condition"; try (Statement stmt = conn.createStatement()) { int rowsDeleted = stmt.executeUpdate(sql); if (rowsDeleted > 0) { System.out.println(rowsDeleted + " rows deleted."); } } catch (SQLException e) { e.printStackTrace(); } } ``` #### 2. 简化连接管理 在实际应用中，每次访问数据库都手动编写打开连接的逻辑会很繁琐，并且容易出错。可以通过创建一个类来处理所有的连接管理，以下是具体步骤： 1. **创建 `CreateConnection.java` 类**：封装应用程序的连接逻辑。 ```java import java.io.File; import java.io.IOException; import java.io.InputStream; import java.nio.file.FileSystems; import java.nio.file.Files; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Properties; public class CreateConnection { static Properties props = new Properties(); String hostname = null; String port = null; String database = null; String username = null; String password = null; public CreateConnection() { try (InputStream in = Files.newInputStream(FileSystems.getDefault(). getPath(System.getProperty("user.dir") + File.separator + "db_props.properties"))) { props.load(in); in.close(); } catch (IOException ex) { ex.printS ```