青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

Codejie's C++ Space

Using C++

OCI : do NOT debug on TWO different windows

    這兩天在使用Oracle,好久沒(méi)用了,生疏了很多。。。
    開(kāi)始使用occi訪問(wèn),可以是代碼很精簡(jiǎn),因?yàn)閛cci封裝的還是很好的,使用起來(lái)跟mysql++很類似,也不知道他們誰(shuí)參考誰(shuí)的,反正用起來(lái)就是很簡(jiǎn)單。
    聯(lián)調(diào)起來(lái)卻碰到了個(gè)大麻煩,本來(lái)說(shuō)好是Linux平臺(tái)的,等調(diào)試時(shí)卻要換到Windows上,問(wèn)題來(lái)了,occi11跟VC9似乎不合拍,Environment初始就出錯(cuò),折騰了很久,最終只有放棄了。測(cè)試下oci,嗯,可以用。。。
    于是,晚上一狠心,自己封裝oci,模仿occi做個(gè)ocipp來(lái),好用了。。。

    這里說(shuō)個(gè)調(diào)試過(guò)程中一件丟臉的事情--使用ocipp訪問(wèn)同時(shí),打開(kāi)SQLPlus窗口,進(jìn)行對(duì)比測(cè)試,select語(yǔ)句很好用,但到update/delete語(yǔ)句時(shí),程序卡死在execute調(diào)用中,想了很久,也嘗試了很久,到了凌晨1點(diǎn)半,一直卡死,人近瘋狂,突然想起,SQLPlus窗口下的語(yǔ)句默認(rèn)需要自己輸入commit語(yǔ)句提交的,而ocipp用的是Auto-commit方式,兩者應(yīng)該有沖突的。于是在SQLPlus輸入個(gè)commit,一切pass。。。
    所以,記得,調(diào)試oci接口時(shí),不要開(kāi)兩個(gè)窗口,會(huì)死人的。。。


    下面是ocipp代碼,僅供看熱鬧,不推薦使用,因?yàn)槌擞形kU(xiǎn)外,也很有限制,比如ocipp僅支持string類型的define和bind,因?yàn)椋业拇a僅需要這一種類型。。。

ocipp.h

#include 
<string>
#include 
<iostream>
#include 
<vector>

#include 
"oci.h"

namespace ocipp
{

class Exception
{
public:
    Exception(
int code, const std::string& msg);
    Exception(
int code, OCIError *err, const std::string& msg);

    
void show(std::ostream& os) const;
protected:
    
void getError(int code);
    
void getError(int code, OCIError *err);
protected:
    
int _code;
    std::
string _msg;
}
;

class Connection;

class Environment
{
public:
    Environment(unsigned 
int mode = OCI_DEFAULT);
    
virtual ~Environment();

    Connection
* makeConnection(const std::string& user, const std::string& passwd, const std::string& server = "");
    
void destroyConnection(Connection* conn);

    OCIEnv 
*getEnv() return _env; }
    OCIError 
*getError() return _err; }
private:
    
void makeEnvironment(unsigned int mode);
protected:
    OCIEnv 
*_env;
    OCIError 
*_err;
}
;

class Statement;

class Connection
{
    friend 
class Environment;
protected:
    Connection(Environment
* env);
    
virtual ~Connection() {}
public:
    Statement 
*makeStatement(const std::string& sql);
    
void destroyStatement(Statement* stmt);

    Environment 
*getEnvironment() return _env; }

    OCISvcCtx 
*getSvc() return _svc; }
private:
    Environment 
*_env;
protected:
    OCIServer 
*_srv;
    OCISvcCtx 
*_svc;
    OCISession 
*_auth;
}
;

class Statement
{
    friend 
class Connection;
protected:
    
static const size_t BUF_SIZE = 256;
    
struct TDefData
    
{
        TDefData(std::
string& val)
            : str(
&val), buf(NULL)
        
{
            buf 
= new char[BUF_SIZE];
        }


        std::
string* str;
        
char* buf;
    }
;
    typedef std::vector
<TDefData> TDefVector;
protected:
    Statement(Connection
* conn);
    
virtual ~Statement() {}

    
void syncDefVector();
    
void freeDefVector();
public:
    
int bindString(unsigned int pos, const std::string& val);
    
int defineString(unsigned int pos, std::string& val);

    
int execute();
    
int getNext();
private:
    Connection 
*_conn;
protected:
    O CIStmt 
*_stmt;

    TDefVector _vctDef;
}
;

}


