From 6d21515939388c5f24e3954880a21bea10c35173 Mon Sep 17 00:00:00 2001
From: Spp <spp@jorge.gr>
Date: Mon, 6 Aug 2012 13:20:24 +0200
Subject: [PATCH] Core/Logging: Implement logging to database

---
 sql/updates/auth/2012_08_06_00_auth_logs.sql |  2 ++
 src/server/shared/Logging/AppenderDB.cpp     | 27 +++++++++++---------
 2 files changed, 17 insertions(+), 12 deletions(-)
 create mode 100644 sql/updates/auth/2012_08_06_00_auth_logs.sql

diff --git a/sql/updates/auth/2012_08_06_00_auth_logs.sql b/sql/updates/auth/2012_08_06_00_auth_logs.sql
new file mode 100644
index 0000000000..04e90e7d20
--- /dev/null
+++ b/sql/updates/auth/2012_08_06_00_auth_logs.sql
@@ -0,0 +1,2 @@
+ALTER TABLE `logs` ADD COLUMN `level` TINYINT(3) UNSIGNED NOT NULL DEFAULT 0 AFTER `type`;
+
diff --git a/src/server/shared/Logging/AppenderDB.cpp b/src/server/shared/Logging/AppenderDB.cpp
index 63af917619..0254ec72bd 100644
--- a/src/server/shared/Logging/AppenderDB.cpp
+++ b/src/server/shared/Logging/AppenderDB.cpp
@@ -16,12 +16,7 @@
  */
 
 #include "AppenderDB.h"
-
-/* FIXME
-#include "DatabaseWorkerPool.h"
-#include "Implementation/LoginDatabase.h" // For logging
-extern DatabaseWorkerPool LoginDatabase;
-*/
+#include "Database/DatabaseEnv.h"
 
 AppenderDB::AppenderDB(uint8 id, std::string const& name, LogLevel level, uint8 realmId):
 Appender(id, name, APPENDER_DB, level), realm(realmId), enable(false)
@@ -32,13 +27,21 @@ AppenderDB::~AppenderDB()
 {
 }
 
-void AppenderDB::_write(LogMessage& /*message*/)
+void AppenderDB::_write(LogMessage& message)
 {
-/* FIXME
-    if (enable)
-        LoginDatabase.PExecute("INSERT INTO logs (time, realm, type, severity, string) "
-            "VALUES (" UI64FMTD ", %u, %u, '%s');", message.mtime, realm, message.type, message.level, message.text.c_str());
-*/
+    if (!enable)
+        return;
+    switch (message.type)
+    {
+        case LOG_FILTER_SQL:
+        case LOG_FILTER_SQL_DRIVER:
+        case LOG_FILTER_SQL_DEV:
+            break; // Avoid infinite loop, PExecute triggers Logging with LOG_FILTER_SQL type
+        default:
+            LoginDatabase.PExecute("INSERT INTO logs (time, realm, type, level, string) "
+            "VALUES (" UI64FMTD ", %u, %u, %u, '%s');", message.mtime, realm, message.type, message.level, message.text.c_str());
+            break;
+    }
 }
 
 void AppenderDB::setEnable(bool _enable)