mgrbaseclient.h

1)安装sp2补丁. 2)安装中文语言包. 3)关闭除系统盘除外的系统还原 4)控制面板->区域和语言选项->区域选项 选择中国,位置:选择中国.高级选项卡 非unicode程序的语

BOOL  TreeQueryDataEx(LPCSTR dbname,LPCSTR treename,LPCSTR idxname,NetTable &param,LPCSTR cols,NetTable *data);
BOOL  TreeGetItem(LPCSTR dbname,LPCSTR treename,superint_ut id,LPCSTR cols,NetTable *data);
BOOL  TreeIsFamily(LPCSTR dbname,LPCSTR treename,superint_ut parentid,superint_ut id);


BOOL  GetStatus(LPCSTR dbname,NetTable *status);
superint_ut FSCacheGetModifySize();
superint_ut FSCacheGetMemSize();
superint_ut DatabaseGetMemSize(LPCSTR dbname);
superint_ut DatabaseGetModifySize(LPCSTR dbname);
superint_ut TableGetModifySize(LPCSTR dbname,LPCSTR tblname);
superint_ut TableGetMemSize(LPCSTR dbname,LPCSTR tblname);
superint_ut IndexGetModifySize(LPCSTR dbname,LPCSTR idxname);
superint_ut IndexGetMemSize(LPCSTR dbname,LPCSTR idxname);
superint_ut SortGetModifySize(LPCSTR dbname,LPCSTR sortname);
superint_ut SortGetMemSize(LPCSTR dbname,LPCSTR sortname);

BOOL GetCurrentProcs(NetTable *procs);
BOOL DumpThreadStack(HANDLE threadid,NetTable *stack);


//memory file support
BOOL  MemoryFileCreate(LPCSTR name,superint_ut size);
BOOL  MemoryFileDrop(LPCSTR name);
int   MemoryFileRead(LPCSTR name,superint_ut pos,BYTE *buf,int bufsize);
int   MemoryFileWrite(LPCSTR name,superint_ut pos,BYTE *buf,int bufsize);
superint_ut  MemoryFileGetLength(LPCSTR name);
BOOL  MemoryFileIsExist(LPCSTR name);
BOOL  MemoryFileList(NetTable *nt);


BOOL LogLoadClientConfig();

//pipe support
superint_ut PipePoolCountFreeSpace();
superint_ut PipePoolCountTotalSpace();
int         PipePoolCountActivePipe();

superint_ut PipeOpen(LPCSTR dbname,LPCSTR tblname,superint_ut rowid,LPCSTR colname);
BOOL        PipeClose(superint_ut pipe);
BOOL        PipeIsValid(superint_ut pipe);
int         PipeRead(superint_ut pipe,BYTE *buf,int bufsize);
int         PipeTryRead(superint_ut pipe,BYTE *buf,int bufsize);
int         PipeSkipRead(superint_ut pipe,int size);
BOOL        PipeWrite(superint_ut pipe,BYTE *buf,int bufsize);
BOOL        PipeWriteEnd(superint_ut pipe);
BOOL        PipeWriteBack(superint_ut pipe,BYTE *buf,int bufsize);
BOOL        PipeAbort(superint_ut pipe);
BOOL        PipeIsAbort(superint_ut pipe);
BOOL        PipeIsWriteEnd(superint_ut pipe);
BOOL        PipeIsFinished(superint_ut pipe);
int         PipeCountReadableData(superint_ut pipe);
BOOL        PipeIsEmpty(superint_ut pipe);
BOOL        PipeCanRead(superint_ut pipe);
BOOL        PipeCanWrite(superint_ut pipe);

};


class MLongBinaryFile :public CFile
{
public:
	superint_ut m_pos;
	MGRBaseClient *m_client;

	CString m_dbname;
	CString m_tblname;
	superint_ut m_rowid;
	CString m_colname;

public:

	MLongBinaryFile(MGRBaseClient *client);
	~MLongBinaryFile();

