当前位置:首页 > 数据库 > 批量Excel数据导入Oracle数据库

批量Excel数据导入Oracle数据库

2022年11月08日 19:44:24数据库23

由于一直基于Oracle数据库上做开发,因此常常会需要把大量的Excel数据导入到Oracle数据库中,其实如果从事SqlServer数据库的开发,那么思路也是一样的,本文主要介绍如何导入Excel数据进入Oracle数据库的内容。

一般我们拿到的Excel数据,都会有一个表头说明,然后下面是一连串的数据内容,如下图所示:

批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记 

而Oracle中数据库一般为英文名称,中文名称就需要转义,为了方便导入,我把中文名称对照数据库的字段,把表头修改为对应的字段名称,如果没有数据库对应的字段,那么删除Excel的无用列即可,如下所示。

批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记 

首先我们在导入Excel的例子中加载显示要导入的数据,一个是为了直观,第二个也是为了检查数据的有效性,避免出错,界面如下所示:

 批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记

在介绍导入操作前,我们先要分析下数据,否则就很容易出现错误的语句,一般日期的格式、数字的格式就要特别注意,文本格式一般看是否超出字段的长度,一般成功导入前都会发生好多次的错误问题,解决了这些格式的问题,基本上就OK了。如下面日期和数字的格式问题,就必须注意转换为对应的内容格式:

批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记 批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记

 

下面介绍具体的显示数据和导入数据的操作代码:

 显示Excel数据的代码如下所示:

 批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记代码

         private   string  connectionStringFormat  =   " Provider = Microsoft.Jet.OLEDB.4.0 ; Data Source = '{0}';Extended Properties=Excel 8.0 " ;
        
private  DataSet myDs  =   new  DataSet();

        
private   void  btnViewData_Click( object  sender, EventArgs e)
        {
            
if  ( this .txtFilePath.Text  ==   "" )
            {
                MessageUtil.ShowTips(
" 请选择指定的Excel文件 " );
                
return ;
            }

            
string  connectString  =   string .Format(connectionStringFormat,  this .txtFilePath.Text);
            
try
            {
                myDs.Tables.Clear();
                myDs.Clear();
                OleDbConnection cnnxls 
=   new  OleDbConnection(connectString);
                OleDbDataAdapter myDa 
=   new  OleDbDataAdapter( " select * from [Sheet1$] " , cnnxls);
                myDa.Fill(myDs, 
" c " );

                dataGrid1.DataSource 
=  myDs.Tables[ 0 ];
            }
            
catch  (Exception ex)
            {
                MessageBox.Show(ex.Message);
            }
        }

 

 

