debug tags updated
[public/netxms.git] / src / db / libnxdb / session.cpp
index 3a7211f..8b68062 100644 (file)
@@ -23,6 +23,9 @@
 
 #include "libnxdb.h"
 
+#define DEBUG_TAG_CONNECTION  _T("db.conn")
+#define DEBUG_TAG_QUERY       _T("db.query")
+
 /**
  * Check if statement handle is valid
  */
@@ -66,7 +69,7 @@ DB_HANDLE LIBNXDB_EXPORTABLE DBConnect(DB_DRIVER driver, const TCHAR *server, co
    DBDRV_CONNECTION hDrvConn;
    DB_HANDLE hConn = NULL;
 
-       nxlog_debug_tag(_T("db.connect"), 8, _T("DBConnect: server=%s db=%s login=%s schema=%s"), CHECK_NULL(server), CHECK_NULL(dbName), CHECK_NULL(login), CHECK_NULL(schema));
+       nxlog_debug_tag(DEBUG_TAG_CONNECTION, 8, _T("DBConnect: server=%s db=%s login=%s schema=%s"), CHECK_NULL(server), CHECK_NULL(dbName), CHECK_NULL(login), CHECK_NULL(schema));
 #ifdef UNICODE
        char *mbServer = (server == NULL) ? NULL : MBStringFromWideString(server);
        char *mbDatabase = (dbName == NULL) ? NULL : MBStringFromWideString(dbName);
@@ -108,7 +111,7 @@ DB_HANDLE LIBNXDB_EXPORTABLE DBConnect(DB_DRIVER driver, const TCHAR *server, co
 #endif
          if (driver->m_fpDrvSetPrefetchLimit != NULL)
             driver->m_fpDrvSetPrefetchLimit(hDrvConn, driver->m_defaultPrefetchLimit);
-                  nxlog_debug_tag(_T("db.connect"), 4, _T("New DB connection opened: handle=%p"), hConn);
+                  nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("New DB connection opened: handle=%p"), hConn);
          if (s_sessionInitCb != NULL)
             s_sessionInitCb(hConn);
       }
@@ -138,7 +141,7 @@ void LIBNXDB_EXPORTABLE DBDisconnect(DB_HANDLE hConn)
    if (hConn == NULL)
       return;
 
-   nxlog_debug_tag(_T("db.connect"), 4, _T("DB connection %p closed"), hConn);
+   nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("DB connection %p closed"), hConn);
    
    InvalidatePreparedStatements(hConn);
 
@@ -172,7 +175,7 @@ static void DBReconnect(DB_HANDLE hConn)
    int nCount;
        WCHAR errorText[DBDRV_MAX_ERROR_TEXT];
 
-   nxlog_debug_tag(_T("db.connect"), 4, _T("DB reconnect: handle=%p"), hConn);
+   nxlog_debug_tag(DEBUG_TAG_CONNECTION, 4, _T("DB reconnect: handle=%p"), hConn);
 
    InvalidatePreparedStatements(hConn);
        hConn->m_driver->m_fpDrvDisconnect(hConn->m_connection);
@@ -264,11 +267,11 @@ bool LIBNXDB_EXPORTABLE DBQueryEx(DB_HANDLE hConn, const TCHAR *szQuery, TCHAR *
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), szQuery, ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), szQuery, ms);
    }
    if ((dwResult == DBERR_SUCCESS) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    
@@ -335,11 +338,11 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectEx(DB_HANDLE hConn, const TCHAR *szQuery, T
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s sync query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s sync query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    MutexUnlock(hConn->m_mutexTransLock);
@@ -816,11 +819,11 @@ DB_UNBUFFERED_RESULT LIBNXDB_EXPORTABLE DBSelectUnbufferedEx(DB_HANDLE hConn, co
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s unbuffered query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s unbuffered query: \"%s\" [%d ms]"), (hResult != NULL) ? _T("Successful") : _T("Failed"), szQuery, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), szQuery, (int)ms);
       s_perfLongRunningQueries++;
    }
    if (hResult == NULL)
@@ -1163,7 +1166,7 @@ DB_STATEMENT LIBNXDB_EXPORTABLE DBPrepareEx(DB_HANDLE hConn, const TCHAR *query,
    if (hConn->m_driver->m_dumpSql)
    {
       ms = GetCurrentTimeMs() - ms;
-               nxlog_debug_tag(_T("db.query"), 9, _T("{%p} %s prepare: \"%s\" [%d ms]"), result, (result != NULL) ? _T("Successful") : _T("Failed"), query, ms);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} %s prepare: \"%s\" [%d ms]"), result, (result != NULL) ? _T("Successful") : _T("Failed"), query, ms);
        }
 
 #ifndef UNICODE