	BOOL Open(LPCSTR dbname,LPCSTR tblname,superint_ut rowid,LPCSTR colname);

	virtual superint_ut GetPosition() ;
	virtual superint_ut Seek(superint_ut lOff, UINT nFrom);
	virtual superint_ut GetLength() ;

	virtual long Read(void* lpBuf, long nCount);
	virtual long Write(const void* lpBuf, long nCount);

	virtual BOOL Close();

};


class MatrixPipe:public BasePipe
{
public:
	superint_ut m_pipeid;
	MGRBaseClient *m_client;

public:
	MatrixPipe(MGRBaseClient *client);
	~MatrixPipe();

	BOOL Open(LPCSTR dbname,LPCSTR tblname,superint_ut rowid,LPCSTR colname);
	BOOL Close();

virtual BOOL  Write(BYTE *buf,int size);  //thread safe
virtual BOOL  WriteEnd();                 //thread safe
virtual BOOL  WriteBack(BYTE *buf,int size);//thread safe
virtual int   Read(BYTE *buf,int size);   //thread safe
virtual int   TryRead(BYTE *buf,int size);//thread safe
virtual int   SkipRead(int size);
virtual BOOL  Abort();                    //thread safe
virtual BOOL  IsEmpty();                  //thread safe
virtual BOOL  IsFinished();               //thread safe
virtual BOOL  IsAbort();                  //thread safe
virtual BOOL  CanWrite();                 //thread safe
virtual BOOL  CanRead();                  //thread safe
virtual int   CountReadableData();        //thread safe
virtual BOOL  IsWriteEnd();               //thread safe

};

class MatrixMemoryFile:public CFile
{
public:
	superint_ut m_pos,m_length;
	MGRBaseClient m_client;
	CString m_name;

public:
	MatrixMemoryFile(NetManager *nfm);
	~MatrixMemoryFile();


	BOOL Create(LPCSTR server,int port,LPCSTR name,superint_ut size);
	BOOL Drop(LPCSTR server,int port,LPCSTR name);

	virtual superint_ut GetPosition() ;
	virtual superint_ut Seek(superint_ut lOff, UINT nFrom);
	virtual superint_ut GetLength() ;

	virtual long Read(void* lpBuf, long nCount);
	virtual long Write(const void* lpBuf, long nCount);

	virtual BOOL Close();

};

struct MGRBASE{
	CString server;
	int     port;
	CString dbname;
};

struct MULTIMGRBASE{

	MGRBASE  db[256];
	int      dbn;

	MTReadWriteLock    wrcs;
};

class MultiBase :public CObject
{
public:
	NetManager *m_nm; 

	MULTIMGRBASE *m_mb;

	CMonitorServer *m_mon;
public:
	MultiBase(NetManager *nm,CMonitorServer *mon=NULL);
	~MultiBase();

BOOL  SetServer(MULTIMGRBASE *mb);

BOOL  TableCreate(LPCSTR tblname,LPCSTR colsdef);
BOOL  TableDrop(LPCSTR tblname);
int   TableInsert(LPCSTR tblname,NetTable &data);
int   TableInsert(NetTable &param);
superint_ut TableCountRow(LPCSTR tblname);
BOOL  _TableCountRow(LPCSTR tblname,NetTable *count);
BOOL  TableCountRow(LPCSTR tblname,NetTable *count);

BOOL  IndexCreate(LPCSTR tblname,LPCSTR idxname,BOOL bunique,LPCSTR keydef);
BOOL  IndexDrop(LPCSTR tblname,LPCSTR idxname);
BOOL  IndexQueryData(LPCSTR tblname,LPCSTR idxname,MFTKEY &key,int num,LPCSTR cols,NetTable *data);
superint_ut  IndexCountKey(LPCSTR idxname,MFTKEY &key);
BOOL  IndexDeleteData(LPCSTR tblname,LPCSTR idxname,MFTKEY &key);

};

#endif