summaryrefslogtreecommitdiff
path: root/ext/dbplus/php_dbplus.c
diff options
context:
space:
mode:
Diffstat (limited to 'ext/dbplus/php_dbplus.c')
-rw-r--r--ext/dbplus/php_dbplus.c1561
1 files changed, 0 insertions, 1561 deletions
diff --git a/ext/dbplus/php_dbplus.c b/ext/dbplus/php_dbplus.c
deleted file mode 100644
index 26256672e5..0000000000
--- a/ext/dbplus/php_dbplus.c
+++ /dev/null
@@ -1,1561 +0,0 @@
-/*
- +----------------------------------------------------------------------+
- | 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"
-
-#include "ext/standard/php_string.h"
-
-#include <saccess.h>
-#include <relation.h>
-#include <dblight.h>
-
-/* missing prototypes in dbplus header files */
-void string_to_scalop(char *op, enum scalop *sop);
-field * string_to_field(char *val, attribute *ap, int flags);
-void cdb_tcl(int,char *,char **, int *);
-relf * aql_exec(char *, char *);
-tuple *rnext(relf *);
-
-
-#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:
- /* short integer */
- convert_to_long_ex(element);
- AFFIX(ap, t)->f_short = (short) (*element)->value.lval;
- break;
-
- case FT_UNSIGNED:
- /* unsigned short integer */
- convert_to_long_ex(element);
- AFFIX(ap, t)->f_unsigned = (unsigned) (*element)->value.lval;
- break;
-
- case FT_LONG:
- /* 32bit signed long */
- case FT_SEQUENCE:
- /* unique sequence number -> just a long to outsiders */
- convert_to_long_ex(element);
- AFFIX(ap, t)->f_long = (long4) (*element)->value.lval;
- break;
-
- case FT_DATE:
- /* date -> long containing YYYYMMDD */
- convert_to_long_ex(element);
- AFFIX(ap, t)->f_date = (long4) (*element)->value.lval;
- break;
-
- case FT_TIME:
- /* time as unix timestamp */
- convert_to_long_ex(element);
- AFFIX(ap, t)->f_time = (long4) (*element)->value.lval;
- break;
-
- case FT_FLOAT:
- /* single prec. floating point */
- convert_to_double_ex(element);
- AFFIX(ap, t)->f_float = (float) (*element)->value.dval;
- break;
-
- case FT_DOUBLE:
- /* double prec. floating point */
- convert_to_double_ex(element);
- AFFIX(ap, t)->f_double = (double) (*element)->value.dval;
- break;
-
- case FT_STRING:
- case FT_DEUTSCH:
- case FT_CHAR:
- case FT_ANSI:
- case FT_ISO:
- case FT_ISOL:
- /* different variants of Strings */
- convert_to_string_ex(element);
- afput(ap, t, (field *)0, (*element)->value.str.val);
- break;
-
- default:
- php_error(E_WARNING,"%s is of yet unsupported type %d",ap->att_name,ap->att_type);
- break;
- }
- } while (ap++, --deg);
- return 0;
-}
-
-
-
-static int
-tuple2var(relf * r, tuple * t, zval **zv)
-{
- register attribute *ap ;
- unsigned deg ;
- 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:
- case FT_SEQUENCE:
- ZVAL_LONG(element, AFFIX(ap, t)->f_long);
- break;
-
- case FT_TIME:
- ZVAL_LONG(element, AFFIX(ap, t)->f_time);
- 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;
-
- default:
- php_error(E_WARNING,"%s is of yet unsupported type %d",ap->att_name,ap->att_type);
- break;
- }
-
- 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;
- field *f;
- enum scalop sop;
- 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;
- 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);
- if(stat==ERR_NOERR) {
- tuple2var(r, &t, data);
- }
-
- RETURN_LONG(stat);
-}
-/* }}} */
-
-/* {{{ proto resource 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;
- char *p;
- zval **newdir;
-
- argc = ZEND_NUM_ARGS();
- switch(argc) {
- case 0:
- break;
- case 1:
- if(zend_get_parameters_ex(1, &newdir) == FAILURE) {
- WRONG_PARAM_COUNT;
- } else {
- convert_to_string_ex(newdir);
- }
- break;
- default:
- WRONG_PARAM_COUNT;
- }
-
- p = cdb_chdir((argc)?_STRING(newdir):NULL);
- if(p) {
- RETURN_STRING(p, 1);
- } else {
- RETURN_FALSE;
- }
-}
-/* }}} */
-
-/* {{{ 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 int 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, mixed tuple)
- Set a constraint on a relation*/
-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)
- Release write lock on tuple */
-PHP_FUNCTION(dbplus_freelock)
-{
- zval **relation, **data;
- 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;
- 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)
- Get a id number unique to a relation */
-PHP_FUNCTION(dbplus_getunique)
-{
- relf *r;
- zval **relation, **uniqueid;
- long l;
- int stat;
-
- if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &uniqueid) == FAILURE){
- WRONG_PARAM_COUNT;
- }
-
- DBPLUS_FETCH_RESOURCE(r, relation);
-
- stat = cdb_getunique(r, &l, 1);
- if(!stat) {
- ZVAL_LONG(*uniqueid,l);
- }
-
- RETURN_LONG(stat);
-}
-/* }}} */
-
-/* {{{ 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 write 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;
- 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);
-
- if(r->r_sid = 9999) {
- t = rnext(r);
- stat = Acc_error;
- } else {
- t = (tuple *) pmalloc(sizeof(tuple));
- stat = cdb_next(r, t);
- }
- if(stat==ERR_NOERR) {
- tuple2var(r, t, tname);
- }
-
- RETURN_LONG(stat);
-}
-/* }}} */
-
-/* {{{ proto resource 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 resource dbplus_rcreate(string name, mixed domlist [, int overwrite])
- Create a new db++ reslation
-*/
-PHP_FUNCTION(dbplus_rcreate)
-{
- zval **name, **domlist, **overwrite;
- relf *r=NULL;
- int flag, ndoms, argc = ZEND_NUM_ARGS();
- attdef *at0;
-
- switch(argc) {
- case 3:
- if(zend_get_parameters_ex(3, &name, &domlist, &overwrite) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- convert_to_long_ex(overwrite);
- flag=_INT(overwrite);
- break;
- case 2:
- if(zend_get_parameters_ex(3, &name, &domlist) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- flag=0;
- break;
- default:
- WRONG_PARAM_COUNT;
- break;
- }
-
- convert_to_string_ex(name);
-
- switch ( (*domlist)->type ) {
- case IS_STRING:
- convert_to_string_ex(domlist);
- break;
-
- case IS_ARRAY:
- {
- zval tmp;
- ZVAL_STRING(&tmp," ",0);
- php_implode(&tmp,*domlist,*domlist);
- }
- break;
-
- default:
- }
-
- at0 = create2att(_STRING(domlist), &ndoms);
- if (at0) {
- r = cdbRcreate(_STRING(name), 0666, 0, ndoms, at0, flag);
- dbxfree((char *) at0);
- }
- if(r == NULL) {
- /* TODO error handling */
- RETURN_FALSE;
- }
-
- ZEND_REGISTER_RESOURCE(return_value, r, le_dbplus_relation);
-}
-/* }}} */
-
-/* {{{ proto resource dbplus_rcrtexact(string name, resource relation [, boolean overwrite])
- Create an exact but empty copy of a relation including indices
- */
-PHP_FUNCTION(dbplus_rcrtexact)
-{
- zval **name, **relation, **overwrite;
- relf *r;
- int f,argc = ZEND_NUM_ARGS();
-
- switch(argc) {
- case 3:
- if(zend_get_parameters_ex(3, &name, &relation, &overwrite) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- convert_to_long_ex(overwrite);
- f=_INT(overwrite);
- break;
- case 2:
- if(zend_get_parameters_ex(3, &name, &relation) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- f=0;
- break;
- default:
- WRONG_PARAM_COUNT;
- break;
- }
-
- convert_to_string_ex(name);
- DBPLUS_FETCH_RESOURCE(r, relation);
-
- r = cdbRcrtexact(_STRING(name), 0666, r, f);
- if(r == NULL) {
- /* TODO error handling */
- RETURN_FALSE;
- }
-
- ZEND_REGISTER_RESOURCE(return_value, r, le_dbplus_relation);
-}
-/* }}} */
-
-/* {{{ proto resource dbplus_rcrtlike(string name, int handle [, int overwrite])
- Create an empty copy of a relation with default indices
-*/
-PHP_FUNCTION(dbplus_rcrtlike)
-{
- zval **name, **relation, **overwrite;
- relf *r;
- int f,argc = ZEND_NUM_ARGS();
-
- switch(argc) {
- case 3:
- if(zend_get_parameters_ex(3, &name, &relation, &overwrite) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- convert_to_long_ex(overwrite);
- f=_INT(overwrite);
- break;
- case 2:
- if(zend_get_parameters_ex(3, &name, &relation) == FAILURE) {
- WRONG_PARAM_COUNT;
- }
- f=0;
- break;
- default:
- WRONG_PARAM_COUNT;
- break;
- }
-
- convert_to_string_ex(name);
- DBPLUS_FETCH_RESOURCE(r, relation);
-
- r = cdbRcrtlike(_STRING(name), 0666, 0, r, f);
- if(r == NULL) {
- /* TODO error handling */
- RETURN_FALSE;
- }
-
- ZEND_REGISTER_RESOURCE(return_value, r, le_dbplus_relation);
-}
-/* }}} */
-
-/* {{{ proto int dbplus_resolve(string name)
- Resolve host information for relation */
-PHP_FUNCTION(dbplus_resolve)
-{
- zval **name, *element;
- char * host;
- char * host_path;
- int sid;
-
- if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &name) == FAILURE){
- WRONG_PARAM_COUNT;
- }
-
- convert_to_string_ex(name);
-
- sid = cdb_resolve(_STRING(name), &host, &host_path);
- if (sid <= 0)
- RETURN_FALSE;
-
- if (array_init(return_value) == FAILURE) {
- RETURN_FALSE;
- }
-
-
- MAKE_STD_ZVAL(element); element->type=IS_NULL;
- ZVAL_LONG(element,sid);
- zend_hash_update(Z_ARRVAL_P(return_value), "sid", 4,
- &element, sizeof(zval *), NULL);
-
- MAKE_STD_ZVAL(element); element->type=IS_NULL;
- ZVAL_STRING(element,host,1);
- zend_hash_update(Z_ARRVAL_P(return_value), "host", 5,
- &element, sizeof(zval *), NULL);
-
- MAKE_STD_ZVAL(element); element->type=IS_NULL;
- ZVAL_STRING(element,host_path,1);
- zend_hash_update(Z_ARRVAL_P(return_value), "host_path", 10,
- &element, sizeof(zval *), NULL);
-}
-/* }}} */
-
-/* {{{ 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 resource dbplus_rkeys(resource relation, mixed domlist)
- Define primary key for relation
-*/
-PHP_FUNCTION(dbplus_rkeys)
-{
- relf *r, *rnew;
- zval **relation, **domlist, **zdata;
- int nkeys=0;
- char *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);
-
- switch((*domlist)->type) {
- case 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, "dbplus_rkeys: domlist array contains non-string value(s)");
- Acc_error = ERR_USER;
- RETURN_FALSE;
- }
- }
- break;
-
- case IS_STRING:
- convert_to_string_ex(domlist);
- keys[0] = _STRING(domlist);
- nkeys = 1;
- break;
-
- default:
- php_error(E_WARNING, "dbplus_rkeys: domlist has to be of type string or an array of strings");
- Acc_error = ERR_USER;
- RETURN_FALSE;
- }
-
- rnew = cdbRkeys(r, nkeys, keys);
- if(name) efree(name);
-
- if(rnew) {
- /* TODO realy delete old relation resource ? */
-#if 0
- zend_list_delete((*relation)->value.lval);
-#endif
- ZEND_REGISTER_RESOURCE(return_value, rnew, le_dbplus_relation);
- } else {
- /* TODO error reporting */
- RETURN_FALSE;
- }
-}
-/* }}} */
-
-/* {{{ proto resource dbplus_ropen(string name)
- Open relation file local */
-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 resceour dbplus_rquery(string name, string dbpath)
- */
-PHP_FUNCTION(dbplus_rquery)
-{
- relf *r;
- zval **name, **dbpath;
- int argc = ZEND_NUM_ARGS();
-
- if ((argc <1) || (argc>2) || (zend_get_parameters_ex(2, &name, &dbpath) == FAILURE)){
- WRONG_PARAM_COUNT;
- }
-
- r = aql_exec(_STRING(name), (argc==2)?_STRING(dbpath):NULL);
-
- if(!r) {
- /* TODO error handling */
- RETURN_FALSE;
- }
-
- r->r_sid = 9999;
-
- ZEND_REGISTER_RESOURCE(return_value, r, le_dbplus_relation);
-}
-/* }}} */
-
-/* {{{ proto int dbplus_rrename(int relation, string name)
- */
-PHP_FUNCTION(dbplus_rrename)
-{
- relf *r;
- zval **relation, **name;
- if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &relation, &name) == FAILURE){
- WRONG_PARAM_COUNT;
- }
-
- DBPLUS_FETCH_RESOURCE(r, relation);
-
- convert_to_string_ex(name);
-
- RETURN_LONG(cdbRrename(r, _STRING(name), 0));
-}
-/* }}} */
-
-/* {{{ proto resource dbplus_rsecindex(resource relation, mixed domlist, int compact)
- Create an additional index on relation
-*/
-PHP_FUNCTION(dbplus_rsecindex)
-{
- relf *r, *rnew;
- zval **relation, **domlist, **compact, **zdata;
- int nkeys=0;
- char *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);
-
- switch ( (*domlist)->type ) {
- case 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, "dbplus_rsecindex: domlist array contains non-string value(s)");
- Acc_error = ERR_USER;
- RETURN_FALSE;
- }
- }
- break;
-
- case IS_STRING:
- convert_to_string_ex(domlist);
- keys[0] = _STRING(domlist);
- nkeys = 1;
- break;
-
- default:
- php_error(E_WARNING, "dbplus_rsecindex: domlist has to be of type string or an array of strings");
- Acc_error = ERR_USER;
- RETURN_FALSE;
- }
-
- 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;
- if (ZEND_NUM_ARGS() != 1 || zend_get_parameters_ex(1, &relation) == FAILURE){
- WRONG_PARAM_COUNT;
- }
-
- DBPLUS_FETCH_RESOURCE(r, relation);
-
- RETURN_LONG(cdbRzap(r, 1));
-}
-/* }}} */
-
-/* {{{ 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 resource 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 string dbplus_tcl(int sid, string script)
- Execute server side TCL code
- */
-PHP_FUNCTION(dbplus_tcl)
-{
- zval **sid, **script;
- char *ret;
- int result_type;
-
- if (ZEND_NUM_ARGS() != 2 || zend_get_parameters_ex(2, &sid, &script) == FAILURE){
- WRONG_PARAM_COUNT;
- }
-
- convert_to_long_ex(sid);
- convert_to_string_ex(script);
-
- cdb_tcl(_INT(sid),_STRING(script),&ret,&result_type);
-
- if(ret) {
- RETURN_STRING(ret,1);
- } else {
- RETURN_FALSE;
- }
-}
-/* }}} */
-
-/* {{{ 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, &current) == 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 write 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)
- Remove constraint from 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 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 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:
- */
View Lorry Controller Status