using System.Data;

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

publicclass ImportExportData1
   {
///<summary>
/// 导出数据库到Oralce
///</summary>
publicvoid Export()
       {

//this.ExportTable("ItemDetails");
//this.ExportTable("Items_Condition");

//this.ExportTable("Items_Currency");
//this.ExportTable("Items_E_Signature");
//this.ExportTable("Items_RoleCategory");
//this.ExportTable("Items_SecurityLevel");
//this.ExportTable("Items_TablePermissionScope");

//this.ExportTable("Base_Comment");
//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_Organize");
this.ExportTable("Base_Module");
//this.ExportTable("Base_PermissionItem");

//this.ExportTable("Base_Role");

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

//this.ExportTable("Base_Sequence");
// this.ExportTable("Base_TableColumns");
// this.ExportTable("Base_User");
// this.ExportTable("Base_UserAddress");
// this.ExportTable("Base_UserOrganize");
// this.ExportTable("Base_UserRole");

//this.ExportTable("Base_WorkFlowActivity");
//this.ExportTable("Base_WorkFlowCurrent");
//this.ExportTable("Base_WorkFlowHistory");
//this.ExportTable("Base_WorkFlowProcess");

System.Console.ReadLine();
       }

publicvoid ExportTable(string tableName)
       {
           ExportTable(tableName.ToUpper(), tableName.ToUpper());
       }

///<summary>
/// 导出一个表
///</summary>
///<param name="tableName">表名</param>
///<param name="table">里面的数据</param>
publicvoid ExportTable(string tableName, string table)
       {
// 这里是获取目标数据表的方法
           IDbHelper sourceDB =new SqlHelper("Data Source=192.168.0.121;Initial Catalog=UserCenterJMCB;User Id = sa ; Password = Password@1;");
           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=usercenter;");
// IDbHelper targetDB = new DB2Helper("Database=JMCB_UC;UserID=JoinMoreCash;Password=P@ssw0rd;Server=WIN-3T3M2TTDAFK;");
           IDbHelper targetDB =new DB2Helper("Database=JMCB_UC;UserID=administrator;Password=p@ssw0rd2077;Server=WIN-3T3M2TTDAFK;");
           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();
           }
       }
   }
}