std::ostream
& operator << (std::ostream& os, const ocipp::Exception& e);



ocipp.cpp


#include 
"ocipp.h"

namespace ocipp
{

Exception::Exception(
int code, const std::string &msg)
: _code(code)
, _msg(msg)
{
    getError(code);
}


Exception::Exception(
int code, OCIError* err, const std::string &msg)
: _code(code)
, _msg(msg)
{
    getError(code, err);
}


void Exception::getError(int code)
{
    
switch(code)
    
{
    
case OCI_SUCCESS:
        _msg 
= "(OCI_SUCCESS) - " + _msg;
        
break;
    
case OCI_SUCCESS_WITH_INFO:
        _msg 
= "(OCI_SUCCESS_WITH_INFO) - " + _msg;
        
break;
    
case OCI_NEED_DATA:
        _msg 
= "(OCI_NEED_DATA) - " + _msg;
        
break;
    
case OCI_NO_DATA:
        _msg 
= "(OCI_NODATA) - " + _msg;
        
break;
    
case OCI_ERROR:
        _msg 
= "(OCI_ERROR) - " + _msg;
        
break;
    
case OCI_INVALID_HANDLE:
        _msg 
= "(OCI_INVALID_HANDLE) - " + _msg;
        
break;
    
case OCI_STILL_EXECUTING:
        _msg 
= "(OCI_STILL_EXECUTE) - " + _msg;
        
break;
    
case OCI_CONTINUE:
        _msg 
= "(OCI_CONTINUE) - " + _msg;
        
break;
    
default:
        _msg 
= "(UNKNOWN) - " + _msg;
    }

}


void Exception::getError(int code, OCIError *err)
{
    getError(code);
    
//if(code == OCI_ERROR)
    {
        
char buf[512];
        OCIErrorGet((
void*)err, 1, NULL, &code, (OraText*)buf, sizeof(buf), OCI_HTYPE_ERROR);
        _msg 
+= "::";
        _msg 
+=  buf;
    }

}


void Exception::show(std::ostream &os) const
{
    os 
<< "[" << _code << "]" << _msg;
}


////

Environment::Environment(unsigned 
int mode)
: _env(NULL)
, _err(NULL)
{
    makeEnvironment(mode);    
}


Environment::
~Environment()
{
    
if(_err != NULL)
    
{
        OCIHandleFree((
void*)_err, OCI_HTYPE_ERROR);
        _err 
= NULL;
    }

    
if(_env != NULL)
    
{
        OCIHandleFree((
void*)_env, OCI_HTYPE_ENV);
        _env 
= NULL;
    }

}


void Environment::makeEnvironment(unsigned int mode)
{
    
int ret = OCIEnvCreate(&_env, mode, NULL, NULL, NULL, NULL, 0, NULL);
    
if(ret != OCI_SUCCESS || _env == NULL)
    
{
        
throw Exception(ret, "create Environment failed.");
    }

    
    ret 
= OCIHandleAlloc((const void*)_env, (void**)&_err, OCI_HTYPE_ERROR, 0, NULL);
    
if(ret != OCI_SUCCESS || _env == NULL)
    
{
        
throw Exception(ret, _err, "create Error failed.");
    }

}


Connection
* Environment::makeConnection(const std::string &user, const std::string &passwd, const std::string &server)
{
    Connection 
*conn = new Connection(this);

    
int ret = OCIHandleAlloc((const void*)_env, (void**)&(conn->_srv), OCI_HTYPE_SERVER, 0, NULL);
    
if((ret != OCI_SUCCESS && ret != OCI_SUCCESS_WITH_INFO) || conn->_srv == NULL)
    
{
        
throw Exception(ret, "create Server failed.");
    }


    ret 
= OCIHandleAlloc((const void*)_env, (void**)&(conn->_svc), OCI_HTYPE_SVCCTX, 0, NULL);
    
if(ret != OCI_SUCCESS || conn->_svc == NULL)
    
{
        
throw Exception(ret, "create ScvCtx failed.");
    }


    ret 
= OCIServerAttach(conn->_srv, _err, (const OraText*)server.c_str(), server.size(), 0);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _err, "attach Server failed.");
    }


    ret 
= OCIAttrSet((void*)conn->_svc, OCI_HTYPE_SVCCTX, (void*)conn->_srv, 0, OCI_ATTR_SERVER, _err);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _err, "set SVCCTX attrib failed.");
    }


    ret 