导入操作的代码如下所示(由于数据格式需要验证,以及需要判断数据库是否存在指定关键字的记录,如果存在,那么更新,否则插入新的记录,如果仅仅是第一次导入,操作代码可以更为精简一些):

 批量Excel数据导入Oracle数据库 _ JavaClub全栈架构师技术笔记代码

         private   void  btnSaveData_Click( object  sender, EventArgs e)
        {
            
if  ( this .txtFilePath.Text  ==   "" )
            {
                MessageUtil.ShowTips(
" 请选择指定的Excel文件 " );
                
return ;
            }

            
if  (MessageUtil.ShowYesNoAndWarning( " 该操作将把数据导入到系统的用户数据库中,您确定是否继续? " ==  DialogResult.Yes)
            {
                InsertData();
            }
        }

        
private   bool  CheckIsDate( string  columnName)
        {
            
string  str  =   " ,PREPARE_DATE,COPY_DATE,COPY_VALIDITY,BUSINESS_VALIDITY,OPENING_APPROVAL_DATE,OPENING_DATE,EDITTIME,LICENSE_DATE,LICENSE_VALIDITY,TEMP_OPENING_DATE,LICENSE_START_DATE,ADDTIME,EDITTIME, " ;
            
return  str.Contains( " , "   +  columnName.ToUpper()  +   " , " );
        }

        
private   bool  CheckIsNumeric( string  columnName)
        {
            
string  str  =   " ,FIXED_CAPITAL,REG_CAPITAL,MARGIN,PARK_AREA,PARK_SPACE_NUMBER, " ;
            
return  str.Contains( " , "   +  columnName.ToUpper()  +   " , " );
        }

        
private   void  InsertData()
        {
            
int  intOk  =   0 ;
            
int  intFail  =   0 ;

            
if  (myDs  !=   null   &&  myDs.Tables[ 0 ].Rows.Count  >   0 )
            {
                
string  accessConnectString  =  config.GetConnectionString( " DataAccess " );
                OracleConnection conn 
=   new  OracleConnection(accessConnectString);
                conn.Open();
                OracleCommand com 
=   null ;

                
#region  组装字段列表
                
string  insertColumnString  =   " ID, " ;
                DataTable dt 
=  myDs.Tables[ 0 ];
                
int  k  =   0 ;
                
foreach  (DataColumn col  in  dt.Columns)
                {
                    insertColumnString 
+=   string .Format( " {0}, " , col.ColumnName);
                }
                insertColumnString 
=  insertColumnString.Trim( ' , ' );

                
#endregion

                
try
                {
                    
foreach  (DataRow dr  in  dt.Rows)
                    {
                        
if  (dr[ 0 ].ToString()  ==   "" )
                        {
                            
continue ;
                        }

                        
#region  组装Sql语句
                        
string  insertValueString  =   " SEQ_TBPARK_ENTERPRISE.Nextval, " ;
                        
string  updateValueString  =   "" ;
                        
string  COMPANY_CODE  =  dr[ " COMPANY_CODE " ].ToString().Replace( " <空> " "" );

                        
#region  拼接Sql字符串

                        
for ( int  i  =   0 ; i  <  dt.Columns.Count; i ++ )
                        {
                            
string  originalValue  =  dr[i].ToString().Replace( " <空> " "" );
                            
// if (!CheckIsDate(dt.Rows[0][i].ToString()))
                             if  ( ! CheckIsDate(dt.Columns[i].ColumnName))
                            {
                                
if  ( ! string .IsNullOrEmpty(originalValue))
                                {
                                    
if  (CheckIsNumeric(dt.Columns[i].ColumnName))
                                    {
                                        insertValueString 
+=   string .Format( " '{0}', " , Convert.ToDecimal(originalValue));
                                        updateValueString 
+=   string .Format( " {0}='{1}', " , dt.Columns[i].ColumnName, Convert.ToDecimal(originalValue));
                                    }
                                    
else
                                    {
                                        insertValueString 
+=   string .Format( " '{0}', " , originalValue);
                                        updateValueString 
+=   string .Format( " {0}='{1}', " , dt.Columns[i].ColumnName, originalValue);
                                    }
                                }
                                
else
                                {
                                    insertValueString 
+=   string .Format( " NULL, " );
                                    updateValueString 
+=   string .Format( " {0}=NULL, " , dt.Columns[i].ColumnName);
                                }
                            }
                            
else
                            {
                                
if  ( ! string .IsNullOrEmpty(originalValue))
                                {
                                    insertValueString 
+=   string .Format( " to_date('{0}','yyyy-mm-dd'), " , Convert.ToDateTime(originalValue).ToString( " yyyy-MM-dd " ));
                                    updateValueString 
+=   string .Format( " {0}=to_date('{1}','yyyy-mm-dd'), " , dt.Columns[i].ColumnName, Convert.ToDateTime(originalValue).ToString( " yyyy-MM-dd " ));
                                }
                                
else
                                {
                                    insertValueString 
+=   string .Format( " NULL, " );
                                    updateValueString 
+=   string .Format( " {0}=NULL, " , dt.Columns[i].ColumnName);
                                }
                            }
                        }
                        insertValueString 
=  insertValueString.Trim( ' , ' );
                        updateValueString 
=  updateValueString.Trim( ' , ' ); 
                        
#endregion

                        
string  insertSql  =   string .Format( @" INSERT INTO tbpark_enterprise ({0}) VALUES({1}) " , insertColumnString, insertValueString);
                        
string  updateSql  =   string .Format( " Update tbpark_enterprise set {0} Where COMPANY_CODE='{1}'  " , updateValueString, COMPANY_CODE);
                        
string  checkExistSql  =   string .Format( " Select count(*) from tbpark_enterprise where COMPANY_CODE='{0}'  " , COMPANY_CODE);
                        
#endregion

                        
#region  写入数据
                        
try
                        {
                            com 
=   new  OracleCommand();
                            com.Connection 
=  conn;
                            com.CommandText 
=  checkExistSql;
                            
object  objCount  =  com.ExecuteScalar();

                            
bool  succeed  =   false ;
                            
bool  exist  =  Convert.ToInt32(objCount)  >   0 ;
                            
if  (exist)
                            {
                                
// 需要更新
                                
// WriteString(updateSql);
                                com.CommandText  =  updateSql;
                                succeed 
=  com.ExecuteNonQuery()  >   0 ;
                            }
                            
else
                            {
                                
// 需要插入
                                
// WriteString2(insertSql);
                                com.CommandText  =  insertSql;
                                succeed 
=  com.ExecuteNonQuery()  >   0 ;
                            }

                            
if  (succeed)
                            {
                                intOk
++ ;
                            }
                            
else
                            {
                                intFail
++ ;
                            }
                        }
                        
catch  (Exception ex)
                        {
                            intFail
++ ;
                            WriteString(com.CommandText);
                            LogHelper.Error(ex);
                            
break ;
                        }

                        
#endregion
                    }

                    
#region  关闭
                    
if  (conn  !=   null   &&  conn.State  !=  ConnectionState.Closed)
                    {
                        conn.Close();
                    }
                    
if  (com  !=   null )
                    {
                        com.Dispose();
                    }
                    
#endregion
                }
                
catch  (Exception ex)
                {
                    LogHelper.Error(ex);
                    MessageUtil.ShowError(ex.ToString());
                }

                
if  (intOk  >   0   ||  intFail  >   0 )
                {
                    
string  tips  =   string .Format( " 数据导入成功:{0}个,失败:{1}个 " , intOk, intFail);
                    MessageUtil.ShowTips(tips);
                }
            }
        }

 

以上代码,为了方便,使用了输出脚本的方式进行验证对比,一般情况下也是用得着的。

最后附上该程序的源码,和大家分享学习:https://files.cnblogs.com/wuhuacong/ImportExcelToOracle.rar 

来源链接:https://www.cnblogs.com/wuhuacong/archive/2010/04/28/1723142.html

版权声明:
1、JavaClub(https://www.javaclub.cn)以学习交流为目的,由作者投稿、网友推荐和小编整理收藏优秀的IT技术及相关内容,包括但不限于文字、图片、音频、视频、软件、程序等,其均来自互联网,本站不享有版权,版权归原作者所有。

2、本站提供的内容仅用于个人学习、研究或欣赏,以及其他非商业性或非盈利性用途,但同时应遵守著作权法及其他相关法律的规定,不得侵犯相关权利人及本网站的合法权利。
3、本网站内容原作者如不愿意在本网站刊登内容,请及时通知本站(javaclubcn@163.com),我们将第一时间核实后及时予以删除。


本文链接:https://www.javaclub.cn/database/68561.html

标签: Oracle
分享给朋友:

“批量Excel数据导入Oracle数据库” 的相关文章

Java使用多线程导入数据到Oracle中

Oracle中的设置 多线程导入数据到Oracle中,如果是自己设置主键的值,那么肯定会遇到主键冲突的问题。例如线程A计算出的id为10(max(id) + 1),在A线程还没有完成导入时线程B用相同办法得到的id也是10,这时两个线程都请求插入数...

使用Docker安装Oracle步骤

使用Docker安装Oracle步骤

理由 : docker安装Oracle数据库既能减少安装的时间而且还能够快速进行部署  1 搜索镜像 docker search oracle 来搜索oralce镜像 2 创建volume以持久化数据 docker volume create or...

ORACLE数据库与Navicat安装 随手笔记

ORACLE数据库与Navicat安装 随手笔记

一、安装oracle数据库 1、下载安装包 oracle数据库下载地址: https://www.oracle.com/database/technologies/oracle-database-software-downloads.html#19c...

springBoot 整合 mybatis+Oracle

springBoot 整合 mybatis+Oracle

现在比较流行的操作数据库操作层框架Mybatis,下面我们就来看看Springboot如何整合mybatis, 之前一直在用xml形式写sql,这次依然用xml的方式感觉这种还是比较灵活方便。   添加mybatis关键就是要引入mybatis-spring-boot-start...

MySQL和Oracle使用group by的区别

Oracle在使用group by时,查询字段必须是分组的依据或聚合函数。 MySQL没有此限制,会自动取第一行。 作者:思想永无止境 来源链接:https://blog.csdn.net/u012643122/articl...

在xshell连接oracle,客户端XShell+Xmanager配置oracle流程

客户端:XShell + Xmanager配置流程: 1.使用XShell建立连接时,设置连接属性,在 SSH --> tunneling 选项下勾选 Forward X11 connections to:勾选 Xmanager。 2.登陆...

oracle 用sql语句管理数据库

oracle 用sql语句管理数据库

基础sql语句 创建数据库 :create database database_name; 创建表:create table(字段名 字段类型 字段为空约束 ,字段名 字段类型 字段为空约束,,,, 主键约束primary key(字段名多个字段用逗号隔开));...

Java添加系统当前时间到Oracle数据库

Java添加系统当前时间到Oracle数据库

Java添加系统当前时间到Oracle数据库 代码示例: // 获取系统当前时间 java.util.Date sysDate = new java.util.Date(); // 添加到Oracl...

Oracle数据库安装+PLSQL安装配置整理

Oracle数据库安装+PLSQL安装配置整理

1、Oracle安装过程   1.1 下载11g安装包 oracle Database 11g 第 2 版 (11.2.0.1.0) 标准版、标准版 1 以及企业版,适用于 Microsoft Windows (x64) 的 Oracle Databa...

oracle plsql基本语法

oracle plsql 基本语法 --plsql默认规则:plsql赋值用":=" plsql判断用"=" plsql输入用"&" --输入输出 declare v_str varchar2(20); begin -- Dbms_Output.put('hell...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。