如何將csv文件導入到ms sql數據庫中？

Question

我真的不在我的聯盟，但我聽說它可以完成。

我有數以千計的被捕獲每隔一段時間不同的CSV文件的原始電話數據PBX電話服務器中存儲的日期的文件夾（8分鐘和2小時之間）。

我可以連接到服務器的唯一途徑是通過WinSCP賦予，它只是給我的文件結構（看起來像Filezilla的FTP）。

所以兩件事：

1. 怎麼會有人去導入數以千計的文件到一個SQL Server數據庫（2008）？
2. 某人如何設置定時事件以在創建新CSV文件時導入？

我只是需要一些方向。我甚至不知道從哪裏開始。

感謝您的幫助。

Answer 1

如果您有權限，你可以使用sqlcmd一個批處理文件做一個BULK INSERT。另外，您可以創建一個SSIS包。

更多信息here和here。

Answer 2

1 - 有許多方法爲csv文件加載到SQL Server即BCP，批量加載，OPENROWSET（散裝提供商），SSIS，您的自定義.NET應用程序

最流行的是批量插入。看到這個博客的教程

http://blog.sqlauthority.com/2008/02/06/sql-server-import-csv-file-into-sql-server-using-bulk-insert-load-comma-delimited-file-into-sql-server/

2-定時事件？再次很多選項，但最直接 - >安裝Nighly SQL作業

Answer 3

using System; 
using System.Data; 
using Microsoft.VisualBasic.FileIO; 

namespace ReadDataFromCSVFile 
    { 
    static class Program 
     { 
     static void Main() 
     { 
      string csv_file_path=@"C:\Users\Administrator\Desktop\test.csv"; 
      DataTable csvData = GetDataTabletFromCSVFile(csv_file_path); 
      Console.WriteLine("Rows count:" + csvData.Rows.Count);    
      Console.ReadLine(); 
     } 
    private static DataTable GetDataTabletFromCSVFile(string csv_file_path) 
     { 
      DataTable csvData = new DataTable(); 
      try 
      { 
       using(TextFieldParser csvReader = new TextFieldParser(csv_file_path)) 
       { 
        csvReader.SetDelimiters(new string[] { "," }); 
        csvReader.HasFieldsEnclosedInQuotes = true; 
        string[] colFields = csvReader.ReadFields(); 
        foreach (string column in colFields) 
        { 
         DataColumn datecolumn = new DataColumn(column); 
         datecolumn.AllowDBNull = true; 
         csvData.Columns.Add(datecolumn); 
        } 
        while (!csvReader.EndOfData) 
        { 
         string[] fieldData = csvReader.ReadFields(); 
         //Making empty value as null 
         for (int i = 0; i < fieldData.Length; i++) 
         { 
          if (fieldData[i] == "") 
          { 
           fieldData[i] = null; 
          } 
         } 
         csvData.Rows.Add(fieldData); 
        } 
       } 
      } 
      catch (Exception ex) 
      { 
      } 
      return csvData; 
     } 
     } 
    }