求助：linux下如何使用多线程操作数据库

starsea3

语言是C++。我原来的想法是在每个线程中操作数据库，但现在在每个线程中仅连接数据库都会出现错误。哪位前辈能不能指点一二，如果有这方面的程序示例能否让我拜读、学习？不胜感激！

Bayweb

>>
>>
>>你用的什么数据库？多线程是怎么形成的？
>>
>>

starsea3

数据库是oralce8i;使用pthread_create创建线程;操作数据库的工具是一个已写好的类,这个类封装了对数据库的操作;通过一个该类的指针对数据库进行连接,插入删除等操作.
我现在在线程里new一个这个类的指针,但连接数据库就会出错.

Bayweb

原帖由 starsea3 于 2006-7-26 09:22 发表
数据库是oralce8i;使用pthread_create创建线程;操作数据库的工具是一个已写好的类,这个类封装了对数据库的操作;通过一个该类的指针对数据库进行连接,插入删除等操作.
我现在在线程里new一个这个类的指针,但连接数 ...

>>
>>
>>我以前做过多进程操作数据库的，多线程的没做过。不过应该都支持的。
>>你可以把你的操作数据库相关的代码贴出来看看吗？或者把你的错误信息
>>贴出来看看。
>>
>>

starsea3

我现在在主程序创建连接字段，传入线程处理函数，但仅查询就会出错。代码如下（DBHandlerImpl是一个封装数据库操作的类，太长，就不贴在这里了，是.pc文件，通过proc预编译为cpp文件）：
#include "DBHandlerImpl.h"

#include <cstdlib>
#include <iostream>
#include <string>
#include <pthread.h>

using namespace std;

void* threadHandle0(void* pArg);
void* threadHandle1(void* pArg);

int main(void)
{
                DBHandlerImpl* pDBHandler[2];
        pthread_t id[2];
        pDBHandler[0] = new DBHandlerImpl();
        pDBHandler[0]->connect("avs/ora142@37");
        pDBHandler[1] = new DBHandlerImpl();
        pDBHandler[1]->connect("avs/ora142@37");
        pthread_create(&id[0], NULL, threadHandle0,(void*)pDBHandler[0]);
        pthread_create(&id[1], NULL, threadHandle1,(void*)pDBHandler[1]);
        pthread_join(id[0], NULL);
        pthread_join(id[1], NULL);
       
        pDBHandler[0]->close();
        delete pDBHandler[0];
        pDBHandler[1]->close();
        delete pDBHandler[1];
       
        return 0;
}

void* threadHandle0(void* pArg)
{
        cout<<"in the thread 0"<<endl;
       
        DBHandlerImpl* pDBHandlerImpl = (DBHandlerImpl*)pArg;
        string strSql = "select * from A1";
        Recordset rs;
        int nRet = pDBHandlerImpl->execute(strSql.c_str(), &rs, SQL_SELECT, true);
        cout<<"查询结果:"<<nRet<<endl;       
}

void* threadHandle1(void* pArg)
{
        cout<<"in the thread 1"<<endl;
       
        DBHandlerImpl* pDBHandlerImpl = (DBHandlerImpl*)pArg;
        string strSql = "select * from A2";
        Recordset rs;
        int nRet = pDBHandlerImpl->select(strSql.c_str(), &rs);
        cout<<"查询结果:"<<nRet<<endl;       
}

执行结果：
in the thread 0
in the thread 1
Segmentation Fault(coredump)

是不是不能有同一个进程中的两个线程同时操作数据库呀？

[ 本帖最后由 starsea3 于 2006-7-26 14:22 编辑 ]

jonasan

Segmentation Fault(coredump)

内存溢出了