diff options
| author | devil1234 <ingerasu1234@yahoo.com> | 2014-11-11 13:14:36 +0000 |
|---|---|---|
| committer | DDuarte <dnpd.dd@gmail.com> | 2014-11-11 13:14:36 +0000 |
| commit | b978f0286c4ff1f00d4806b332f825df80c0112e (patch) | |
| tree | 376bb153c84b14fede7133fb1513c88ea19ebb34 /src/server/shared/Database/Implementation | |
| parent | e876201ac4341243507c8383fdd1bc77daa48f47 (diff) | |
Core/Databases: Add hotfix database to world config and prepared statement for it.
Closes #13533
Diffstat (limited to 'src/server/shared/Database/Implementation')
| -rw-r--r-- | src/server/shared/Database/Implementation/HotfixDatabase.cpp | 24 | ||||
| -rw-r--r-- | src/server/shared/Database/Implementation/HotfixDatabase.h | 48 |
2 files changed, 72 insertions, 0 deletions
diff --git a/src/server/shared/Database/Implementation/HotfixDatabase.cpp b/src/server/shared/Database/Implementation/HotfixDatabase.cpp new file mode 100644 index 00000000000..f60287ef1a7 --- /dev/null +++ b/src/server/shared/Database/Implementation/HotfixDatabase.cpp @@ -0,0 +1,24 @@ +/* + * Copyright (C) 2008-2014 TrinityCore <http://www.trinitycore.org/> + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for + * more details. + * + * You should have received a copy of the GNU General Public License along + * with this program. If not, see <http://www.gnu.org/licenses/>. + */ + +#include "HotfixDatabase.h" + +void HotfixDatabaseConnection::DoPrepareStatements() +{ + if (!m_reconnecting) + m_stmts.resize(MAX_HOTFIXDATABASE_STATEMENTS); +} diff --git a/src/server/shared/Database/Implementation/HotfixDatabase.h b/src/server/shared/Database/Implementation/HotfixDatabase.h new file mode 100644 index 00000000000..13c3af6714e --- /dev/null +++ b/src/server/shared/Database/Implementation/HotfixDatabase.h @@ -0,0 +1,48 @@ +/* + * Copyright (C) 2008-2014 TrinityCore <http://www.trinitycore.org/> + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License as published by the + * Free Software Foundation; either version 2 of the License, or (at your + * option) any later version. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for + * more details. + * + * You should have received a copy of the GNU General Public License along + * with this program. If not, see <http://www.gnu.org/licenses/>. + */ + +#ifndef _HOTFIXDATABASE_H +#define _HOTFIXDATABASE_H + +#include "DatabaseWorkerPool.h" +#include "MySQLConnection.h" + +class HotfixDatabaseConnection : public MySQLConnection +{ + public: + //- Constructors for sync and async connections + HotfixDatabaseConnection(MySQLConnectionInfo& connInfo) : MySQLConnection(connInfo) { } + HotfixDatabaseConnection(ProducerConsumerQueue<SQLOperation*>* q, MySQLConnectionInfo& connInfo) : MySQLConnection(q, connInfo) { } + + //- Loads database type specific prepared statements + void DoPrepareStatements() override; +}; + +typedef DatabaseWorkerPool<HotfixDatabaseConnection> HotfixDatabaseWorkerPool; + +enum HotfixDatabaseStatements +{ + /* Naming standard for defines: + {DB}_{SEL/INS/UPD/DEL/REP}_{Summary of data changed} + When updating more than one field, consider looking at the calling function + name for a suiting suffix. + */ + + MAX_HOTFIXDATABASE_STATEMENTS +}; + +#endif |
