使用C＃将CSV文件导入SQL

2 回答

• 2

  尝试使用CSV解析器库来读取CSV文件，而不是自己动手 . 有很多库可用：CSV parser/reader for C#?

  读取CSV数据后，可以使用ORM或普通ADO.Net将其写回数据库，如您在示例中所使用的那样 . 如果您自己编写SQL，则应确保在查询中使用SQL参数 . 这不仅可以保证每种数据类型都能正确存储，而且还可以保护您免受任何恶意内容的侵害（不是您的情况下很可能） .

  最简单的解决方案可能是使用基于数据库表的SqlDataAdapter .

  回复于 2024-05-05T00:16:14+08:00
• 0

  • Visual Studio 2017

  • 文件 - >新建 - > Projcet - > Visual C＃ - >控制台应用程序（.NET Framework） - >文件名：-ImportCSVToSQL

  3.打开“Program.cs”编写代码

  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Text;
  using System.Threading.Tasks;
  using System.Data.SqlClient;
  using System.Data;
  using System.IO;
  
  namespace ImportCSVToSQL
  {
      class Program
      {
          static void Main(string[] args)
          {
              try
              {
                  using (SqlConnection conn = new SqlConnection(@"Data Source=**ServerName**; User ID = **; Password = **; Integrated Security=false"))
                  {
                      conn.Open();
  
                      #region create table
  
                      using (SqlCommand createTable = new SqlCommand(@"
            IF EXISTS(SELECT TOP 1 *
            FROM  [DatabaseName].[dbo].[TableName])
            DROP TABLE [DatabaseName].[dbo].[TableName]            
            IF NOT EXISTS
          (
              SELECT *
              FROM
                  sys.schemas s
                      INNER JOIN sys.tables t ON
                          t.[schema_id] = s.[schema_id]
              WHERE
                  s.name = 'dbo' AND
                  t.name = 'TableName'
          )
              CREATE TABLE [DatabaseName].[dbo].[TableName]
              (
                  createddate varchar(500), 
                  fid0 varchar(500),
                  fid1 varchar(500),
                  fid2 varchar(500),
                  fid3 varchar(500),
                  fpip varchar(500),
                  pid varchar(500),
                  isloggedin varchar(500),
                  sessionid varchar(500),
                  source varchar(500),
                  useragent varchar(500),
                  jpnumber varchar(500)
              )
  
              ;
          ", conn))
                      {
                          createTable.ExecuteNonQuery();
                      }
  
                      #endregion
  
                      using (var reader = new StreamReader(@"CSV FILE PATH"))
                      {
                          Console.WriteLine("******* Uploading Data ...... ***********************");
                          while (!reader.EndOfStream)
                          {
                              var line = reader.ReadLine();
                              var data = line.Split(',');
                              // data[0] data[1]
  
                              string query = @"Insert into [DatabaseName].[dbo].[TableName]" + " values ('" + data[0] + "','" + data[1] + "','" + data[2] + "','" + data[3] + "','" + data[4] + "','" + data[5] + "','" + data[6] + "','" + data[7] + "','" + data[8] + "','" + data[9] + "','" + data[10] + "','" + data[11] + "')";
  
  
  
                              SqlCommand cmd = new SqlCommand();
                              cmd.Connection = conn;
                              cmd.CommandText = query;
                              cmd.CommandType = CommandType.Text;
                              cmd.ExecuteNonQuery();
                          }
                          Console.WriteLine("******* Uploading Data Completed ***********************");
                      }
  
                      conn.Close();
                  }
              }
              catch(Exception ex)
              {
                  Console.WriteLine(" \n**************************** Error - " + ex.Message);
              }
  
              Console.ReadLine();
          }
      }
  }
  

  • 构建并执行

  回复于 2024-05-05T00:16:14+08:00