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, 
        dbeMysqlError, 
        dbeSqliteError, 
        dbePgsqlError, 
    };

    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();

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

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

    virtual size_t 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 size_t insertId();

    virtual winux::String escape( winux::String const & str, winux::String const & addQuote = "\'" );

    virtual winux::String escape( void const * buf, size_t 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 size_t loadSql( winux::String const & sqlText, winux::StringArray * arrSql );
    virtual size_t loadSqlFile( winux::IFile * sqlScriptFile, winux::StringArray * arrSql );
    virtual size_t getPrimaryKey( winux::String const & tableName, winux::StringArray * arrKeyColumn );

    virtual winux::SharedPointer<IDbStatement> buildStmt( winux::String const & sql );
    virtual winux::SharedPointer<IDbStatement> buildStmt( winux::String const & sql, winux::Mixed const & params );
    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 );
    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( size_t 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( size_t index );

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

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

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

    virtual winux::String fieldName( size_t fieldIndex );

    virtual bool free();

    virtual size_t fieldsCount();

    virtual size_t rowsCount();

    virtual winux::String fieldType( size_t 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 );

    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 );
};

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 ) override;
    virtual bool addNew( winux::Mixed const & fields ) override;
    virtual bool modify( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::Mixed const & prkValue ) override;
    virtual bool modify( winux::Mixed const & fields, winux::Mixed const & prkValue ) override;
    virtual bool modifyEx( winux::StringArray const & fieldNames, winux::MixedArray const & values, winux::String const & where ) override;
    virtual bool modifyEx( winux::Mixed const & fields, winux::String const & where ) override;
    virtual bool deleteOne( winux::Mixed const & prkValue ) override;
    virtual bool deleteEx( winux::String const & where ) override;

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__