使用C在MySql中導入csv＃

Question

在Stackoverflow上爲每個人問候！ 我一直在研究這個問題，並沒有運氣。我想將一個csv文件導入到我的mysql數據庫中，但是我一直收到錯誤1：「數據太長，無法在列1上添加列」，錯誤2：「參數'@sku'已被定義」。錯誤1出現一次，錯誤2，我想重複，直到循環結束。我的代碼如下：

using System; 
using System.Collections.Generic; 
using System.ComponentModel; 
using System.Data; 
using System.Drawing; 
using System.Linq; 
using System.Text; 
using System.Threading.Tasks; 
using System.Windows.Forms; 
using System.IO; 
using MySql.Data; 
using MySql.Data.MySqlClient; 
//using Microsoft.VisualBasic.FileIO; 

namespace cvsimporttrial 
{ 
    public partial class Form1 : Form 
    { 
     public Form1() 
     { 
      InitializeComponent(); 
     } 

     private void btnOpenFile_Click(object sender, EventArgs e) 
     { 
      OpenFileDialog fd = new OpenFileDialog(); 

      fd.DefaultExt = "*.csv"; 
      fd.Filter = "CSV files (*.csv)|*.csv"; 
      fd.ShowDialog(); 
      textBox1.Text = fd.FileName; 
     } 

     private void btnSaveToDatabase_Click(object sender, EventArgs e) 
     { 
      string constr = "server=localhost;user id=*****;password=*****;persistsecurityinfo=True;database=*****"; 
      MySqlConnection con = new MySqlConnection(constr); 
      MySqlCommand cmd = new MySqlCommand(); 
      cmd.Connection = con; 
      cmd.CommandText = "insert into testimport values (@sku,@itemname,@itemdescription,@upc)"; 
      DataTable dt = new DataTable(); 

       try 
       { 
        con.Open(); 
        cmd.Prepare(); 
        // Open the text file using a stream reader. 
        using (StreamReader sr = new StreamReader(textBox1.Text)) 
        { 

        dt.Columns.Add("sku"); 
        dt.Columns.Add("ItemName"); 
        dt.Columns.Add("ItemDescription"); 
        dt.Columns.Add("upc"); 


        while (!sr.EndOfStream) 
        {// Read the stream to a string, and write the string to the console. 
         //DataRow dr = dt.NewRow(); 
         String line = sr.ReadLine(); //sr.ReadToEnd(); 
         string[] columns = line.Split(','); 

         foreach (DataColumn cols in dt.Columns) 
         { DataRow dr = dt.NewRow(); 
          dr["sku"]= columns[0]; 
           if (columns[0] == "sku") { continue; }//skip the heading as database already has heading, is there any other way to achieve this. 
          dr["ItemName"]= columns[1]; 
          dr["ItemDescription"] = columns[2]; 
          dr["upc"]= columns[3]; 
          dt.Rows.Add(dr); 
          //Console.WriteLine(columns[3]); 
         }//foreach loop 
         //Console.WriteLine(line); 
         //Console.WriteLine(columns[0]); 
         //Console.WriteLine(columns[1]); 
         //Console.WriteLine(columns[2]); 
         //Console.WriteLine(columns[3]); 
         try 
         { 

          foreach (DataRow r in dt.Rows) 
          { 
           //cmd.Parameters["@sku"].Value = r["sku"]; 
           cmd.Parameters.AddWithValue("@sku", r["sku"]); 
           cmd.Parameters.AddWithValue("@itemname", r["ItemName"]); 
           cmd.Parameters.AddWithValue("@itemdescription", r["ItemDescription"]); 
           cmd.Parameters.AddWithValue("@upc", r["upc"]); 
           cmd.ExecuteNonQuery(); 
          } 
         }//mysql try block 
         catch (MySqlException mse) { MessageBox.Show(mse.Message); }//mysql catch 

        }//while loop 

       } 
      }//try block for file stream 
      catch (Exception ex) { Console.WriteLine(ex.Message); }//catch for file stream 

     }//btnSaveToDatabase_click event 

    } 
} 

我的csv文件樣本： SKU，ITEMNAME，ItemDescription，UPC XY-1-12-ZX，零度可樂易拉罐百毫升 - 12包，「讓口感清爽可樂與零糖「，6111111113

謝謝你的時間。

Answer 1

胡亂猜測這裏......當您創建列

dt.Columns.Add("sku"); 

這將創建一個名爲「SKU」字符串類型的列。如果你的MySQL表不僅存儲字符串，而且還存儲其他類型，我猜你會得到這個或者非常類似的錯誤。

嘗試添加類型到您的dt.column.add。這是指向支持的數據類型的鏈接。 https://msdn.microsoft.com/en-us/library/system.data.datacolumn.datatype(v=vs.110).aspx