bj_datarecovery.h

oracle下调用数据泵接口进行远程数据导出和导入（数据恢复）的CORBA服务

//    BJ_DataRecovery.h
//   北京数据恢复服务的本地代理，用于封装
//   北京数据恢复服务：BJ_DataRecovery，编写依据《接口规范》。
//   相关软件：DataRecoveryManager_impl、XX_DataRecovery_impl
//

#ifndef BJ_DATARECOVERY_H
#define BJ_DATARECOVERY_H

#include <STAR/CORBA.h>
#include <STAR/Afls.h>
#include "queryserver.h"
//#include <iostream>
//using namespace std;
//#ifdef HAVE_STD_IOSTREAM
//        using namespace std;
//#endif
//#ifdef HAVE_FSTREAM
#include <fstream>
//#else 
//#include <fstream.h>
//#endif
#include <Exception602.h>
#include <predefine.h>
#include "DataRecovery.h"
#include "TimeInterval.h"



//	数据恢复类
class BJ_DataRecovery
{
	     DataRecovery_ptr  bjDR;
	     IDRecoveryServer_ptr bjDRServer;
	     char    m_strPathName[1000];
	     
	     //用来保存从BJ传过来的数据文件
			 fstream m_outfile;
			 //用来保存日志表的数据
			 Records_var		m_values;
			 CORBA::Long m_nRealFileSize;
			 CORBA::Short m_nExpdTimes;
			 char    m_TableName[ MAX_TABLE_NAME_LENGTH ];
			 int     m_nTableType;
			 //int 		 m_nExpdTimes;
			 int     m_nCurrentExpdTimes;
			 int     m_DXX_TABLE[25];
			 int     m_nDXX_TABLE_FIELD;
			 int     m_RecordsNum;
			 
public:
			BJ_DataRecovery();
			~BJ_DataRecovery();
			
			//	异地中间件的数据恢复管理服务调用该方法通知其数据丢失。
			//	返回值：int  0：成功，<0：失败，>0：警告
			int loseData(const char  DXX_BLOCK_ID[DXX_BLOCK_ID_LENGTH],
			            TimeInterval timeInter,
			            const char* strProvinceCode,
			            const char* TableName) throw(Exception602);
			
			//	开始一个恢复数据的会话，根据输入参数，将数据保存在调用方指定的路径下
			//	的文件中，该方法由数据提供方实现，由丢失数据的本地中间件调用
			//	返回值：int  0：成功，<0：失败，>0：警告
			//	短信息文件格式为文本文件，文本文件的格式是一行一条记录，如附件eg.txt
			//	所示，统计和配置数据为Oracle的Export导出的不带元信息和约束索引等的
			//	数据文件，需要用Oracle的Import导入
			int nBeginGetData(const char DXX_BLOCK_ID[DXX_BLOCK_ID_LENGTH],
			                  const TimeInterval timeInter,
			                  const char* strProvinceCode,
			                  const char* strTableName,
			                  const char* strFileName,
			                  const char* strPathName,
			                  const int nFileSize,
			                  const int timeout)  throw(Exception602);
			
			//	得到下一个文件
			//	返回值：int  0：成功，<0：失败，>0：警告
			//	文件为空，即表示数据处理结束
			int nGetNextData()   throw(Exception602); 
						
			//	返回值：int  0：成功，<0：失败，>0：警告
			int nCancel()  throw(Exception602);
			
			//	获取出错信息，用户使用
			const char* strErrorMessage(int nErrorId)  throw(Exception602); 
			
			int transfer() throw(Exception602);

};

#endif