使用C#和NPGSQL将数据从CSV文件导入到PostgreSQL表中的步骤如下:
using System;
using System.IO;
using Npgsql;
public void ImportDataFromCSV(string csvFilePath, string connectionString, string tableName)
{
using (var connection = new NpgsqlConnection(connectionString))
{
connection.Open();
using (var command = new NpgsqlCommand())
{
command.Connection = connection;
// 创建目标表
command.CommandText = $"CREATE TABLE IF NOT EXISTS {tableName} (column1 datatype1, column2 datatype2, ...)";
command.ExecuteNonQuery();
// 读取CSV文件
using (var reader = new StreamReader(csvFilePath))
{
while (!reader.EndOfStream)
{
var line = reader.ReadLine();
var values = line.Split(',');
// 插入数据到表中
command.CommandText = $"INSERT INTO {tableName} VALUES (@value1, @value2, ...)";
command.Parameters.AddWithValue("@value1", values[0]);
command.Parameters.AddWithValue("@value2", values[1]);
// 添加更多参数以匹配CSV文件中的列数
command.ExecuteNonQuery();
command.Parameters.Clear();
}
}
}
connection.Close();
}
}
string csvFilePath = "path/to/your/csv/file.csv";
string connectionString = "your_connection_string";
string tableName = "your_table_name";
ImportDataFromCSV(csvFilePath, connectionString, tableName);
在上述代码中,需要替换以下参数:
csvFilePath
:CSV文件的路径。connectionString
:PostgreSQL数据库的连接字符串,包括主机、端口、用户名、密码等信息。tableName
:要导入数据的目标表的名称。这样,使用C#和NPGSQL就可以将数据从CSV文件导入到PostgreSQL表中了。
注意:以上代码仅为示例,实际应用中可能需要根据CSV文件的结构和目标表的结构进行适当的修改和调整。
领取专属 10元无门槛券
手把手带您无忧上云