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

news/2024/7/24 1:58:34 标签: oracle, 数据库

背景:最近在做和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


http://www.niftyadmin.cn/n/5391642.html

相关文章

快速清理_卸载docker_找到不用的进程_centos磁盘爆满_清理磁盘---Linux工作笔记071

查看大文件,并且按照大小排名 cd / | du -h |sort -hr|head -30 可以看到根据不用的结果进行删除 可以看到在/data/dict目录很大,里面的都可以删除 然后再去卸载docker,要不然,没有磁盘是卸载不了的 systemctl stop docker systemctl stop docker.socket yum remove docker-…

【Linux】部署单机项目(自动化启动)

目录 一.jdk安装 二.tomcat安装 三.MySQL安装 四.部署项目 一.jdk安装 1.上传jdk安装包 jdk-8u151-linux-x64.tar.gz 进入opt目录&#xff0c;将安装包拖进去 2.解压安装包 防止后面单个系列解压操作&#xff0c;我这边就直接将所有的要用的全部给解压&#xff0c;如下图注…

system_v

共享内存 创建共享内存 key_t ftok(const char *pathname, int proj_id);使用相同的pathname和proj_id可以得到相同的key_t pathname必须是一个存在的目录 int shmget(key_t key, size_t size, int shmflg);需要使用ftok获取key_t IPC_CREAT——不存在就创建&#xff0c…

【Elasticsearch专栏 12】深入探索:Elasticsearch使用索引生命周期管理(ILM)自动化删除旧数据

导言 在Elasticsearch中&#xff0c;随着数据的不断积累&#xff0c;管理旧数据成为了一个重要的问题。为了有效地管理这些数据&#xff0c;Elasticsearch提供了索引生命周期管理&#xff08;ILM&#xff09;功能。ILM允许根据索引的年龄、大小或其他条件自动执行一系列操作&a…

上一篇文章补充:已经存在的小文件合并

对于HDFS上已经存在的大量小文件问题&#xff0c;有多种策略可以进行处理和优化&#xff1a; 1. **合并小文件**&#xff1a; - **使用Spark作业合并**&#xff1a;通过编写Spark程序读取小文件并调用repartition()或coalesce()函数重新分区数据&#xff0c;然后将合并后的…

解决easyExcel模板填充时转义字符\{xxx\}失效

正常我们在使用easyExcel进行模板填充时&#xff0c;定义的变量会填充好对应的实际数据&#xff0c;未定义的变量会被清空&#xff0c;但是如果这个未定义的变量其实是模板的一部分&#xff0c;那么清空了就出错了。 在这张图里&#xff0c;上面的是模板填充后导出的文件&…

spinalhdl,vivado,fpga

https://spinalhdl.github.io/SpinalDoc-RTD/master spinal hdl sudo apt install openjdk-17-jdk scala curl echo “deb https://repo.scala-sbt.org/scalasbt/debian all main” | sudo tee /etc/apt/sources.list.d/sbt.list echo “deb https://repo.scala-sbt.org/scal…

LeetCode 2433.找出前缀异或的原始数组

给你一个长度为 n 的 整数 数组 pref 。找出并返回满足下述条件且长度为 n 的数组 arr &#xff1a; pref[i] arr[0] ^ arr[1] ^ … ^ arr[i]. 注意 ^ 表示 按位异或&#xff08;bitwise-xor&#xff09;运算。 可以证明答案是 唯一 的。 示例 1&#xff1a; 输入&#xf…