语言是C++。我原来的想法是在每个线程中操作数据库,但现在在每个线程中仅连接数据库都会出现错误。哪位前辈能不能指点一二,如果有这方面的程序示例能否让我拜读、学习?不胜感激!
>>>>>>你用的什么数据库?多线程是怎么形成的?>>>>
数据库是oralce8i;使用pthread_create创建线程;操作数据库的工具是一个已写好的类,这个类封装了对数据库的操作;通过一个该类的指针对数据库进行连接,插入删除等操作.我现在在线程里new一个这个类的指针,但连接数据库就会出错.
原帖由 starsea3 于 2006-7-26 09:22 发表数据库是oralce8i;使用pthread_create创建线程;操作数据库的工具是一个已写好的类,这个类封装了对数据库的操作;通过一个该类的指针对数据库进行连接,插入删除等操作.我现在在线程里new一个这个类的指针,但连接数 ...
>>>>>>我以前做过多进程操作数据库的,多线程的没做过。不过应该都支持的。>>你可以把你的操作数据库相关的代码贴出来看看吗?或者把你的错误信息>>贴出来看看。>>>>
我现在在主程序创建连接字段,传入线程处理函数,但仅查询就会出错。代码如下(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 0in the thread 1Segmentation Fault(coredump)
是不是不能有同一个进程中的两个线程同时操作数据库呀?
[ 本帖最后由 starsea3 于 2006-7-26 14:22 编辑 ]
Segmentation Fault(coredump)
内存溢出了
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
暂无简介
文章 0 评论 0
接受
发布评论
评论(5)
>>
>>
>>你用的什么数据库?多线程是怎么形成的?
>>
>>
数据库是oralce8i;使用pthread_create创建线程;操作数据库的工具是一个已写好的类,这个类封装了对数据库的操作;通过一个该类的指针对数据库进行连接,插入删除等操作.
我现在在线程里new一个这个类的指针,但连接数据库就会出错.
>>
>>
>>我以前做过多进程操作数据库的,多线程的没做过。不过应该都支持的。
>>你可以把你的操作数据库相关的代码贴出来看看吗?或者把你的错误信息
>>贴出来看看。
>>
>>
我现在在主程序创建连接字段,传入线程处理函数,但仅查询就会出错。代码如下(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 编辑 ]
Segmentation Fault(coredump)
内存溢出了