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