dba_flatfile.c 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176
  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: Marcus Boerger <helly@php.net> |
  14. +----------------------------------------------------------------------+
  15. */
  16. #ifdef HAVE_CONFIG_H
  17. #include "config.h"
  18. #endif
  19. #include "php.h"
  20. #if DBA_FLATFILE
  21. #include "php_flatfile.h"
  22. #include "libflatfile/flatfile.h"
  23. #ifdef HAVE_UNISTD_H
  24. #include <unistd.h>
  25. #endif
  26. #include <sys/types.h>
  27. #include <sys/stat.h>
  28. #include <fcntl.h>
  29. #define FLATFILE_DATA flatfile *dba = info->dbf
  30. #define FLATFILE_GKEY datum gkey; gkey.dptr = (char *) key; gkey.dsize = keylen
  31. DBA_OPEN_FUNC(flatfile)
  32. {
  33. info->dbf = pemalloc(sizeof(flatfile), info->flags&DBA_PERSISTENT);
  34. memset(info->dbf, 0, sizeof(flatfile));
  35. ((flatfile*)info->dbf)->fp = info->fp;
  36. return SUCCESS;
  37. }
  38. DBA_CLOSE_FUNC(flatfile)
  39. {
  40. FLATFILE_DATA;
  41. if (dba->nextkey.dptr) {
  42. efree(dba->nextkey.dptr);
  43. }
  44. pefree(dba, info->flags&DBA_PERSISTENT);
  45. }
  46. DBA_FETCH_FUNC(flatfile)
  47. {
  48. datum gval;
  49. char *new = NULL;
  50. FLATFILE_DATA;
  51. FLATFILE_GKEY;
  52. gval = flatfile_fetch(dba, gkey);
  53. if (gval.dptr) {
  54. if (newlen) {
  55. *newlen = gval.dsize;
  56. }
  57. new = estrndup(gval.dptr, gval.dsize);
  58. efree(gval.dptr);
  59. }
  60. return new;
  61. }
  62. DBA_UPDATE_FUNC(flatfile)
  63. {
  64. datum gval;
  65. FLATFILE_DATA;
  66. FLATFILE_GKEY;
  67. gval.dptr = (char *) val;
  68. gval.dsize = vallen;
  69. switch(flatfile_store(dba, gkey, gval, mode==1 ? FLATFILE_INSERT : FLATFILE_REPLACE)) {
  70. case 0:
  71. return SUCCESS;
  72. case 1:
  73. return FAILURE;
  74. case -1:
  75. php_error_docref1(NULL, key, E_WARNING, "Operation not possible");
  76. return FAILURE;
  77. default:
  78. php_error_docref2(NULL, key, val, E_WARNING, "Unknown return value");
  79. return FAILURE;
  80. }
  81. }
  82. DBA_EXISTS_FUNC(flatfile)
  83. {
  84. datum gval;
  85. FLATFILE_DATA;
  86. FLATFILE_GKEY;
  87. gval = flatfile_fetch(dba, gkey);
  88. if (gval.dptr) {
  89. efree(gval.dptr);
  90. return SUCCESS;
  91. }
  92. return FAILURE;
  93. }
  94. DBA_DELETE_FUNC(flatfile)
  95. {
  96. FLATFILE_DATA;
  97. FLATFILE_GKEY;
  98. return(flatfile_delete(dba, gkey) == -1 ? FAILURE : SUCCESS);
  99. }
  100. DBA_FIRSTKEY_FUNC(flatfile)
  101. {
  102. FLATFILE_DATA;
  103. if (dba->nextkey.dptr) {
  104. efree(dba->nextkey.dptr);
  105. }
  106. dba->nextkey = flatfile_firstkey(dba);
  107. if (dba->nextkey.dptr) {
  108. if (newlen) {
  109. *newlen = dba->nextkey.dsize;
  110. }
  111. return estrndup(dba->nextkey.dptr, dba->nextkey.dsize);
  112. }
  113. return NULL;
  114. }
  115. DBA_NEXTKEY_FUNC(flatfile)
  116. {
  117. FLATFILE_DATA;
  118. if (!dba->nextkey.dptr) {
  119. return NULL;
  120. }
  121. if (dba->nextkey.dptr) {
  122. efree(dba->nextkey.dptr);
  123. }
  124. dba->nextkey = flatfile_nextkey(dba);
  125. if (dba->nextkey.dptr) {
  126. if (newlen) {
  127. *newlen = dba->nextkey.dsize;
  128. }
  129. return estrndup(dba->nextkey.dptr, dba->nextkey.dsize);
  130. }
  131. return NULL;
  132. }
  133. DBA_OPTIMIZE_FUNC(flatfile)
  134. {
  135. /* dummy */
  136. return SUCCESS;
  137. }
  138. DBA_SYNC_FUNC(flatfile)
  139. {
  140. /* dummy */
  141. return SUCCESS;
  142. }
  143. DBA_INFO_FUNC(flatfile)
  144. {
  145. return estrdup(flatfile_version());
  146. }
  147. #endif