• 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 columns = new List(); 
                        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

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

  • 相关阅读:
    Shelby American 汽车 NFT 系列来袭!
    天翼云探索云原生、边缘计算融合新思路
    7.新增类型Symbol
    《自卑与超越》爱情篇
    每天一道leetcode:14.最长公共前缀(简单)
    shell中实用eval命令和安全问题
    重置Mac电脑的SMC怎么操作,重置SMC方法分享~
    共码未来 | 2022 Google 谷歌开发者大会参会现场记
    MATLAB科技绘图与数据分析
    攻防演练怎样从外网进行纵深突破
  • 原文地址:https://blog.csdn.net/A_nanda/article/details/136225511