How to use SqlBulkCopy with Entity Framework

Question

User-1664485818 posted

Hi everyone, how do I use  Entity Framework with SqlBulkCopy,

Any help much appreciated, my problem is with the second method, not sure how to use Entity Framework with SqlBulkCopy...

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 null;
            }

            return csvData;
        }

        static void InsertDataIntoSQLServerUsingSQLBulkCopy(DataTable csvFileData)
        {
            using (Entities dbcontext = new Entities())
            {
                SqlConnection sqlCon = (SqlConnection)dbcontext

                using (SqlBulkCopy s = new SqlBulkCopy(dbcontext))
                {
                    s.DestinationTableName = dbcontext.tablename;

                    foreach (var column in csvFileData.Columns)

                        s.ColumnMappings.Add(column.ToString(), column.ToString());

                    s.WriteToServer(csvFileData);
                }
            }

        }