问将csv文件读取到数据表并传递到存储过程

EN

using (StreamReader sr = new StreamReader(filename))
            {
                //this assume the first record is filled with the column names

                    string[] headers = sr.ReadLine().Split(',');
                    foreach (string header in headers)
                    {
                        tvp.Columns.Add(header);
                    }
                    while (!sr.EndOfStream)
                    {
                        string[] rows = sr.ReadLine().Split(',');
                        //Create a new row
                        DataRow dr = tvp.NewRow();
                        for (int i = 0; i < headers.Length; i++)
                        {
                            dr[i] = rows[i];
                        }
                        tvp.Rows.Add(dr);
                       // Console.WriteLine(tvp);
                    }               
            }

            //Passing a Table-Valued Parameter to a Stored Procedure
            using (SqlConnection con = new SqlConnection(Connectionstring))
            {
                con.Open();
                //Execute the cmd
                // Configure the command and sql parameter. 
                SqlCommand cmd = new SqlCommand("dbo.DataTable", con);
                cmd.CommandType = CommandType.StoredProcedure;
                cmd.CommandTimeout = 5000;

                // Create a DataTable with the modified rows.  
                DataTable addedCategories = tvp.GetChanges(DataRowState.Added);
                // these next lines are important to map the C# DataTable object to the correct SQL User Defined Type
                SqlParameter tvparam = cmd.Parameters.AddWithValue("@dt", tvp);
                tvparam.SqlDbType = SqlDbType.Structured;
                tvparam.TypeName = "dbo.DataTableType";
                //SqlParameter parameter = new SqlParameter("@dt", SqlDbType.Structured)
                cmd.Parameters.AddWithValue("@fy", drlFY.SelectedValue);
                cmd.Parameters.AddWithValue("@offid", drlOfficeID.SelectedValue);
                cmd.Parameters.AddWithValue("@updateBy", "9999");
                cmd.Parameters.AddWithValue("@sourcefile", strSrcFile);

                // Execute the command
                cmd.ExecuteNonQuery();
                con.Close();