xref: /PHP-7.2/ext/interbase/php_ibase_udf.c (revision 7a7ec01a)
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: Ard Biesheuvel <a.k.biesheuvel@ewi.tudelft.nl>               |
16    +----------------------------------------------------------------------+
17  */
18 
19 /**
20 * This UDF library adds the ability to call PHP functions from SQL
21 * statements. Because of SQL's strong typing, you will have to declare
22 * an external function for every combination { output type, #args } that
23 * your application requires.
24 *
25 * Declare the functions like this:
26 *
27 *     DECLARE EXTERNAL FUNCTION CALL_PHP1
28 *         CSTRING(xx),
29 *         <return type> BY DESCRIPTOR,
30 *         INTEGER BY DESCRIPTOR
31 *         RETURNS PARAMETER 2
32 *         ENTRY_POINT 'udf_call_php1' MODULE_NAME 'php_ibase_udf'
33 *
34 *     DECLARE EXTERNAL FUNCTION CALL_PHP2
35 *         CSTRING(xx),
36 *         <return type> BY DESCRIPTOR,
37 *         INTEGER BY DESCRIPTOR,
38 *         INTEGER BY DESCRIPTOR
39 *         RETURNS PARAMETER 2
40 *         ENTRY_POINT 'udf_call_php2' MODULE_NAME 'php_ibase_udf'
41 *
42 *     ... and so on. [for up to 8 input arguments]
43 *
44 * The first input parameter contains the name of the PHP function you want
45 * to call. The second argument is the result. (omit this argument when calling
46 * the function) The return type of the function is the declared type of the
47 * result. The value returned from the PHP function being called will
48 * automatically be converted if necessary.
49 * The arguments should have their types declared as well, but you're free
50 * to pass arguments of other types instead. They will be converted to the
51 * best matching PHP type before being passed to the PHP function.
52 *
53 * The declared functions can be called from SQL like:
54 *
55 *     SELECT * FROM <table> WHERE CALL_PHP1('soundex',<field>) NOT LIKE ?
56 * or
57 *     UPDATE <table> SET <field> = CALL_PHP1('ucwords',<field>)
58 *
59 * Additionally, there's a function 'exec_php' which allows the contents
60 * of text BLOB fields to be parsed and executed by PHP. This is most useful
61 * for declaring functions that can then be called with CALL_PHPx.
62 *
63 *    DECLARE EXTERNAL FUNCTION EXEC_PHP
64 *        BLOB,
65 *        INTEGER BY DESCRIPTOR,
66 *        SMALLINT
67 *        RETURNS PARAMETER 2
68 *        ENTRY_POINT 'exec_php' MODULE_NAME 'php_ibase_udf'
69 *
70 * The function will return 1 if execution succeeded and 0 if an error
71 * occurred. The result that is returned from the executed PHP code is
72 * ignored. You can pass a non-zero value as second argument to force
73 * the embedded PHP engine to re-initialise.
74 *
75 * There are several ways to build this library, depending on which way the
76 * database is accessed. If you're using the classic server on a local
77 * connection, you should compile the library like this:
78 *
79 *     gcc -shared `php-config --includes` `php-config --ldflags` \
80 *         `php-config --libs` -o php_ibase_udf.so php_ibase_udf.c
81 *
82 * If you connect to the classic server by TCP/IP, you should build the
83 * PHP embedded static library and link against that.
84 *
85 *     gcc -shared `php-config --includes` `php-config --ldflags` \
86 *         `php-config --libs` -o php_ibase_udf.so php_ibase_udf.c \
87 *         /usr/lib/libphp7.a
88 *
89 * If you use the super server, you should also link against the embedded
90 * library, but be sure to enable thread safety, as the super server is
91 * multi-threaded. After building, copy the resulting file to the folder
92 * where your database expects to find its UDFs.
93 */
94 
95 #include "zend.h"
96 #include "zend_API.h"
97 
98 #include "php.h"
99 #include "php_ini.h"
100 
101 #include "ibase.h"
102 
103 #define min(a,b) ((a)<(b)?(a):(b))
104 
105 #ifdef PHP_WIN32
106 #define LL_LIT(lit) lit ## I64
107 #else
108 #define LL_LIT(lit) lit ## ll
109 #endif
110 
111 #ifdef ZTS
112 #  include <pthread.h>
113 
114 static void ***tsrm_ls;
115 pthread_mutex_t mtx_res = PTHREAD_MUTEX_INITIALIZER;
116 
117 #define LOCK() do { pthread_mutex_lock(&mtx_res); } while (0)
118 #define UNLOCK() do { pthread_mutex_unlock(&mtx_res); } while (0)
119 #else
120 #define LOCK()
121 #define UNLOCK()
122 #endif
123 
124 #ifdef PHP_EMBED
125 # include "php_main.h"
126 # include "sapi/embed/php_embed.h"
127 
init()128 static void __attribute__((constructor)) init()
129 {
130 	php_embed_init(0, NULL P);
131 }
132 
fini()133 static void __attribute__((destructor)) fini()
134 {
135 	php_embed_shutdown();
136 }
137 
138 #endif
139 
140 /**
141 * Gets the contents of the BLOB b and offers it to Zend for parsing/execution
142 */
exec_php(BLOBCALLBACK b,PARAMDSC * res,ISC_SHORT * init)143 void exec_php(BLOBCALLBACK b, PARAMDSC *res, ISC_SHORT *init)
144 {
145 	int result, remaining = b->blob_total_length, i = 0;
146 	char *code = pemalloc(remaining+1, 1);
147 	ISC_USHORT read;
148 
149 	for (code[remaining] = '\0'; remaining > 0; remaining -= read)
150 		b->blob_get_segment(b->blob_handle, &code[i++<<16],min(0x10000,remaining), &read);
151 
152 	LOCK();
153 
154 	switch (init && *init) {
155 
156 		default:
157 #ifdef PHP_EMBED
158 			php_request_shutdown(NULL);
159 			if (FAILURE == (result = php_request_startup())) {
160 				break;
161 			}
162 		case 0:
163 #endif
164 			/* feed it to the parser */
165 			zend_first_try {
166 				result = zend_eval_stringl(code, b->blob_total_length, NULL, "Firebird Embedded PHP engine");
167 			} zend_end_try();
168 	}
169 
170 	UNLOCK();
171 
172 	free(code);
173 
174 	res->dsc_dtype = dtype_long;
175 	*(ISC_LONG*)res->dsc_address = (result == SUCCESS);
176 }
177 
178 static ISC_INT64 const scales[] = { 1, 10, 100, 1000, 10000, 100000, 1000000, 100000000, 1000000000,
179 	1000000000, LL_LIT(10000000000),LL_LIT(100000000000),LL_LIT(10000000000000),LL_LIT(100000000000000),
180 	LL_LIT(1000000000000000),LL_LIT(1000000000000000),LL_LIT(1000000000000000000) };
181 
182 
call_php(char * name,PARAMDSC * r,int argc,PARAMDSC ** argv)183 static void call_php(char *name, PARAMDSC *r, int argc, PARAMDSC **argv)
184 {
185 	do {
186 		zval callback, args[4], return_value;
187 		PARAMVARY *res = (PARAMVARY*)r->dsc_address;
188 		int i;
189 
190 		ZVAL_STRING(&callback, name);
191 
192 		LOCK();
193 
194 		/* check if the requested function exists */
195 		if (!zend_is_callable(&callback, 0, NULL)) {
196 			break;
197 		}
198 
199 		UNLOCK();
200 
201 		/* create the argument array */
202 		for (i = 0; i < argc; ++i) {
203 
204 			/* test arg for null */
205 			if (argv[i]->dsc_flags & DSC_null) {
206 				ZVAL_NULL(&args[i]);
207 				continue;
208 			}
209 
210 			switch (argv[i]->dsc_dtype) {
211 				ISC_INT64 l;
212 				struct tm t;
213 				char const *fmt;
214 				char d[64];
215 
216 				case dtype_cstring:
217 //???
218 					ZVAL_STRING(&args[i], (char*)argv[i]->dsc_address);
219 					break;
220 
221 				case dtype_text:
222 //???
223 					ZVAL_STRINGL(&args[i], (char*)argv[i]->dsc_address, argv[i]->dsc_length);
224 					break;
225 
226 				case dtype_varying:
227 //???
228 					ZVAL_STRINGL(&args[i], ((PARAMVARY*)argv[i]->dsc_address)->vary_string,
229 						((PARAMVARY*)argv[i]->dsc_address)->vary_length);
230 					break;
231 
232 				case dtype_short:
233 					if (argv[i]->dsc_scale == 0) {
234 						ZVAL_LONG(&args[i], *(short*)argv[i]->dsc_address);
235 					} else {
236 						ZVAL_DOUBLE(&args[i],
237 							((double)*(short*)argv[i]->dsc_address)/scales[-argv[i]->dsc_scale]);
238 					}
239 					break;
240 
241 				case dtype_long:
242 					if (argv[i]->dsc_scale == 0) {
243 						ZVAL_LONG(&args[i], *(ISC_LONG*)argv[i]->dsc_address);
244 					} else {
245 						ZVAL_DOUBLE(&args[i],
246 							((double)*(ISC_LONG*)argv[i]->dsc_address)/scales[-argv[i]->dsc_scale]);
247 					}
248 					break;
249 
250 				case dtype_int64:
251 					l = *(ISC_INT64*)argv[i]->dsc_address;
252 
253 					if (argv[i]->dsc_scale == 0 && l <= ZEND_LONG_MAX && l >= ZEND_LONG_MIN) {
254 						ZVAL_LONG(&args[i], (zend_long)l);
255 					} else {
256 						ZVAL_DOUBLE(&args[i], ((double)l)/scales[-argv[i]->dsc_scale]);
257 					}
258 					break;
259 
260 				case dtype_real:
261 					ZVAL_DOUBLE(&args[i], *(float*)argv[i]->dsc_address);
262 					break;
263 
264 				case dtype_double:
265 					ZVAL_DOUBLE(&args[i], *(double*)argv[i]->dsc_address);
266 					break;
267 
268 				case dtype_sql_date:
269 					isc_decode_sql_date((ISC_DATE*)argv[i]->dsc_address, &t);
270 					ZVAL_STRINGL(&args[i], d, strftime(d, sizeof(d), INI_STR("ibase.dateformat"), &t),1);
271 					break;
272 
273 				case dtype_sql_time:
274 					isc_decode_sql_time((ISC_TIME*)argv[i]->dsc_address, &t);
275 					ZVAL_STRINGL(&args[i], d, strftime(d, sizeof(d), INI_STR("ibase.timeformat"), &t),1);
276 					break;
277 
278 				case dtype_timestamp:
279 					isc_decode_timestamp((ISC_TIMESTAMP*)argv[i]->dsc_address, &t);
280 					ZVAL_STRINGL(&args[i], d, strftime(d, sizeof(d), INI_STR("ibase.timestampformat"), &t));
281 					break;
282 			}
283 		}
284 
285 		LOCK();
286 
287 		/* now call the function */
288 		if (FAILURE == call_user_function(EG(function_table), NULL,
289 				&callback, &return_value, argc, args)) {
290 			UNLOCK();
291 			break;
292 		}
293 
294 		UNLOCK();
295 
296 		for (i = 0; i < argc; ++i) {
297 			switch (argv[i]->dsc_dtype) {
298 				case dtype_sql_date:
299 				case dtype_sql_time:
300 				case dtype_timestamp:
301 					zval_dtor(&args[i]);
302 			}
303 		}
304 
305 		zval_dtor(&callback);
306 
307 		/* return whatever type we got back from the callback: let DB handle conversion */
308 		switch (Z_TYPE(return_value)) {
309 
310 			case IS_LONG:
311 				r->dsc_dtype = dtype_long;
312 				*(zend_long*)r->dsc_address = Z_LVAL(return_value);
313 				r->dsc_length = sizeof(zend_long);
314 				break;
315 
316 			case IS_DOUBLE:
317 				r->dsc_dtype = dtype_double;
318 				*(double*)r->dsc_address = Z_DVAL(return_value);
319 				r->dsc_length = sizeof(double);
320 				break;
321 
322 			case IS_NULL:
323 				r->dsc_flags |= DSC_null;
324 				break;
325 
326 			default:
327 				convert_to_string(&return_value);
328 
329 			case IS_STRING:
330 				r->dsc_dtype = dtype_varying;
331 				memcpy(res->vary_string, Z_STRVAL(return_value),
332 					(res->vary_length = min(r->dsc_length-2,Z_STRLEN(return_value))));
333 				r->dsc_length = res->vary_length+2;
334 				break;
335 		}
336 
337 		zval_dtor(&return_value);
338 
339 		return;
340 
341 	} while (0);
342 
343 	/**
344 	* If we end up here, we should report an error back to the DB engine, but
345 	* that's not possible. We can however report it back to PHP.
346 	*/
347 	LOCK();
348 	php_error_docref(NULL, E_WARNING, "Error calling function '%s' from database", name);
349 	UNLOCK();
350 }
351 
352 
353 /* Entry points for the DB engine */
354 
udf_call_php1(char * name,PARAMDSC * r,PARAMDSC * arg1)355 void udf_call_php1(char *name, PARAMDSC *r, PARAMDSC *arg1)
356 {
357 	PARAMDSC *args[1] = { arg1 };
358 	call_php(name, r, 1, args);
359 }
360 
udf_call_php2(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2)361 void udf_call_php2(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2)
362 {
363 	PARAMDSC *args[2] = { arg1, arg2 };
364 	call_php(name, r, 2, args);
365 }
366 
udf_call_php3(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3)367 void udf_call_php3(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3)
368 {
369 	PARAMDSC *args[3] = { arg1, arg2, arg3 };
370 	call_php(name, r, 3, args);
371 }
372 
udf_call_php4(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3,PARAMDSC * arg4)373 void udf_call_php4(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3,
374 	PARAMDSC *arg4)
375 {
376 	PARAMDSC *args[4] = { arg1, arg2, arg3, arg4 };
377 	call_php(name, r, 4, args);
378 }
379 
udf_call_php5(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3,PARAMDSC * arg4,PARAMDSC * arg5)380 void udf_call_php5(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3,
381 	PARAMDSC *arg4, PARAMDSC *arg5)
382 {
383 	PARAMDSC *args[5] = { arg1, arg2, arg3, arg4, arg5 };
384 	call_php(name, r, 5, args);
385 }
386 
udf_call_php6(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3,PARAMDSC * arg4,PARAMDSC * arg5,PARAMDSC * arg6)387 void udf_call_php6(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3,
388 	PARAMDSC *arg4, PARAMDSC *arg5, PARAMDSC *arg6)
389 {
390 	PARAMDSC *args[6] = { arg1, arg2, arg3, arg4, arg5, arg6 };
391 	call_php(name, r, 6, args);
392 }
393 
udf_call_php7(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3,PARAMDSC * arg4,PARAMDSC * arg5,PARAMDSC * arg6,PARAMDSC * arg7)394 void udf_call_php7(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3,
395 	PARAMDSC *arg4, PARAMDSC *arg5, PARAMDSC *arg6, PARAMDSC *arg7)
396 {
397 	PARAMDSC *args[7] = { arg1, arg2, arg3, arg4, arg5, arg6, arg7 };
398 	call_php(name, r, 7, args);
399 }
400 
udf_call_php8(char * name,PARAMDSC * r,PARAMDSC * arg1,PARAMDSC * arg2,PARAMDSC * arg3,PARAMDSC * arg4,PARAMDSC * arg5,PARAMDSC * arg6,PARAMDSC * arg7,PARAMDSC * arg8)401 void udf_call_php8(char *name, PARAMDSC *r, PARAMDSC *arg1, PARAMDSC *arg2, PARAMDSC *arg3,
402 	PARAMDSC *arg4, PARAMDSC *arg5, PARAMDSC *arg6, PARAMDSC *arg7, PARAMDSC *arg8)
403 {
404 	PARAMDSC *args[8] = { arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8 };
405 	call_php(name, r, 8, args);
406 }
407