queryserver.idl

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

/*
 *  file name :  queryserver.idl
 *  create at :  2004-12-28
 *  contents  :  interface IQueryServer
 */

#include "utilities.idl"

typedef sequence <string> Record;
//结果记录，其中sequence为序列，表示可变多个元素的序列

typedef sequence <Record> Records;	
//多条结果记录

interface IResult
{
	short nBegin(in short timeOut);
	
	short nCommit(in short timeOut);
	
	short nRollBack(in short timeOut);
	
	short nGetRecord(out Record value);
	//取当前结果记录，并向后移动一条记录
	
	short nGetRecords(in long nCount, out Records value);
	//取当前记录起的nCount条结果记录，并向后移动nCount条记录
	
	boolean bIsEOF();
	//记录是否取完
	
	boolean bIsBOF();
	//游标是否在第一行之前
	
	short nMoveFirst();	
	//将游标移动到第一行
	
	short nMoveLast();
	//将游标移动到最后一行
	
	short nMoveNext();	
	//向后移动一条记录
	
	short nMovePrev();
	//将游标前移一行
	
	short nGetFieldCount();
	//取结果纪录的属性个数
	
	
	short nGetFieldTypeByIndex(in short nIndex);
	//取结果纪录的属性类型
	//属性类型在Predefine.h中定义
	 
	
	short nGetFieldNameByIndex(in short nIndex, out string strName);
	//取属性名
	
	short nGetFieldValueByIndex(in short nIndex, out string strValue);
	//取当前结果记录的第nIndex个属性值
	
	short nGetFieldValueByFieldName(in string FieldName, out string strValue);
	
	void destroy();
	//释放结果集对象
	
	short  nSelect(in string strStatement, in short nBufSize, in short timeOut);
	
	short  nExec(in string strStatement, in short nBufSize, in short timeOut);
	//执行询问（select）语句strStatement
	
	short  nCacheSelect(in string strStatement, in short nBufSize, in short timeOut);
	//执行基于语义缓存的查询（select）语句strStatement
	
	short  nTopkSelect(in string strStatement, in long nk, in short timeOut);
	//执行Top-k查询语句strStatement
	
	boolean bIsBad();
	
	string strErrorMessage(in short nErrorId);
	
	
};

typedef sequence < IResult > ResultSeq;

interface IQueryServer: IRequestCounter,ILevelControl
//interface IQueryServer
{
	string strErrorMessage(in short nErrorId);
	
	IResult ResConnect(in string strClientID, in short timeOut);
	
	long nListResult(in string strClientID, out ResultSeq Results);
	//返回服务方所有没有释放的nUserID的结果对象,
	//如果nUserID为0,则返回服务方所有结果对象

	
	short nRefresh(in short nMode);
	// 	更新数据字典，在refresh时，将阻塞所有其它请求，直到refresh成功
	//	nMode[0,1],	0:Refresh immediately，and destroy all results
	//			1:Refresh wait until all results destroyed
	
//	short nSetDebug(in short nDebugLevel);
	//进入调试状态，0 表示非调试状态
	//		1 表示调试状态，产生日志
};