MFC 쓰레드 DB 작업하기

메인 쓰레드에서만 처리하는 경우 일반적으로 아래 처럼 사용한다.
(g_mysql 은 전역변수)

mysql_init(&g_mysql);
if (!mysql_real_connect(&g_mysql, _DB서버주소, _DBID, _DB암호, _DB명, 3306, 0, 0))
{
    AfxMessageBox(mysql_error(&g_mysql), MB_OK);
    return FALSE;
}
mysql_query(&g_mysql, "set names euckr"); //한글 인식
//AfxMessageBox("DB 연결 성공", MB_OK);
 
// DB 쿼리 실행
...
 
mysql_close(&g_mysql);
 

만약, 쓰레드에서 DB작업을 하게 되면 각 쓰레드마다 연결해야했고, 각 워커 쓰레드는 다른 전역변수 g_mysql_쓰레드1, g_mysql_쓰레드2 (4, 24행) 를 사용한다. (메인 쓰레드에서 연결한걸로 작업 쓰레드에서 사용하면 쿼리 실행 시 예외 발생한다.)

 

UINT Thread함수1(LPVOID arg)
{
    ....
    mysql_init(&g_mysql_쓰레드1);
    if (!mysql_real_connect(&g_mysql_쓰레드1, _DB서버주소, _DBID, _DB암호, _DB명, 3306, 0, 0))
    {
        AfxMessageBox(mysql_error(&g_mysql_쓰레드1), MB_OK);
        return FALSE;
    }
    mysql_query(&g_mysql_쓰레드1, "set names euckr"); //한글 인식
    //AfxMessageBox("DB 연결 성공", MB_OK);
 
    while(1)
    {
        .... // SQL 쿼리
    }
    mysql_close(&g_mysql_쓰레드1);
    return 0L;
}
 
UINT Thread함수2(LPVOID arg)
{
    ....
    mysql_init(&g_mysql_쓰레드2);
    if (!mysql_real_connect(&g_mysql_쓰레드2, _DB서버주소, _DBID, _DB암호, _DB명, 3306, 0, 0))
    {
        AfxMessageBox(mysql_error(&g_mysql_쓰레드2), MB_OK);
        return FALSE;
    }
    mysql_query(&g_mysql_쓰레드2, "set names euckr"); //한글 인식
    //AfxMessageBox("DB 연결 성공", MB_OK);
 
    while(1)
    {
        .... // SQL 쿼리
    }
    mysql_close(&g_mysql_쓰레드2);
    return 0L;
}