首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

使用C#将大型CSV文件导入SQL Server

可以通过以下步骤实现:

  1. 读取CSV文件:使用C#的文件操作功能,打开CSV文件并逐行读取数据。可以使用StreamReader类来实现文件读取操作。
  2. 解析CSV数据:将读取到的每一行数据进行解析,可以使用Split方法将每行数据按照逗号分隔成字段数组。
  3. 创建数据库连接:使用C#的SQL Server连接库,如System.Data.SqlClient,创建与SQL Server数据库的连接。可以使用SqlConnection类来实现。
  4. 创建表和插入数据:根据CSV文件的数据结构,在SQL Server中创建对应的表,并使用INSERT语句将解析后的数据逐行插入到表中。可以使用SqlCommand类来执行SQL语句。
  5. 关闭连接:在数据导入完成后,关闭数据库连接,释放资源。

下面是一个示例代码,演示了如何使用C#将大型CSV文件导入SQL Server:

代码语言:txt
复制
using System;
using System.Data.SqlClient;
using System.IO;

namespace CSVtoSQL
{
    class Program
    {
        static void Main(string[] args)
        {
            string csvFilePath = "path/to/csv/file.csv";
            string connectionString = "Data Source=your_server;Initial Catalog=your_database;User ID=your_username;Password=your_password";

            using (StreamReader reader = new StreamReader(csvFilePath))
            {
                using (SqlConnection connection = new SqlConnection(connectionString))
                {
                    connection.Open();

                    string line;
                    while ((line = reader.ReadLine()) != null)
                    {
                        string[] fields = line.Split(',');

                        // Assuming the CSV file has three columns: Column1, Column2, Column3
                        string column1 = fields[0];
                        string column2 = fields[1];
                        string column3 = fields[2];

                        string insertQuery = $"INSERT INTO YourTable (Column1, Column2, Column3) VALUES ('{column1}', '{column2}', '{column3}')";

                        using (SqlCommand command = new SqlCommand(insertQuery, connection))
                        {
                            command.ExecuteNonQuery();
                        }
                    }

                    connection.Close();
                }
            }

            Console.WriteLine("CSV data imported successfully to SQL Server.");
        }
    }
}

在上述示例代码中,需要将csvFilePath替换为实际的CSV文件路径,connectionString替换为实际的SQL Server连接字符串,以及根据CSV文件的数据结构修改插入语句中的表名和列名。

这个示例代码仅供参考,实际使用时需要根据具体需求进行适当的修改和优化。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

领券