diff options
Diffstat (limited to 'ext/dbase/dbase.c')
| -rw-r--r-- | ext/dbase/dbase.c | 686 |
1 files changed, 686 insertions, 0 deletions
diff --git a/ext/dbase/dbase.c b/ext/dbase/dbase.c new file mode 100644 index 0000000000..46b1162583 --- /dev/null +++ b/ext/dbase/dbase.c @@ -0,0 +1,686 @@ +/* + +----------------------------------------------------------------------+ + | PHP HTML Embedded Scripting Language Version 3.0 | + +----------------------------------------------------------------------+ + | Copyright (c) 1997,1998 PHP Development Team (See Credits file) | + +----------------------------------------------------------------------+ + | This program is free software; you can redistribute it and/or modify | + | it under the terms of one of the following licenses: | + | | + | A) the GNU General Public License as published by the Free Software | + | Foundation; either version 2 of the License, or (at your option) | + | any later version. | + | | + | B) the PHP License as published by the PHP Development Team and | + | included in the distribution in the file: LICENSE | + | | + | This program is distributed in the hope that it will be useful, | + | but WITHOUT ANY WARRANTY; without even the implied warranty of | + | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | + | GNU General Public License for more details. | + | | + | You should have received a copy of both licenses referred to here. | + | If you did not, or have any questions about PHP licensing, please | + | contact core@php.net. | + +----------------------------------------------------------------------+ + | Authors: Jim Winstead (jimw@php.net) | + +----------------------------------------------------------------------+ + */ +#if defined(COMPILE_DL) +#include "dl/phpdl.h" +#endif + +#if defined(THREAD_SAFE) +#include "tls.h" +#endif +#include <stdlib.h> + +#include "php.h" +#include "safe_mode.h" +#include "fopen-wrappers.h" +#include "php_globals.h" + +#if DBASE +#include "dbase.h" +#include "../dbase/dbf.h" +#if defined(THREAD_SAFE) +DWORD DbaseTls; +static int numthreads=0; +void *dbase_mutex; + +typedef struct dbase_global_struct{ + int le_dbhead; +}dbase_global_struct; + +#define DBase_GLOBAL(a) dbase_globals->a + +#define DBase_TLS_VARS \ + dbase_global_struct *dbase_globals; \ + dbase_globals=TlsGetValue(DbaseTls); + +#else +static int le_dbhead; +#define DBase_GLOBAL(a) a +#define DBase_TLS_VARS +#endif + +#include <fcntl.h> +#include <errno.h> + + +static void _close_dbase(dbhead_t *dbhead) +{ + close(dbhead->db_fd); + free_dbf_head(dbhead); +} + + +int php3_minit_dbase(INIT_FUNC_ARGS) +{ +#if defined(THREAD_SAFE) + dbase_global_struct *dbase_globals; +#if !defined(COMPILE_DL) + CREATE_MUTEX(dbase_mutex,"DBase_TLS"); + SET_MUTEX(dbase_mutex); + numthreads++; + if (numthreads==1){ + if ((DbaseTls=TlsAlloc())==0xFFFFFFFF){ + FREE_MUTEX(dbase_mutex); + return 0; + }} + FREE_MUTEX(dbase_mutex); +#endif + dbase_globals = (dbase_global_struct *) LocalAlloc(LPTR, sizeof(dbase_global_struct)); + TlsSetValue(DbaseTls, (void *) dbase_globals); +#endif + DBase_GLOBAL(le_dbhead) = register_list_destructors(_close_dbase,NULL); + return SUCCESS; +} + +static int php3_mend_dbase(void){ +#if defined(THREAD_SAFE) + dbase_global_struct *dbase_globals; + dbase_globals = TlsGetValue(DbaseTls); + if (dbase_globals != 0) + LocalFree((HLOCAL) dbase_globals); +#if !defined(COMPILE_DL) + SET_MUTEX(dbase_mutex); + numthreads--; + if (!numthreads){ + if (!TlsFree(DbaseTls)){ + FREE_MUTEX(dbase_mutex); + return 0; + }} + FREE_MUTEX(dbase_mutex); +#endif +#endif + return SUCCESS; +} + +/* {{{ proto int dbase_open(string name, int mode) + Opens a dBase-format database file */ +void php3_dbase_open(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbf_name, *options; + dbhead_t *dbh; + int handle; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&dbf_name,&options)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_string(dbf_name); + convert_to_long(options); + + if (PG(safe_mode) && (!_php3_checkuid(dbf_name->value.str.val, 2))) { + RETURN_FALSE; + } + + if (_php3_check_open_basedir(dbf_name->value.str.val)) { + RETURN_FALSE; + } + + dbh = dbf_open(dbf_name->value.str.val, options->value.lval); + if (dbh == NULL) { + php3_error(E_WARNING, "unable to open database %s", dbf_name->value.str.val); + RETURN_FALSE; + } + + handle = php3_list_insert(dbh, DBase_GLOBAL(le_dbhead)); + RETURN_LONG(handle); +} +/* }}} */ + +/* {{{ proto bool dbase_close(int identifier) + Closes an open dBase-format database file */ +void php3_dbase_close(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id; + dbhead_t *dbh; + int dbh_type; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 1 || getParameters(ht,1,&dbh_id)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + php3_list_delete(dbh_id->value.lval); + RETURN_TRUE; +} +/* }}} */ + +/* {{{ proto int dbase_numrecords(int identifier) + Returns the number of records in the database */ +void php3_dbase_numrecords(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id; + dbhead_t *dbh; + int dbh_type; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 1 || getParameters(ht,1,&dbh_id)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + RETURN_LONG(dbh->db_records); +} +/* }}} */ + +/* {{{ proto int dbase_numfields(int identifier) + Returns the number of fields (columns) in the database */ +void php3_dbase_numfields(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id; + dbhead_t *dbh; + int dbh_type; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 1 || getParameters(ht,1,&dbh_id)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + RETURN_LONG(dbh->db_nfields); +} +/* }}} */ + +/* {{{ proto bool dbase_pack(int identifier) + Packs the database (deletes records marked for deletion) */ +void php3_dbase_pack(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id; + dbhead_t *dbh; + int dbh_type; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 1 || getParameters(ht,1,&dbh_id)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + pack_dbf(dbh); + put_dbf_info(dbh); + RETURN_TRUE; +} +/* }}} */ + +/* {{{ proto bool dbase_add_record(int identifier, array data) + Adds a record to the database */ +void php3_dbase_add_record(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id, *fields, *field; + dbhead_t *dbh; + int dbh_type; + + int num_fields; + dbfield_t *dbf, *cur_f; + char *cp, *t_cp; + int i; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&dbh_id,&fields)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + if (fields->type != IS_ARRAY) { + php3_error(E_WARNING, "Expected array as second parameter"); + RETURN_FALSE; + } + + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + num_fields = _php3_hash_num_elements(fields->value.ht); + + if (num_fields != dbh->db_nfields) { + php3_error(E_WARNING, "Wrong number of fields specified"); + RETURN_FALSE; + } + + cp = t_cp = (char *)emalloc(dbh->db_rlen + 1); + if (!cp) { + php3_error(E_WARNING, "unable to allocate memory"); + RETURN_FALSE; + } + *t_cp++ = VALID_RECORD; + + dbf = dbh->db_fields; + for (i = 0, cur_f = dbf; cur_f < &dbf[num_fields]; i++, cur_f++) { + if (_php3_hash_index_find(fields->value.ht, i, (void **)&field) == FAILURE) { + php3_error(E_WARNING, "unexpected error"); + efree(cp); + RETURN_FALSE; + } + convert_to_string(field); + sprintf(t_cp, cur_f->db_format, field->value.str.val); + t_cp += cur_f->db_flen; + } + + dbh->db_records++; + if (put_dbf_record(dbh, dbh->db_records, cp) < 0) { + php3_error(E_WARNING, "unable to put record at %ld", dbh->db_records); + efree(cp); + RETURN_FALSE; + } + + put_dbf_info(dbh); + efree(cp); + + RETURN_TRUE; +} +/* }}} */ + +/* {{{ proto bool dbase_delete_record(int identifier, int record) + Marks a record to be deleted */ +void php3_dbase_delete_record(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id, *record; + dbhead_t *dbh; + int dbh_type; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&dbh_id,&record)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + convert_to_long(record); + + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + if (del_dbf_record(dbh, record->value.lval) < 0) { + if (record->value.lval > dbh->db_records) { + php3_error(E_WARNING, "record %d out of bounds", record->value.lval); + } else { + php3_error(E_WARNING, "unable to delete record %d", record->value.lval); + } + RETURN_FALSE; + } + + put_dbf_info(dbh); + RETURN_TRUE; +} +/* }}} */ + +/* {{{ proto array dbase_get_record(int identifier, int record) + Returns an array representing a record from the database */ +void php3_dbase_get_record(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id, *record; + dbhead_t *dbh; + int dbh_type; + dbfield_t *dbf, *cur_f; + char *data, *fnp, *str_value; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&dbh_id,&record)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + convert_to_long(record); + + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + if ((data = get_dbf_record(dbh, record->value.lval)) == NULL) { + php3_error(E_WARNING, "Tried to read bad record %d", record->value.lval); + RETURN_FALSE; + } + + dbf = dbh->db_fields; + + if (array_init(return_value) == FAILURE) { + RETURN_FALSE; + } + + fnp = (char *)emalloc(dbh->db_rlen); + for (cur_f = dbf; cur_f < &dbf[dbh->db_nfields]; cur_f++) { + /* get the value */ + str_value = (char *)emalloc(cur_f->db_flen + 1); + sprintf(str_value, cur_f->db_format, get_field_val(data, cur_f, fnp)); + + /* now convert it to the right php internal type */ + switch (cur_f->db_type) { + case 'C': + case 'D': + add_next_index_string(return_value,str_value,1); + break; + case 'N': /* FALLS THROUGH */ + case 'L': /* FALLS THROUGH */ + if (cur_f->db_fdc == 0) { + add_next_index_long(return_value, strtol(str_value, NULL, 10)); + } else { + add_next_index_double(return_value, atof(str_value)); + } + break; + case 'M': + /* this is a memo field. don't know how to deal with + this yet */ + break; + default: + /* should deal with this in some way */ + break; + } + efree(str_value); + } + efree(fnp); + + /* mark whether this record was deleted */ + if (data[0] == '*') { + add_assoc_long(return_value,"deleted",1); + } + else { + add_assoc_long(return_value,"deleted",0); + } + + free(data); +} +/* }}} */ + +/* From Martin Kuba <makub@aida.inet.cz> */ +/* {{{ proto array dbase_get_record_with_names(int identifier, int record) + Returns an associative array representing a record from the database */ +void php3_dbase_get_record_with_names(INTERNAL_FUNCTION_PARAMETERS) { + pval *dbh_id, *record; + dbhead_t *dbh; + int dbh_type; + dbfield_t *dbf, *cur_f; + char *data, *fnp, *str_value; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&dbh_id,&record)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_long(dbh_id); + convert_to_long(record); + + dbh = php3_list_find(dbh_id->value.lval, &dbh_type); + if (!dbh || dbh_type != DBase_GLOBAL(le_dbhead)) { + php3_error(E_WARNING, "Unable to find database for identifier %d", dbh_id->value.lval); + RETURN_FALSE; + } + + if ((data = get_dbf_record(dbh, record->value.lval)) == NULL) { + php3_error(E_WARNING, "Tried to read bad record %d", record->value.lval); + RETURN_FALSE; + } + + dbf = dbh->db_fields; + + if (array_init(return_value) == FAILURE) { + RETURN_FALSE; + } + + fnp = (char *)emalloc(dbh->db_rlen); + for (cur_f = dbf; cur_f < &dbf[dbh->db_nfields]; cur_f++) { + /* get the value */ + str_value = (char *)emalloc(cur_f->db_flen + 1); + sprintf(str_value, cur_f->db_format, get_field_val(data, cur_f, fnp)); + + /* now convert it to the right php internal type */ + switch (cur_f->db_type) { + case 'C': + case 'D': + add_assoc_string(return_value,cur_f->db_fname,str_value,1); + break; + case 'N': /* FALLS THROUGH */ + case 'L': /* FALLS THROUGH */ + if (cur_f->db_fdc == 0) { + add_assoc_long(return_value,cur_f->db_fname,strtol(str_value, NULL, 10)); + } else { + add_assoc_double(return_value,cur_f->db_fname,atof(str_value)); + } + break; + case 'M': + /* this is a memo field. don't know how to deal with this yet */ + break; + default: + /* should deal with this in some way */ + break; + } + efree(str_value); + } + efree(fnp); + + /* mark whether this record was deleted */ + if (data[0] == '*') { + add_assoc_long(return_value,"deleted",1); + } else { + add_assoc_long(return_value,"deleted",0); + } + + free(data); +} +/* }}} */ + +/* {{{ proto bool dbase_create(string filename, array fields) + Creates a new dBase-format database file */ +void php3_dbase_create(INTERNAL_FUNCTION_PARAMETERS) { + pval *filename, *fields, *field, *value; + int fd; + dbhead_t *dbh; + + int num_fields; + dbfield_t *dbf, *cur_f; + int i, rlen, handle; + DBase_TLS_VARS; + + if (ARG_COUNT(ht) != 2 || getParameters(ht,2,&filename,&fields)==FAILURE) { + WRONG_PARAM_COUNT; + } + convert_to_string(filename); + + if (fields->type != IS_ARRAY) { + php3_error(E_WARNING, "Expected array as second parameter"); + RETURN_FALSE; + } + + if (PG(safe_mode) && (!_php3_checkuid(filename->value.str.val, 2))) { + RETURN_FALSE; + } + + if (_php3_check_open_basedir(filename->value.str.val)) { + RETURN_FALSE; + } + + if ((fd = open(filename->value.str.val, O_BINARY|O_RDWR|O_CREAT, 0644)) < 0) { + php3_error(E_WARNING, "Unable to create database (%d): %s", errno, strerror(errno)); + RETURN_FALSE; + } + + num_fields = _php3_hash_num_elements(fields->value.ht); + + /* have to use regular malloc() because this gets free()d by + code in the dbase library */ + dbh = (dbhead_t *)malloc(sizeof(dbhead_t)); + dbf = (dbfield_t *)malloc(sizeof(dbfield_t) * num_fields); + if (!dbh || !dbf) { + php3_error(E_WARNING, "Unable to allocate memory for header info"); + RETURN_FALSE; + } + + /* initialize the header structure */ + dbh->db_fields = dbf; + dbh->db_fd = fd; + dbh->db_dbt = DBH_TYPE_NORMAL; + strcpy(dbh->db_date, "19930818"); + dbh->db_records = 0; + dbh->db_nfields = num_fields; + dbh->db_hlen = sizeof(struct dbf_dhead) + 2 + num_fields * sizeof(struct dbf_dfield); + + rlen = 1; + + for (i = 0, cur_f = dbf; i < num_fields; i++, cur_f++) { + /* look up the first field */ + if (_php3_hash_index_find(fields->value.ht, i, (void **)&field) == FAILURE) { + php3_error(E_WARNING, "unable to find field %d", i); + free_dbf_head(dbh); + RETURN_FALSE; + } + + if (field->type != IS_ARRAY) { + php3_error(E_WARNING, "second parameter must be array of arrays"); + free_dbf_head(dbh); + RETURN_FALSE; + } + + /* field name */ + if (_php3_hash_index_find(field->value.ht, 0, (void **)&value) == FAILURE) { + php3_error(E_WARNING, "expected field name as first element of list in field %d", i); + free_dbf_head(dbh); + RETURN_FALSE; + } + convert_to_string(value); + if (value->value.str.len > 10 || value->value.str.len == 0) { + php3_error(E_WARNING, "invalid field name '%s' (must be non-empty and less than or equal to 10 characters)", value->value.str.val); + free_dbf_head(dbh); + RETURN_FALSE; + } + copy_crimp(cur_f->db_fname, value->value.str.val, value->value.str.len); + + /* field type */ + if (_php3_hash_index_find(field->value.ht,1,(void **)&value) == FAILURE) { + php3_error(E_WARNING, "expected field type as sececond element of list in field %d", i); + RETURN_FALSE; + } + convert_to_string(value); + cur_f->db_type = toupper(*value->value.str.val); + + cur_f->db_fdc = 0; + + /* verify the field length */ + switch (cur_f->db_type) { + case 'L': + cur_f->db_flen = 1; + break; + case 'M': + cur_f->db_flen = 9; + dbh->db_dbt = DBH_TYPE_MEMO; + /* should create the memo file here, probably */ + break; + case 'D': + cur_f->db_flen = 8; + break; + case 'N': + case 'C': + /* field length */ + if (_php3_hash_index_find(field->value.ht,2,(void **)&value) == FAILURE) { + php3_error(E_WARNING, "expected field length as third element of list in field %d", i); + free_dbf_head(dbh); + RETURN_FALSE; + } + convert_to_long(value); + cur_f->db_flen = value->value.lval; + + if (cur_f->db_type == 'N') { + if (_php3_hash_index_find(field->value.ht,3,(void **)&value) == FAILURE) { + php3_error(E_WARNING, "expected field precision as fourth element of list in field %d", i); + free_dbf_head(dbh); + RETURN_FALSE; + } + convert_to_long(value); + cur_f->db_fdc = value->value.lval; + } + break; + default: + php3_error(E_WARNING, "unknown field type '%c'", cur_f->db_type); + } + cur_f->db_foffset = rlen; + rlen += cur_f->db_flen; + + cur_f->db_format = get_dbf_f_fmt(cur_f); + } + + dbh->db_rlen = rlen; + put_dbf_info(dbh); + + handle = php3_list_insert(dbh, DBase_GLOBAL(le_dbhead)); + RETURN_LONG(handle); +} +/* }}} */ + +function_entry dbase_functions[] = { + {"dbase_open", php3_dbase_open, NULL}, + {"dbase_create", php3_dbase_create, NULL}, + {"dbase_close", php3_dbase_close, NULL}, + {"dbase_numrecords", php3_dbase_numrecords, NULL}, + {"dbase_numfields", php3_dbase_numfields, NULL}, + {"dbase_add_record", php3_dbase_add_record, NULL}, + {"dbase_get_record", php3_dbase_get_record, NULL}, + {"dbase_get_record_with_names", php3_dbase_get_record_with_names, NULL}, + {"dbase_delete_record", php3_dbase_delete_record, NULL}, + {"dbase_pack", php3_dbase_pack, NULL}, + {NULL, NULL, NULL} +}; + +php3_module_entry dbase_module_entry = { + "DBase", dbase_functions, php3_minit_dbase, php3_mend_dbase, NULL, NULL, NULL, STANDARD_MODULE_PROPERTIES +}; + + +#if defined(COMPILE_DL) +DLEXPORT php3_module_entry *get_module(void) { return &dbase_module_entry; } + +#if (WIN32|WINNT) && defined(THREAD_SAFE) + +/*NOTE: You should have an odbc.def file where you +export DllMain*/ +BOOL WINAPI DllMain(HANDLE hModule, + DWORD ul_reason_for_call, + LPVOID lpReserved) +{ + return 1; +} +#endif +#endif + +#endif +/* + * Local variables: + * tab-width: 4 + * c-basic-offset: 4 + * End: + */ |