eiendb_base.hpp

浏览该文件的文档.

#ifndef __EIENDB_BASE_HPP__
#define __EIENDB_BASE_HPP__

#include "winux.hpp"

namespace eiendb
{

#ifdef EIENDB_DLL_USE
    #if defined(_MSC_VER) || defined(WIN32)
        #pragma warning( disable: 4251 )
        #ifdef  EIENDB_DLL_EXPORTS
            #define EIENDB_DLL  __declspec(dllexport)
        #else
            #define EIENDB_DLL  __declspec(dllimport)
        #endif

        #define EIENDB_API __stdcall
    #else
        #define EIENDB_DLL
        #define EIENDB_API
    #endif
#else
    #define EIENDB_DLL
    #define EIENDB_API
#endif

#define EIENDB_FUNC_DECL(ret) EIENDB_DLL ret EIENDB_API
#define EIENDB_FUNC_IMPL(ret) ret EIENDB_API


#ifndef interface
#define interface struct
#endif

typedef void * DBHandle;

class EIENDB_DLL DbError : public winux::Error
{
public:
    enum
    {
        dbeNone, 
        dbeDbSelfError, 
        dbeNotImplemented, 
        dbeConfigParamsError, 
    };

    DbError( int errType, winux::AnsiString const & s ) throw() : winux::Error( errType, s ) { }
};

interface IDBConnection;
interface IDBStatement;
interface IDBResult;

interface EIENDB_DLL IDBConnection
{
    virtual ~IDBConnection() { }

    virtual bool connect();

    virtual bool close();

    virtual void alive() = 0;

    virtual bool selectDb( winux::String const & database );

    virtual bool setLinkCharset( winux::String const & charset );

    virtual winux::ulong affectedRows();

    virtual bool createDb( winux::String const & database );

    virtual bool dropDb( winux::String const & database );

    virtual int errNo();

    virtual winux::String error();

    virtual winux::SharedPointer<IDBResult> query( winux::String const & sql );
    virtual winux::SharedPointer<IDBResult> query( winux::SharedPointer<IDBStatement> stmt );

    virtual bool exec( winux::String const & sql );
    virtual bool exec( winux::SharedPointer<IDBStatement> stmt );

    virtual winux::ulong insertId();

    virtual winux::String escape( winux::String const & str, winux::String const & addQuote = "\'" );
    virtual winux::String escape( winux::byte const * buf, int size, winux::String const & addQuote = "\'" );

    virtual winux::SharedPointer<IDBResult> listDbs();

    virtual winux::SharedPointer<IDBResult> listFields( winux::String const & tableName );

    virtual winux::SharedPointer<IDBResult> listTables();

    virtual winux::String tableDdl( winux::String const & tableName );

    virtual winux::String symbolQuotes( winux::String const & str );

    virtual int loadSql( winux::String const & sqlText, winux::StringArray * arrSql ) = 0;
    virtual int loadSqlFile( winux::IFile * sqlScriptFile, winux::StringArray * arrSql ) = 0;
    virtual int getPrimaryKey( winux::String const & tableName, winux::StringArray * arrKeyColumn ) = 0;

    virtual winux::SharedPointer<IDBStatement> buildStmt( winux::String const & sql );
    virtual winux::SharedPointer<IDBStatement> buildStmt( winux::String const & sql, winux::Mixed const & params ) = 0;
    virtual winux::SharedPointer<IDBStatement> buildStmt( winux::String const & sql, winux::MixedArray const & params );
    virtual winux::SharedPointer<IDBStatement> buildStmt( winux::String const & sql, winux::StringMixedMap const & params );

    virtual operator bool() const = 0;
};

interface EIENDB_DLL IDBStatement
{
    virtual ~IDBStatement() { }
    virtual bool build( winux::String const & sql );
    virtual bool build( winux::String const & sql, winux::Mixed const & params ) = 0;
    virtual bool build( winux::String const & sql, winux::MixedArray const & params );
    virtual bool build( winux::String const & sql, winux::StringMixedMap const & params );
    virtual bool bind( int paramIndex, winux::Mixed const & val );
    virtual bool bind( winux::String const & paramName, winux::Mixed const & val );
};

interface EIENDB_DLL IDBResult
{
    virtual ~IDBResult() { }

    virtual bool dataSeek( int index );

    virtual bool fetchRow( winux::Mixed * fields, int type = 0 ) = 0;

    virtual bool fetchRow( winux::MixedArray * fields );

    virtual bool fetchRow( winux::StringMixedMap * fields );

    virtual winux::String fieldName( int fieldIndex );

    virtual bool free();

    virtual winux::ulong fieldsCount();

    virtual winux::ulong rowsCount();

    virtual winux::String fieldType( int fieldIndex );

    /*  \brief 获取一个结果集中指定字段相关的标记
    \param fieldIndex int 字段索引
    \return string
    virtual winux::String fieldFlags( int fieldIndex )
    {
        throw DBException("fieldFlags() not implemented");
    }*/

    /* \brief 返回结果集中指定字段的长度
     *  \param fieldIndex int 字段索引
     *  \return int
    virtual int fieldLen( int fieldIndex )
    {
        throw DBException("fieldLen() not implemented");
    }*/

    /* \brief 获取指定字段所在表的名称
     *  \param fieldIndex int 字段索引
     *  \return string
    virtual winux::String fieldTable( int fieldIndex )
    {
        throw DBException("fieldTable() not implemented");
    }*/

    /* \brief 从结果集里获取一个单元格的内容
    \param row int 记录索引
    \param field int 字段索引
    \return string
    virtual winux::String result( int row, int field )
    {
        throw DBException("result() not implemented");
    }*/

};

interface EIENDB_DLL IDBModifier
{
    virtual ~IDBModifier() { }

    virtual bool addNew( winux::StringArray const & fieldNames, winux::MixedArray const & values );

    virtual bool addNew( winux::Mixed const & fields ) = 0;

    virtual bool modify( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::Mixed const & prkValue );

    virtual bool modify( winux::Mixed const & fields, winux::Mixed const & prkValue ) = 0;

    virtual bool modifyEx( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::String const & where );

    virtual bool modifyEx( winux::Mixed const & fields, winux::String const & where ) = 0;

    virtual bool deleteOne( winux::Mixed const & prkValue );

    virtual bool deleteEx( winux::String const & where );
};

EIENDB_FUNC_DECL(winux::String) MixedToEscapedStr( winux::Mixed const & m, IDBConnection * cnn, winux::String const & addQuote = "\'" );

class EIENDB_DLL DBModifier : public IDBModifier
{
public:
    DBModifier( IDBConnection * cnn, winux::String const & tableName );
    virtual ~DBModifier();

    virtual bool addNew( winux::StringArray const & fieldNames, winux::MixedArray const & values );
    virtual bool addNew( winux::Mixed const & fields );
    virtual bool modify( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::Mixed const & prkValue );
    virtual bool modify( winux::Mixed const & fields, winux::Mixed const & prkValue );
    virtual bool modifyEx( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::String const & where );
    virtual bool modifyEx( winux::Mixed const & fields, winux::String const & where );
    virtual bool deleteOne( winux::Mixed const & prkValue );
    virtual bool deleteEx( winux::String const & where );

protected:
    virtual void _getTableInfo() = 0;
    IDBConnection * _cnn;
    winux::String _tableName;
    winux::StringArray _prkColumn; // 主键
    winux::StringArray _fieldNames; // 原始字段名
    //bool _prkAutoIncrement;  // 自动增长

    DISABLE_OBJECT_COPY(DBModifier)
};


}

#endif // __EIENDB_BASE_HPP__