记一次SQL Server2005导入Oracle10G的折腾过程【供多种数据库导入导出数据的C#程序源码参考】

简介:

 曾经很早的时候用 SQL Server2000 时就见过我们老大,用 SQL Server2000 的导入导出功能,把数据都导入到了 Oracle9 里去,所以我也对导入导出数据有充分的信心,绝对能做好。


  客户需要一个Oracle版本的通用权限管理系统组件的数据库,而且为此还支付了5000元的技术咨询费。最近一段时间Oracle用得不多,电脑里没也装Oracle,想来想去应该家里的移动硬盘里,有Oracle11G,就装了一个,装好后总感觉用户创建的不正确,折腾来折腾去,又卸载又重新装了一下,这个前后估计耗费了2-3个小时。

  但是想从 SQL Server2005 导入到Oracle11G时总是出现错误,折腾了1-2个小时也没能搞定,接着又尝试从 SQL Server2008 导入到 Oracle11G还是不行照样有错无法正常导入,这时候简直有些绝望了,唉连微软的工具都无法正常导入导出数据。


  这时候我就咨询群里的朋友,有一个做开发的朋友推荐用 Kettle ,这个数据库导入导出工具好不容易在网上下载了一个,无法正常运行,又下载了JDK什么的,接着还说缺这个文件缺哪个文件,然后朋友又发了那些缺的文件,但是程序还是无法正常运行,折腾这些,足足消耗了2个小时以上,家里的网络只有2M,下载的速度也不太快。

  所以用一些不熟悉的东西,有一定的风险,同时可能还需要很多学习成本。我电脑用的是win7 32位的,始终没明白为啥 Kettle 没能正常运行。


  有一个比较擅长开发Oralce的朋友又推荐我用sqldeveloper-3.0.03.45.zip,但是死活找不到相关下载,好不容易Oracle的下载里有一个,但是也无法下载,版本也过低,由于这个软件也比较庞大,客户也无法从网上很顺利的发过来,左找右找,又耗费了1-2个小时,顺便看看相关的文章,折腾了半死,结果没能突破,再次想用工具的想法被破灭了。


  有朋友推荐用微软的SQL Server Business Intelligence Development Studio 来折腾导入导出,结果折腾1-2个小时,还是无法正确导入导出表结构及数据,又是失败告终,真是折腾人啊。


  4次想用工具导入数据的尝试,均告失败后,真是有些绝望了,足足一天时间就被这么浪费掉了。只能硬这头皮自己上了,客户的问题总需要解决。

  实在是没办法那就自己动手导入吧,从 PowerDesigner 15 的模型里把数据库表结构都折腾好,导入到 Oracle11G 结果发现表名被区别大小写了,又把所有创建好的表都删除了,折腾了1个小时,又把 表重新建立一遍, 把SQL语句里的“符号全部替换掉了,才把表结构建立好了。

  实在忍无可忍了,自己写了程序写了1个小时不到,把导入导出的程序写了一遍,一执行,几分钟就搞定了,唉,早知道这个效果早就自己写个程序就好了,前后也就2-3个小时就可以了。


  好不容易导入 Oracle11G 成功后,客户无法正确导入我提供的数据文件,客户用的是  Oracle10G, 我又在电脑里装了一个 Oracle10G 的客户端,又把数据用 Oracle10G 导出一次,客户才正确导入了数据,这么一来回折腾又耗费了好几个小时。


  这期间程序的多数据库兼容性测试也耗费了几个小时调试,其实光把 SQL Server2005导入Oracle10G 的折腾过程,足足耗费了2天时间,人都有点儿累了,虽然嘴巴说说是很简单的事情,真的折腾起来真是不只是脑力活儿还更是体力活儿。



  程序代码的参考如下:

//--------------------------------------------------------------------

//  All Rights Reserved , Copyright (C) 2011 , Hairihan TECH, Ltd. 
// --------------------------------------------------------------------

using  System.Data;

