UNIX下的线程与ORACLE数据库的连接问题，在线等待！！

wlkwlk

我用UNIX下的多线程访问ORACLE数据库，出现了一些问题请大家帮忙。
在主线程中创建数据库连接，子线程可以共享此连接对数据库进行访问。
但是我想让数据库连接在子线程中创建，通过日志查看 connect 已经成功，
但是 select 一个表中的数据则报告错误代码为 1012的信息（数据库没有连接的错误）。请问各位谁能帮忙解决此问题，谢谢!!

deathbravo

有没有use context呀？
子线程里是不是默认使用default的context；
另外请告诉我你的程序的访问速度好吗

wlkwlk

我有用 context 但是不行，我是在UNIXWARE 上编译的，我将代码贴上，请帮忙看一看，怎样才能实现。谢谢。。。
#include        <string.h>;
#include        <pthread.h>;
#include        <stdio.h>;
#include        <unistd.h>;
#include        <stdlib.h>;
#include        <errno.h>;
#include        <sys/errno.h>;
#include        <math.h>;
#include        <time.h>;
#include        <varargs.h>;
#include        <sys/time.h>;
#include        <sqlda.h>;
#include        <sqlcpr.h>;
#include        <sqlca.h>;
#include        <oraca.h>;


EXEC SQL BEGIN DECLARE SECTION;
        sql_context     envtext;
EXEC SQL END DECLARE SECTION;

/* 连接ORACLE数据库*/
int connectoracle()
{
EXEC SQL BEGIN DECLARE SECTION;
        char    userid[40];
        char    passid[40];
        int        intfilename=0;
EXEC SQL END DECLARE SECTION;

        strcpy(userid , "datalook";
        strcpy(passid , "datalook";

        EXEC SQL CONNECT :userid IDENTIFIED BY :passid;
        EXEC SQL CONTEXT ALLOCATE :envtext;
        EXEC SQL CONTEXT USE :envtext;

        if(sqlca.sqlcode!=0)
        {
                printf("连接失败 sqlcode=[%d]\n",sqlca.sqlcode);
                return(-1);
        }
        printf("Oracle Connect Sucess!!!\n";
        EXEC SQL SELECT FILENAME
                INTO :intfilename FROM SYS_TMP;
        printf("sqlca.sqlcode        =[%d]\n",sqlca.sqlcode);
        printf("intfilename        =[%d]\n",intfilename);
return(0);
}
void FreeConText()
{
        EXEC SQL CONTEXT FREE :envtext;
}
/* Set specify thread stack size */
int SetThreadStackSize(pthread_attr_t *Attr_t,int stacksize)
{
        pthread_attr_t  thread_attr;
        size_t  stack_size;
        int     retcode=0;

        retcode=pthread_attr_init(&thread_attr);
        if(retcode)
        {
                printf("pthread_attr_init\n";
                return(retcode);
        }
        retcode=pthread_attr_getstacksize(&thread_attr,&stack_size);
        if(retcode)
        {
                printf("pthread_attr_getstacksize\n";
                return(retcode);
        }
        retcode=pthread_attr_setstacksize(&thread_attr,stack_size*100);
        if(retcode)
        {
                printf("pthread_attr_setstacksize\n";
                return(retcode);
        }
        memcpy((char *)Attr_t,(char *)&thread_attr,sizeof(pthread_attr_t));
return(0);
}
void *firstthread(void *param)
{
        int        retcode=0;
        pthread_t        conid;
        int        memlen=0;
        pthread_attr_t  attr_val;

        retcode= connectoracle();
        FreeConText();
        printf("firstthread is over..!!!\n";
return(0);
}

int main()
{
        int        retcode=0;
        pthread_t        conid;
        int        memlen=0;
        pthread_attr_t  attr_val;

        memlen=100*16000;
        SetThreadStackSize(&attr_val,memlen);
        retcode=pthread_create(&conid,&attr_val,firstthread,(void *)NULL);
        if(retcode)
        {
                printf("create  ConSumeThread is error [%d]\n",retcode);
                perror("error";
                return(-1);
        }

        retcode=pthread_join(conid,NULL);
        if(retcode)
        {
                printf("pthread_join is error [%d]\n",retcode);
                perror("error";
                return(-1);
        }
        printf("主线程退出!!!\n";
return(0);
}

wlkwlk

我采用的是子线程调度 动态库的形式。
数度大概在每分钟 3000－4000笔左右。

deathbravo

EXEC SQL CONTEXT USE :envtext;
应该在connect之前呀；
要不然你连接的就是default;
envtext的环境里就是未连接的；

wlkwlk

非常感谢，我试了一下，还请问一下，如果在子线程里创建连接，context 变量 envtext 是否必须定义为全局变量。

deathbravo

不必；
但是这个连接只能在子线程内部使用；
子线程结束就释放掉；

可是我觉得这样开销比较大呀；
我是在主线程里建立了一个context池；
可是速度并不比你得快多少；每分钟也就7000到8000比；
最高不超过10000；
你如果发现什么提高速度的窍门，请一定告诉我；

wlkwlk

以前我也是采用在主线程建立连接，然后子线程直接共享主线程的连接对DB进行操作，但是如果两个子线程同时对DB进行操作则会 Core 程序崩溃 ，而且我建立的子线程是守候线程，不会退出，所有我需要为每个子线程创建一个context池。速度我也在通过各种方式优化。如有大的提高我会通知您的。

wlkwlk

/* 此函数在子线程中被调用 */
int contest()
{
EXEC SQL BEGIN DECLARE SECTION;
int     intfilename=0;
EXEC SQL END DECLARE SECTION;

EXEC SQL SELECT FILENAME INTO :intfilename FROM SYS_TMP;
printf("in contest sqlca.sqlcode=[%d]\n",sqlca.sqlcode);
printf("in contest intfilename  =[%d]\n",intfilename);
return(0);
/* 子线程 */
void *firstthread(void *param)
{
EXEC SQL BEGIN DECLARE SECTION;
char    userid[40];
char    passid[40];
char    currdate[40];
int     intfilename=0;
sql_context     envtext;
EXEC SQL END DECLARE SECTION;

        strcpy(userid , "datalook";
        strcpy(passid , "datalook";

        EXEC SQL CONTEXT ALLOCATE :envtext;
        EXEC SQL CONTEXT USE :envtext;
        EXEC SQL CONNECT :userid IDENTIFIED BY :passid;
        if(sqlca.sqlcode!=0)
        {
                printf("连接失败 sqlcode=[%d]\n",sqlca.sqlcode);
                return;
        }
        printf("Oracle Connect Sucess!!!\n";
        EXEC SQL SELECT FILENAME INTO :intfilename FROM SYS_TMP;
        printf("sqlca.sqlcode   =[%d]\n",sqlca.sqlcode);
        printf("intfilename     =[%d]\n",intfilename);
        EXEC SQL SELECT TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS') INTO :currdate
                FROM SYS_TMP;
        currdate[14]=0;

        contest();
        printf("contest is over...........\n";

        EXEC SQL CONTEXT FREE :envtext;
return(0);
}
此代码执行以后报告 函数contest 不能连接数据库，麻烦请看一看。谢谢！！

deathbravo

调用contest 时需要把envtext作为参数传给它；
然后在contest 内部所有SQL语句前面加上
EXEC SQL CONTEXT USE xxxxxx;

不然contest 内部的嵌入SQL会使用default context;