= OCIHandleAlloc((const void*)_env, (void**)&conn->_auth, OCI_HTYPE_SESSION, 0, NULL);
    
if(ret != OCI_SUCCESS || conn->_auth == NULL)
    
{
        
throw Exception(ret, "create Auth Session failed.");
    }


    ret 
= OCIAttrSet((void*)conn->_auth, OCI_HTYPE_SESSION, (void*)user.c_str(), user.size(), OCI_ATTR_USERNAME, _err);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _err, "set Username attrib failed.");
    }


    ret 
= OCIAttrSet((void*)conn->_auth, OCI_HTYPE_SESSION, (void*)passwd.c_str(), passwd.size(), OCI_ATTR_PASSWORD, _err);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _err, "set Password attrib failed.");
    }

    
    ret 
= OCISessionBegin(conn->_svc, _err, conn->_auth, OCI_CRED_RDBMS, OCI_DEFAULT);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _err, "Start session failed.");
    }


    OCIAttrSet((
void*)conn->_svc, OCI_HTYPE_SVCCTX, (void*)conn->_auth, 0, OCI_ATTR_SESSION, _err);

    
return conn;
}


void Environment::destroyConnection(ocipp::Connection *conn)
{
    
if(conn == NULL)
        
return;

    OCISessionEnd(conn
->_svc, _err, conn->_auth, OCI_DEFAULT);
    OCIServerDetach(conn
->_srv, _err, 0);

    OCIHandleFree((
void*)conn->_auth, OCI_HTYPE_SESSION);
    OCIHandleFree((
void*)conn->_svc, OCI_HTYPE_SVCCTX);
    OCIHandleFree((
void*)conn->_srv, OCI_HTYPE_SERVER);

    delete conn, conn 
= NULL;
}


////
Connection::Connection(ocipp::Environment *env)
: _env(env)
, _srv(NULL)
, _svc(NULL)
, _auth(NULL)
{
}


Statement
* Connection::makeStatement(const std::string &sql)
{
    Statement 
*stmt = new Statement(this);

    
int ret = OCIHandleAlloc((const void*)_env->getEnv(), (void**)&(stmt->_stmt), OCI_HTYPE_STMT, 0, NULL);
    
if(ret != OCI_SUCCESS || stmt->_stmt == NULL)
    
{
        
throw Exception(ret, "create Stmt fail.");
    }


    ret 
= OCIStmtPrepare(stmt->_stmt, _env->getError(), (const OraText*)sql.c_str(), sql.size(), OCI_NTV_SYNTAX, OCI_DEFAULT);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _env->getError(), "prepare Stmt failed.");
    }


    
return stmt;
}


void Connection::destroyStatement(ocipp::Statement *stmt)
{
    stmt
->freeDefVector();
    OCIHandleFree(stmt
->_stmt, OCI_HTYPE_STMT);
    delete stmt, stmt 
= NULL;
}


////
Statement::Statement(ocipp::Connection *conn)
: _conn(conn)
, _stmt(NULL)
{
}


int Statement::bindString(unsigned int pos, const std::string &val)
{
    OCIBind
* bd = NULL;
    
int ret = OCIBindByPos(_stmt, &bd, _conn->getEnvironment()->getError(), pos, (void*)val.c_str(), val.size() + 1/* very dangerous */, SQLT_STR, NULL, NULL, NULL, 0, NULL, OCI_DEFAULT);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _conn->getEnvironment()->getError(), "bind String failed.");
    }


    
return 0;
}


int Statement::defineString(unsigned int pos, std::string& val)
{
    TDefData data(val);
    OCIDefine
* def = NULL;
    
int ret = OCIDefineByPos(_stmt, &def, _conn->getEnvironment()->getError(), pos, (void*)data.buf, BUF_SIZE, SQLT_STR, NULL, NULL, NULL, OCI_DEFAULT);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _conn->getEnvironment()->getError(), "define String failed.");
    }

    _vctDef.push_back(data);

    
return 0;
}


int Statement::execute()
{
    unsigned 
short type = 0;
    
int ret = OCIAttrGet((const void*)_stmt, OCI_HTYPE_STMT, (void*)&type, 0, OCI_ATTR_STMT_TYPE, _conn->getEnvironment()->getError());
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _conn->getEnvironment()->getError(), "get Stmt type failed.");
    }


    ret 
