dba_qdbm.c 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183
  1. /*
  2. +----------------------------------------------------------------------+
  3. | Copyright (c) The PHP Group |
  4. +----------------------------------------------------------------------+
  5. | This source file is subject to version 3.01 of the PHP license, |
  6. | that is bundled with this package in the file LICENSE, and is |
  7. | available through the world-wide-web at the following url: |
  8. | https://www.php.net/license/3_01.txt |
  9. | If you did not receive a copy of the PHP license and are unable to |
  10. | obtain it through the world-wide-web, please send a note to |
  11. | license@php.net so we can mail you a copy immediately. |
  12. +----------------------------------------------------------------------+
  13. | Author: Marcin Gibula <mg@iceni.pl> |
  14. +----------------------------------------------------------------------+
  15. */
  16. #ifdef HAVE_CONFIG_H
  17. #include "config.h"
  18. #endif
  19. #include "php.h"
  20. #if DBA_QDBM
  21. #include "php_qdbm.h"
  22. #ifdef QDBM_INCLUDE_FILE
  23. #include QDBM_INCLUDE_FILE
  24. #endif
  25. #define QDBM_DATA dba_qdbm_data *dba = info->dbf
  26. typedef struct {
  27. DEPOT *dbf;
  28. } dba_qdbm_data;
  29. DBA_OPEN_FUNC(qdbm)
  30. {
  31. DEPOT *dbf;
  32. switch(info->mode) {
  33. case DBA_READER:
  34. dbf = dpopen(info->path, DP_OREADER, 0);
  35. break;
  36. case DBA_WRITER:
  37. dbf = dpopen(info->path, DP_OWRITER, 0);
  38. break;
  39. case DBA_CREAT:
  40. dbf = dpopen(info->path, DP_OWRITER | DP_OCREAT, 0);
  41. break;
  42. case DBA_TRUNC:
  43. dbf = dpopen(info->path, DP_OWRITER | DP_OCREAT | DP_OTRUNC, 0);
  44. break;
  45. default:
  46. return FAILURE;
  47. }
  48. if (dbf) {
  49. info->dbf = pemalloc(sizeof(dba_qdbm_data), info->flags & DBA_PERSISTENT);
  50. memset(info->dbf, 0, sizeof(dba_qdbm_data));
  51. ((dba_qdbm_data *) info->dbf)->dbf = dbf;
  52. return SUCCESS;
  53. }
  54. *error = (char *) dperrmsg(dpecode);
  55. return FAILURE;
  56. }
  57. DBA_CLOSE_FUNC(qdbm)
  58. {
  59. QDBM_DATA;
  60. dpclose(dba->dbf);
  61. pefree(dba, info->flags & DBA_PERSISTENT);
  62. }
  63. DBA_FETCH_FUNC(qdbm)
  64. {
  65. QDBM_DATA;
  66. char *value, *new = NULL;
  67. int value_size;
  68. value = dpget(dba->dbf, key, keylen, 0, -1, &value_size);
  69. if (value) {
  70. if (newlen) *newlen = value_size;
  71. new = estrndup(value, value_size);
  72. free(value);
  73. }
  74. return new;
  75. }
  76. DBA_UPDATE_FUNC(qdbm)
  77. {
  78. QDBM_DATA;
  79. if (dpput(dba->dbf, key, keylen, val, vallen, mode == 1 ? DP_DKEEP : DP_DOVER)) {
  80. return SUCCESS;
  81. }
  82. if (dpecode != DP_EKEEP) {
  83. php_error_docref2(NULL, key, val, E_WARNING, "%s", dperrmsg(dpecode));
  84. }
  85. return FAILURE;
  86. }
  87. DBA_EXISTS_FUNC(qdbm)
  88. {
  89. QDBM_DATA;
  90. char *value;
  91. value = dpget(dba->dbf, key, keylen, 0, -1, NULL);
  92. if (value) {
  93. free(value);
  94. return SUCCESS;
  95. }
  96. return FAILURE;
  97. }
  98. DBA_DELETE_FUNC(qdbm)
  99. {
  100. QDBM_DATA;
  101. return dpout(dba->dbf, key, keylen) ? SUCCESS : FAILURE;
  102. }
  103. DBA_FIRSTKEY_FUNC(qdbm)
  104. {
  105. QDBM_DATA;
  106. int value_size;
  107. char *value, *new = NULL;
  108. dpiterinit(dba->dbf);
  109. value = dpiternext(dba->dbf, &value_size);
  110. if (value) {
  111. if (newlen) *newlen = value_size;
  112. new = estrndup(value, value_size);
  113. free(value);
  114. }
  115. return new;
  116. }
  117. DBA_NEXTKEY_FUNC(qdbm)
  118. {
  119. QDBM_DATA;
  120. int value_size;
  121. char *value, *new = NULL;
  122. value = dpiternext(dba->dbf, &value_size);
  123. if (value) {
  124. if (newlen) *newlen = value_size;
  125. new = estrndup(value, value_size);
  126. free(value);
  127. }
  128. return new;
  129. }
  130. DBA_OPTIMIZE_FUNC(qdbm)
  131. {
  132. QDBM_DATA;
  133. dpoptimize(dba->dbf, 0);
  134. return SUCCESS;
  135. }
  136. DBA_SYNC_FUNC(qdbm)
  137. {
  138. QDBM_DATA;
  139. dpsync(dba->dbf);
  140. return SUCCESS;
  141. }
  142. DBA_INFO_FUNC(qdbm)
  143. {
  144. return estrdup(dpversion);
  145. }
  146. #endif