java读取csv文件导入到达梦数据库
时间: 2023-11-20 13:55:12 浏览: 337
以下是Java读取CSV文件并将其导入到达梦数据库的示例代码:
```java
import java.io.BufferedReader;import java.io.FileReader;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
public class CsvToDatabase {
public static void main(String[] args) {
String csvFile = "path/to/csv/file.csv";
String jdbcUrl = "jdbc:dm://localhost:5236";
String username = "username";
String password = "password";
String tableName = "table_name";
try {
// 创建数据库连接
Connection conn = DriverManager.getConnection(jdbcUrl, username, password);
// 准备SQL语句
String sql = "INSERT INTO " + tableName + " VALUES (?, ?, ?)";
PreparedStatement statement = conn.prepareStatement(sql);
// 读取CSV文件
BufferedReader reader = new BufferedReader(new FileReader(csvFile));
String line;
while ((line = reader.readLine()) != null) {
// 解析CSV行
String[] fields = line.split(",");
// 设置SQL参数
statement.setString(1, fields[0]);
statement.setString(2, fields[1]);
statement.setString(3, fields[2]);
// 执行SQL语句
statement.executeUpdate();
}
// 关闭资源
reader.close();
statement.close();
conn.close();
System.out.println("CSV文件已成功导入到数据库中。");
} catch (Exception e) {
e.printStackTrace();
}
}
}
```
请注意,您需要将示例代码中的以下变量替换为您自己的值:
- csvFile:CSV文件的路径。
- jdbcUrl:达梦数据库的JDBC URL。
- username:数据库用户名。
- password:数据库密码。
- tableName:要将数据插入的表的名称。
阅读全文