interfaces.hpp

ncbi源码

    virtual ~CMSDBL_CursorCmd();

private:
    bool x_AssignParams();
    I_ITDescriptor* x_GetITDescriptor(unsigned int item_num);

    CMSDBL_Connection*   m_Connect;
    DBPROCESS*         m_Cmd;
    string             m_Name;
    CDB_LangCmd*       m_LCmd;
    string             m_Query;
    CDB_Params         m_Params;
    bool               m_IsOpen;
    bool               m_HasFailed;
    bool               m_IsDeclared;
    CMSDBL_CursorResult* m_Res;
    int                m_RowCount;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_BCPInCmd::
//

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_BCPInCmd : public I_BCPInCmd
{
    friend class CMSDBL_Connection;
protected:
    CMSDBL_BCPInCmd(CMSDBL_Connection* con, DBPROCESS* cmd,
                  const string& table_name, unsigned int nof_columns);

    virtual bool Bind(unsigned int column_num, CDB_Object* param_ptr);
    virtual bool SendRow();
    virtual bool CompleteBatch();
    virtual bool Cancel();
    virtual bool CompleteBCP();
    virtual void Release();

    ~CMSDBL_BCPInCmd();

private:
    bool x_AssignParams(void* pb);

    CMSDBL_Connection* m_Connect;
    DBPROCESS*       m_Cmd;
    CDB_Params       m_Params;
    bool             m_WasSent;
    bool             m_HasFailed;
    bool             m_HasTextImage;
    bool             m_WasBound;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_SendDataCmd::
//

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_SendDataCmd : public I_SendDataCmd {
    friend class CMSDBL_Connection;
protected:
    CMSDBL_SendDataCmd(CMSDBL_Connection* con, DBPROCESS* cmd, size_t nof_bytes);

    virtual size_t SendChunk(const void* chunk_ptr, size_t nof_bytes);
    virtual void   Release();

    ~CMSDBL_SendDataCmd();

private:
    CMSDBL_Connection* m_Connect;
    DBPROCESS*       m_Cmd;
    size_t           m_Bytes2go;
};



/////////////////////////////////////////////////////////////////////////////
//
//  SDBL_ColDescr::
//

struct SDBL_ColDescr
{
    DBINT      max_length;
    EDB_Type   data_type;
    string     col_name;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_RowResult::
//

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_RowResult : public I_Result
{
    friend class CMSDBL_LangCmd;
    friend class CMSDBL_RPCCmd;
    friend class CMSDBL_Connection;
protected:
    CMSDBL_RowResult(DBPROCESS* cmd, unsigned int* res_status,
                   bool need_init = true);

    virtual EDB_ResType     ResultType() const;
    virtual unsigned int    NofItems() const;
    virtual const char*     ItemName    (unsigned int item_num) const;
    virtual size_t          ItemMaxSize (unsigned int item_num) const;
    virtual EDB_Type        ItemDataType(unsigned int item_num) const;
    virtual bool            Fetch();
    virtual int             CurrentItemNo() const;
    virtual CDB_Object*     GetItem(CDB_Object* item_buf = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();
    virtual bool            SkipItem();

    virtual ~CMSDBL_RowResult();

    // data
    DBPROCESS*     m_Cmd;
    int            m_CurrItem;
    bool           m_EOR;
    unsigned int   m_NofCols;
    int            m_CmdNum;
    unsigned int*  m_ResStatus;
    size_t         m_Offset;
    SDBL_ColDescr* m_ColFmt;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_BlobResult::
//

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_BlobResult : public I_Result
{
    friend class CMSDBL_LangCmd;
    friend class CMSDBL_RPCCmd;
    friend class CMSDBL_Connection;
protected:
    CMSDBL_BlobResult(DBPROCESS* cmd);

    virtual EDB_ResType     ResultType() const;
    virtual unsigned int    NofItems() const;
    virtual const char*     ItemName    (unsigned int item_num) const;
    virtual size_t          ItemMaxSize (unsigned int item_num) const;
    virtual EDB_Type        ItemDataType(unsigned int item_num) const;
    virtual bool            Fetch();
    virtual int             CurrentItemNo() const;
    virtual CDB_Object*     GetItem(CDB_Object* item_buf = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();
    virtual bool            SkipItem();

    virtual ~CMSDBL_BlobResult();

    // data
    DBPROCESS*    m_Cmd;
    int           m_CurrItem;
    bool          m_EOR;
    int           m_CmdNum;
    char          m_Buff[2048];
    SDBL_ColDescr m_ColFmt;
    int           m_BytesInBuffer;
    int           m_ReadedBytes;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_ParamResult::
//  CMSDBL_ComputeResult::
//  CMSDBL_StatusResult::
//  CMSDBL_CursorResult::
//

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_ParamResult : public CMSDBL_RowResult
{
    friend class CMSDBL_LangCmd;
    friend class CMSDBL_RPCCmd;
    friend class CMSDBL_Connection;
protected:
    CMSDBL_ParamResult(DBPROCESS* cmd, int nof_params);
    virtual EDB_ResType     ResultType() const;
    virtual bool            Fetch();
    virtual CDB_Object*     GetItem(CDB_Object* item_buff = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();

    virtual ~CMSDBL_ParamResult();

    // data
    bool m_1stFetch;
};


class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_ComputeResult : public CMSDBL_RowResult
{
    friend class CMSDBL_LangCmd;
    friend class CMSDBL_RPCCmd;
    friend class CMSDBL_Connection;
protected:
    CMSDBL_ComputeResult(DBPROCESS* cmd, unsigned int* res_stat);
    virtual EDB_ResType     ResultType() const;
    virtual bool            Fetch();
    virtual int             CurrentItemNo() const;
    virtual CDB_Object*     GetItem(CDB_Object* item_buff = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();

    virtual ~CMSDBL_ComputeResult();

    // data
    int  m_ComputeId;
    bool m_1stFetch;
};


class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_StatusResult : public I_Result
{
    friend class CMSDBL_LangCmd;
    friend class CMSDBL_RPCCmd;
    friend class CMSDBL_Connection;
protected:
    CMSDBL_StatusResult(DBPROCESS* cmd);
    virtual EDB_ResType     ResultType() const;
    virtual unsigned int    NofItems() const;
    virtual const char*     ItemName    (unsigned int item_num) const;
    virtual size_t          ItemMaxSize (unsigned int item_num) const;
    virtual EDB_Type        ItemDataType(unsigned int item_num) const;
    virtual bool            Fetch();
    virtual int             CurrentItemNo() const ;
    virtual CDB_Object*     GetItem(CDB_Object* item_buff = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();
    virtual bool            SkipItem();

    virtual ~CMSDBL_StatusResult();

    // data
    int    m_Val;
    size_t m_Offset;
    bool   m_1stFetch;
};


class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_CursorResult : public I_Result
{
    friend class CMSDBL_CursorCmd;
protected:
    CMSDBL_CursorResult(CDB_LangCmd* cmd);
    virtual EDB_ResType     ResultType() const;
    virtual unsigned int    NofItems() const;
    virtual const char*     ItemName    (unsigned int item_num) const;
    virtual size_t          ItemMaxSize (unsigned int item_num) const;
    virtual EDB_Type        ItemDataType(unsigned int item_num) const;
    virtual bool            Fetch();
    virtual int             CurrentItemNo() const;
    virtual CDB_Object*     GetItem(CDB_Object* item_buff = 0);
    virtual size_t          ReadItem(void* buffer, size_t buffer_size,
                                     bool* is_null = 0);
    virtual I_ITDescriptor* GetImageOrTextDescriptor();
    virtual bool            SkipItem();

    virtual ~CMSDBL_CursorResult();

    // data
    CDB_LangCmd* m_Cmd;
    CDB_Result*  m_Res;
};



/////////////////////////////////////////////////////////////////////////////
//
//  CMSDBL_ITDescriptor::
//

#define CMSDBL_ITDESCRIPTOR_TYPE_MAGNUM 0xd01

class NCBI_DBAPIDRIVER_MSDBLIB_EXPORT CMSDBL_ITDescriptor : public I_ITDescriptor
{
    friend class CMSDBL_RowResult;
    friend class CMSDBL_BlobResult;
    friend class CMSDBL_Connection;
    friend class CMSDBL_CursorCmd;
public:
    virtual int DescriptorType() const;
    virtual ~CMSDBL_ITDescriptor();

protected:
    CMSDBL_ITDescriptor(DBPROCESS* m_link, int col_num);
    CMSDBL_ITDescriptor(DBPROCESS* m_link, const CDB_ITDescriptor& inp_d);

    // data
    string   m_ObjName;
    DBBINARY m_TxtPtr[DBTXPLEN];
    DBBINARY m_TimeStamp[DBTXTSLEN];
    bool     m_TxtPtr_is_NULL;
    bool     m_TimeStamp_is_NULL;
};


END_NCBI_SCOPE

#endif  /* NCBI_OS_MSWIN */
#endif  /* DBAPI_DRIVER_DBLIB___INTERFACES__HPP */



/*
 * ===========================================================================
 * $Log: interfaces.hpp,v $
 * Revision 1000.1  2004/06/01 19:17:57  gouriano
 * PRODUCTION: UPGRADED [GCC34_MSVC7] Dev-tree R1.6
 *
 * Revision 1.6  2004/05/18 19:22:08  gorelenk
 * Conditionaly added typedef for LPCBYTE missed in MSVC7 headers .
 *
 * Revision 1.5  2003/07/17 20:42:47  soussov
 * connections pool improvements
 *
 * Revision 1.4  2003/06/06 18:43:16  soussov
 * Removes SetPacketSize()
 *
 * Revision 1.3  2003/06/05 15:56:19  soussov
 * adds DumpResults method for LangCmd and RPC, SetResultProcessor method for Connection interface
 *
 * Revision 1.2  2003/02/13 15:43:18  ivanov
 * Added export specifier NCBI_DBAPIDRIVER_MSDBLIB_EXPORT for class definitions
 *
 * Revision 1.1  2002/07/02 16:02:25  soussov
 * initial commit
 *
 * ===========================================================================
 */