//    BJ_DataRecovery.h//   北京數(shù)據(jù)恢復(fù)服務(wù)的本地代理，用于封裝//   北京數(shù)據(jù)恢復(fù)服務(wù)：BJ_DataRecovery，編寫依據(jù)《接口規(guī)范》。//   相關(guān)軟件：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"//	數(shù)據(jù)恢復(fù)類class BJ_DataRecovery{	     DataRecovery_ptr  bjDR;	     IDRecoveryServer_ptr bjDRServer;	     char    m_strPathName[1000];	     	     //用來保存從BJ傳過來的數(shù)據(jù)文件			 fstream m_outfile;			 //用來保存日志表的數(shù)據(jù)			 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();						//	異地中間件的數(shù)據(jù)恢復(fù)管理服務(wù)調(diào)用該方法通知其數(shù)據(jù)丟失。			//	返回值：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);						//	開始一個恢復(fù)數(shù)據(jù)的會話，根據(jù)輸入?yún)?shù)，將數(shù)據(jù)保存在調(diào)用方指定的路徑下			//	的文件中，該方法由數(shù)據(jù)提供方實現(xiàn)，由丟失數(shù)據(jù)的本地中間件調(diào)用			//	返回值：int  0：成功，<0：失敗，>0：警告			//	短信息文件格式為文本文件，文本文件的格式是一行一條記錄，如附件eg.txt			//	所示，統(tǒng)計和配置數(shù)據(jù)為Oracle的Export導(dǎo)出的不帶元信息和約束索引等的			//	數(shù)據(jù)文件，需要用Oracle的Import導(dǎo)入			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：警告			//	文件為空，即表示數(shù)據(jù)處理結(jié)束			int nGetNextData()   throw(Exception602); 									//	返回值：int  0：成功，<0：失敗，>0：警告			int nCancel()  throw(Exception602);						//	獲取出錯信息，用戶使用			const char* strErrorMessage(int nErrorId)  throw(Exception602); 						int transfer() throw(Exception602);};#endif