From 1d2aafd39bcb79a67357d198ce9b2345642fdd39 Mon Sep 17 00:00:00 2001 From: StormBytePP Date: Wed, 19 Aug 2015 19:02:10 +0200 Subject: Core/Build: Merge common library and move database out of shared --- src/server/database/Logging/AppenderDB.cpp | 45 ++++++++++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 src/server/database/Logging/AppenderDB.cpp (limited to 'src/server/database/Logging/AppenderDB.cpp') diff --git a/src/server/database/Logging/AppenderDB.cpp b/src/server/database/Logging/AppenderDB.cpp new file mode 100644 index 00000000000..9e6ab1a057c --- /dev/null +++ b/src/server/database/Logging/AppenderDB.cpp @@ -0,0 +1,45 @@ +/* + * Copyright (C) 2008-2015 TrinityCore + * + * 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 . + */ + +#include "AppenderDB.h" +#include "Database/DatabaseEnv.h" + +AppenderDB::AppenderDB(uint8 id, std::string const& name, LogLevel level, AppenderFlags /*flags*/, ExtraAppenderArgs /*extraArgs*/) + : Appender(id, name, level), realmId(0), enabled(false) { } + +AppenderDB::~AppenderDB() { } + +void AppenderDB::_write(LogMessage const* message) +{ + // Avoid infinite loop, PExecute triggers Logging with "sql.sql" type + if (!enabled || (message->type.find("sql") != std::string::npos)) + return; + + PreparedStatement* stmt = LoginDatabase.GetPreparedStatement(LOGIN_INS_LOG); + stmt->setUInt64(0, message->mtime); + stmt->setUInt32(1, realmId); + stmt->setString(2, message->type); + stmt->setUInt8(3, uint8(message->level)); + stmt->setString(4, message->text); + LoginDatabase.Execute(stmt); +} + +void AppenderDB::setRealmId(uint32 _realmId) +{ + enabled = true; + realmId = _realmId; +} -- cgit v1.2.3