📄 connpool_8c-source.html
字号:
<a name="l00136"></a>00136 <a name="l00137"></a>00137 <span class="comment">/* create internal lists */</span><a name="l00138"></a>00138 <a name="l00139"></a>00139 pool-><a class="code" href="struct_o_c_i___conn_pool.html#d3d8ff5a19eb253338f6951315c1f824">cons</a> = OCI_ListCreate(OCI_IPC_CONNECTION); <a name="l00140"></a>00140 <a name="l00141"></a>00141 <span class="keywordflow">if</span> (OCI_LIB_THREADED)<a name="l00142"></a>00142 {<a name="l00143"></a>00143 <span class="comment">/* create mutex for OCI_ConnPoolGetConnection() */</span><a name="l00144"></a>00144 <a name="l00145"></a>00145 pool-><a class="code" href="struct_o_c_i___conn_pool.html#7a9e6a95517c3fe35b1d6d1eaca742f9">mutex</a> = OCI_MutexCreateInternal();<a name="l00146"></a>00146 <a name="l00147"></a>00147 res = (pool-><a class="code" href="struct_o_c_i___conn_pool.html#7a9e6a95517c3fe35b1d6d1eaca742f9">mutex</a> != NULL);<a name="l00148"></a>00148 }<a name="l00149"></a>00149 }<a name="l00150"></a>00150 <a name="l00151"></a>00151 <span class="comment">/* set attributes */</span><a name="l00152"></a>00152 <a name="l00153"></a>00153 <span class="keywordflow">if</span> (res == TRUE)<a name="l00154"></a>00154 {<a name="l00155"></a>00155 <a name="l00156"></a>00156 pool-><a class="code" href="struct_o_c_i___conn_pool.html#b8e888f25184c362b0070ea5a972ee28">mode</a> = mode;<a name="l00157"></a>00157 pool-><a class="code" href="struct_o_c_i___conn_pool.html#ef66b256823aa066b81a6e8f7fd15d5c">min</a> = min_con;<a name="l00158"></a>00158 pool-><a class="code" href="struct_o_c_i___conn_pool.html#39c9b42b23f075338efd5f29aece833f">max</a> = max_con;<a name="l00159"></a>00159 pool-><a class="code" href="struct_o_c_i___conn_pool.html#cc48d8aa34b0bf06ba6bb83be6ec120a">incr</a> = incr_con;<a name="l00160"></a>00160 <a name="l00161"></a>00161 pool-><a class="code" href="struct_o_c_i___conn_pool.html#bb78ea3b8eaa958dcef81dff352d9077">db</a> = mtsdup(db != NULL ? db : MT(<span class="stringliteral">""</span>));<a name="l00162"></a>00162 pool-><a class="code" href="struct_o_c_i___conn_pool.html#c92e9493167088e1143195216a23c073">user</a> = mtsdup(user != NULL ? user : MT(<span class="stringliteral">""</span>));<a name="l00163"></a>00163 pool-><a class="code" href="struct_o_c_i___conn_pool.html#d73354126d5aa4ccea4913593ca6b911">pwd</a> = mtsdup(pwd != NULL ? pwd : MT(<span class="stringliteral">""</span>));<a name="l00164"></a>00164 }<a name="l00165"></a>00165 <a name="l00166"></a>00166 <a name="l00167"></a>00167 <span class="preprocessor">#if OCI_VERSION_COMPILE >= OCI_9</span><a name="l00168"></a>00168 <span class="preprocessor"></span><a name="l00169"></a>00169 <span class="keywordflow">if</span> (OCILib.ver_runtime >= OCI_9)<a name="l00170"></a>00170 {<a name="l00171"></a>00171 <span class="keywordtype">int</span> osize_name = -1;<a name="l00172"></a>00172 <span class="keywordtype">int</span> osize_db = -1;<a name="l00173"></a>00173 <span class="keywordtype">int</span> osize_user = -1;<a name="l00174"></a>00174 <span class="keywordtype">int</span> osize_pwd = -1;<a name="l00175"></a>00175 <a name="l00176"></a>00176 <span class="keywordtype">void</span> *ostr_name = NULL;<a name="l00177"></a>00177 <span class="keywordtype">void</span> *ostr_db = NULL;<a name="l00178"></a>00178 <span class="keywordtype">void</span> *ostr_user = NULL;<a name="l00179"></a>00179 <span class="keywordtype">void</span> *ostr_pwd = NULL;<a name="l00180"></a>00180 <a name="l00181"></a>00181 <span class="comment">/* allocate error handle */</span><a name="l00182"></a>00182 <a name="l00183"></a>00183 <span class="keywordflow">if</span> (res == TRUE)<a name="l00184"></a>00184 res = (OCI_SUCCESS == OCI_HandleAlloc((dvoid *) OCILib.env,<a name="l00185"></a>00185 (dvoid **) (<span class="keywordtype">void</span> *) &pool-><a class="code" href="struct_o_c_i___conn_pool.html#e960f1a00bee41c9d195c15332dafd2d">err</a>,<a name="l00186"></a>00186 (ub4) OCI_HTYPE_ERROR, <a name="l00187"></a>00187 (<span class="keywordtype">size_t</span>) 0, <a name="l00188"></a>00188 (dvoid **) NULL));<a name="l00189"></a>00189 <a name="l00190"></a>00190 <span class="comment">/* allocate connection pool handle */</span><a name="l00191"></a>00191 <span class="keywordflow">if</span> (res == TRUE)<a name="l00192"></a>00192 res = (OCI_SUCCESS == OCI_HandleAlloc((dvoid *) OCILib.env, <a name="l00193"></a>00193 (dvoid **) (<span class="keywordtype">void</span> *) &pool-><a class="code" href="struct_o_c_i___conn_pool.html#167d91c8dc07bb4713b11394c839457b">handle</a>,<a name="l00194"></a>00194 (ub4) OCI_HTYPE_CPOOL, <a name="l00195"></a>00195 (<span class="keywordtype">size_t</span>) 0, <a name="l00196"></a>00196 (dvoid **) NULL));<a name="l00197"></a>00197 <a name="l00198"></a>00198 <span class="comment">/* create the pool */</span><a name="l00199"></a>00199 <a name="l00200"></a>00200 <span class="keywordflow">if</span> (res == TRUE)<a name="l00201"></a>00201 {<a name="l00202"></a>00202 ostr_db = OCI_GetInputMetaString(pool-><a class="code" href="struct_o_c_i___conn_pool.html#bb78ea3b8eaa958dcef81dff352d9077">db</a>, &osize_db);<a name="l00203"></a>00203 ostr_user = OCI_GetInputMetaString(pool-><a class="code" href="struct_o_c_i___conn_pool.html#c92e9493167088e1143195216a23c073">user</a>, &osize_user);<a name="l00204"></a>00204 ostr_pwd = OCI_GetInputMetaString(pool-><a class="code" href="struct_o_c_i___conn_pool.html#d73354126d5aa4ccea4913593ca6b911">pwd</a>, &osize_pwd);<a name="l00205"></a>00205 <a name="l00206"></a>00206 OCI_CALL3<a name="l00207"></a>00207 (<a name="l00208"></a>00208 res, pool-><a class="code" href="struct_o_c_i___conn_pool.html#e960f1a00bee41c9d195c15332dafd2d">err</a>,<a name="l00209"></a>00209 <a name="l00210"></a>00210 OCIConnectionPoolCreate(OCILib.env, pool-><a class="code" href="struct_o_c_i___conn_pool.html#e960f1a00bee41c9d195c15332dafd2d">err</a>, pool-><a class="code" href="struct_o_c_i___conn_pool.html#167d91c8dc07bb4713b11394c839457b">handle</a>,<a name="l00211"></a>00211 (OraText **) &ostr_name, (sb4*) &osize_name, <a name="l00212"></a>00212 (OraText *) ostr_db, (sb4) osize_db,<a name="l00213"></a>00213 (ub4) pool-><a class="code" href="struct_o_c_i___conn_pool.html#ef66b256823aa066b81a6e8f7fd15d5c">min</a>, (ub4) pool-><a class="code" href="struct_o_c_i___conn_pool.html#39c9b42b23f075338efd5f29aece833f">max</a>,<a name="l00214"></a>00214 (ub4) pool-><a class="code" href="struct_o_c_i___conn_pool.html#cc48d8aa34b0bf06ba6bb83be6ec120a">incr</a>, (OraText *) ostr_user, <a name="l00215"></a>00215 (sb4) osize_user, (OraText *) ostr_pwd, <a name="l00216"></a>00216 (sb4) osize_pwd, (ub4) OCI_DEFAULT)<a name="l00217"></a>00217 )<a name="l00218"></a>00218 <a name="l00219"></a>00219 OCI_ReleaseMetaString(ostr_db);<a name="l00220"></a>00220 OCI_ReleaseMetaString(ostr_user);<a name="l00221"></a>00221 OCI_ReleaseMetaString(ostr_pwd);<a name="l00222"></a>00222 }<a name="l00223"></a>00223 <a name="l00224"></a>00224 <span class="keywordflow">if</span> ((res == TRUE) && (ostr_name != NULL))<a name="l00225"></a>00225 {<a name="l00226"></a>00226 pool-><a class="code" href="struct_o_c_i___conn_pool.html#bae2a49d41482b4ed064b0ecf839ea42">name</a> = (mtext *) OCI_MemAlloc(OCI_IPC_STRING, <span class="keyword">sizeof</span>(mtext),<a name="l00227"></a>00227 (osize_name/<span class="keyword">sizeof</span>(omtext)) + 1,<a name="l00228"></a>00228 FALSE);<a name="l00229"></a>00229 <a name="l00230"></a>00230 <span class="keywordflow">if</span> (pool-><a class="code" href="struct_o_c_i___conn_pool.html#bae2a49d41482b4ed064b0ecf839ea42">name</a> != NULL)<a name="l00231"></a>00231 {<a name="l00232"></a>00232 OCI_CopyString(ostr_name, pool-><a class="code" href="struct_o_c_i___conn_pool.html#bae2a49d41482b4ed064b0ecf839ea42">name</a>, &osize_name, <a name="l00233"></a>00233 <span class="keyword">sizeof</span>(omtext), <span class="keyword">sizeof</span>(mtext));<a name="l00234"></a>00234 }<a name="l00235"></a>00235 <span class="keywordflow">else</span><a name="l00236"></a>00236 res = FALSE;<a name="l00237"></a>00237 }<a name="l00238"></a>00238 }<a name="l00239"></a>00239 <a name="l00240"></a>00240 <span class="preprocessor">#endif</span><a name="l00241"></a>00241 <span class="preprocessor"></span><a name="l00242"></a>00242 <span class="comment">/* on success, we allocate internal OCI connection objects for pool </span><a name="l00243"></a>00243 <span class="comment"> minimum size */</span><a name="l00244"></a>00244 <a name="l00245"></a>00245 <span class="keywordflow">if</span> (res == TRUE)<a name="l00246"></a>00246 {<a name="l00247"></a>00247 <a class="code" href="struct_o_c_i___connection.html" title="Oracle physical connection.">OCI_Connection</a> *cn;<a name="l00248"></a>00248 <a name="l00249"></a>00249 <span class="keywordflow">while</span> ((min_con--) > 0)<a name="l00250"></a>00250 {<a name="l00251"></a>00251 cn = OCI_ConnectionAllocate(pool, pool-><a class="code" href="struct_o_c_i___conn_pool.html#bb78ea3b8eaa958dcef81dff352d9077">db</a>, pool-><a class="code" href="struct_o_c_i___conn_pool.html#c92e9493167088e1143195216a23c073">user</a>, <a name="l00252"></a>00252 pool-><a class="code" href="struct_o_c_i___conn_pool.html#d73354126d5aa4ccea4913593ca6b911">pwd</a>, pool-><a class="code" href="struct_o_c_i___conn_pool.html#b8e888f25184c362b0070ea5a972ee28">mode</a>);<a name="l00253"></a>00253 }<a name="l00254"></a>00254 }<a name="l00255"></a>00255 <span class="keywordflow">else</span><a name="l00256"></a>00256 {<a name="l00257"></a>00257 <a class="code" href="group__g__connpool.html#g4bca447fc21e09cb1cc4cc3ec2cfcde1" title="Destroy a Connection pool object.">OCI_ConnPoolFree</a>(pool);<a name="l00258"></a>00258 pool = NULL;<a name="l00259"></a>00259 }<a name="l00260"></a>00260 <a name="l00261"></a>00261 OCI_RESULT(res);<a name="l00262"></a>00262 <a name="l00263"></a>00263 <span class="keywordflow">return</span> pool;<a name="l00264"></a>00264 }<a name="l00265"></a>00265 <a name="l00266"></a>00266 <span class="comment">/* ------------------------------------------------------------------------ *</span><a name="l00267"></a>00267 <span class="comment"> * OCI_ConnPoolFree</span><a name="l00268"></a>00268 <span class="comment"> * ------------------------------------------------------------------------ */</span><a name="l00269"></a>00269 <a name="l00270"></a><a class="code" href="group__g__connpool.html#g4bca447fc21e09cb1cc4cc3ec2cfcde1">00270</a> <span class="keywordtype">boolean</span> OCI_API <a class="code" href="group__g__connpool.html#g4bca447fc21e09cb1cc4cc3ec2cfcde1" title="Destroy a Connection pool object.">OCI_ConnPoolFree</a>(<a class="code" href="struct_o_c_i___conn_pool.html" title="Oracle Connection Pool.">OCI_ConnPool</a> *pool)<a name="l00271"></a>00271 {<a name="l00272"></a>00272 <span class="keywordtype">boolean</span> res = TRUE;<a name="l00273"></a>00273 <a name="l00274"></a>00274 OCI_CHECK_PTR(OCI_IPC_CONNPOOL, pool, FALSE);<a name="l00275"></a>00275 <a name="l00276"></a>00276 res = OCI_ConnPoolClose(pool);<a name="l00277"></a>00277 <a name="l00278"></a>00278 OCI_ListRemove(OCILib.pools, pool);<a name="l00279"></a>00279 <a name="l00280"></a>00280 OCI_FREE(pool);<a name="l00281"></a>00281 <a name="l00282"></a>00282 OCI_RESULT(res);<a name="l00283"></a>00283 <a name="l00284"></a>00284 <span class="keywordflow">return</span> res;<a name="l00285"></a>00285 }⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -