本文共 4105 字，大约阅读时间需要 13 分钟。

      在做项目是，数据的导入是经常被客户提出的一个基础需求了，这也导致很多系统都需要使用导入功能。个人整理了做过项目，整理一份导入的代码实现方法（项目中做了封装，此文只介绍实现思路）。

    项目使用的mvc模式，数据库访问使用的EF处理数据增删改查。

• 首先你要有一个最直接的封装有SqlBulkCopy的类，如下：    

        /// 
        /// 大批量数据导入到数据库中        /// 
        /// 数据表        /// 表名称        /// 
   
    成功返回true，否则false
           public static bool BulkCopyTable(DataTable dataTable, string tableName)        {            try            {                using (var sqlBulkCopy = new SqlBulkCopy(connectionString))                {                    sqlBulkCopy.DestinationTableName = tableName;                    if (dataTable != null && dataTable.Rows.Count != 0)                    {                        sqlBulkCopy.WriteToServer(dataTable);                    }                    sqlBulkCopy.Close();                    return true;                }            }            catch (System.Exception ex)            {                Console.WriteLine(ex.Message);                return false;            }        }

• 其次，项目中使用到了一个DataTable的扩展类，具体如下：

/// 
    /// DataTable扩展类    /// 
    public static class DataTableExtensions    {        /// 
        /// Convert a List{T} to a DataTable.        /// 
        public static DataTable ToDataTable
   
    (List
    
      items)        {            var tb = new DataTable(typeof(T).Name);            PropertyInfo[] props = typeof(T).GetProperties(BindingFlags.Public | BindingFlags.Instance);            foreach (PropertyInfo prop in props)            {                Type t = GetCoreType(prop.PropertyType);                tb.Columns.Add(prop.Name, t);            }            foreach (T item in items)            {                var values = new object[props.Length];                for (int i = 0; i < props.Length; i++)                {                    values[i] = props[i].GetValue(item, null);                }                tb.Rows.Add(values);            }            return tb;        }        /// 
     
        /// Return underlying type if type is Nullable otherwise return the type        /// 
        public static Type GetCoreType(Type t)        {            if (t != null && IsNullable(t))            {                if (!t.IsValueType)                {                    return t;                }                return Nullable.GetUnderlyingType(t);            }            return t;        }        /// 
     
        /// Determine of specified type is nullable        /// 
        public static bool IsNullable(Type t)        {            return !t.IsValueType || (t.IsGenericType && t.GetGenericTypeDefinition() == typeof(Nullable<>));        }    }
    
   

注：这个类主要是将导入的数据集合转换为datatable以方便作为批量插入方法的参数。

• 具体的导入代码如下：

var data = ExcelOpr.ImportExcel(path);   var lstA = new List();   for (int rowIndex = 1; rowIndex < data.GetLength(0); rowIndex++)   {        var a = new A();	//处理具体的字段赋值	lstA.Add(a);   }   //导入到数据库中   if (lstA != null && lstA.Count > 0)   {       var dt = DataTableExtensions.ToDataTable(lstA);       tempService.ImportExecel(dt);   }

注：1、此处A为具体需要导入的数据表在EF中对应的c#类名，请一定保证EF中对象字段的顺序和数据库中的列顺序一致，否则无法导入；

    2、第一句代码

ExcelOpr.ImportExcel(path);

    path为导入文件的绝对路径，使用的是封装的导入方法，代码如下：（需要使用Aspose.Cells，在vs中自行下载、添加）

/// 
        /// 导入excel；返回是object的数组类型数据；        /// 其中data.GetLength(0)表示数据的条数，包括标题栏；        /// data.GetLength(1)表示数据的列数；        /// data.GetValue(1, 1)表示拿到对应下表的数据；        /// 使用形如：for (int i = 1; i 小于 data.GetLength(0); i++){}方式生成具体类型即可！        /// 
        /// 文件名（包含路径）        /// 
   
    Object[,]数组类型
           public static Object[,] ImportExcel(String strFileName)        {            Workbook book = new Workbook(strFileName);            //book.Open(strFileName);            Worksheet sheet = book.Worksheets[0];            Cells cells = sheet.Cells;            return cells.ExportArray(0, 0, cells.MaxDataRow + 1, cells.MaxDataColumn + 1);        }

tempService.ImportExecel(dt);

/// 
        /// excel数据导入，批量导入        /// 
        /// datatable        /// 
           public bool ImportExecel(System.Data.DataTable dt)        {            return SqlHelper.BulkCopyTable(dt, "数据库表名");        }

转载地址：http://xrwhj.baihongyu.com/