test.cpp

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

//#include <STAR/CORBA.h>

//#include <STAR/AFLSInitializer.h>
//#include <STAR/Properties.h>
//#include <MTL/MTL.h>

//#include <checkConfig.h>
//#include <STAR/Properties.h>
//#include "BJ_DataRecovery_impl.h"
#include "BJ_DataRecovery.h"
//#include  "queryserver.h"
//#include "TimeInterval.h"
//#include "predefine.h"
#define  NOT_FINISH_GETING_RESULT 101  //代表还需要继续取结果
#define  FINISH_GETING_RESULT     102  //代表已经取完数据了
#define  NOT_ENOUGH_ROOM_FOR_RECOVERYFILE  -103    //用户提供的供恢复的文件大小

#ifdef __UNIX__
#include <sys/time.h>
#endif

#ifdef _WIN32
#include <time.h>
#endif

#ifdef HAVE_FSTREAM
#   include <fstream>
#else
#   include <fstream.h>
#endif

#ifdef HAVE_STD_IOSTREAM
using namespace std;
#endif
#define DEFAULT_FILE_SIZE 300
#define DEFAULT_TIME_OUT  300

int main(int argc, char* argv[], char*[])
{
		int rc;
		BJ_DataRecovery * cDataRecovery;
		cDataRecovery = new BJ_DataRecovery();
		TimeInterval time;
		strcpy(time.BeginTime, "2006-3-16 2:00:00" );
		strcpy(time.EndTime, "2006-3-17 9:00:00");
		

//		rc = cDataRecovery->loseData("20", time, "5\,6", "jm_dxx");

//	  rc = cDataRecovery -> nBeginGetData( "20",
//								            time,
//		                          "5\,6",
//		                           "JM_DXX",
//		                            "",
//		                             "/root/pdb/CBJ_DataRecovery/RECOVERED_DATA",
//		                              DEFAULT_FILE_SIZE,
//		                               DEFAULT_TIME_OUT );
//		cout << "shit3" << endl;
//		cout << "rc =" << rc <<endl;
//	  if (rc == SUCCESS)
//	  {
//    		while (rc == SUCCESS)
//	  		{
//	  			  cout << "nihao1" << endl;
//	  				rc = cDataRecovery -> nGetNextData();
//	  				cout << "nihao2" << endl;
////	  				for (i=0; i<test_values->length(); i++)
////	  				{
////	  						nRecordCount++;
////	  						cout << nRecordCount << ":";
////	  						for(int j=0; j<m_nFieldCount; j++)
////								{
////									cout<<"\t"<<test_values[i][j];
////								}
////								cout<<endl;
////						}
//	  		}
//	  }
//	  cout << "start" << endl;
//	  rc = cDataRecovery -> transfer();
//	  cout << "end" << endl;
		//测试配置表
//	  rc = cDataRecovery -> nBeginGetData( "20",
//								            time,
//		                          "5\,6",
//		                          "GJHH_DZJC_ZB",   //注意！这里必须是大写，这样nTableType里面才认！！！
//		                            "",
//		                             "/root/pdb/CBJ_DataRecovery/RECOVERED_DATA",
//		                              DEFAULT_FILE_SIZE,
//		                               DEFAULT_TIME_OUT );		
		//
		//测试统计表
	  rc = cDataRecovery -> nBeginGetData( "20",
					 									time,
		                          "5\,6",
		                           "DXTJ_DXFL",
		                            "",
		                             "/home/oracle/pdb_rx/DataRecovery/CBJ_DataRecovery/RECOVERED_DATA",
		                              1,  //DEFAULT_FILE_SIZE,
		                               DEFAULT_TIME_OUT );

		char    ExpStatement[ MAX_STATEMENT_LEN ];		
		int i=0;
		while (rc != FINISH_GETING_RESULT)
		{
					 rc = cDataRecovery -> nGetNextData();
					 i++;
					 if (i == 1)
					 {
					 			cout << "111"<< endl;
					  	 //sprintf(ExpStatement, "impdp pdb_cuser/dbc DIRECTORY=dump_dir DUMPFILE=tab.dmp CONTENT=DATA_ONLY TABLE_EXISTS_ACTION=TRUNCATE TABLES= DXTJ_DXFL ");         //, TableName);
					 		 //system (ExpStatement);
					 }
					 else 
					 {
					  	 cout << "222"<< endl;
					  	 //sprintf(ExpStatement, "impdp pdb_cuser/dbc DIRECTORY=dump_dir DUMPFILE=tab.dmp CONTENT=DATA_ONLY TABLE_EXISTS_ACTION=APPEND TABLES= DXTJ_DXFL ");         //, TableName);
					 		 //system (ExpStatement);					 
					 }
	  }

	  return rc;	
}