使用 C# 在 MySql 中导入 csv

Question

向 Stackoverflow 上的每个人问好！ 我一直在解决这个问题，但没有运气。我想将一个 csv 文件导入到我的 mysql 数据库中，但我不断收到错误 1：“第 1 行的列 'upc' 的数据太长”和错误 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，项目名称，项目描述，upc XY-1-12-ZX，可乐零罐 100 毫升 - 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