使用 DriverManager.getConnection() 方法建立与 MySQL 数据库的连接,需要传入数据库的连接 URL、用户名和密码进行连接。 通过连接对象 driver 创建一个 Statement 对象,用于执行 SQL 语句。 创建一个 StringBuilder 对象 buffer,用于构建 SQL 插入语句。 使用 for 循环遍历 h 集合中的元素,将每个元素的字段值拼接成一个插入语句的值部分。 将拼接好的插入语句值部分加入到 buffer 中。 将 buffer 转换成字符串,并去除最后一个逗号,得到完整的插入语句。 使用 statement.execute(sql) 方法执行插入语句。 关闭 Statement 对象和数据库连接
时间: 2024-04-12 17:32:08 浏览: 27
根据您提供的描述,以下是带有注释的代码示例,展示如何使用 `DriverManager.getConnection()` 方法建立与 MySQL 数据库的连接,并执行插入语句:
```java
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;
public class Main {
public static void main(String[] args) {
// 数据库连接信息
String url = "jdbc:mysql://10.1.1.41:19030/ods_yuqing";
String username = "root";
String password = "root";
// 建立数据库连接
try (Connection connection = DriverManager.getConnection(url, username, password)) {
// 创建 Statement 对象
Statement statement = connection.createStatement();
// 创建 StringBuilder 对象用于构建插入语句
StringBuilder buffer = new StringBuilder();
buffer.append("INSERT INTO ods_quanguo_source_list VALUES ");
// 遍历 h 集合中的元素,构建插入语句的值部分
for (Elem elem : h) {
String id = elem.getId();
String url = elem.getUrl();
String title = elem.getTitle().replaceAll("'", "‘");
String author = elem.getAuthor().replaceAll("'", "‘");
String pub_time = elem.getPubTime();
String source_name = elem.getSourceName();
String create_time = elem.getCreateTime();
String sql = "('" + id + "','" + title + "','" + url + "','" + author + "','" + source_name + "','" + pub_time + "','" + create_time + "'),";
buffer.append(sql);
}
// 获取完整的插入语句字符串,并去除最后一个逗号
String sql = buffer.toString();
sql = sql.substring(0, sql.length() - 1);
// 执行插入语句
statement.execute(sql);
// 关闭 Statement 对象
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
```
请注意,这只是一个示例,您需要根据实际情况进行适当的修改和调整。在代码中,我假设您已经定义了 `Elem` 类来表示 `h` 集合中的元素,并提供了相应的 getter 方法来获取字段值。确保在使用完数据库连接和 Statement 对象后,通过关闭它们来释放资源。