UniSet  1.4.0
DBServer_MySQL.h
См. документацию.
00001 /* This file is part of the UniSet project
00002  * Copyright (c) 2002 Free Software Foundation, Inc.
00003  * Copyright (c) 2002 Pavel Vainerman
00004  *
00005  * This program is free software; you can redistribute it and/or modify
00006  * it under the terms of the GNU General Public License as published by
00007  * the Free Software Foundation; either version 2 of the License, or
00008  * (at your option) any later version.
00009  *
00010  * This program is distributed in the hope that it will be useful,
00011  * but WITHOUT ANY WARRANTY; without even the implied warranty of
00012  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00013  * GNU General Public License for more details.
00014  *
00015  * You should have received a copy of the GNU General Public License
00016  * along with this program; if not, write to the Free Software
00017  * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
00018  */
00019 // --------------------------------------------------------------------------
00023 // -------------------------------------------------------------------------- 
00024 #ifndef DBServer_MySQL_H_
00025 #define DBServer_MySQL_H_
00026 // --------------------------------------------------------------------------
00027 #include <map>
00028 #include "UniSetTypes.h"
00029 #include "DBInterface.h"
00030 #include "DBServer.h"
00031 //------------------------------------------------------------------------------------------
00133 class DBServer_MySQL: 
00134     public DBServer
00135 {
00136     public:
00137         DBServer_MySQL( UniSetTypes::ObjectId id );
00138         DBServer_MySQL();
00139         ~DBServer_MySQL();
00140 
00141         static const Debug::type DBLogInfoLevel = Debug::LEVEL9;
00142 
00143     protected:
00144         typedef std::map<int, std::string> DBTableMap;
00145 
00146         virtual void initDB(DBInterface *db){};
00147         virtual void initDBTableMap(DBTableMap& tblMap){};
00148 
00149         virtual void processingMessage( UniSetTypes::VoidMessage *msg );
00150         virtual void timerInfo( UniSetTypes::TimerMessage* tm );
00151         virtual void sysCommand( UniSetTypes::SystemMessage* sm );
00152 
00153         // Функции обработки пришедших сообщений
00154         virtual void parse( UniSetTypes::SensorMessage* sm );
00155         virtual void parse( UniSetTypes::DBMessage* dbmsg );
00156         virtual void parse( UniSetTypes::InfoMessage* imsg );
00157         virtual void parse( UniSetTypes::AlarmMessage* amsg );
00158         virtual void parse( UniSetTypes::ConfirmMessage* cmsg );
00159 
00160         bool writeToBase( const string& query );
00161         virtual void init_dbserver();
00162         void createTables( DBInterface* db );
00163         
00164         inline const char* tblName(int key)
00165         {
00166             return tblMap[key].c_str();
00167         }
00168 
00169         enum Timers
00170         {
00171             PingTimer,        
00172             ReconnectTimer,   
00173             lastNumberOfTimer
00174         };
00175 
00176 
00177         DBInterface *db;
00178         int PingTime;
00179         int ReconnectTime;
00180         bool connect_ok;    
00182         bool activate;
00183 
00184     private:
00185         DBTableMap tblMap;
00186 
00187 };
00188 //------------------------------------------------------------------------------------------
00189 #endif