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 "DataRecovery_impl.h"
#include "DataRecovery.h"
#include  "queryserver.h"
#include "TimeInterval.h"
#include "predefine.h"

#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

char * 			g_sAflsConfig;
Records_var theRecords;
DataRecovery_var g_BJDataRecovery;

int exec_test()
{
		int rc = SUCCESS;
		rc =g_BJDataRecovery -> loseData("20", 
		      													 "2005-12-8 1:00:00",
		                                 "2005-12-9 23:00:00",
		                                 "5\,6",
		                                 "dzfx_dxx");
		                                 
		if (rc != SUCCESS)
		{
				cerr << "loseData error! error code =" << rc <<endl;
		}
		
		
}

int  run(CORBA::ORB_ptr orb, int argc, char* argv[])
{  
	//Get "Afls Server" object
	CORBA::Object_var aflsobj = orb->string_to_object(g_sAflsConfig);
	Afls_var afls=Afls::_narrow(aflsobj);
	assert(!CORBA::is_nil(afls));
	
	try
	{
		if (CORBA::is_nil(g_BJDataRecovery))
		{
			// Get "SServer" object
		    CORBA::Object_var drobj =afls->alloc_obj("DataRecovery");
		    assert(!CORBA::is_nil(drobj));		   	    	
		    g_BJDataRecovery = DataRecovery::_narrow(drobj);
		    assert(!CORBA::is_nil(g_BJDataRecovery));
		}
		
		exec_test();
	}
	catch(const CORBA::Exception& ex)
	{
		g_BJDataRecovery =NULL;
		cout <<"perhaps QueryServer have breakdown ! please  check it "<<endl;
		cout << ex <<endl;
	} 
	return 0;
}

int main(int argc, char* argv[], char*[])
{
	int status = 0;

	CConfCheck AflsConfCheck;
	
	if (AflsConfCheck.nCheckConf() != 0)
		return -1;
	
	g_sAflsConfig = AflsConfCheck.sGetAflsConf();
	
	CORBA::ORB_var orb;
	
	try
	{
		orb = CORBA::ORB_init(argc, argv);
		status = run(orb, argc, argv);
	     
	}
	catch(const CORBA::Exception& ex)
	{
		cout<<endl;
		cout <<" some Server Objects have breakdown !\n"
	        <<"please restart psql after check those Server\n";
	}
	if(!CORBA::is_nil(orb))
	{
		try
		{
			orb -> destroy();
		}
		catch(const CORBA::Exception& ex)
		{ 
			cout<<endl;
			cout <<"orb destroy is error!"<<endl;
		}
	}
	
	return status;
}