tcdatabase.h

// **************************************************************************
// Tianchi C++ library for Qt (open source)
// 天池共享源码库
// 版权所有 (C) 天池共享源码库开发组
// 授权协议：请阅读天池共享源码库附带的授权协议
// **************************************************************************
// 文档说明：数据库操作类
// ==========================================================================
// 开发日志：
// 日期         人员        说明
// --------------------------------------------------------------------------
// 2013.05.03   圣域天子    建立
//
// ==========================================================================
// ==========================================================================
#ifndef TIANCHI_TCDATABASE_H
#define TIANCHI_TCDATABASE_H

#include <tianchi/tcglobal.h>

#include <QVariant>
#include <QMultiHash>
#include <QStringList>
#include <QSqlDatabase>

typedef QHash<QString, QByteArray>  TcParams;
class TIANCHI_API TcDatabase
{
public:
    TcDatabase();
    virtual ~TcDatabase(void);

    enum DBType
    {
        SQLSERVER =  1,
        SQLITE    = 11
    };

    static  char     typeFrom(QVariant::Type type);

    static  int      dbType(const QString& typeName);
    static  TcParams addParams(const QStringList& keys, 
            const QList<QByteArray>& values);


    void setDatabase(int dbType,
                     const QString& hostName, int hostPort,
                     const QString& dbName, const QString& username, 
                     const QString& password);
    bool setDatabase(const QString& typeName,
                     const QString& hostName, int hostPort,
                     const QString& dbName, const QString& username, 
                     const QString& password);
    void setDatabase(int dbType,
                     const QString& dbName, 
                     const QString& username = QString(), 
                     const QString& password = QString());
    bool setDatabase(const QString& typeName,
                     const QString& dbName, 
                     const QString& username = QString(), 
                     const QString& password = QString());

    QString CreateDDL;

    QString SqlLibrary;

    QStringList errors;

    QString lastError();

protected:
    int     m_dbType;
    QString m_typeName;
    QString m_hostName;
    int     m_hostPort;
    QString m_dbName;
    QString m_username;
    QString m_password;

    QSqlDatabase    m_handle;

    // 数据引擎
    QString m_engineFile;
    struct SQLContext
    {
        QString                         id;
        QString                         text;
        QMultiHash<QString, QString>    params;
    };
    QHash<QString, SQLContext>  m_sqls;
    void clearComment(QString& s);

    QSqlQuery* prepare(const QString& sqlID, TcParams prams,
                       QString& error, int userNo = 0, 
                       const QString& userID = QString(), 
                       const QString& username = QString());
public:
    inline int      dbType()   const { return m_dbType;   }
    inline QString  typeName() const { return m_typeName; }
    inline QString  hostName() const { return m_hostName; }
    inline int      hostPort() const { return m_hostPort; }
    inline QString  dbName()   const { return m_dbName;   }

    inline QSqlDatabase handle() const { return m_handle; }
    inline int          sqlCount() const { return m_sqls.count(); }

public:
    int  open();

    void close();

    inline bool isOpened() const { return m_handle.isOpen(); }

    void loadEngine();
    void loadEngine(const QString& filename);

    bool exec(int& result, const QString& sqlID, 
            const TcParams& prams,
            int userNo = 0, 
            const QString& userID = QString(), 
            const QString& username = QString());
    bool exec(QVariantList& list, 
            const QString& sqlID, 
            const TcParams& params,
            int userNo = 0, 
            const QString& userID = QString(), 
            const QString& username = QString());
    int exec(int& result, QVariantList& list, 
            const QString& sqlID, const TcParams& params,
            int userNo = 0, 
            const QString& userID = QString(), 
            const QString& username = QString());
    int exec(int& result, QList<QByteArray>& list, 
            const QString& sqlID, const TcParams& params,
            int userNo = 0, 
            const QString& userID = QString(), 
            const QString& username = QString());
};

#endif // TIANCHI_TCDATABASE_H