jnet::JNetDBConnPool 클래스 참조

DB 커넥션 인스턴스 Pool 더 자세히 ...

#include <JNetDB.h>

Public 멤버 함수
	JNetDBConnPool ()
	JNetDBConnPool (bool dbConnErrorLog)
	~JNetDBConnPool ()
bool	Connect (INT32 connectionCount, const WCHAR *connectionString)
void	Clear ()
JNetDBConn *	Pop ()
void	Push (JNetDBConn *connection, bool isDisconnected=false, bool tryToConnect=false, const WCHAR *connectionString=NULL)

Private 속성
SQLHENV	m_SqlEnvironment = SQL_NULL_HANDLE
std::queue< JNetDBConn * >	m_DBConnectionsQueue
std::mutex	m_DBConnectionsMtx
bool	m_DBConnErrorLogFlag

상세한 설명

DB 커넥션 인스턴스 Pool

생성자 & 소멸자 문서화

JNetDBConnPool() [1/2]

jnet::JNetDBConnPool::JNetDBConnPool ( )

inline

: JNetDBConnPool(false) {}

JNetDBConnPool() [2/2]

jnet::JNetDBConnPool::JNetDBConnPool ( bool dbConnErrorLog )

inline

: m_DBConnErrorLogFlag(dbConnErrorLog) {}

~JNetDBConnPool()

jnet::JNetDBConnPool::~JNetDBConnPool ( )

inline

                          {
            Clear();
        }

멤버 함수 문서화

Connect()

bool JNetDBConnPool::Connect	(	INT32	connectionCount,
		const WCHAR *	connectionString )

{
    // 1. SQL 환경 핸들을 할당
    if (::SQLAllocHandle(SQL_HANDLE_ENV, SQL_NULL_HANDLE, &m_SqlEnvironment) != SQL_SUCCESS)
        return false;
 
    // 2. SQL 환경 핸들 이용하여 ODBC 버전 설정
    if (::SQLSetEnvAttr(m_SqlEnvironment, SQL_ATTR_ODBC_VERSION, reinterpret_cast<SQLPOINTER>(SQL_OV_ODBC3), 0) != SQL_SUCCESS)
        return false;
 
    // 3. connectionCount 갯수만큼 연결을 맺어준다(연결 생성). 
    //      - DBConnection 객체를 통해 간접적으로 DB에 연결을 요청한다. 
    //      - (DB와 연결된 스레드가 여러 개라면, 커넥션 카운터를 이 스레드 갯수만큼 만들수도 있다.)
    std::lock_guard<std::mutex> lockGuard(m_DBConnectionsMtx);
    for (INT32 i = 0; i < connectionCount; i++)
    {
        JNetDBConn* connection = new JNetDBConn(m_DBConnErrorLogFlag);
        // 할당 받은 SQL 환경 핸들을 전달한다. 
        if (connection->Connect(m_SqlEnvironment, connectionString) == false)
            return false;
        //m_DBConnections.push_back(connection);
        m_DBConnectionsQueue.push(connection);
    }
 
    return true;
}

Clear()

void JNetDBConnPool::Clear

(

)

{
    // 1. SQL 환경 핸들 반환
    if (m_SqlEnvironment != SQL_NULL_HANDLE)
    {
        ::SQLFreeHandle(SQL_HANDLE_ENV, m_SqlEnvironment);
        m_SqlEnvironment = SQL_NULL_HANDLE;
    }
 
    // 2. 커넥션 풀의 커넥션 들에 대한 메모리를 반환
    std::lock_guard<std::mutex> lockGuard(m_DBConnectionsMtx);
    //for (DBConnection* connection : m_DBConnections)
    //  delete connection;
    //
    //m_DBConnections.clear();
 
    while (!m_DBConnectionsQueue.empty()) {
        JNetDBConn* dbConn = m_DBConnectionsQueue.front();
        m_DBConnectionsQueue.pop();
        delete dbConn;
    }
}

Pop()

JNetDBConn * JNetDBConnPool::Pop

(

)

{
    std::lock_guard<std::mutex> lockGuard(m_DBConnectionsMtx);
 
    //if (m_DBConnections.empty())
    if (m_DBConnectionsQueue.empty())
        return nullptr;
 
    //DBConnection* connection = m_DBConnections.back();
    //m_DBConnections.pop_back();
    JNetDBConn* connection = m_DBConnectionsQueue.front();
    m_DBConnectionsQueue.pop();
    return connection;
}

Push()

void JNetDBConnPool::Push	(	JNetDBConn *	connection,
		bool	isDisconnected = false,
		bool	tryToConnect = false,
		const WCHAR *	connectionString = NULL )

{
    std::lock_guard<std::mutex> lockGuard(m_DBConnectionsMtx);
 
    if (isDisconnected) {
        if (!connection->Ping()) {
            delete connection;
 
            if (tryToConnect) {
                connection = new JNetDBConn(m_DBConnErrorLogFlag);
                if (!connection->Connect(m_SqlEnvironment, connectionString)) {
                    return;
                }
                //m_DBConnections.push_back(connection);
                m_DBConnectionsQueue.push(connection);
            }
        }
        else {
            // isDisconnected: true -> ping 성공?
            //m_DBConnections.push_back(connection);
            m_DBConnectionsQueue.push(connection);
        }
    }
    else {
        //m_DBConnections.push_back(connection);
        m_DBConnectionsQueue.push(connection);
    }
}

멤버 데이터 문서화

m_SqlEnvironment

SQLHENV jnet::JNetDBConnPool::m_SqlEnvironment = SQL_NULL_HANDLE

private

m_DBConnectionsQueue

std::queue<JNetDBConn*> jnet::JNetDBConnPool::m_DBConnectionsQueue

private

m_DBConnectionsMtx

std::mutex jnet::JNetDBConnPool::m_DBConnectionsMtx

private

m_DBConnErrorLogFlag

bool jnet::JNetDBConnPool::m_DBConnErrorLogFlag

private

---

이 클래스에 대한 문서화 페이지는 다음의 파일들로부터 생성되었습니다.:

• include/JNetDB.h
• JNetCore/JNetDB.cpp