C#.NET通用权限管理在DB2数据库上运行的脚本参考 - 通过程序将数据导入到目标数据库中...

ゝ一世哀愁。 2022-02-04 14:45 70阅读 0赞

参考代码如下：

// \--------------------------------------------------------------------  
 //  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\_Nationality " );  
 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\_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\_Gender " );  
 this .ExportTable( " Items\_Title " );  
 this .ExportTable( " Items\_Units " );  
 this .ExportTable( " Items\_Wed " );  
 this .ExportTable( " Items\_AuditStatus " );  
 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.ToUpper(), tableName.ToUpper());  
\}  
  
 ///  <summary>   
 ///  导出一个表  
 ///  </summary>   
 ///  <param name="tableName"> 表名 </param>   
 ///  <param name="table"> 里面的数据 </param>   
  public  void  ExportTable( string  tableName,  string  table)  
\{  
 //  这里是获取目标数据表的方法   
  IDbHelper sourceDB  =  new  SqlHelper( " Data Source=192.168.0.121;Initial Catalog=UserCenterV36;User Id = sa ; Password = xx; " );  
sourceDB.Open();  
DataTable dataTable  =  new  DataTable(tableName);  
 if  (tableName.Equals(table))  
\{  
dataTable  =  sourceDB.Fill( " SELECT \* FROM  "  \+  table);  
\}  
 else   
\{  
dataTable  =  sourceDB.Fill(table);  
\}  
sourceDB.Close();  
  
 //  这里是目标表的数据插入处理  
 //  IDbHelper targetDB = new OracleHelper("Data Source=KANGFU;user=usercenter;password=xx;");   
  IDbHelper targetDB  =  new  DB2Helper( " Database=UCV36;UserID=JIRIGALA;Password=xx;Server=JIRIGALA-PC; " );  
targetDB.Open();  
targetDB.BeginTransaction();  
SQLBuilder sqlBuilder  =  new  SQLBuilder(targetDB);  
 try   
\{  
 //  清除表数据  
 //  targetDB.ExecuteNonQuery(" TRUNCATE TABLE " + tableName);   
  targetDB.ExecuteNonQuery( "  DELETE FROM  "  \+  tableName);  
 //  创建配套的序列  
 //  targetDB.ExecuteNonQuery("create sequence SEQ\_" + tableName.ToUpper() + " as bigint start with 1000000 increment by 1 minvalue 10000 maxvalue 99999999999999999 cycle cache 20 order");  
 //  targetDB.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()  \+  "  行 " );  
targetDB.CommitTransaction();  
\}  
 catch  (System.Exception exception)  
\{  
 //  targetDB.RollbackTransaction();   
  System.Console.WriteLine(tableName  \+  "  \--  "  \+  exception.Message);  
\}  
 finally   
\{  
targetDB.Close();  
\}  
\}  
\}  
\}本文转自jirigala\_bao 51CTO博客，原文链接:http://blog.51cto.com/jirigala/812629