--- /dev/null
+/*
+ +----------------------------------------------------------------------+
+ | PHP version 4.0 |
+ +----------------------------------------------------------------------+
+ | Copyright (c) 1997, 1998, 1999, 2000, 2001 The PHP Group |
+ +----------------------------------------------------------------------+
+ | This source file is subject to version 2.02 of the PHP license, |
+ | that is bundled with this package in the file LICENSE, and is |
+ | available at through the world-wide-web at |
+ | http://www.php.net/license/2_02.txt. |
+ | If you did not receive a copy of the PHP license and are unable to |
+ | obtain it through the world-wide-web, please send a note to |
+ | license@php.net so we can mail you a copy immediately. |
+ +----------------------------------------------------------------------+
+ | Authors: Hartmut Holzgraefe <hartmut@six.de> |
+ | |
+ +----------------------------------------------------------------------+
+ */
+
+#include "php.h"
+#include "php_ini.h"
+#include "php_dbplus.h"
+
+
+#define _STRING(x) ((*x)->value.str.val)
+#define _INT(x) ((*x)->value.lval)
+#define _HASH(x) ((*x)->value.ht)
+
+#define DBPLUS_FETCH_RESOURCE(r,z) ZEND_FETCH_RESOURCE(r, relf *, z, -1, "dbplus_relation", le_dbplus_relation); \
+ if(!r) RETURN_LONG(ERR_UNKNOWN);
+
+
+static int
+var2tuple(relf *r, zval **zv, tuple *t)
+{
+ register attribute *ap ;
+ unsigned deg ;
+ zval **element;
+
+ if ((*zv)->type!=IS_ARRAY)
+ return 1;
+
+ rtupinit(r, t);
+
+ ap = r->r_atts;
+ deg = r->r_rel.rel_deg;
+ do {
+ if(SUCCESS!=zend_hash_find((*zv)->value.ht,ap->att_name,strlen(ap->att_name)+1,(void **)&element))
+ continue;
+
+ if (! *element) return 1;
+
+ switch(ap->att_type) {
+ case FT_SHORT:
+ convert_to_long_ex(element);
+ AFFIX(ap, t)->f_short = (short) (*element)->value.lval;
+ break;
+ case FT_UNSIGNED:
+ convert_to_long_ex(element);
+ AFFIX(ap, t)->f_unsigned = (unsigned) (*element)->value.lval;
+ break;
+ case FT_SEQUENCE:
+ case FT_LONG:
+ convert_to_long_ex(element);
+ AFFIX(ap, t)->f_long = (long) (*element)->value.lval;
+ break;
+ case FT_DATE:
+ convert_to_long_ex(element);
+ AFFIX(ap, t)->f_date = (long) (*element)->value.lval;
+ break;
+ case FT_FLOAT:
+ convert_to_double_ex(element);
+ AFFIX(ap, t)->f_float = (float) (*element)->value.dval;
+ break;
+ case FT_DOUBLE:
+ convert_to_double_ex(element);
+ AFFIX(ap, t)->f_double = (double) (*element)->value.dval;
+ break;
+ case FT_STRING: case FT_DEUTSCH: case FT_CHAR:
+ convert_to_string_ex(element);
+ afput(ap, t, (field *)0, (*element)->value.str.val);
+ break;
+ case FT_TIMESTAMP:
+ /* TODO
+ str2timestamp(SvPV(sv, na), (timestamp *)AFFIX(ap, t));
+ */
+ break;
+ case FT_BINARY:
+ case FT_BLOB:
+ case FT_MEMO:
+ break;
+ }
+ } while (ap++, --deg);
+ return 0;
+}
+
+
+
+static int
+tuple2var(relf * r, tuple * t, zval **zv)
+{
+ register attribute *ap ;
+ unsigned deg ;
+ char buf[20];
+ zval *element;
+
+ zval_dtor(*zv);
+ if (array_init(*zv) == FAILURE) {
+ return 1;
+ }
+
+ ap = r->r_atts;
+ deg = r->r_rel.rel_deg;
+ do {
+ MAKE_STD_ZVAL(element); element->type=IS_NULL;
+
+ switch(ap->att_type) {
+ case FT_SHORT:
+ ZVAL_LONG(element,AFFIX(ap, t)->f_short);
+ break;
+
+ case FT_UNSIGNED:
+ ZVAL_LONG(element,AFFIX(ap, t)->f_unsigned);
+ break;
+
+ case FT_LONG:
+ ZVAL_LONG(element,AFFIX(ap, t)->f_long);
+ break;
+
+ case FT_FLOAT:
+ ZVAL_DOUBLE(element,AFFIX(ap, t)->f_float);
+ break;
+
+ case FT_DOUBLE:
+ ZVAL_DOUBLE(element,AFFIX(ap, t)->f_double);
+ break;
+
+ case FT_STRING: case FT_DEUTSCH: case FT_CHAR:
+ ZVAL_STRING(element,AFVAR(ap, t)->f_string,1);
+ break;
+
+ /*
+ case FT_P_SHORT: return "FT_P_SHORT";
+ case FT_P_LONG: return "FT_P_LONG";
+ case FT_DATE: return "FT_DATE";
+ case FT_TIME: return "FT_TIME";
+ case FT_BINARY: return "FT_BINARY";
+ case FT_BLOB: return "FT_BLOB";
+ case FT_ANSI: return "FT_ANSI";
+ case FT_TIMESTAMP: return "FT_TIMESTAMP";
+ case FT_SEQUENCE: return "FT_SEQUENCE";
+ case FT_MEMO: return "FT_MEMO";
+ case FT_ISO: return "FT_ISO";
+ case FT_ISOL: return "FT_ISOL";
+ case FT_ANON: return "FT_ANON";
+ case FT_TUPID: return "FT_TUPID";
+ case FT_INVALID: return "FT_INVALID";
+ */
+ }
+
+ if(element->type!=IS_NULL)
+ zend_hash_update((*zv)->value.ht
+ ,ap->att_name
+ ,strlen(ap->att_name)+1
+ ,(void *)&element
+ ,sizeof(zval*)
+ ,NULL);
+
+ } while (ap++, --deg);
+ return 0;
+}
+
+static constraint *
+ary2constr(relf * r, zval** constr)
+{
+ attribute *ap;
+ static constraint c;
+ int len;
+ int alen;
+ field *f;
+ enum scalop sop;
+ int n_elems;
+ int n;
+ char * dom;
+ char * val;
+ char * op;
+ zval **zdata;
+
+ /* init first */
+ db_coninit(r, &c);
+
+ if ((*constr)->type != IS_ARRAY) {
+ php_error(E_WARNING,"Constraint is not an array");
+ return NULL;
+ }
+
+ zend_hash_internal_pointer_reset(_HASH(constr));
+ if(zend_hash_get_current_data(_HASH(constr),(void **)&zdata)!=SUCCESS) {
+ php_error(E_WARNING,"Constraint array is empty");
+ return NULL;
+ }
+
+ switch((*zdata)->type) {
+ case IS_STRING: /* constraints in plain string array */
+ if (_HASH(constr)->nNumOfElements%3) {
+ php_error(E_WARNING,"Constraint array has to have triples of strings");
+ return NULL;
+ }
+
+ do {
+ convert_to_string_ex(zdata);
+ dom = _STRING(zdata);
+ zend_hash_move_forward(_HASH(constr));
+ zend_hash_get_current_data(_HASH(constr),(void **)&zdata);
+ convert_to_string_ex(zdata);
+ op = _STRING(zdata);
+ zend_hash_move_forward(_HASH(constr));
+ zend_hash_get_current_data(_HASH(constr),(void **)&zdata);
+ convert_to_string_ex(zdata);
+ val = _STRING(zdata);
+ zend_hash_move_forward(_HASH(constr));
+
+ if (!(ap = (attribute *) attno (r, dom))) {
+ fprintf(stderr, "Invalid domain \"%s\"\n", dom);
+ return 0;
+ }
+
+ /* operator */
+ string_to_scalop(op, &sop);
+
+ /* value */
+ f = string_to_field(val, ap, 0);
+
+ (void) db_constrain(r, &c, dom, sop, f ? f : (field *) val);
+ } while(SUCCESS==zend_hash_get_current_data(_HASH(constr),(void **)&zdata));
+
+ break;
+ case IS_ARRAY:
+ {
+ zval **entry;
+ for(zend_hash_internal_pointer_reset(_HASH(constr));
+ SUCCESS==zend_hash_get_current_data(_HASH(constr),(void **)&zdata);
+ zend_hash_move_forward(_HASH(constr))) {
+ if(!((*zdata)->type==IS_ARRAY)) {
+ php_error(E_WARNING,"Constraint array element not an array");
+ return NULL;
+ }
+ if(_HASH(zdata)->nNumOfElements!=3) {
+ php_error(E_WARNING,"Constraint array element not an array of size 3");
+ return NULL;
+ }
+
+ zend_hash_internal_pointer_reset(_HASH(zdata));
+ zend_hash_get_current_data(_HASH(zdata),(void **)&entry);
+ convert_to_string_ex(entry);
+ dom=_STRING(entry);
+
+ zend_hash_move_forward(_HASH(zdata));
+ zend_hash_get_current_data(_HASH(zdata),(void **)&entry);
+ convert_to_string_ex(entry);
+ op=_STRING(entry);
+
+ zend_hash_move_forward(_HASH(zdata));
+ zend_hash_get_current_data(_HASH(zdata),(void **)&entry);
+ convert_to_string_ex(entry);
+ val=_STRING(entry);
+
+ if (!(ap = (attribute *) attno (r, dom))) {
+ fprintf(stderr, "Invalid domain \"%s\"\n", dom);
+ return 0;
+ }
+
+ /* operator */
+ string_to_scalop(op, &sop);
+
+ /* value */
+ f = string_to_field(val, ap, 0);
+
+ (void) db_constrain(r, &c, dom, sop, f ? f : (field *) val);
+ }
+
+ }
+ break;
+ default:
+ /* TODO error-handling */
+ return NULL;
+ }
+
+ return &c;
+}
+
+
+/* {{{ proto int dbplus_add(int relation, array tuple)
+ Add a tuple to a relation */
+PHP_FUNCTION(dbplus_add)
+{
+ zval **relation, **data, **element;
+ enum errorcond stat = ERR_UNKNOWN;
+ relf *r;
+ tuple t;
+
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &data) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+ convert_to_array_ex(data);
+
+ if(var2tuple(r,data,&t))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ stat=cdb_add(r,&t);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_aql(string query [, string server [, string dbpath]])
+ Perform AQL query */
+PHP_FUNCTION(dbplus_aql)
+{
+ int argc;
+ zval **query, **server, **dbpath;
+ relf *r;
+
+ argc = ZEND_NUM_ARGS();
+ if (argc < 1 || argc > 3 || zend_get_parameters_ex(argc, &query, &server, &dbpath) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ switch (argc) {
+ case 3:
+ convert_to_string_ex(dbpath);
+ php_error(E_WARNING,"Arg dbpath: %s",_STRING(dbpath));
+ /* Fall-through. */
+ case 2:
+ convert_to_string_ex(server);
+ php_error(E_WARNING,"Arg server: %s",_STRING(server));
+ /* Fall-through. */
+ case 1:
+ convert_to_string_ex(query);
+ php_error(E_WARNING,"Arg query: %s",_STRING(query));
+ break;
+ }
+
+ r = cdb_aql((argc>=2)?_STRING(server):"localhost"
+ ,_STRING(query)
+ ,(argc==3)?_STRING(dbpath):NULL);
+ if(r == NULL) {
+ /* TODO error handling */
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value,r,le_dbplus_relation);
+}
+/* }}} */
+
+/* {{{ proto string dbplus_chdir([string newdir])
+ Get/Set database virtual current directory */
+PHP_FUNCTION(dbplus_chdir)
+{
+ int argc;
+ zval **newdir;
+
+ argc = ZEND_NUM_ARGS();
+ if (argc > 1 || zend_get_parameters_ex(1, &newdir) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ convert_to_string_ex(newdir);
+
+ RETURN_STRING(cdb_chdir((argc==1)?_STRING(newdir):NULL),1);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_close(int relation)
+ Close a relation */
+PHP_FUNCTION(dbplus_close)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ zend_list_delete((*relation)->value.lval);
+
+ RETURN_TRUE;
+}
+/* }}} */
+
+/* {{{ proto int dbplus_curr(int relation, array tuple)
+ Get current tuple from relation */
+PHP_FUNCTION(dbplus_curr)
+{
+ zval **relation, **tname;
+ relf *r;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_current(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto string dbplus_errcode(int err)
+ Get error string for given errorcode or last error */
+PHP_FUNCTION(dbplus_errcode)
+{
+ zval **err;
+ int errno;
+
+ switch (ZEND_NUM_ARGS()) {
+ case 0:
+ errno=-1;
+ break;
+ case 1:
+ if( zend_get_parameters_ex(1, &err) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+ convert_to_long_ex(err);
+ errno = _INT(err);
+ }
+
+ if(errno==-1) errno = Acc_error;
+
+ RETURN_STRING(dbErrorMsg(errno,NULL),1);
+}
+/* }}} */
+
+/* {{{ proto string dbplus_errno(void)
+ Get error code for last operation */
+PHP_FUNCTION(dbplus_errno)
+{
+ RETURN_LONG(Acc_error);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_find(int relation, array constr, array tuple)
+ */
+PHP_FUNCTION(dbplus_find)
+{
+ relf *r;
+ zval **relation, **constr, **data;
+ constraint *c;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &constr, &data) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ if ((*constr)->type != IS_ARRAY) {
+ php_error(E_WARNING,"Constraint is not an array");
+ RETURN_LONG(ERR_UNKNOWN);
+ }
+
+ convert_to_array_ex(data);
+
+ c = ary2constr(r,constr);
+
+ if (!c){
+ RETURN_LONG(ERR_USER);
+ }
+
+ stat = cdb_find(r, &t, c);
+
+ if(stat==ERR_NOERR)
+ tuple2var(r,&t,data);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_first(int relation, array tuple)
+ Get first tuple from relation */
+PHP_FUNCTION(dbplus_first)
+{
+ zval **relation, **tname;
+ relf *r;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_first(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_flush(int relation)
+ ??? */
+PHP_FUNCTION(dbplus_flush)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_flush(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_freealllocks(void)
+ Free all locks held by this client */
+PHP_FUNCTION(dbplus_freealllocks)
+{
+ RETURN_LONG(cdbFreeAllLocks());
+}
+/* }}} */
+
+
+/* {{{ proto int dbplus_freelock(int relation, array tuple)
+ Give up lock on tuple */
+PHP_FUNCTION(dbplus_freelock)
+{
+ zval **relation, **data, **element;
+ enum errorcond stat = ERR_UNKNOWN;
+ relf *r;
+ tuple t;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &data) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_array_ex(data);
+
+ if(var2tuple(r,data,&t))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ stat=cdb_freelock(r,&t);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_freerlocks(int relation)
+ Free all locks on given relation */
+PHP_FUNCTION(dbplus_freerlocks)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_freerlocks(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_getlock(int relation, array tuple)
+ Request locking of tuple */
+PHP_FUNCTION(dbplus_getlock)
+{
+ zval **relation, **data, **element;
+ enum errorcond stat = ERR_UNKNOWN;
+ relf *r;
+ tuple t;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &data) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_array_ex(data);
+
+ if(var2tuple(r,data,&t))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ stat=cdb_getlock(r,&t);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_getunique(int handle, int uniqueid, int flush)
+ */
+PHP_FUNCTION(dbplus_getunique)
+{
+ relf *r;
+ zval **relation, **uniqueid, **flush;
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &uniqueid, &flush) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+ convert_to_long_ex(uniqueid);
+ convert_to_long_ex(flush);
+
+ RETURN_LONG(cdb_getunique(r,&(_INT(uniqueid)),_INT(flush)));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_info(int relation, string key, array &result)
+ ??? */
+PHP_FUNCTION(dbplus_info)
+{
+ zval **relation, **key, **result, *element;
+ relf *r;
+ register attribute *ap;
+ unsigned deg;
+
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &key, &result) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ ap = r->r_atts;
+ deg = r->r_rel.rel_deg;
+
+ convert_to_string_ex(key);
+
+ zval_dtor(*result);
+ if (array_init(*result) == FAILURE)
+ RETURN_LONG(ERR_USER);
+
+ if(!strcmp("atts",(*key)->value.str.val)) {
+ do {
+ MAKE_STD_ZVAL(element);
+
+ ZVAL_STRING(element,ap->att_name,1);
+
+ zend_hash_update((*result)->value.ht
+ ,ap->att_name
+ ,strlen(ap->att_name)+1
+ ,(void *)&element
+ ,sizeof(zval*)
+ ,NULL);
+ } while (ap++,deg--);
+ RETURN_LONG(ERR_NOERR);
+ }
+
+ RETURN_LONG(ERR_USER);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_last(int relation, array tuple)
+ Get last tuple from relation */
+PHP_FUNCTION(dbplus_last)
+{
+ zval **relation, **tname;
+ relf *r;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_last(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+
+/* {{{ proto int dbplus_lockrel(int relation)
+ Request read-lock on relation */
+PHP_FUNCTION(dbplus_lockrel)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_lockrel(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_next(int relation, array &tname)
+ Get next tuple from relation */
+PHP_FUNCTION(dbplus_next)
+{
+ zval **relation, **tname, *element;
+ relf *r;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_next(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_open(string name)
+ Open a relation file */
+PHP_FUNCTION(dbplus_open)
+{
+ relf *r;
+ zval **tname;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ convert_to_string_ex(tname);
+
+ r = cdb_open((*tname)->value.str.val,1,1);
+ if(r == NULL) {
+ /* TODO error handling */
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value,r,le_dbplus_relation);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_prev(int relation, array tuple)
+ Get previous tuple from relation */
+PHP_FUNCTION(dbplus_prev)
+{
+ zval **relation, **tname;
+ relf *r;
+ tuple t;
+ int stat;
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_previous(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rchperm(int relation, int mask, string user, string group)
+ */
+PHP_FUNCTION(dbplus_rchperm)
+{
+ relf *r;
+ zval **relation, **mask, **user, **group;
+ if (ZEND_NUM_ARGS() != 4 || zend_get_parameters_ex(4, &relation, &mask, &user, &group) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_long_ex(mask);
+ convert_to_string_ex(user);
+ convert_to_string_ex(group);
+
+ RETURN_LONG(cdbRchperm(r,_INT(mask),_STRING(user),_STRING(group)));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_restorepos(int relation, array tuple)
+ ??? */
+PHP_FUNCTION(dbplus_restorepos)
+{
+ zval **relation, **tname;
+ relf *r;
+ tuple t;
+ int stat;
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ stat = cdb_next(r,&t);
+ if(stat==ERR_NOERR) {
+ tuple2var(r,&t,tname);
+ }
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rkeys(int relation, [string|array] domlist)
+ */
+PHP_FUNCTION(dbplus_rkeys)
+{
+ relf *r,*rnew;
+ zval **relation, **domlist, **zdata;
+ int nkeys=0;
+ char *p, *name=NULL, *keys[40]; /* TODO hardcoded magic number ??? */
+
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &domlist) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ if((*domlist)->type == IS_ARRAY) {
+ convert_to_array_ex(domlist);
+ for(zend_hash_internal_pointer_reset(_HASH(domlist));
+ SUCCESS==zend_hash_get_current_data(_HASH(domlist),(void **)&zdata);
+ zend_hash_move_forward(_HASH(domlist))) {
+ if((*zdata)->type==IS_STRING)
+ keys[nkeys++] = _STRING(zdata);
+ else {
+ php_error(E_WARNING,"Domlist array contains non-string value(s)");
+ Acc_error = ERR_USER;
+ RETURN_FALSE;
+ }
+ }
+ } else {
+ convert_to_string_ex(domlist);
+ name = estrdup(_STRING(domlist));
+ while (p = strtok(nkeys ? 0 : name, " "))
+ keys[nkeys++] = p;
+ }
+
+ rnew = cdbRkeys(r, nkeys, keys);
+ if(name) efree(name);
+
+ if(rnew) {
+ /* TODO realy delete old relation resource ? */
+ zend_list_delete((*relation)->value.lval);
+
+ ZEND_REGISTER_RESOURCE(return_value,rnew,le_dbplus_relation);
+ } else {
+ /* TODO error reporting */
+ RETURN_FALSE;
+ }
+}
+/* }}} */
+
+/* {{{ proto int dbplus_ropen(string name)
+ Open relation file ... ??? */
+PHP_FUNCTION(dbplus_ropen)
+{
+ relf *r;
+ zval **tname;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &tname) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ convert_to_string_ex(tname);
+
+ r = ropen((*tname)->value.str.val,0,0);
+ if(r == NULL) {
+ /* TODO error handling */
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value,r,le_dbplus_relation);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rquery(string name, string dbpath)
+ */
+PHP_FUNCTION(dbplus_rquery)
+{
+ relf *r;
+ zval **name, **dbpath;
+ int argc;
+
+ if (argc <1 || argc>2 || zend_get_parameters_ex(1, &name, &dbpath) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ r = aql_exec(_STRING(name),(argc==2)?_STRING(dbpath):NULL);
+
+ if(!r) {
+ /* TODO error handling */
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value,r,le_dbplus_relation);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rrename(int relation, string name, int flag)
+ */
+PHP_FUNCTION(dbplus_rrename)
+{
+ relf *r;
+ zval **relation, **name, **flag;
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &name, &flag) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_string_ex(name);
+ convert_to_long_ex(flag);
+
+ RETURN_LONG(cdbRrename(r,_STRING(name),(*flag)->value.lval));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rsecindex(int relation, string domlist, int compact)
+ */
+PHP_FUNCTION(dbplus_rsecindex)
+{
+ relf *r,*rnew;
+ zval **relation, **domlist, **compact, **zdata;
+ int nkeys=0;
+ char *p, *name=NULL, *keys[40]; /* TODO hardcoded magic number ??? */
+
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &domlist, &compact) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ if((*domlist)->type == IS_ARRAY) {
+ convert_to_array_ex(domlist);
+ for(zend_hash_internal_pointer_reset(_HASH(domlist));
+ SUCCESS==zend_hash_get_current_data(_HASH(domlist),(void **)&zdata);
+ zend_hash_move_forward(_HASH(domlist))) {
+ if((*zdata)->type==IS_STRING)
+ keys[nkeys++] = _STRING(zdata);
+ else {
+ php_error(E_WARNING,"Domlist array contains non-string value(s)");
+ Acc_error = ERR_USER;
+ RETURN_FALSE;
+ }
+ }
+ } else {
+ convert_to_string_ex(domlist);
+ name = estrdup(_STRING(domlist));
+ while (p = strtok(nkeys ? 0 : name, " "))
+ keys[nkeys++] = p;
+ }
+
+ convert_to_long_ex(compact);
+
+ rnew = cdbRsecindex(r, nkeys, keys, _INT(compact));
+ if(name) efree(name);
+
+ if(rnew) {
+ /* TODO realy delete old relation resource ? */
+ zend_list_delete((*relation)->value.lval);
+
+ ZEND_REGISTER_RESOURCE(return_value,rnew,le_dbplus_relation);
+ } else {
+ /* TODO error reporting */
+ RETURN_FALSE;
+ }
+}
+/* }}} */
+
+/* {{{ proto int dbplus_runlink(int relation)
+ Remove relation from filesystem */
+PHP_FUNCTION(dbplus_runlink)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdbRunlink(&r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_rzap(int relation, int truncate)
+ Remove all tuples from relation */
+PHP_FUNCTION(dbplus_rzap)
+{
+
+ /* todo: optional argument */
+ relf *r;
+ zval **relation, **truncate;
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &truncate) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ convert_to_long_ex(truncate);
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdbRzap(r,(*truncate)->value.lval));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_savepos(int relation)
+ ??? */
+PHP_FUNCTION(dbplus_savepos)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_savepos(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_setindex(int relation, string idx_name)
+ ???? */
+PHP_FUNCTION(dbplus_setindex)
+{
+ relf *r;
+ zval **relation, **idx_name;
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &idx_name) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_string_ex(idx_name);
+
+ RETURN_LONG(cdb_setindex(r,_STRING(idx_name)));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_setindexbynumber(int relation, int idx_number)
+ ??? */
+PHP_FUNCTION(dbplus_setindexbynumber)
+{
+ relf *r;
+ zval **relation, **idx_number;
+ if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &idx_number) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_long_ex(idx_number);
+
+ RETURN_LONG(cdb_setindexbynumber(r,(*idx_number)->value.lval));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_sql(string query, string server, string dbpath)
+ Perform SQL query */
+PHP_FUNCTION(dbplus_sql)
+{
+ int argc;
+ zval **query, **server, **dbpath;
+ relf *r;
+
+ argc = ZEND_NUM_ARGS();
+ if (argc < 1 || argc > 3 || zend_get_parameters_ex(argc, &query, &server, &dbpath) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ switch (argc) {
+ case 3:
+ convert_to_string_ex(dbpath);
+ php_error(E_WARNING,"Arg dbpath: %s",_STRING(dbpath));
+ /* Fall-through. */
+ case 2:
+ convert_to_string_ex(server);
+ php_error(E_WARNING,"Arg server: %s",_STRING(server));
+ /* Fall-through. */
+ case 1:
+ convert_to_string_ex(query);
+ php_error(E_WARNING,"Arg query: %s",_STRING(query));
+ break;
+ }
+
+ r = cdb_sql((argc>=2)?_STRING(server):"localhost"
+ ,_STRING(query)
+ ,(argc==3)?_STRING(dbpath):NULL);
+ if(r == NULL) {
+ /* TODO error handling */
+ RETURN_FALSE;
+ }
+
+ ZEND_REGISTER_RESOURCE(return_value,r,le_dbplus_relation);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_tremove(int relation, array old [, array current])
+ Remove tuple and return new current tuple */
+PHP_FUNCTION(dbplus_tremove)
+{
+ zval **relation, **old, **current;
+ enum errorcond stat = ERR_UNKNOWN;
+ relf *r;
+ tuple told,tcurr;
+ int argc;
+
+ argc = ZEND_NUM_ARGS();
+ if ( argc<2 || argc>3 || zend_get_parameters_ex(2, &relation, &old, ¤t) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_array_ex(old);
+
+ if(var2tuple(r,old,&told))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ stat=cdbTremove(r,&told,&tcurr);
+
+ if((stat==ERR_NOERR) && (argc==3))
+ tuple2var(r,&tcurr,current);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_undo(int relation)
+ ??? */
+PHP_FUNCTION(dbplus_undo)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_undo(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_undoprepare(int relation)
+ ??? */
+PHP_FUNCTION(dbplus_undoprepare)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_undoprepare(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_unlockrel(int relation)
+ Give up read-lock on relation */
+PHP_FUNCTION(dbplus_unlockrel)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_unlockrel(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_unselect(int relation)
+ ??? */
+PHP_FUNCTION(dbplus_unselect)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_unselect(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_update(int relation, array old, array new)
+ Update specified tuple in relation */
+PHP_FUNCTION(dbplus_update)
+{
+ zval **relation, **old, **new;
+ enum errorcond stat = ERR_UNKNOWN;
+ relf *r;
+ tuple told,tnew;
+
+ if (ZEND_NUM_ARGS() != 3 || zend_get_parameters_ex(3, &relation, &old, &new) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ convert_to_array_ex(old);
+ convert_to_array_ex(new);
+
+ if(var2tuple(r,old,&told))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ if(var2tuple(r,new,&tnew))
+ RETURN_LONG(ERR_UNKNOWN);
+
+ stat=cdb_update(r,&told,&tnew);
+
+ RETURN_LONG(stat);
+}
+/* }}} */
+
+/* {{{ proto int dbplus_xlockrel(int relation)
+ Request exclusive write lock on relation */
+PHP_FUNCTION(dbplus_xlockrel)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_xlockrel(r));
+}
+/* }}} */
+
+/* {{{ proto int dbplus_xunlockrel(int relation)
+ Free exclusive write lock on relation */
+PHP_FUNCTION(dbplus_xunlockrel)
+{
+ relf *r;
+ zval **relation;
+ if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
+ WRONG_PARAM_COUNT;
+ }
+
+ DBPLUS_FETCH_RESOURCE(r,relation);
+
+ RETURN_LONG(cdb_xunlockrel(r));
+}
+/* }}} */
+
+/*
+ * Local variables:
+ * tab-width: 2
+ * c-basic-offset: 2
+ * End:
+ */
projects / php / commitdiff