2 * Copyright (C) 2005,2006,2007 MaNGOS <http://www.mangosproject.org/>
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; either version 2 of the License, or
7 * (at your option) any later version.
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 * GNU General Public License for more details.
14 * You should have received a copy of the GNU General Public License
15 * along with this program; if not, write to the Free Software
16 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 #ifndef _DatabasePostgre_H
20 #define _DatabasePostgre_H
22 #include "Policies/Singleton.h"
23 #include "zthread/FastMutex.h"
27 #define FD_SETSIZE 1024
29 #include <postgre/libpq/libpq-fe.h>
34 class DatabasePostgre
: public Database
36 friend class MaNGOS::OperatorNew
<DatabasePostgre
>;
42 //! Initializes Postgres and connects to a server.
43 /*! infoString should be formated like hostname;username;password;database. */
44 bool Initialize(const char *infoString
);
45 void InitDelayThread();
46 void HaltDelayThread();
47 QueryResult
* Query(const char *sql
);
48 bool Execute(const char *sql
);
49 bool DirectExecute(const char* sql
);
50 bool BeginTransaction();
51 bool CommitTransaction();
52 bool RollbackTransaction();
54 operator bool () const { return mPGconn
!= NULL
; }
56 unsigned long escape_string(char *to
, const char *from
, unsigned long length
);
57 using Database::escape_string
;
59 // must be call before first query in thread
61 // must be call before finish thread run
64 ZThread::FastMutex mMutex
;
65 ZThread::FastMutex tranMutex
;
67 ZThread::ThreadImpl
* tranThread
;
71 static size_t db_count
;
73 bool _TransactionCmd(const char *sql
);