D:/source/c++/Programme/sally/sally/sallyAPI/DatabaseConnection.h

Go to the documentation of this file.

#pragma once
#include "Define.h"
#include <sqlite3.h>
#include <map>
#include <string>
#include "DatabaseMetaData.h"
#include "Statement.h"
#include "DatabaseObject.h"
#include "StringHelper.h"

namespace SallyAPI
{
        namespace Database
        {

                class DLL_API_SALLY CDatabaseConnection
                {
                private:
                        static std::map<std::string, SallyAPI::Database::CDatabaseConnection*>  m_pOpenFiles;
                        static CRITICAL_SECTION                                                                                                 m_critSectOpenCloseDatabase;

                        int                                     m_iConnectedThreads;
                        sqlite3*                        m_pSqlite;
                        CStatement*                     m_pStatement;
                        CDatabaseMetaData*      m_pDatabaseMetaData;
                        CRITICAL_SECTION        m_critSectLockDatabase;
                        

                        CDatabaseConnection();
                        ~CDatabaseConnection();

                        void                            ConnectThread();
                        void                            DisconnectThread();

                        void                            OpenDB(const std::string& db_name);
                        void                            CloseDB();
                public:
                        int                                     GetConnectedThreads();

                        static SallyAPI::Database::CDatabaseConnection* Open(const std::string& file);
                        static void                     Close(const std::string& file);

                        static void                     Init();
                        static void                     Destroy();
                        
                        CStatement*                     CreateStatement();
                        CDatabaseMetaData*      GetDatabaseMetaData();
                        void                            RefreshMetaData();                      
                        void                            LockDatabase();
                        void                            ReleaseDatabase();
                };
        }
}