= OCIStmtExecute(_conn->getSvc(), _stmt, _conn->getEnvironment()->getError(), (type != OCI_STMT_SELECT ? 1 : 0), 0, NULL, NULL, OCI_COMMIT_ON_SUCCESS/*OCI_DEFAULT*/);
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _conn->getEnvironment()->getError(), "execute Stmt failed.");
    }


    
//unsigned int rc = 0;
    
//ret = OCIAttrGet((const void*)_stmt, OCI_HTYPE_STMT, &rc, (ub4*)sizeof(rc), OCI_ATTR_ROW_COUNT, _conn->getEnvironment()->getError());
 
//   if(ret != OCI_SUCCESS)
 
//   {
 
//       throw Exception(ret, _conn->getEnvironment()->getError(), "get Stmt row_count failed.");
 
//   }
    return 0;
}


int Statement::getNext()
{
    
int ret = OCIStmtFetch2(_stmt, _conn->getEnvironment()->getError(), 1, OCI_FETCH_NEXT, 1, OCI_DEFAULT);
    
if(ret == OCI_NO_DATA)
        
return -1;
    
if(ret != OCI_SUCCESS)
    
{
        
throw Exception(ret, _conn->getEnvironment()->getError(), "fetch Stmt failed.");
    }


    syncDefVector();

    
return 0;
}


void Statement::syncDefVector()
{
    
for(TDefVector::iterator it = _vctDef.begin(); it != _vctDef.end(); ++ it)
    
{
        it
->str->assign(it->buf, strlen(it->buf));
    }

}


void Statement::freeDefVector()
{
    
for(TDefVector::iterator it = _vctDef.begin(); it != _vctDef.end(); ++ it)
    
{
        delete [] it
->buf;
    }

    _vctDef.clear();
}



}


/////
std::ostream& operator << (std::ostream& os, const ocipp::Exception& e)
{
    e.show(os);
    
return os;
}



posted on 2011-07-08 11:23 codejie 閱讀(2125) 評(píng)論(2)  編輯 收藏 引用 所屬分類: C++輪子精神

評(píng)論

# re: OCI : do NOT debug on TWO different windows 2011-07-10 15:02 pansunyou

我也封裝過(guò)類似的東西,DB2的CLI庫(kù),也就自己爽,別人都不敢用。  回復(fù)  更多評(píng)論   

# re: OCI : do NOT debug on TWO different windows 2011-07-11 14:38 codejie

@pansunyou
是的,很爽。。。  回復(fù)  更多評(píng)論   

公告

Using C++

導(dǎo)航

統(tǒng)計(jì)

留言簿(73)

隨筆分類(513)

