excel数据导入到数据库的方法

背景：最近在做和HW对接的某项目，需要将第三方接口提供的数据进行展示；在对方提供了详细的excel后，觉得也挺简单的就是将excel数据导入到数据库中。

方案一：

普通的初学者肯定会想，那我读取excel数据，一行一行的读，然后插入到数据库中进行存储，然而这样利用事务进行存储本身也没有问题；但是数据库如果涉及不规范，某列数据的数据类型（长度不够后），就会导致整个执行过程进行回滚；效率也不是很高。

excel数据存放到table中代码： 

DataTable dt = new DataTable();

                IWorkbook workbook; 
                string fileExt = Path.GetExtension(path).ToLower(); 
                using (FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read))

                {
                    if (fileExt == ".xlsx") 
                    {
                        workbook = new XSSFWorkbook(fs);
                    }
                    else if (fileExt == ".xls")
                    { 
                        workbook = new HSSFWorkbook(fs); 
                    } 
                    else 
                    { 
                        workbook = null;
                    }
                    if (workbook == null) return;

                    ISheet sheet = workbook.GetSheetAt(0);//表头

                    IRow header = sheet.GetRow(sheet.FirstRowNum);

                    List<int> columns = new List<int>(); 
                    for (int i = 0; i < header.LastCellNum; i++)
                    {
                        object obj = GetValueType(header.GetCell(i));
                        if (obj == null || obj.ToString() == string.Empty)

                        {

                            dt.Columns.Add(new DataColumn("Columns" + i.ToString()));

                        }
                        else dt.Columns.Add(new DataColumn(obj.ToString()));

                        columns.Add(i);

                    }//数据

                    for (int i = sheet.FirstRowNum + 1; i <= sheet.LastRowNum; i++)

                    {

                        DataRow dr = dt.NewRow(); bool hasValue = false; 
                        foreach (int j in columns)

                        {

                            dr[j] = GetValueType(sheet.GetRow(i).GetCell(j)); if (dr[j] != null && dr[j].ToString() != string.Empty)

                            {

                                hasValue = true;

                            }

                        }
                        if (hasValue)
                        {

                            dt.Rows.Add(dr);
                        }

                    }

                }
遍历table数据到数据库

string connectstring = "";//数据库连接字符串
                SqlConnection conn = new SqlConnection(connectstring); //数据库连接
                conn.Open();                                                       
                for (int i = 0; i < dt.Rows.Count; i++)
                {
                    string sqlstr = "insert t_table (Column1,Column2,Column3,Column4,Column5) values ('" + dt.Rows[i][0].ToString()+"','" + dt.Rows[i][1].ToString() + "','"
                        + dt.Rows[i][2].ToString() + "','" + dt.Rows[i][3].ToString() + "','"+ dt.Rows[i][4].ToString() + "')";
                    SqlCommand com = new SqlCommand(sqlstr, conn);
                    if (com.ExecuteNonQuery() < 1)
                    {
                        Console.WriteLine("导入数据失败！");
                        System.Console.WriteLine("编码："+dt.Rows[i][0].ToString()+"导入失败！");
                    }
                    System.Console.WriteLine("编码：" + dt.Rows[i][0].ToString() + "导入成功！");
                } 

其中 t_table为数据库中表名称，Column1~Column5为数据库中字段名称.

方案二：

比较高效的做法是利用office自带的功能OLEDB结合OPENROWSET导入数据；具体代码如下：

string connectstring = "";//数据库连接字符串
                SqlConnection conn = new SqlConnection(connectstring); //数据库连接   
                conn.Open();
                string sqlstr = @"insert into t_HWPromptMsg select 编码, 提示, 场景,提示信息,备注 from OPENROWSET('MICROSOFT.JET.OLEDB.4.0','Excel 5.0;HDR=YES;DATABASE="+ path + "',sheet1$)";
                SqlCommand cmd = new SqlCommand(sqlstr, conn);
                cmd.ExecuteNonQuery();
                conn.Close(); 

注意事项：在利用 OPENROWSET时需要打开SQL Server的Ad Hoc Distributed Queries组件，否则会报：报错内容是：SQL  Server 阻止了对组件 'Ad Hoc Distributed Queries' 的  STATEMENT'OpenRowset/OpenDatasource'  的访问，因为此组件已作为此服务器安全配置的一部分而被关闭。系统管理员可以通过使用 sp_configure 启用 'Ad Hoc  Distributed Queries'。有关启用 'Ad Hoc Distributed Queries' 的详细信息，请参阅 SQL  Server 联机丛书中的 "外围应用配置器"。

具体执行步骤：

1.开启Ad Hoc Distributed Queries组件，在sql查询编辑器中执行如下语句：

exec sp_configure 'show advanced options',1
reconfigure
exec sp_configure 'Ad Hoc Distributed Queries',1
reconfigure

2.执行c#程序代码

3.关闭Ad Hoc Distributed Queries组件，在sql查询编辑器中执行如下语句：

exec sp_configure 'Ad Hoc Distributed Queries',0
reconfigure
exec sp_configure 'show advanced options',0
reconfigure

看到这了，如果您觉得我的文章对您有帮助，我强烈建议您，在能力所极时，给我发一元打赏买瓶水；您的支持将是我无线创作的动力。