namespace  DotNet.Example
{
using  DotNet.BaseManager;
using  DotNet.DbUtilities;

public class  ImportExportData
   {
/// <summary>
///  导出数据库到Oralce
/// </summary>
public void  Export()
       {
// this.ExportTable("Items_Area");
// this.ExportTable("Items_AuditStatus");
// this.ExportTable("Items_Degree");
// this.ExportTable("Items_Duty");
// this.ExportTable("Items_Education");
// this.ExportTable("Items_Express");
// this.ExportTable("Items_Links");
// this.ExportTable("Items_MembershipLevels");
// this.ExportTable("Items_Nationality");
// this.ExportTable("Items_NewsCategory");
// this.ExportTable("Items_OnSale");
// this.ExportTable("Items_OrganizeCategory");
// this.ExportTable("Items_Party");
// this.ExportTable("Items_Pattern");
// this.ExportTable("Items_PayCategory");
// this.ExportTable("Items_PostCategory");
// this.ExportTable("Items_RoleCategory");
// this.ExportTable("Items_SalaryItemCategory");
// this.ExportTable("Items_SendCategory");
// this.ExportTable("Items_Sex");
// this.ExportTable("Items_Title");
// this.ExportTable("Items_Units");
// this.ExportTable("Items_UserAuditStates");
// this.ExportTable("Items_Wed");
// this.ExportTable("Items_WorkCategory");
// this.ExportTable("Items_WorkFlowCategories");
// this.ExportTable("Items_WorkingProperty");
// this.ExportTable("Base_Businesscard");
// this.ExportTable("Base_Comment");
// this.ExportTable("Base_Contact");
// this.ExportTable("Base_ContactDetails");
// this.ExportTable("Base_Exception");
// this.ExportTable("Base_File");
// this.ExportTable("Base_Folder");
// this.ExportTable("Base_Items");
// this.ExportTable("Base_Log");
// this.ExportTable("Base_Message");
// this.ExportTable("Base_News");

// this.ExportTable("Base_Organize");
// this.ExportTable("Base_Module", " SELECT * FROM BASE_MODULE ORDER BY PARENTID, ID ");
// this.ExportTable("Base_PermissionItem");
// this.ExportTable("Base_Role");
// this.ExportTable("Base_Staff");

// this.ExportTable("Base_Parameter");
// this.ExportTable("Base_Project");
// this.ExportTable("Base_Permission");
// this.ExportTable("Base_PermissionScope");

this .ExportTable( " Base_Sequence " );

// this.ExportTable("Base_StaffOrganize");
// this.ExportTable("Base_TableColumns");
// this.ExportTable("Base_User");
// this.ExportTable("Base_UserAddress");
// this.ExportTable("Base_UserOrganize");
// this.ExportTable("Base_UserRole");
// this.ExportTable("Base_StaffOrganize");
// this.ExportTable("Base_WorkFlowActivity");
// this.ExportTable("Base_WorkFlowCurrent");
// this.ExportTable("Base_WorkFlowHistory");
// this.ExportTable("Base_WorkFlowProcess");

           System.Console.ReadLine();
       }

public void  ExportTable( string  tableName)
       {
           ExportTable(tableName, tableName);
       }

/// <summary>
///  导出一个表
/// </summary>
/// <param name="tableName"> 表名 </param>
/// <param name="table"> 里面的数据 </param>
public void  ExportTable( string  tableName,  string  table)
       {
//  这里是获取数据
           SqlHelper sqlHelper  = new  SqlHelper( " Data Source=localhost;Initial Catalog=UserCenterV32;Integrated Security=SSPI; " );
           sqlHelper.Open();
           DataTable dataTable 
= new  DataTable(tableName);
if  (tableName.Equals(table))
           {
               dataTable 
=  sqlHelper.Fill( " SELECT * FROM  " +  table);
           }
else
           {
               dataTable 
=  sqlHelper.Fill(table);
           }
           sqlHelper.Close();

//  这里是插入数据
           OracleHelper oracleHelper  = new  OracleHelper( " Data Source=ORACLE11;user=DBO_USERCENTERV32;password=DBO_USERCENTERV32; " );
           oracleHelper.Open();
           oracleHelper.BeginTransaction();
           SQLBuilder sqlBuilder 
= new  SQLBuilder(oracleHelper);
try
           {
//  清除表数据
               oracleHelper.ExecuteNonQuery( " TRUNCATE TABLE  " +  tableName);
//  创建配套的序列
//  oracleHelper.ExecuteNonQuery("create sequence SEQ_" + tableName + " minvalue 1 maxvalue 999999999999999999999999 start with 1 increment by 1 cache 20");

int  r  = 0 ;
for  (r  = 0 ; r  <  dataTable.Rows.Count; r ++ )
               {
                   sqlBuilder.BeginInsert(tableName);
for  ( int  i  = 0 ; i  <  dataTable.Columns.Count; i ++ )
                   {
                       sqlBuilder.SetValue(dataTable.Columns[i].ColumnName, dataTable.Rows[r][dataTable.Columns[i].ColumnName]);
                   }
                   sqlBuilder.EndInsert();
                   System.Console.WriteLine(
" 表  " +  tableName  + "  已插入第  " +  r.ToString()  + "  行 " );
               }
               System.Console.WriteLine(
"  - - 表  " +  tableName  + "  共插入  " +  r.ToString()  + "  行 " );
               oracleHelper.CommitTransaction();
           }
catch  (System.Exception exception)
           {
               oracleHelper.RollbackTransaction();
               System.Console.WriteLine(tableName 
+ "  --  " +  exception.Message);
           }
finally
           {
               oracleHelper.Close();
           }
       }
   }

}





