dbcom.pc

学习oracle的脚本,包括备份,proc编程的,例子,是学习oracle的好资料

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <math.h>
#include <pthread.h>

#include "sqlca.h"
#include "sqlda.h"

#include "const.h"
#include "db.h"

#define MODULE_NAME "DBCOM"

typedef struct
{
    sql_context context; 
} thread_connect_t;
thread_connect_t a_thread_connect[10];


int DbsEnableThread()
{
    EXEC SQL ENABLE THREADS;
    return(sqlca.sqlcode);
}


int DbsConnectThread(int thread_index, char *connect)
{
    SQL_THREAD_SAFE_PREPARE;
    char buf[100], *p_str, *p_cur, dbuser[10], password[10];

    if(connect==NULL)  return -1;
    strcpy(buf, connect);
    p_str=strtok_r(buf, "/", &p_cur);
    if(p_str==NULL)  return -1;
    strcpy(dbuser, p_str);
    p_str=strtok_r(NULL, "/", &p_cur);
    if(p_str==NULL)  return -1;
    strcpy(password, p_str);

    EXEC SQL context allocate :a_thread_connect[thread_index].context;
    EXEC SQL context use :a_thread_connect[thread_index].context;
    EXEC SQL connect :dbuser identified by :password;

    SQL_CODE_PROCESS("SYS", "CON");
}


int DbsDisconnThread(int thread_index)
{
    SQL_THREAD_SAFE_PREPARE;

    EXEC SQL context use :a_thread_connect[thread_index].context;
    EXEC SQL commit work release;
    EXEC SQL context free :a_thread_connect[thread_index].context;

    SQL_CODE_PROCESS("SYS", "CON");
}


int DbsCommit(int thread_index)
{
    SQL_THREAD_SAFE_PREPARE;

    EXEC SQL commit;

    SQL_CODE_PROCESS("SYS", "COM");
}


int DbsRollback(int thread_index)
{
    SQL_THREAD_SAFE_PREPARE;

    EXEC SQL rollback;

    SQL_CODE_PROCESS("SYS", "ROL");
}