开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
java_Dbc.c
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：6k
源码类别：

MySQL数据库

开发平台：

Visual C++

java_Dbc.c：源码内容
  1. /*-
  2.  * See the file LICENSE for redistribution information.
  3.  *
  4.  * Copyright (c) 1997-2002
  5.  * Sleepycat Software.  All rights reserved.
  6.  */
  7. #include "db_config.h"
  9. #ifndef lint
  10. static const char revid[] = "$Id: java_Dbc.c,v 11.23 2002/08/06 05:19:06 bostic Exp $";
  11. #endif /* not lint */
  13. #include <jni.h>
  14. #include <errno.h>
  15. #include <stdlib.h>
  16. #include <string.h>
  17. #ifdef DIAGNOSTIC
  18. #include <stdio.h>
  19. #endif
  21. #include "db_int.h"
  22. #include "java_util.h"
  23. #include "com_sleepycat_db_Dbc.h"
  25. JNIEXPORT void JNICALL Java_com_sleepycat_db_Dbc_close
  26.   (JNIEnv *jnienv, jobject jthis)
  27. {
  28. int err;
  29. DBC *dbc = get_DBC(jnienv, jthis);
  31. if (!verify_non_null(jnienv, dbc))
  32. return;
  33. err = dbc->c_close(dbc);
  34. if (verify_return(jnienv, err, 0)) {
  35. set_private_dbobj(jnienv, name_DBC, jthis, 0);
  36. }
  37. }
  39. JNIEXPORT jint JNICALL Java_com_sleepycat_db_Dbc_count
  40.   (JNIEnv *jnienv, jobject jthis, jint flags)
  41. {
  42. int err;
  43. DBC *dbc = get_DBC(jnienv, jthis);
  44. db_recno_t count;
  46. if (!verify_non_null(jnienv, dbc))
  47. return (0);
  48. err = dbc->c_count(dbc, &count, flags);
  49. verify_return(jnienv, err, 0);
  50. return (count);
  51. }
  53. JAVADB_METHOD_INT(Dbc_del, (JAVADB_ARGS, jint flags), DBC,
  54.     c_del, (c_this, flags), DB_RETOK_DBCDEL)
  56. JNIEXPORT jobject JNICALL Java_com_sleepycat_db_Dbc_dup
  57.   (JNIEnv *jnienv, jobject jthis, jint flags)
  58. {
  59. int err;
  60. DBC *dbc = get_DBC(jnienv, jthis);
  61. DBC *dbc_ret = NULL;
  63. if (!verify_non_null(jnienv, dbc))
  64. return (0);
  65. err = dbc->c_dup(dbc, &dbc_ret, flags);
  66. if (!verify_return(jnienv, err, 0))
  67. return (0);
  69. return (get_Dbc(jnienv, dbc_ret));
  70. }
  72. JNIEXPORT jint JNICALL Java_com_sleepycat_db_Dbc_get
  73.   (JNIEnv *jnienv, jobject jthis,
  74.    /*Dbt*/ jobject key, /*Dbt*/ jobject data, jint flags)
  75. {
  76. int err, retry, op_flags;
  77. DBC *dbc;
  78. DB_ENV *dbenv;
  79. LOCKED_DBT lkey, ldata;
  80. OpKind keyop, dataop;
  82. /*
  83.  * Depending on flags, the user may be supplying the key,
  84.  * or else we may have to retrieve it.
  85.  */
  86. err = 0;
  87. keyop = outOp;
  88. dataop = outOp;
  90. op_flags = flags & DB_OPFLAGS_MASK;
  91. if (op_flags == DB_SET) {
  92. keyop = inOp;
  93. }
  94. else if (op_flags == DB_SET_RANGE ||
  95.  op_flags == DB_SET_RECNO) {
  96. keyop = inOutOp;
  97. }
  98. else if (op_flags == DB_GET_BOTH || op_flags == DB_GET_BOTH_RANGE) {
  99. keyop = inOutOp;
  100. dataop = inOutOp;
  101. }
  103. dbc = get_DBC(jnienv, jthis);
  104. if (!verify_non_null(jnienv, dbc))
  105. return (0);
  106. dbenv = dbc->dbp->dbenv;
  108. if (locked_dbt_get(&lkey, jnienv, dbenv, key, keyop) != 0)
  109. goto out2;
  110. if (locked_dbt_get(&ldata, jnienv, dbenv, data, dataop) != 0)
  111. goto out1;
  113. if (!verify_non_null(jnienv, dbc))
  114. goto out1;
  116. for (retry = 0; retry < 3; retry++) {
  117. err = dbc->c_get(dbc,
  118.     &lkey.javainfo->dbt, &ldata.javainfo->dbt, flags);
  120. /*
  121.  * If we failed due to lack of memory in our DBT arrays,
  122.  * retry.
  123.  */
  124. if (err != ENOMEM)
  125. break;
  126. if (!locked_dbt_realloc(&lkey, jnienv,
  127.     dbenv) && !locked_dbt_realloc(&ldata, jnienv, dbenv))
  128. break;
  129. }
  130.  out1:
  131. locked_dbt_put(&ldata, jnienv, dbenv);
  132.  out2:
  133. locked_dbt_put(&lkey, jnienv, dbenv);
  134. if (!DB_RETOK_DBCGET(err)) {
  135. if (verify_dbt(jnienv, err, &lkey) &&
  136.     verify_dbt(jnienv, err, &ldata))
  137. verify_return(jnienv, err, 0);
  138. }
  139. return (err);
  140. }
  142. JNIEXPORT jint JNICALL Java_com_sleepycat_db_Dbc_pget
  143.   (JNIEnv *jnienv, jobject jthis,
  144.    /*Dbt*/ jobject key, /*Dbt*/ jobject pkey, /*Dbt*/ jobject data, jint flags)
  145. {
  146. int err, retry, op_flags;
  147. DBC *dbc;
  148. DB_ENV *dbenv;
  149. LOCKED_DBT lkey, lpkey, ldata;
  150. OpKind keyop, pkeyop, dataop;
  152. /*
  153.  * Depending on flags, the user may be supplying the key,
  154.  * or else we may have to retrieve it.
  155.  */
  156. err = 0;
  157. keyop = outOp;
  158. pkeyop = outOp;
  159. dataop = outOp;
  161. op_flags = flags & DB_OPFLAGS_MASK;
  162. if (op_flags == DB_SET) {
  163. keyop = inOp;
  164. }
  165. else if (op_flags == DB_SET_RANGE ||
  166.  op_flags == DB_SET_RECNO) {
  167. keyop = inOutOp;
  168. }
  169. else if (op_flags == DB_GET_BOTH || op_flags == DB_GET_BOTH_RANGE) {
  170. pkeyop = inOutOp;
  171. keyop = inOutOp;
  172. dataop = inOutOp;
  173. }
  175. dbc = get_DBC(jnienv, jthis);
  176. if (!verify_non_null(jnienv, dbc))
  177. return (0);
  178. dbenv = dbc->dbp->dbenv;
  179. if (locked_dbt_get(&lkey, jnienv, dbenv, key, keyop) != 0)
  180. goto out3;
  181. if (locked_dbt_get(&lpkey, jnienv, dbenv, pkey, pkeyop) != 0)
  182. goto out2;
  183. if (locked_dbt_get(&ldata, jnienv, dbenv, data, dataop) != 0)
  184. goto out1;
  186. if (!verify_non_null(jnienv, dbc))
  187. goto out1;
  189. for (retry = 0; retry < 3; retry++) {
  190. err = dbc->c_pget(dbc, &lkey.javainfo->dbt,
  191. &lpkey.javainfo->dbt, &ldata.javainfo->dbt, flags);
  193. /*
  194.  * If we failed due to lack of memory in our DBT arrays,
  195.  * retry.
  196.  */
  197. if (err != ENOMEM)
  198. break;
  199. if (!locked_dbt_realloc(&lkey, jnienv, dbenv) &&
  200.     !locked_dbt_realloc(&lpkey, jnienv, dbenv) &&
  201.     !locked_dbt_realloc(&ldata, jnienv, dbenv))
  202. break;
  203. }
  204.  out1:
  205. locked_dbt_put(&ldata, jnienv, dbenv);
  206.  out2:
  207. locked_dbt_put(&lpkey, jnienv, dbenv);
  208.  out3:
  209. locked_dbt_put(&lkey, jnienv, dbenv);
  210. if (!DB_RETOK_DBCGET(err)) {
  211. if (verify_dbt(jnienv, err, &lkey) &&
  212.     verify_dbt(jnienv, err, &lpkey) &&
  213.     verify_dbt(jnienv, err, &ldata))
  214. verify_return(jnienv, err, 0);
  215. }
  216. return (err);
  217. }
  219. JNIEXPORT jint JNICALL Java_com_sleepycat_db_Dbc_put
  220.   (JNIEnv *jnienv, jobject jthis,
  221.    /*Dbt*/ jobject key, /*Dbt*/ jobject data, jint flags)
  222. {
  223. int err;
  224. DBC *dbc;
  225. DB_ENV *dbenv;
  226. LOCKED_DBT lkey, ldata;
  227. OpKind keyop;
  229. err = 0;
  230. dbc = get_DBC(jnienv, jthis);
  231. if (!verify_non_null(jnienv, dbc))
  232. return (0);
  233. dbenv = dbc->dbp->dbenv;
  234. keyop = (dbc->dbp->type == DB_RECNO &&
  235.     (flags == DB_BEFORE || flags == DB_AFTER)) ? outOp : inOp;
  236. if (locked_dbt_get(&lkey, jnienv, dbenv, key, keyop) != 0)
  237. goto out2;
  238. if (locked_dbt_get(&ldata, jnienv, dbenv, data, inOp) != 0)
  239. goto out1;
  241. if (!verify_non_null(jnienv, dbc))
  242. goto out1;
  243. err = dbc->c_put(dbc, &lkey.javainfo->dbt, &ldata.javainfo->dbt, flags);
  244. if (!DB_RETOK_DBCPUT(err))
  245. verify_return(jnienv, err, 0);
  246.  out1:
  247. locked_dbt_put(&ldata, jnienv, dbenv);
  248.  out2:
  249. locked_dbt_put(&lkey, jnienv, dbenv);
  250. return (err);
  251. }
  253. JNIEXPORT void JNICALL Java_com_sleepycat_db_Dbc_finalize
  254.   (JNIEnv *jnienv, jobject jthis)
  255. {
  256. /*
  257.  * Free any data related to DBC here.
  258.  * If we ever have java-only data embedded in the DBC
  259.  * and need to do this, we'll have to track Dbc's
  260.  * according to which Db owns them, just as
  261.  * we track Db's according to which DbEnv owns them.
  262.  * That's necessary to avoid double freeing that
  263.  * comes about when closes interact with GC.
  264.  */
  266. #ifdef DIAGNOSTIC
  267. DBC *dbc;
  269. dbc = get_DBC(jnienv, jthis);
  270. if (dbc != NULL)
  271. fprintf(stderr, "Java API: Dbc has not been closedn");
  272. #else
  274. COMPQUIET(jnienv, NULL);
  275. COMPQUIET(jthis, NULL);
  277. #endif
  278. }