Changeset 3336 for Enterprise/branches/0075_TR_SCRIPTING/AppServer/src/ApplicationServer.hpp

Timestamp:

01/30/10 15:53:00 (6 months ago)

Author:

mgray

Message:

Implemented getDatabaseConnection() in ApplicationServer?.

Files:

• Enterprise/branches/0075_TR_SCRIPTING/AppServer/src/ApplicationServer.hpp (modified) (6 diffs)

Enterprise/branches/0075_TR_SCRIPTING/AppServer/src/ApplicationServer.hpp

@@ -3 +3 @@
 //
 // Copyright (C) 2001 - 2010 Tony Richards
-// Copyright (C) 2008 - 2009 Matthew Alan Gray
+// Copyright (C) 2008 - 2010 Matthew Alan Gray
 // Copyright (C)        2009 Joshua Cassity
 //
@@ -31 +31 @@
 #include "../I_ApplicationServer.hpp"
 
+#include <Zen/Core/Threading/I_Thread.hpp>
 #include <Zen/Core/Threading/ThreadPool.hpp>
 
@@ -40 +41 @@
 //-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~-~
 namespace Zen {
+    namespace Database {
+        class I_DatabaseService;
+        class I_DatabaseConnection;
+    }   // namespace Database
 namespace Enterprise {
 namespace AppServer {
@@ -86 +91 @@
     virtual void handleRequest(pRequest_type _pRequest, pResponseHandler_type _pResponseHandler);
     virtual void handleSessionEvent(pSessionEvent_type _pSessionEvent);
+    virtual pDatabaseConnection_type getDatabaseConnection(const std::string& _database, Zen::Threading::I_Thread::ThreadId& _threadId);
     /// @}
 
@@ -108 +114 @@
 
     Threading::ThreadPool& getSharedThreadPool() { return m_sharedThreadPool; }
+    /// @}
+
+    /// @name Inner classes
+    /// @{
+private:
+    class DatabaseConnections
+    {
+        /// @name Types
+        /// @{
+    public:
+        typedef Zen::Memory::managed_ptr<Zen::Database::I_DatabaseService>              pDatabaseService_type;
+        typedef std::map<std::string,std::string>                                       config_type;
+        typedef Zen::Memory::managed_ptr<Zen::Database::I_DatabaseConnection>           pDatabaseConnection_type;
+        typedef std::map<Zen::Threading::I_Thread::ThreadId,pDatabaseConnection_type>   DatabaseConnections_type;
+        /// @}
+
+        /// @name DatabaseConnections implementation
+        /// @{
+    public:
+        pDatabaseConnection_type getConnection(Zen::Threading::I_Thread::ThreadId& _threadId);
+        /// @}
+
+        /// @name 'Structors
+        /// @{
+                 DatabaseConnections(pDatabaseService_type _pService, config_type _connectionConfig);
+                ~DatabaseConnections();
+        /// @}
+
+        /// @name Member Variables
+        /// @{
+    private:
+        pDatabaseService_type           m_pDatabaseService;
+        config_type                     m_connectionConfig;
+        DatabaseConnections_type        m_databaseConnections;
+        Zen::Threading::I_Mutex*        m_databaseConnectionsMutex;
+        /// @}
+
+    };  // class DatabaseConnections
     /// @}
 
@@ -156 +200 @@
 
     pMessageRegistry_type       m_pMessageRegistry_type;
+
+    typedef std::map<std::string, DatabaseConnections>  DatabaseConnectionsMap_type;
+    DatabaseConnectionsMap_type m_databaseConnectionsMap;
     /// @}