/// <summary>    /// 通过文件流的方式来读取CSV文件    /// </summary>    /// <param name="files">文件名称</param>    /// <param name="HeadYes">第一行是否为列标题</param>    /// <param name="span">分隔符</param>    /// <returns></returns>    public DataTable ReadCsvFileToTable(bool HeadYes, char span)    {        //文件路径和文件名        string files = path + fileName;        DataTable dt = new DataTable();        StreamReader fileReader = new StreamReader(files, Encoding.Default);        try        {            //是否为第一行（如果HeadYes为TRUE，则第一行为标题行）            int lsi = 0;            //列之间的分隔符            char cv = span;            while (fileReader.EndOfStream == false)            {                string line = fileReader.ReadLine();                string[] y = line.Split(cv);                //第一行为标题行                if (HeadYes == true)                {                    //第一行                    if (lsi == 0)                    {                        for (int i = 0; i < y.Length; i++)                        {                            dt.Columns.Add(y[i].Trim().ToString());                        }                        lsi++;                    }                    //从第二列开始为数据列                    else                    {                        DataRow dr = dt.NewRow();                        for (int i = 0; i < y.Length; i++)                        {                            dr[i] = y[i].Trim();                        }                        dt.Rows.Add(dr);                    }                }                //第一行不为标题行                else                {                    if (lsi == 0)                    {                        for (int i = 0; i < y.Length; i++)                        {                            dt.Columns.Add("Col" + i.ToString());                        }                        lsi++;                    }                    DataRow dr = dt.NewRow();                    for (int i = 0; i < y.Length; i++)                    {                        dr[i] = y[i].Trim();                    }                    dt.Rows.Add(dr);                }            }        }        catch (Exception ex)        {            throw ex;        }        finally        {            fileReader.Close();            fileReader.Dispose();        }        return dt;    }

    private string conn = ConfigurationManager.ConnectionStrings["ConStr"].ToString();
    /// <summary>
    /// 将指定表的数据Copy至目标数据库    /// </summary>    /// <param name="dt">数据表</param>    /// <param name="outTime">超时时间</param>    /// <returns></returns>    public string CopyTableToSql(DataTable dt, int outTime, string tableName)    {        SqlBulkCopy sbc = new SqlBulkCopy(conn, SqlBulkCopyOptions.UseInternalTransaction);        sbc.BulkCopyTimeout = outTime;        sbc.NotifyAfter = dt.Rows.Count;        try        {            sbc.DestinationTableName = tableName;            sbc.WriteToServer(dt);            return "";        }        catch (Exception ex)        {            return ex.Message;        }        finally        {            sbc.Close();        }    }