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

桃扇骨 2022-01-17 10:41 74阅读 0赞

[为什么80%的码农都做不了架构师？>>> ][80_]  ![hot3.png][]

参考代码如下：

// \--------------------------------------------------------------------  
 //  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();  
            \}  
        \}  
    \}  
\}

转载于:https://my.oschina.net/iwenr/blog/227836

[80_]: https://my.oschina.net/u/2663968/blog/3051541
[hot3.png]: /images/20220117/4c13c3c7c62f4abdaf50d6d0e5f6e246.png