@@ -1245,11 +1248,11 @@ void LIBNXDB_EXPORTABLE DBBind(DB_STATEMENT hStmt, int pos, int sqlType, int cTy
    {
                if (cType == DB_CTYPE_STRING)
                {
-                       nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, buffer);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, buffer);
                }
                else if (cType == DB_CTYPE_UTF8_STRING)
       {
-         nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d (UTF-8): \"%hs\""), hStmt, pos, buffer);
+         nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d (UTF-8): \"%hs\""), hStmt, pos, buffer);
       }
                else
                {
@@ -1272,7 +1275,7 @@ void LIBNXDB_EXPORTABLE DBBind(DB_STATEMENT hStmt, int pos, int sqlType, int cTy
                                        _sntprintf(text, 64, _T("%f"), *((double *)buffer));
                                        break;
                        }
-                       nxlog_debug_tag(_T("db.query"), 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, text);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("{%p} bind at pos %d: \"%s\""), hStmt, pos, text);
                }
        }
 
@@ -1431,11 +1434,11 @@ bool LIBNXDB_EXPORTABLE DBExecuteEx(DB_STATEMENT hStmt, TCHAR *errorText)
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"), (dwResult == DBERR_SUCCESS) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((dwResult == DBERR_SUCCESS) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1514,12 +1517,12 @@ DB_RESULT LIBNXDB_EXPORTABLE DBSelectPreparedEx(DB_STATEMENT hStmt, TCHAR *error
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
                              (hResult != NULL) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1606,12 +1609,12 @@ DB_UNBUFFERED_RESULT LIBNXDB_EXPORTABLE DBSelectPreparedUnbufferedEx(DB_STATEMEN
    ms = GetCurrentTimeMs() - ms;
    if (hConn->m_driver->m_dumpSql)
    {
-      nxlog_debug_tag(_T("db.query"), 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("%s prepared sync query: \"%s\" [%d ms]"),
                     (hResult != NULL) ? _T("Successful") : _T("Failed"), hStmt->m_query, (int)ms);
    }
    if ((hResult != NULL) && ((UINT32)ms > g_sqlQueryExecTimeThreshold))
    {
-      nxlog_debug_tag(_T("db.query"), 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
+      nxlog_debug_tag(DEBUG_TAG_QUERY, 3, _T("Long running query: \"%s\" [%d ms]"), hStmt->m_query, (int)ms);
       s_perfLongRunningQueries++;
    }
 
@@ -1688,19 +1691,19 @@ bool LIBNXDB_EXPORTABLE DBBegin(DB_HANDLE hConn)
       {
          hConn->m_transactionLevel++;
          bRet = true;
-                       nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
       }
       else
       {
          MutexUnlock(hConn->m_mutexTransLock);
-                       nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION failed"), hConn->m_transactionLevel);
+                       nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION failed"), hConn->m_transactionLevel);
       }
    }
    else
    {
       hConn->m_transactionLevel++;
       bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("BEGIN TRANSACTION successful (level %d)"), hConn->m_transactionLevel);
    }
    return bRet;
 }
@@ -1720,7 +1723,7 @@ bool LIBNXDB_EXPORTABLE DBCommit(DB_HANDLE hConn)
          bRet = (hConn->m_driver->m_fpDrvCommit(hConn->m_connection) == DBERR_SUCCESS);
       else
          bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("COMMIT TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("COMMIT TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
       MutexUnlock(hConn->m_mutexTransLock);
    }
    MutexUnlock(hConn->m_mutexTransLock);
@@ -1742,7 +1745,7 @@ bool LIBNXDB_EXPORTABLE DBRollback(DB_HANDLE hConn)
          bRet = (hConn->m_driver->m_fpDrvRollback(hConn->m_connection) == DBERR_SUCCESS);
       else
          bRet = true;
-               nxlog_debug_tag(_T("db.query"), 9, _T("ROLLBACK TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
+               nxlog_debug_tag(DEBUG_TAG_QUERY, 9, _T("ROLLBACK TRANSACTION %s (level %d)"), bRet ? _T("successful") : _T("failed"), hConn->m_transactionLevel);
       MutexUnlock(hConn->m_mutexTransLock);
    }
    MutexUnlock(hConn->m_mutexTransLock);