積分與排名

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            夜夜夜精品看看| 99国产精品私拍| 久久婷婷国产综合尤物精品| 国产美女诱惑一区二区| 久久久精品五月天| 久久婷婷国产综合国色天香| 亚洲国产小视频在线观看| 亚洲国产中文字幕在线观看| 欧美精品手机在线| 久久国产视频网站| 欧美成人午夜| 翔田千里一区二区| 麻豆成人在线| 亚洲欧美在线免费观看| 久久国产精品99久久久久久老狼| 在线观看欧美亚洲| 一区二区高清视频在线观看| 韩国自拍一区| 一区二区三区|亚洲午夜| 韩国欧美国产1区| 亚洲精品日本| 在线观看国产成人av片| 中文日韩在线| 亚洲激情成人在线| 午夜久久一区| 中文精品在线| 狂野欧美性猛交xxxx巴西| 亚洲欧美在线磁力| 欧美国产欧美亚州国产日韩mv天天看完整| 亚洲欧美日韩国产综合在线 | 免费试看一区| 国产精品草草| 亚洲黄色在线观看| 国产一区二区电影在线观看| 99在线精品免费视频九九视| 亚洲第一黄网| 欧美一级视频| 午夜精品久久久久久久久| 欧美国产日韩a欧美在线观看| 久久久欧美一区二区| 国产精品国产三级国产aⅴ浪潮| 欧美激情导航| 尹人成人综合网| 欧美中文字幕在线视频| 午夜精品免费在线| 欧美午夜在线一二页| 亚洲人成啪啪网站| 亚洲精品欧美专区| 六月丁香综合| 免费试看一区| 狠狠久久婷婷| 久久久精品日韩| 久久久久久亚洲精品中文字幕| 国产精品美女一区二区| 一区二区欧美在线| 亚洲影院在线观看| 国产精品高潮在线| 亚洲午夜久久久| 亚洲欧美日韩国产一区二区| 国产精品成人免费| 亚洲香蕉成视频在线观看| 午夜精品亚洲| 国产午夜精品福利| 欧美一区二区日韩一区二区| 久久精品最新地址| 激情欧美一区| 美女国产一区| 亚洲精品影视| 亚洲欧美视频一区| 国产一区二区三区久久久| 欧美在线观看视频在线| 免费不卡在线观看| 亚洲卡通欧美制服中文| 欧美欧美全黄| 亚洲午夜视频在线观看| 久久久久久久欧美精品| 亚洲大胆女人| 欧美日韩爆操| 亚洲综合丁香| 免费成人小视频| 99这里只有久久精品视频| 国产精品wwwwww| 欧美专区18| 亚洲激情不卡| 欧美一区影院| 亚洲高清三级视频| 欧美日韩三级视频| 久久国产免费看| 亚洲破处大片| 欧美在线地址| 亚洲久久在线| 国产日韩欧美精品综合| 欧美18av| 午夜精品在线| 亚洲乱码国产乱码精品精天堂 | 久久精品二区亚洲w码| 亚洲国内自拍| 国产精品一区二区在线观看网站 | 亚洲性av在线| 黄网站免费久久| 欧美日韩一区综合| 美女国产精品| 午夜亚洲福利| 亚洲乱码国产乱码精品精可以看| 久久精品国产一区二区三| 99热这里只有精品8| 狠狠久久亚洲欧美| 国产精品乱码妇女bbbb| 欧美成人嫩草网站| 欧美在线精品一区| 中文高清一区| 日韩视频一区二区在线观看 | 亚洲精品中文在线| 国内精品久久久久影院薰衣草| 欧美日韩一区二区免费视频| 久久综合久久综合九色| 亚洲欧美另类国产| 亚洲乱码国产乱码精品精| 欧美激情亚洲| 蜜桃久久精品乱码一区二区| 久久大综合网| 欧美亚洲在线播放| 亚洲一区在线免费| 一区二区三区久久精品| 亚洲黄网站在线观看| 精品51国产黑色丝袜高跟鞋| 国产日韩欧美高清免费| 国产精品女主播| 国产精品久久久久久久久借妻| 欧美激情一二区| 欧美高清自拍一区| 欧美成人福利视频| 嫩草成人www欧美| 免费短视频成人日韩| 久久亚洲精品网站| 老巨人导航500精品| 浪潮色综合久久天堂| 麻豆成人91精品二区三区| 老司机久久99久久精品播放免费| 久久久久成人精品免费播放动漫| 久久国产精品久久w女人spa| 久久久777| 美女诱惑一区| 欧美日本精品| 国产精品白丝av嫩草影院| 国产精品视区| 国产有码一区二区| 尹人成人综合网| 亚洲精品在线视频观看| 中文欧美在线视频| 欧美一区二区三区四区在线 | 亚洲美女毛片| 亚洲午夜女主播在线直播| 亚洲欧美日韩综合aⅴ视频| 午夜在线视频一区二区区别| 久久精品亚洲乱码伦伦中文| 久久婷婷国产麻豆91天堂| 欧美1区2区视频| 亚洲三级免费观看| 亚洲一区二区三区视频| 久久福利毛片| 欧美精品日本| 国产麻豆日韩| 亚洲国产精品专区久久| 亚洲调教视频在线观看| 久久精品在线播放| 亚洲欧洲综合另类在线| 亚洲专区国产精品| 榴莲视频成人在线观看| 国产精品久久一区主播| 红桃视频亚洲| 亚洲一区二区精品| 另类天堂av| 亚洲美女淫视频| 久久精品99久久香蕉国产色戒| 欧美激情精品久久久六区热门| 国产精品久久久一区麻豆最新章节 | 在线观看日韩一区| 中文一区在线| 巨乳诱惑日韩免费av| 99re成人精品视频| 久久久久久一区二区三区| 欧美日韩一区三区| 亚洲国产精品视频一区| 欧美一二三视频| 亚洲国产视频一区| 久久精品国产999大香线蕉| 欧美三级在线视频| 最近看过的日韩成人| 久久精品亚洲乱码伦伦中文 | 欧美中文字幕第一页| 亚洲精品久久久久中文字幕欢迎你 | 亚洲免费电影在线| 久久久亚洲综合| 国产精品私拍pans大尺度在线| 亚洲欧洲美洲综合色网| 久久久久国内| 亚洲欧美中日韩| 国产精品极品美女粉嫩高清在线| 亚洲精品久久嫩草网站秘色|