本文转自 jirigala 51CTO博客,原文链接: http://blog.51cto.com/2347979/1200711,如需转载请自行联系原作者
相关文章
|
5月前
|
SQL Oracle 关系型数据库
Oracle数据库创建表空间和索引的SQL语法示例
以上SQL语法提供了一种标准方式去组织Oracle数据库内部结构,并且通过合理使用可以显著改善查询速度及整体性能。需要注意,在实际应用过程当中应该根据具体业务需求、系统资源状况以及预期目标去合理规划并调整参数设置以达到最佳效果。
405 8
|
11月前
|
存储 Oracle 关系型数据库
【YashanDB 知识库】YMP 校验从 yashandb 同步到 oracle 的数据时,字段 timestamp(0) 出现不一致
在YMP校验过程中,从yashandb同步至Oracle的数据出现timestamp(0)字段不一致问题。原因是yashandb的timestamp(x)存储为固定6位小数,而Oracle的timestamp(0)无小数位,同步时会截断yashandb的6位小数,导致数据差异。受影响版本:yashandb 23.2.7.101、YMP 23.3.1.3、YDS联调版本。此问题会导致YMP校验数据内容不一致。
|
8月前
|
存储 数据库连接 数据库
告别数据库瓶颈!用这个技巧让你的程序跑得飞快!
本文介绍了数据库连接池的概念及其在性能优化中的重要性,通过两个示例展示了如何管理 SQLite 数据库连接。首先,手动实现了一个基于 `sqlite3` 和 `queue.Queue` 的简单连接池,涵盖初始化、获取与释放连接的核心流程。接着,使用功能更强大的 `SQLAlchemy` 库创建连接池,简化了连接管理并支持更多高级特性。对比两种方式后发现,自定义连接池适合学习和小型应用,而 `SQLAlchemy` 更适用于复杂场景。合理使用连接池可显著提升高并发环境下的数据库操作效率。
128 1
|
11月前
|
Oracle 关系型数据库 Java
【YashanDB知识库】Flink CDC实时同步Oracle数据到崖山
本文介绍通过Flink CDC实现Oracle数据实时同步至崖山数据库(YashanDB)的方法,支持全量与增量同步,并涵盖新增、修改和删除的DML操作。内容包括环境准备(如JDK、Flink版本等)、Oracle日志归档启用、用户权限配置、增量日志记录设置、元数据迁移、Flink安装与配置、生成Flink SQL文件、Streampark部署,以及创建和启动实时同步任务的具体步骤。适合需要跨数据库实时同步方案的技术人员参考。
【YashanDB知识库】Flink CDC实时同步Oracle数据到崖山
|
10月前
|
SQL Oracle 关系型数据库
解决大小写、保留字与特殊字符问题!Oracle双引号在SQL中的特殊应用
在Oracle数据库开发中,双引号的使用是一个重要但易被忽视的细节。本文全面解析了双引号在SQL中的特殊应用场景,包括解决标识符与保留字冲突、强制保留大小写、支持特殊字符和数字开头标识符等。同时提供了最佳实践建议,帮助开发者规避常见错误,提高代码可维护性和效率。
402 6
|
11月前
|
存储 Oracle 关系型数据库
【YashanDB 知识库】YMP 校验从 yashandb 同步到 oracle 的数据时,字段 timestamp(0) 出现不一致
【YashanDB 知识库】YMP 校验从 yashandb 同步到 oracle 的数据时,字段 timestamp(0) 出现不一致
|
11月前
|
SQL Oracle 关系型数据库
【YashanDB知识库】共享利用Python脚本解决Oracle的SQL脚本@@用法
【YashanDB知识库】共享利用Python脚本解决Oracle的SQL脚本@@用法
|
11月前
|
SQL Oracle 关系型数据库
【YashanDB知识库】共享利用Python脚本解决Oracle的SQL脚本@@用法
本文来自YashanDB官网,介绍如何处理Oracle客户端sql*plus中使用@@调用同级目录SQL脚本的场景。崖山数据库23.2.x.100已支持@@用法,但旧版本可通过Python脚本批量重写SQL文件,将@@替换为绝对路径。文章通过Oracle示例展示了具体用法,并提供Python脚本实现自动化处理,最后调整批处理脚本以适配YashanDB运行环境。
|
11月前
|
存储 Oracle 关系型数据库
【YashanDB知识库】YMP校验从yashandb同步到oracle的数据时,字段timestamp(0)出现不一致
【YashanDB知识库】YMP校验从yashandb同步到oracle的数据时,字段timestamp(0)出现不一致
|
Oracle 关系型数据库
Oracle和sqlserver数据类型对应
原文:Oracle和sqlserver数据类型对应 Sqlserver类型 Oracle类型 binary     RAW(50) bit     NUMBER(2) char     CHAR(10) datetime     DATE decimal ...
1653 0

推荐镜像

更多