mirrors/php-src
0
0
Fork 0
mirror of https://github.com/php/php-src.git synced 2024-11-30 13:25:43 +08:00
Code Issues Packages Projects Releases Wiki Activity
3f64aa6a94
php-src/ext/fbsql/php_fbsql.c
Frank M. Kromann d5e1266dc5 Initial check-in of FrontBase extension
2001-03-13 20:58:47 +00:00

3040 lines
82 KiB
C
Raw Blame History

/*
+----------------------------------------------------------------------+
| PHP version 4.0 |
+----------------------------------------------------------------------+
| Copyright (c) 1997-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: Frank M. Kromann frank@frontbase.com> |
+----------------------------------------------------------------------+
*/
/* $Id$ */
/* TODO:
*
* ? Safe mode implementation
*/
// SB's list:
// - BLOBs
// - API for a more natural FB connect semantic
// - Connect & set session
// - Autoreconnect when disconnected
// - Comments and cleanup
// - Documentation
//
// - Format database error messages as HTML.
//
// BUGS
// - Select db with no arguments
// - Query with everything defaulted
//
#include "php.h"
#include "php_globals.h"
#include "php_globals.h"
#include "ext/standard/info.h"
#include "ext/standard/php_string.h"
#if WIN32|WINNT
#include <winsock.h>
#else
#include <php_config.h>
#include <build-defs.h>
#if HAVE_SYS_TYPES_H
#include <sys/types.h>
#endif
#include <netdb.h>
#include <netinet/in.h>
#endif
#include "php_ini.h"
#define HAVE_FBSQL 1
#if HAVE_FBSQL
#include "php_fbsql.h"
#include <signal.h>
static int le_result, le_link, le_plink, le_dba;
struct PHPFBDatabase;
typedef struct PHPFBDatabase PHPFBDatabase;
struct PHPFBResult;
typedef struct PHPFBResult PHPFBResult;
struct PHPFBLink;
typedef struct PHPFBLink PHPFBLink;
// The PHPFBLink structure represents a fbsql link. The lion is used for
// a connection to a machine, it may be persistant and is reference counted.
// The reason for refcounting is mostly to avoid to think, it work independent of
// any wierd and unforseen allocation deallocation order.
//
// The PHPFBDatabse structure implements to actual connection to a FrontBase server
// ot may be persistant is the link it is connected to is persistant, and refcounted
// for the same reasons as above.
//
// The PHPFBResult structure implements a result from the FrontBase server, and does all
// required buffereing from of results.
//
// In the PHP code the 3 above a data structures are referenced by means of integers in the
// range from 1 to som configurable maximum. You can put a limit to the number of links, databases
// and results. The integer identifications is implemented by insertion in the list, which is passed
// as an argument to all the functions, please note the list is polymorph.
//
// Database objects and link objects are all reused, base on the host name user name, host name database name
// user name. So connecting twice to the same database as the same user will return the same database id.
// We use the same coding for that as fbsql does, explioiting the underlying implementation of the lists.
//
// Persistant objects are put in the persistent list as well, but only by name, if you connect to a persistant object
// and it is not in the list it is simply added and get a new index, and refcounted. Tricky, tricky ...
//
// Some functions which should be exported from FBCAccess
void* fbaObjectAtIndex();
void fbcInitialize();
void fbaRelease();
unsigned int fbaCount();
struct PHPFBDatabase
{
unsigned int retainCount; // The refcount
unsigned int index; // The index in the list
PHPFBLink* link; // A pointer to the corresponding link object, may be NULL if no link were used
char* databaseName; // The name of the database
char* databasePassword; // The database password
FBCDatabaseConnection* connection; // The connection to the database
unsigned int errorNo; // The latest error on the connection, 0 is ok.
char* errorText; // The error text
unsigned int resultCount; // Number of active result for this database
unsigned int rowIndex; // The row index of the latest row inserted into the database
PHPFBResult** results; // Pointer to the active results
};
struct PHPFBResult
{
unsigned int retainCount; // The refcount
unsigned int index; // The index into the list
PHPFBLink* link; // The link for the result, may be NULL if no link
PHPFBDatabase* database; // The database for the result, may be NULL of no database is related to the result
FBCDatabaseConnection* connection; // The database connection, just a convinience
char* fetchHandle; // The fetch handle, the id used by the server.
FBCMetaData* metaData; // The metadata describing the result
FBCMetaData* ResultmetaData; // The metadata describing the result
FBCRowHandler* rowHandler; // The row handler, the Frontbase structure used for accessing rows in the result
unsigned int batchSize; // The number of row to fetch when expanding the number of rows in the row handler
int rowCount; // The number of rows in the results set. The number of row is not in
// general known when the select is done, one typically needs to fetch all the row
// to figure out how many row you got. When the rowCount is unknown the value is
// 0x7ffffffff
int columnCount; // Number of columns in the row set.
int rowIndex; // The current row index.
int columnIndex; // The current column index
void** row; // The last row accessed
FBArray* array; // The link may return a result set, the database list, we implement that by the
// FBArray, just a list of strings.
FBCPList* list; // The same special kind result just for property list from extract, schema info.
unsigned int selectResults; // number of results in select
unsigned int currentResult; // current result number
};
struct PHPFBLink
{
unsigned int retainCount; // The refcount
unsigned int index; // The index in the list
int persistant; // persistant ?
char* hostName; // Host name
char* userName; // User name
char* userPassword; // User password
FBCExecHandler* execHandler; // The exechandler, can be used for database operations
unsigned int affectedRows;
long autoCommit; // Enable or disable autoCommit
PHPFBDatabase* currentDatabase; // The latest referenced database on this link
unsigned int databaseCount; // The number of database connect to the link
PHPFBDatabase** databases; // and the pointers
unsigned int resultCount; // The number of link results
PHPFBResult** results; // and the pointers. Only used for list_dbs
};
#define FBSQL_ASSOC 1<<0
#define FBSQL_NUM 1<<1
#define FBSQL_BOTH (FBSQL_ASSOC|FBSQL_NUM)
function_entry fbsql_functions[] = {
PHP_FE(fbsql_connect, NULL)
PHP_FE(fbsql_pconnect, NULL)
PHP_FE(fbsql_close, NULL)
PHP_FE(fbsql_select_db, NULL)
PHP_FE(fbsql_create_db, NULL)
PHP_FE(fbsql_drop_db, NULL)
PHP_FE(fbsql_start_db, NULL)
PHP_FE(fbsql_stop_db, NULL)
PHP_FE(fbsql_query, NULL)
PHP_FE(fbsql_db_query, NULL)
PHP_FE(fbsql_list_dbs, NULL)
PHP_FE(fbsql_list_tables, NULL)
PHP_FE(fbsql_list_fields, NULL)
PHP_FE(fbsql_error, NULL)
PHP_FE(fbsql_errno, NULL)
PHP_FE(fbsql_affected_rows, NULL)
PHP_FE(fbsql_insert_id, NULL)
PHP_FE(fbsql_result, NULL)
PHP_FE(fbsql_next_result, NULL)
PHP_FE(fbsql_num_rows, NULL)
PHP_FE(fbsql_num_fields, NULL)
PHP_FE(fbsql_fetch_row, NULL)
PHP_FE(fbsql_fetch_array, NULL)
PHP_FE(fbsql_fetch_object, NULL)
PHP_FE(fbsql_data_seek, NULL)
PHP_FE(fbsql_fetch_lengths, NULL)
PHP_FE(fbsql_fetch_field, NULL)
PHP_FE(fbsql_field_seek, NULL)
PHP_FE(fbsql_free_result, NULL)
PHP_FE(fbsql_field_name, NULL)
PHP_FE(fbsql_field_table, NULL)
PHP_FE(fbsql_field_len, NULL)
PHP_FE(fbsql_field_type, NULL)
PHP_FE(fbsql_field_flags, NULL)
// Fontbase additions:
PHP_FE(fbsql_autocommit, NULL)
PHP_FE(fbsql_commit, NULL)
PHP_FE(fbsql_rollback, NULL)
PHP_FE(fbsql_hostname, NULL)
PHP_FE(fbsql_database, NULL)
PHP_FE(fbsql_database_password, NULL)
PHP_FE(fbsql_username, NULL)
PHP_FE(fbsql_password, NULL)
PHP_FE(fbsql_warnings, NULL)
// Aliases:
PHP_FALIAS(fbsql, fbsql_db_query, NULL)
{NULL, NULL, NULL}
};
zend_module_entry fbsql_module_entry = {
"fbsql",
fbsql_functions,
PHP_MINIT(fbsql),
PHP_MSHUTDOWN(fbsql),
PHP_RINIT(fbsql),
NULL,
PHP_MINFO(fbsql),
STANDARD_MODULE_PROPERTIES
};
ZEND_DECLARE_MODULE_GLOBALS(fbsql)
#ifdef COMPILE_DL_FBSQL
ZEND_GET_MODULE(fbsql)
#endif
void phpfbReleaseResult ( PHPFBResult* result );
void phpfbReleaseDatabase ( PHPFBDatabase* database );
void phpfbReleaseLink ( PHPFBLink* link );
PHPFBResult* phpfbRetainResult ( PHPFBResult* result )
{
if (result) result->retainCount++;
return result;
}
void phpfbReleaseResult ( PHPFBResult* result )
{
unsigned int i;
FBSQLLS_FETCH();
if (result)
{
result->retainCount--;
//printf("Release result %x %d %d\n",result,result->index,result->retainCount);
if (result->retainCount == 0)
{
if (result->fetchHandle) fbcdcCancelFetch(result->connection,result->fetchHandle);
if (result->rowHandler) fbcrhRelease(result->rowHandler);
if (result->ResultmetaData) fbcmdRelease(result->ResultmetaData);
// if (result->metaData) fbcmdRelease(result->metaData);
if (result->list) fbcplRelease(result->list);
if (result->array) fbaRelease(result->array);
if ( result->database)
{
for (i=0; i < result->database->resultCount; i++)
{
if (result->database->results[i] == result)
{
result->database->results[i] = NULL;
break;
}
}
phpfbReleaseDatabase(result->database);
}
if (result->link)
{
for (i=0; i < result->link->resultCount; i++)
{
if (result->link->results[i] == result)
{
result->link->results[i] = NULL;
break;
}
}
phpfbReleaseLink(result->link);
}
result->link = 0;
result->database = 0;
result->connection = NULL;
result->fetchHandle = NULL;
result->metaData = NULL;
result->rowHandler = NULL;
result->batchSize = 0;
result->rowCount = -1;
result->rowIndex = 0;
result->columnIndex = 0;
result->row = NULL;
result->array = NULL;
result->list = NULL;
free(result);
}
}
}
PHPFBDatabase* phpfbRetainDatabase ( PHPFBDatabase* database )
{
if (database) database->retainCount++;
return database;
}
void phpfbReleaseDatabase ( PHPFBDatabase* database )
{
if (database)
{
database->retainCount--;
//printf("Release database %x %d %d\n", database, database->index, database->retainCount);
if (database->retainCount == 0)
{
unsigned int i;
// if (FB_SQL_G(databaseIndex == database->index) FB_SQL_G(databaseIndex = 0;
if (database->link)
{
for (i=0; i < database->link->databaseCount; i++)
{
if (database->link->databases[i] == database)
{
database->link->databases[i] = NULL;
break;
}
}
phpfbReleaseLink(database->link);
}
fbcdcClose(database->connection);
fbcdcRelease(database->connection);
free(database->databaseName);
free(database->databasePassword);
free(database->results);
free(database);
}
}
}
PHPFBLink* phpfbRetainLink ( PHPFBLink* link)
{
if (link) link->retainCount++;
return link;
}
void phpfbReleaseLink ( PHPFBLink* link)
{
// printf("Release %x %d %d\n",link,link->index,link->retainCount);
if (link)
{
link->retainCount--;
//printf("Release link %x %d %d\n", link, link->index, link->retainCount);
if (link->retainCount == 0)
{
// if (link->index == FB_SQL_G(linkIndex) FB_SQL_G(linkIndex = 0;
free(link->hostName);
free(link->userName);
free(link->userPassword);
if (link->results) free(link->results);
if (link->databases) free(link->databases);
free(link);
}
}
}
PHPFBResult* phpfbQuery (INTERNAL_FUNCTION_PARAMETERS, char* sql, PHPFBDatabase* database);
PHP_INI_BEGIN()
STD_PHP_INI_BOOLEAN ("fbsql.allow_persistant", "1" , PHP_INI_SYSTEM, OnUpdateInt, allowPersistent, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_BOOLEAN ("fbsql.generate_warnings", "0", PHP_INI_SYSTEM, OnUpdateInt, generateWarnings, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_BOOLEAN ("fbsql.autocommit", "1", PHP_INI_SYSTEM, OnUpdateInt, autoCommit, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_ENTRY_EX ("fbsql.max_persistent", "-1", PHP_INI_SYSTEM, OnUpdateInt, maxPersistant, zend_fbsql_globals, fbsql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX ("fbsql.max_links", "128", PHP_INI_SYSTEM, OnUpdateInt, maxLinks, zend_fbsql_globals, fbsql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX ("fbsql.max_connections", "128", PHP_INI_SYSTEM, OnUpdateInt, maxConnections, zend_fbsql_globals, fbsql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX ("fbsql.max_results", "128", PHP_INI_SYSTEM, OnUpdateInt, maxResults, zend_fbsql_globals, fbsql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX ("fbsql.mbatchSize", "1000", PHP_INI_SYSTEM, OnUpdateInt, batchSize, zend_fbsql_globals, fbsql_globals, display_link_numbers)
STD_PHP_INI_ENTRY ("fbsql.default_host", NULL, PHP_INI_SYSTEM, OnUpdateString, hostName, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_ENTRY ("fbsql.default_user", "_SYSTEM", PHP_INI_SYSTEM, OnUpdateString, userName, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_ENTRY ("fbsql.default_password", "", PHP_INI_SYSTEM, OnUpdateString, userPassword, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_ENTRY ("fbsql.default_database", "", PHP_INI_SYSTEM, OnUpdateString, databaseName, zend_fbsql_globals, fbsql_globals)
STD_PHP_INI_ENTRY ("fbsql.default_database_password",
"", PHP_INI_SYSTEM, OnUpdateString, databasePassword, zend_fbsql_globals, fbsql_globals)
PHP_INI_END()
static void php_fbsql_init_globals(zend_fbsql_globals *fbsql_globals)
{
fbsql_globals->persistantCount = 0;
if (fbsql_globals->hostName==NULL)
{
char name[256];
gethostname(name,sizeof(name));
name[sizeof(name)-1] = 0;
fbsql_globals->hostName = strdup(name);
}
// fbsql_globals->userName = strdup(fbsql_globals->userName);
// fbsql_globals->userPassword = strdup(fbsql_globals->userPassword);
// fbsql_globals->databaseName = strdup(fbsql_globals->databaseName);
// fbsql_globals->databasePassword = strdup(fbsql_globals->databasePassword);
fbsql_globals->persistantCount = 0;
fbsql_globals->linkCount = 0;
fbsql_globals->resultCount = 0;
fbsql_globals->linkIndex = 0;
fbsql_globals->databaseIndex = 0;
fbsql_globals->resultIndex = 0;
}
PHP_MINIT_FUNCTION(fbsql)
{
ZEND_INIT_MODULE_GLOBALS(fbsql, php_fbsql_init_globals, NULL);
REGISTER_INI_ENTRIES();
fbcInitialize();
le_result = register_list_destructors(phpfbReleaseResult,NULL);
le_link = register_list_destructors(phpfbReleaseLink,NULL);
le_dba = register_list_destructors(phpfbReleaseDatabase,NULL);
REGISTER_LONG_CONSTANT("FBSQL_ASSOC", FBSQL_ASSOC, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("FBSQL_NUM", FBSQL_NUM, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("FBSQL_BOTH", FBSQL_BOTH, CONST_CS | CONST_PERSISTENT);
return SUCCESS;
}
PHP_MSHUTDOWN_FUNCTION(fbsql)
{
UNREGISTER_INI_ENTRIES();
return SUCCESS;
}
PHP_RINIT_FUNCTION(fbsql)
{
return SUCCESS;
}
PHP_MINFO_FUNCTION(fbsql)
{
char buf[32];
FBSQLLS_FETCH();
php_info_print_table_start();
php_info_print_table_header(2, "FrontBase support", "enabled");
php_info_print_table_row(2, "Client API version", "2.20" );
if (FB_SQL_G(allowPersistent))
{
sprintf(buf, "%ld", FB_SQL_G(persistantCount));
php_info_print_table_row(2, "Active Persistant Links", buf);
}
sprintf(buf, "%ld", FB_SQL_G(linkCount));
php_info_print_table_row(2, "Active Links", buf);
sprintf(buf, "%ld", FB_SQL_G(resultCount));
php_info_print_table_row(2, "Active Result Sets", buf);
php_info_print_table_end();
DISPLAY_INI_ENTRIES();
}
PHPFBLink* phpfbConnect
(
INTERNAL_FUNCTION_PARAMETERS,
char* hostName,
char* userName,
char* userPassword,
int persistant
)
{
// Ref count databases and links!!
// Search for the database/link in the hash plist and in the hashed list
// If a link was non persistant then an is opened peristant just insert it
// in the persistant list
//
// Insert the persistant in the list and in the hash p list
// Insert the non persistant in the
PHPFBLink* result;
list_entry *lep;
int type;
char name[1024];
FBSQLLS_FETCH();
if (hostName == NULL) hostName = FB_SQL_G(hostName);
if (userName == NULL) userName = FB_SQL_G(userName);
if (userPassword == NULL) userPassword = FB_SQL_G(userPassword);
//printf("Connection %s %s\n",hostName,userName);
sprintf(name,"fbsql_%s_%s",hostName,userName);
//printf("Hash find '%s'",name);
if(zend_hash_find(&EG(persistent_list), name, strlen(name), (void **) &lep) == SUCCESS)
{
PHPFBLink* lnk;
result = lep->ptr;
lnk = zend_list_find(result->index,&type);
if (lnk != result) result->index = zend_list_insert(result, le_link);
//printf(" Persistant %x %d \n",result,result->index);
}
else if(zend_hash_find (&EG(regular_list),name,strlen(name),(void **)&lep) == SUCCESS)
{
result = lep->ptr;
//printf(" Non persistant %x %d \n",result,result->index);
}
else if ( FB_SQL_G(linkCount) == FB_SQL_G(maxLinks))
{
php_error(E_WARNING,"FrontBase link limit %d exceeded ", FB_SQL_G(maxLinks));
return NULL;
}
else
{
FBCExecHandler* execHandler = fbcehHandlerForHost(hostName,128);
list_entry le;
if (execHandler == NULL)
{
php_error(E_WARNING,"Cannot connect to host '%s'",hostName);
php_error(E_WARNING,fbcehClassErrorMessage());
return NULL;
}
result = malloc(sizeof(PHPFBLink));
result->retainCount = 1;
result->persistant = persistant;
result->hostName = strdup(hostName);
result->userName = strdup(userName);
result->userPassword = strdup(userPassword);
result->execHandler = execHandler;
result->affectedRows = 0;
result->autoCommit = FB_SQL_G(autoCommit);
result->currentDatabase = NULL;
result->databaseCount = 0;
result->databases = NULL;
result->resultCount = 0;
result->results = NULL;
le.ptr = result;
le.type = le_link;
if (zend_hash_update(persistant?&EG(persistent_list):&EG(regular_list), name, strlen(name), &le, sizeof(le), NULL)==FAILURE)
{
phpfbReleaseLink(result);
return NULL;
}
result->index = zend_list_insert (phpfbRetainLink(result), le_link);
FB_SQL_G(linkCount)++;
//printf(" new %x %d \n",result,result->index);
//printf("Ny connection %x %x\n",result,result->execHandler);
}
return result;
}
int phpfbFetchRow ( PHPFBResult* result, int row)
{
if (result->rowHandler == NULL)
{
void *rawData = fbcdcFetch(result->connection,result->batchSize,result->fetchHandle);
if (rawData == NULL)
result->rowCount = 0;
else
result->rowHandler = fbcrhInitWith(rawData, result->metaData);
}
for (;;)
{
void *rawData;
if ( row >= result->rowCount) return 0;
if (fbcrhRowCount(result->rowHandler) > (unsigned int)row) return 1;
rawData = fbcdcFetch(result->connection,result->batchSize,result->fetchHandle);
if (!fbcrhAddBatch(result->rowHandler,rawData)) result->rowCount = fbcrhRowCount(result->rowHandler);
}
return 0;
}
// int fbsql_connect(string [hostname] , string [username] , string [password] );
void phpfbDoConnect(INTERNAL_FUNCTION_PARAMETERS,int persistant)
{
PHPFBLink* result;
char* hostName = NULL;
char* userName = NULL;
char* userPassword = NULL;
int argc = ARG_COUNT(ht);
pval* argv[3];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 3)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_string(argv[0]);
hostName = argv[0]->value.str.val;
}
if (argc >= 2 )
{
convert_to_string(argv[1]);
userName = argv[1]->value.str.val;
}
if (argc == 3 )
{
convert_to_string(argv[2]);
userPassword = argv[2]->value.str.val;
}
result = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,hostName,userName,userPassword,persistant);
if (result == NULL) RETURN_FALSE;
FB_SQL_G(linkIndex) = result->index;
return_value->value.lval = result->index;
return_value->type = IS_LONG;
}
// int fbsql_connect(string [hostname] , string [username] , string [password] );
PHP_FUNCTION(fbsql_connect)
{
phpfbDoConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,0);
}
// int fbsql_pconnect(string [hostname] , string [username] , string [password] );
PHP_FUNCTION(fbsql_pconnect)
{
phpfbDoConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,1);
}
PHPFBLink* phpfbGetLink(int id)
{
int type;
PHPFBLink* phpLink = NULL;
FBSQLLS_FETCH();
if (id == 0 )
{
php_error(E_WARNING,"FrontBase has no default connection");
}
else if ((!(phpLink = (PHPFBLink*) zend_list_find (id,&type))) || (( type != le_link)))
{
php_error(E_WARNING,"%d is not a FBSQL link index",id);
phpLink = NULL;
}
return phpLink;
}
PHPFBResult* phpfbGetResult(int id)
{
int type;
PHPFBResult* result = NULL;
FBSQLLS_FETCH();
if (id == 0 ) {
php_error(E_WARNING,"FBSQL no default result");
}
else if ((!(result = (PHPFBResult*) zend_list_find (id,&type))) || (( type != le_result))) {
php_error(E_WARNING,"%d is not a FBSQL result index",id);
result = NULL;
}
return result;
}
// int fbsql_close([int link_identifier])
PHP_FUNCTION(fbsql_close)
{
int argc = ARG_COUNT(ht);
unsigned i,j;
char name[1024];
PHPFBLink* phpLink = NULL;
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
if (argc == 1)
{
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
}
else if (FB_SQL_G(linkIndex) != 0)
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
for (i=0; i < phpLink->databaseCount; i++)
{
PHPFBDatabase* database = phpLink->databases[i];
if (database)
{
for (j=0; j < database->resultCount; j++) if (database->results[j])
{
zend_list_delete (database->results[j]->index);
FB_SQL_G(resultCount)--;
}
zend_list_delete (database->index);
FB_SQL_G(databaseCount)--;
}
}
sprintf(name,"fbsql_%s_%s",phpLink->hostName,phpLink->userName);
FB_SQL_G(linkCount)--;
if (phpLink->persistant)FB_SQL_G(persistantCount)--;
zend_hash_del (&EG(regular_list),name,strlen(name));
zend_list_delete(phpLink->index);
RETURN_TRUE;
}
// int fbsql_select_db(string database_name [, int link_identifier]
PHPFBDatabase* phpfbSelectDB
( INTERNAL_FUNCTION_PARAMETERS,
char* databaseName,
char* databasePassword,
PHPFBLink* link
)
{
PHPFBDatabase* result = NULL;
list_entry *lep;
unsigned i;
char name[1024];
FBSQLLS_FETCH();
sprintf(name,"fbsql_%s@%s:%s",databaseName,link->hostName,link->userName);
if(zend_hash_find(&EG(persistent_list),name,strlen(name),(void **)&lep) == SUCCESS)
{
PHPFBDatabase* dba;
int type;
result = lep->ptr;
dba = zend_list_find(result->index,&type);
if (dba != result) result->index = zend_list_insert(result, le_dba);
}
else if(zend_hash_find(&EG(regular_list),name,strlen(name),(void **)&lep) == SUCCESS)
{
result = lep->ptr;
}
else if (FB_SQL_G(databaseCount) == FB_SQL_G(maxConnections))
{
php_error(E_WARNING,"FrontBase connection limit %d exceeded", FB_SQL_G(maxConnections));
return NULL;
}
else
{
list_entry le;
FBCDatabaseConnection* c = fbcdcConnectToDatabase(databaseName,link->hostName,databasePassword);
FBCMetaData* md;
if (c == NULL)
{
php_error(E_WARNING, fbcdcClassErrorMessage());
return NULL;
}
md = fbcdcCreateSession(c,"PHP",link->userName,link->userPassword,link->userName);
if (fbcmdErrorsFound(md))
{
FBCErrorMetaData* emd = fbcdcErrorMetaData(c,md);
char* emg = fbcemdAllErrorMessages(emd);
if (emg)
php_error(E_WARNING, emg);
else
php_error(E_WARNING,"No message");
free(emg);
fbcemdRelease(emd);
fbcmdRelease(md);
fbcdcClose(c);
fbcdcRelease(c);
return NULL;
}
fbcmdRelease(md);
if (c)
{
if (link->autoCommit)
md = fbcdcExecuteDirectSQL(c,"SET COMMIT TRUE;");
else
md = fbcdcExecuteDirectSQL(c,"SET COMMIT FALSE;");
fbcmdRelease(md);
}
fbcdcSetOutputCharacterSet(c,FBC_ISO8859_1);
fbcdcSetInputCharacterSet(c,FBC_ISO8859_1);
le.type = le_dba;
le.ptr = result = malloc(sizeof(PHPFBDatabase));
if (zend_hash_update(link->persistant?&EG(persistent_list):&EG(regular_list), name, strlen(name), &le, sizeof(le), NULL)==FAILURE)
{
fbcdcClose(c);
fbcdcRelease(c);
free(result);
//printf("Returning Null\n");
return NULL;
}
result->retainCount = 2;
result->index = zend_list_insert((PHPFBDatabase*)(le.ptr), le_dba);
result->link = phpfbRetainLink(link);
result->databaseName = strdup(databaseName);
result->databasePassword = strdup(databasePassword);
result->connection = c;
result->errorNo = 0;
result->errorText = NULL;
result->resultCount = 0;
result->rowIndex = 0;
result->results = NULL;
for (i=0; i < link->databaseCount; i++) if ((link->databases[i]) == NULL) break;
if (i==link->databaseCount)
{
unsigned j;
link->databaseCount += 5;
link->databases = realloc(link->databases,sizeof(PHPFBDatabase*)*link->databaseCount);
for (j=i; j < link->databaseCount; j++) link->databases[j] = NULL;
}
link->databases[i] = result;
FB_SQL_G(databaseCount)++;
// printf("Return database %x %x\n",result,c);
}
link->currentDatabase = result;
return_value->value.lval = result->index;
return_value->type = IS_LONG;
FB_SQL_G(databaseIndex) = result->index;
return result;
}
void phpfbestrdup (const char * s, int* length, char** value )
{
int l = s?strlen(s):0;
if (value)
{
char* r = emalloc(l+1);
if (s)
strcpy(r,s);
else
r[0] = 0;
*value = r;
}
*length = l;
}
// bool fbsql_list_autocommit(int link_identifier [, bool OnOff])
PHP_FUNCTION(fbsql_autocommit)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
PHPFBLink* phpLink = NULL;
FBCMetaData* md;
zend_bool OnOff;
FBSQLLS_FETCH();
if ((argc < 1 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
if (argc == 2 )
{
convert_to_boolean(argv[1]);
OnOff = Z_BVAL_P(argv[1]);
if (OnOff)
md = fbcdcExecuteDirectSQL(phpLink->currentDatabase->connection , "SET COMMIT TRUE;");
else
md = fbcdcExecuteDirectSQL(phpLink->currentDatabase->connection, "SET COMMIT FALSE;");
fbcmdRelease(md);
RETURN_TRUE;
}
else {
RETURN_BOOL(phpLink->autoCommit);
}
}
// int fbsql_list_commit([int link_identifier])
PHP_FUNCTION(fbsql_commit)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
PHPFBLink* phpLink = NULL;
FBCMetaData* md;
int link;
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc == 1 )
{
convert_to_long(argv[0]);
link = argv[0]->value.lval;
}
phpLink = phpfbGetLink(link);
if (phpLink == NULL) RETURN_FALSE;
md = fbcdcCommit(phpLink->currentDatabase->connection);
if (md) {
fbcmdRelease(md);
RETURN_TRUE;
}
else
RETURN_FALSE;
}
// int fbsql_list_rollback([int link_identifier])
PHP_FUNCTION(fbsql_rollback)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
PHPFBLink* phpLink = NULL;
FBCMetaData* md;
int link;
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc == 1 )
{
convert_to_long(argv[0]);
link = argv[0]->value.lval;
}
phpLink = phpfbGetLink(link);
if (phpLink == NULL) RETURN_FALSE;
md = fbcdcRollback(phpLink->currentDatabase->connection);
if (md) {
fbcmdRelease(md);
RETURN_TRUE;
}
else
RETURN_FALSE;
}
// string fbsql_hostname([string host_name])
PHP_FUNCTION(fbsql_hostname)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
phpfbestrdup(FB_SQL_G(hostName), &return_value->value.str.len, &return_value->value.str.val);
return_value->type = IS_STRING;
if (argc >= 1)
{
convert_to_string(argv[0]);
free(FB_SQL_G(hostName));
FB_SQL_G(hostName) = strdup(argv[0]->value.str.val);
}
}
// string fbsql_database([string database])
PHP_FUNCTION(fbsql_database)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
phpfbestrdup(FB_SQL_G(databaseName), &return_value->value.str.len, &return_value->value.str.val);
return_value->type = IS_STRING;
if (argc >= 1)
{
convert_to_string(argv[0]);
free(FB_SQL_G(databaseName));
FB_SQL_G(databaseName) = strdup(argv[0]->value.str.val);
}
}
// string fbsql_database_password([string database_password])
PHP_FUNCTION(fbsql_database_password)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_string(argv[0]);
free(FB_SQL_G(hostName));
FB_SQL_G(databasePassword) = strdup(argv[0]->value.str.val);
}
}
// string fbsql_username([string username])
PHP_FUNCTION(fbsql_username)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
phpfbestrdup(FB_SQL_G(userName), &return_value->value.str.len, &return_value->value.str.val);
return_value->type = IS_STRING;
if (argc >= 1)
{
convert_to_string(argv[0]);
free(FB_SQL_G(userName));
FB_SQL_G(userName) = strdup(argv[0]->value.str.val);
}
}
// string fbsql_username([string password])
PHP_FUNCTION(fbsql_password)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_string(argv[0]);
free(FB_SQL_G(userPassword));
FB_SQL_G(userPassword) = strdup(argv[0]->value.str.val);
}
}
// int fbsql_select_db([string database_name [, int link_identifier]])
PHP_FUNCTION(fbsql_select_db)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
char* name;
PHPFBLink* phpLink = NULL;
PHPFBDatabase* database = NULL;
FBSQLLS_FETCH();
name = FB_SQL_G(databaseName);
if ((argc < 1) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_string(argv[0]);
name = argv[0]->value.str.val;
}
if (argc >= 2 )
{
convert_to_long(argv[1]);
phpLink = phpfbGetLink(argv[1]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Select db at link %s@%s\n",phpLink->hostName,phpLink->userName);
database = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU,name,"",phpLink);
if (database == NULL) RETURN_FALSE;
phpLink->currentDatabase = database;
FB_SQL_G(linkIndex) = phpLink->index;
return_value->value.lval = database->index;
return_value->type = IS_LONG;
}
// int fbsql_change_user(string user, string password, string [database] , int [link_identifier] );
PHP_FUNCTION(fbsql_change_user)
{
int argc = ARG_COUNT(ht);
pval* argv[4];
int link;
PHPFBLink* phpLink;
PHPFBDatabase * phpDatabase;
char* userName;
char* userPassword;
char* databaseName;
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
databaseName = FB_SQL_G(databaseName);
if ((argc < 2) || (argc > 4)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2],&argv[3])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
userName = argv[0]->value.str.val;
convert_to_string(argv[1]);
userPassword = argv[1]->value.str.val;
if (argc >= 3)
{
convert_to_string(argv[2]);
databaseName = argv[2]->value.str.val;
}
if (argc >= 4)
{
convert_to_long(argv[3]);
link = argv[3]->value.lval;
}
if ((phpLink = phpfbGetLink(link))==NULL) RETURN_FALSE;
if ((phpDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU,databaseName,"",phpLink)) == NULL) RETURN_FALSE;
{
char buffer[1024];
sprintf(buffer,"SET AUTHORIZATION %s;",userName);
phpfbQuery(INTERNAL_FUNCTION_PARAM_PASSTHRU,buffer, phpDatabase);
if (return_value->value.lval)
{
free(phpLink->userName);
phpLink->userName = strdup(userName);
}
}
}
// int fbsql_create_db([string database_name [, int link_identifier]])
PHP_FUNCTION(fbsql_create_db)
{
PHPFBLink* phpLink = NULL;
int i;
int argc = ARG_COUNT(ht);
pval* argv[2];
int link;
char* databaseName;
char* hostName;
FBDatabaseStatus status;
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
hostName = FB_SQL_G(hostName);
if ((argc < 1) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
if (argc == 2 )
{
convert_to_long(argv[1]);
link = argv[1]->value.lval;
phpLink = phpfbGetLink(link);
if (phpLink == NULL) RETURN_FALSE;
}
if (phpLink == NULL)
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
if (phpLink == NULL) RETURN_FALSE;
}
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status != FBUnknownStatus)
{
char* txt = "Unknown status";
if ( status == FBStopped ) txt = "stopped";
else if ( status == FBStarting ) txt = "starting";
else if ( status == FBRunning ) txt = "running";
else if ( status == FBStopping ) txt = "stopping";
else if ( status == FBNoExec ) txt = "no exec";
php_error(E_WARNING, "Could not create %s@%s, database is %s",databaseName,hostName,txt);
RETURN_FALSE;
}
if (!fbcehCreateDatabaseNamedWithOptions(phpLink->execHandler, databaseName, ""))
{
char* error = fbechErrorMessage(phpLink->execHandler);
php_error(E_WARNING, "Could not create %s@%s. %s.",databaseName,hostName,error);
RETURN_FALSE;
}
for (i=0; i < 20; i++)
{
#ifdef PHP_WIN32
Sleep(1000);
#else
sleep(1);
#endif
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status == FBRunning) break;
}
FB_SQL_G(linkIndex) = phpLink->index;
if (status != FBRunning)
{
php_error(E_WARNING, "Database %s@%s created -- status unknown",databaseName,hostName);
RETURN_FALSE;
}
RETURN_TRUE;
}
// int fbsql_drop_db(string database_name [, int link_identifier])
PHP_FUNCTION(fbsql_drop_db)
{
char* databaseName;
int argc = ARG_COUNT(ht);
pval* argv[2];
PHPFBLink* phpLink;
FBDatabaseStatus status;
int i;
FBSQLLS_FETCH();
if ((argc < 1) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
if (argc == 2)
{
convert_to_long(argv[1]);
phpLink = phpfbGetLink(argv[1]->value.lval);
if (phpLink == NULL) RETURN_FALSE;
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL)
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
if (phpLink) RETURN_FALSE;
}
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status != FBStopped)
{
char* txt = "Unknown status";
if ( status == FBStopped ) txt = "stopped";
else if ( status == FBUnknownStatus ) txt = "nonexisting";
else if ( status == FBStarting ) txt = "starting";
else if ( status == FBRunning ) txt = "running";
else if ( status == FBStopping ) txt = "stopping";
else if ( status == FBNoExec ) txt = "no exec";
php_error(E_WARNING, "Could not drop %s@%s, database is %s.",databaseName,phpLink->hostName,txt);
RETURN_FALSE;
}
if (! fbcehDeleteDatabaseNamed (phpLink->execHandler, databaseName))
{
char* error = fbechErrorMessage(phpLink->execHandler);
php_error(E_WARNING, "Could not drop %s@%s. %s.",databaseName,phpLink->hostName,error);
RETURN_FALSE;
}
for (i=0; i < 20; i++)
{
#ifdef PHP_WIN32
Sleep(1000);
#else
sleep(1);
#endif
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status == FBUnknownStatus) break;
}
if (status != FBUnknownStatus)
{
php_error(E_WARNING, "Database %s@%s dropped -- status unknown",databaseName,phpLink->hostName);
RETURN_FALSE;
}
}
// int fbsql_stop_db(string database_name [, int link_identifier])
PHP_FUNCTION(fbsql_stop_db)
{
PHPFBDatabase* phpDatabase;
PHPFBLink* phpLink = NULL;
FBDatabaseStatus status;
char* databaseName;
int argc = ARG_COUNT(ht);
pval* argv[2];
int link;
unsigned i;
char name[1024];
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
if ((argc < 0) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
if (argc == 2)
{
convert_to_long(argv[1]);
link = argv[1]->value.lval;
phpLink = phpfbGetLink(link);
if (phpLink == NULL) RETURN_FALSE;
}
if (phpLink == NULL)
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
if (phpLink == NULL) RETURN_FALSE;
}
phpDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, databaseName,"",phpLink);
if (phpDatabase == NULL) RETURN_FALSE;
//printf("Stop db %x\n",phpDatabase->connection);
if (!fbcdcStopDatabase(phpDatabase->connection))
{
php_error(E_WARNING, "Cannot stop database %s@%s",databaseName,phpLink->hostName);
RETURN_FALSE;
}
for (i=0; i < 20; i++)
{
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status == FBStopped) break;
#ifdef PHP_WIN32
Sleep(1000);
#else
sleep(1);
#endif
}
for (i=0; i < phpLink->databaseCount; i++) if (phpLink->databases[i] == phpDatabase) phpLink->databases[i] = NULL;
for (i=0; i < phpDatabase->resultCount; i++) if (phpDatabase->results[i])
{
FB_SQL_G(resultCount)--;
zend_list_delete(phpDatabase->results[i]->index);
}
// printf("Database %X %d %d\n",phpDatabase,phpDatabase->index,phpDatabase->retainCount);
sprintf(name,"fbsql_%s@%s:%s",databaseName,phpLink->hostName, phpLink->userName);
zend_list_delete(phpDatabase->index);
FB_SQL_G(databaseCount)--;
zend_hash_del(&EG(regular_list),name,strlen(name));
// printf("After list delete\n");
RETURN_TRUE;
}
// int fbsql_start_db(string database_name [, int link_identifier])
PHP_FUNCTION(fbsql_start_db)
{
PHPFBLink* phpLink = NULL;
int i;
int argc = ARG_COUNT(ht);
pval* argv[2];
char* databaseName;
char* hostName;
FBDatabaseStatus status;
FBSQLLS_FETCH();
hostName = FB_SQL_G(hostName);
if ((argc < 1) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
if (argc >= 2 )
{
convert_to_long(argv[1]);
phpLink = phpfbGetLink(argv[1]->value.lval);
}
else if ( FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Start db at link %s@%s\n",phpLink->hostName,phpLink->userName);
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if ((status != FBStopped) && (status != FBRunning) && ( status != FBStarting))
{
char* txt = "Unknown status";
if ( status == FBStopped ) txt = "stopped";
else if ( status == FBStarting ) txt = "starting";
else if ( status == FBRunning ) txt = "running";
else if ( status == FBStopping ) txt = "stopping";
else if ( status == FBNoExec ) txt = "no exec";
php_error(E_WARNING, "Could not start %s@%s, as database is %s.",databaseName,hostName,txt);
RETURN_FALSE;
}
if (status == FBStopped)
{
if (!fbcehStartDatabaseNamed (phpLink->execHandler, databaseName))
{
char* error = fbechErrorMessage(phpLink->execHandler);
php_error(E_WARNING, "Could not start %s@%s. %s.",databaseName,hostName,error);
RETURN_FALSE;
}
}
for (i=0; i < 20; i++)
{
#ifdef PHP_WIN32
Sleep(1000);
#else
sleep(1);
#endif
status = fbcehStatusForDatabaseNamed(phpLink->execHandler,databaseName);
if (status == FBRunning) break;
}
if (status != FBRunning)
{
php_error(E_WARNING, "Database %s@%s started -- status unknown",databaseName,hostName);
RETURN_FALSE;
}
RETURN_TRUE;
}
int mdOk(PHPFBDatabase* database, FBCMetaData* md )
{
FBCDatabaseConnection* c = database->connection;
int result = 1;
FBSQLLS_FETCH();
database->errorNo = 0;
if (database->errorText)
{
free(database->errorText);
database->errorText = NULL;
}
if (md == NULL)
{
database->errorNo = 1;
database->errorText = strdup("Connection was database server was lost");
if (FB_SQL_G(generateWarnings)) php_error(E_WARNING, database->errorText);
result = 0;
}
else if (fbcmdErrorsFound(md))
{
FBCErrorMetaData* emd = fbcdcErrorMetaData(c,md);
char* emg = fbcemdAllErrorMessages(emd);
if (FB_SQL_G(generateWarnings))
{
if (emg)
php_error(E_WARNING, emg);
else
php_error(E_WARNING,"No message");
}
database->errorText = emg;
database->errorNo = 1;
fbcemdRelease(emd);
result = 0;
}
return result;
}
PHPFBResult* phpfbQuery(INTERNAL_FUNCTION_PARAMETERS, char* sql, PHPFBDatabase* database )
{
PHPFBLink* link = database->link;
PHPFBResult* result = NULL;
FBCMetaData* md, *meta;
int ok;
char* tp;
char* fh;
unsigned int sR = 1, cR = 0;
FBSQLLS_FETCH();
meta = fbcdcExecuteDirectSQL(database->connection,sql);
if (fbcmdHasMetaDataArray(meta)) {
sR = fbcmdMetaDataArrayCount(meta);
md = (FBCMetaData*)fbcmdMetaDataAtIndex(meta, cR);
}
else
md = meta;
ok = mdOk(database,md);
tp = fbcmdStatementType(md);
return_value->value.lval = ok?-1:0;
return_value->type = IS_LONG;
// printf("Result kind %s\n",tp);
if (!ok || (tp[0] == 'C') || (tp[0] == 'R'))
{
unsigned i;
for (i=0; i < database->resultCount; i++)
{
PHPFBResult* result = database->results[i];
if (result)
{
// printf("Delete from list %d %x",i,database->results[i],database->results[i]->index);
zend_list_delete(database->results[i]->index);
FB_SQL_G(databaseCount)--;
database->results[i] = NULL;
}
}
}
else if (tp[0] == 'I')
{
database->rowIndex = fbcmdRowIndex(md);
}
else if ((fh = fbcmdFetchHandle(md)) && (FB_SQL_G(resultCount) == FB_SQL_G(maxResults)))
{
fbcdcCancelFetch(database->connection,fh);
php_error(E_WARNING,"FrontBase result set limit %d exceeded",FB_SQL_G(maxResults));
}
else if (fh || (tp[0] == 'E'))
{
unsigned i;
result = malloc(sizeof(PHPFBResult));
result->retainCount = 1;
result->index = zend_list_insert(result,le_result);
result->link = NULL;
result->database = phpfbRetainDatabase(database);
result->connection = database->connection;
result->fetchHandle = fh;
result->ResultmetaData = meta;
result->metaData = md;
result->rowHandler = NULL;
result->batchSize = FB_SQL_G(batchSize);
result->rowCount = 0x7fffffff;
result->columnCount = 0;
result->rowIndex = 0;
result->columnIndex = 0;
result->row = NULL;
result->array = NULL;
result->list = NULL;
result->selectResults = sR;
result->currentResult = cR;
FB_SQL_G(resultCount)++;
for (i=0; i < database->resultCount; i++) if (database->results[i] == NULL) break;
if (i == database->resultCount )
{
unsigned j;
database->resultCount += 5;
database->results = realloc(database->results,sizeof(PHPFBResult*)*database->resultCount);
for (j=i; j < database->resultCount; j++) database->results[j] = NULL;
}
database->results[i] = result;
return_value->value.lval = result->index;
if (tp[0] != 'E')
{
result->rowCount = 0x7fffffff;
result->columnCount = fbcmdColumnCount(md);
result->fetchHandle = fh;
result->batchSize = FB_SQL_G(batchSize);
}
else
{
char* r = fbcmdMessage(result->metaData);
if (( result->list = fbcplParse(r)))
{
result->rowCount = fbcplCount(result->list);
result->columnCount = 7;
}
}
}
if (link) link->affectedRows = fbcmdRowCount(md);
if (result == NULL) fbcmdRelease(md);
return result;
}
// int fbsql_query(string query [, int link_identifier])
PHP_FUNCTION(fbsql_query)
{
PHPFBDatabase* phpDatabase;
PHPFBLink* phpLink = NULL;
PHPFBResult* phpResult;
char* sql;
int argc = ARG_COUNT(ht);
pval* argv[2];
FBSQLLS_FETCH();
if ((argc < 1) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
sql = argv[0]->value.str.val;
if (argc >= 2 )
{
convert_to_long(argv[1]);
phpLink = phpfbGetLink(argv[1]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Query db at link %s@%s\n",phpLink->hostName,phpLink->userName);
phpDatabase = phpLink->currentDatabase;
if (phpDatabase == NULL) RETURN_FALSE;
phpResult = phpfbQuery(INTERNAL_FUNCTION_PARAM_PASSTHRU,sql,phpDatabase);
if (return_value->value.lval)
{
FB_SQL_G(linkIndex) = phpLink->index;
if (phpResult) FB_SQL_G(resultIndex) = phpResult->index;
}
}
// int fbsql_db_query(string database_name, string query [, int link_identifier])
PHP_FUNCTION(fbsql_db_query)
{
PHPFBDatabase* phpDatabase;
PHPFBLink* phpLink;
PHPFBResult* phpResult;
char* sql;
char* databaseName;
int argc = ARG_COUNT(ht);
pval* argv[3];
FBSQLLS_FETCH();
if ((argc < 2) || (argc > 3)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2])==FAILURE) RETURN_FALSE;
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
convert_to_string(argv[1]);
sql = argv[1]->value.str.val;
if (argc >= 3 )
{
convert_to_long(argv[2]);
phpLink = phpfbGetLink(argv[2]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Query db at link %s@%s\n",phpLink->hostName,phpLink->userName);
phpDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, databaseName,"",phpLink);
if ( phpDatabase == NULL) RETURN_FALSE;
phpResult = phpfbQuery(INTERNAL_FUNCTION_PARAM_PASSTHRU,sql,phpDatabase);
if (return_value->value.lval)
{
FB_SQL_G(linkIndex) = phpLink->index;
if (phpResult) FB_SQL_G(resultIndex) = phpResult->index;
}
}
// int fbsql_list_dbs([int link_identifier])
PHP_FUNCTION(fbsql_list_dbs)
{
PHPFBLink* phpLink = NULL;
PHPFBResult* phpResult;
unsigned i;
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
if (argc == 1 )
{
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
if (FB_SQL_G(resultCount) == FB_SQL_G(maxResults))
{
php_error(E_WARNING,"FrontBase result set limit %d exceeded",FB_SQL_G(maxResults));
RETURN_FALSE
}
phpResult = malloc(sizeof(PHPFBResult));
phpResult->retainCount = 1;
phpResult->index = zend_list_insert(phpResult, le_result);
phpResult->link = phpfbRetainLink(phpLink);
phpResult->database = NULL;
phpResult->connection = NULL;
phpResult->fetchHandle = NULL;
phpResult->rowHandler = NULL;
phpResult->metaData = NULL;
phpResult->batchSize = FB_SQL_G(batchSize);
phpResult->columnCount = 1;
phpResult->rowIndex = 0;
phpResult->columnIndex = 0;
phpResult->row = NULL;
phpResult->array = fbcehAvailableDatabases(phpLink->execHandler);
phpResult->rowCount = fbaCount(phpResult->array);
phpResult->list = NULL;
FB_SQL_G(resultCount)++;
for (i=0; i < phpLink->resultCount; i++) if (phpLink->results[i] == NULL) break;
if (i == phpLink->resultCount )
{
unsigned j;
phpLink->resultCount += 5;
phpLink->results = realloc( phpLink->results,sizeof(PHPFBResult*)* phpLink->resultCount);
for (j=i; j < phpLink->resultCount ; j++)phpLink->results[j] = NULL;
}
phpLink->results[i] = phpResult;
return_value->value.lval = phpResult->index;
return_value->type = IS_LONG;
FB_SQL_G(resultIndex) = phpResult->index;
FB_SQL_G(linkIndex) = phpLink->index;
}
// int fbsql_list_tables(string database, int [link_identifier] );
PHP_FUNCTION(fbsql_list_tables)
{
PHPFBDatabase* phpDatabase;
PHPFBLink* phpLink;
PHPFBResult* phpResult;
char* sql = "select t0.\"table_name\"from information_schema.tables t0, information_schema.SCHEMATA t1 where t0.schema_pk = t1.schema_pk and t1.\"schema_name\" = current_schema;";
char* databaseName = NULL;
int argc = ARG_COUNT(ht);
pval* argv[2];
FBSQLLS_FETCH();
if ((argc < 0) || (argc > 2)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if ( argc >= 1 )
{
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
}
if (argc >= 2 )
{
convert_to_long(argv[1]);
phpLink = phpfbGetLink(argv[1]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
if ( databaseName == NULL )
{
phpLink->currentDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, FB_SQL_G(databaseName),"",phpLink);
}
else
{
phpLink->currentDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, databaseName,"",phpLink);
}
phpDatabase = phpLink->currentDatabase;
if (phpDatabase == NULL) RETURN_FALSE;
phpResult = phpfbQuery(INTERNAL_FUNCTION_PARAM_PASSTHRU,sql,phpDatabase);
if (return_value->value.lval)
{
FB_SQL_G(linkIndex) = phpLink->index;
if (phpResult) FB_SQL_G(resultIndex) = phpResult->index;
}
}
//int fbsql_list_fields(string database_name, string table_name [, int link_identifier])
PHP_FUNCTION(fbsql_list_fields)
{
PHPFBDatabase* phpDatabase;
PHPFBLink* phpLink;
PHPFBResult* phpResult;
char sql[1024];
char* databaseName = NULL;
char* tableName = NULL;
int argc = ARG_COUNT(ht);
pval* argv[2];
FBSQLLS_FETCH();
if ((argc < 2) || (argc > 3)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if ( argc >= 1 )
{
convert_to_string(argv[0]);
databaseName = argv[0]->value.str.val;
}
if ( argc >= 2 )
{
convert_to_string(argv[1]);
tableName = argv[1]->value.str.val;
}
if (argc >= 3 )
{
convert_to_long(argv[2]);
phpLink = phpfbGetLink(argv[2]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
phpDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, databaseName,"",phpLink);
phpLink->currentDatabase = phpDatabase;
if (phpDatabase == NULL) RETURN_FALSE;
sprintf(sql,"EXTRACT TABLE %s;",tableName);
phpResult = phpfbQuery(INTERNAL_FUNCTION_PARAM_PASSTHRU,sql,phpDatabase);
if (return_value->value.lval)
{
FB_SQL_G(linkIndex) = phpLink->index;
if (phpResult) FB_SQL_G(resultIndex) = phpResult->index;
}
}
// string fbsql_error([int link_identifier])
PHP_FUNCTION(fbsql_error)
{
PHPFBLink* phpLink = NULL;
PHPFBDatabase* phpDatabase;
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 1)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
}
else if (FB_SQL_G(linkIndex) != 0 )
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Query db at link %s@%s\n",phpLink->hostName,phpLink->userName);
phpDatabase = phpLink->currentDatabase;
if ((phpDatabase == NULL) || (phpDatabase->errorText == NULL)) RETURN_FALSE;
phpfbestrdup(phpDatabase->errorText,&return_value->value.str.len,&return_value->value.str.val);
return_value->type = IS_STRING;
}
// int fbsql_errno([int link_identifier])
PHP_FUNCTION(fbsql_errno)
{
PHPFBLink* phpLink = NULL;
PHPFBDatabase* phpDatabase;
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 1)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
}
else if (FB_SQL_G(linkIndex) != 0 )
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
//printf("Query db at link %s@%s\n",phpLink->hostName,phpLink->userName);
phpDatabase = phpLink->currentDatabase;
if (phpDatabase == NULL) RETURN_FALSE;
return_value->value.lval = phpDatabase->errorNo;
return_value->type = IS_LONG;
}
// int fbsql_generate_warnings( [int flag]);
PHP_FUNCTION(fbsql_warnings)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 1)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
return_value->value.lval = FB_SQL_G(generateWarnings);
return_value->type = IS_LONG;
if (argc >= 1)
{
convert_to_long(argv[0]);
FB_SQL_G(generateWarnings) = argv[0]->value.lval != 0;
}
}
//int fbsql_affected_rows([int link_identifier])
PHP_FUNCTION(fbsql_affected_rows)
{
PHPFBLink* phpLink;
int argc = ARG_COUNT(ht);
pval* argv[1];
int link;
FBSQLLS_FETCH();
link = FB_SQL_G(linkIndex);
if (argc > 1) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc == 1 )
{
convert_to_string(argv[0]);
link = argv[0]->value.lval;
}
phpLink = phpfbGetLink(link);
if (phpLink == NULL) RETURN_FALSE;
return_value->value.lval = phpLink->affectedRows;
return_value->type = IS_LONG;
}
// int fbsql_insert_id([int link_identifier])
PHP_FUNCTION(fbsql_insert_id)
{
PHPFBLink* phpLink;
PHPFBDatabase* phpDatabase;
int argc = ARG_COUNT(ht);
pval* argv[1];
FBSQLLS_FETCH();
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc, &argv[0])==FAILURE) RETURN_FALSE;
if (argc == 1 )
{
convert_to_long(argv[0]);
phpLink = phpfbGetLink(argv[0]->value.lval);
}
else if (FB_SQL_G(linkIndex) == 0 )
{
phpLink = phpfbConnect(INTERNAL_FUNCTION_PARAM_PASSTHRU,NULL,NULL,NULL,0);
}
else
{
phpLink = phpfbGetLink(FB_SQL_G(linkIndex));
}
if (phpLink == NULL) RETURN_FALSE;
if ( phpLink->currentDatabase == NULL)
{
phpLink->currentDatabase = phpfbSelectDB(INTERNAL_FUNCTION_PARAM_PASSTHRU, FB_SQL_G(databaseName),"",phpLink);
}
phpDatabase = phpLink->currentDatabase;
if (phpDatabase == NULL) RETURN_FALSE;
return_value->value.lval = phpDatabase->rowIndex;
return_value->type = IS_LONG;
FB_SQL_G(linkIndex) = phpLink->index;
}
int phpSizeOfInt ( int i )
{
int s = 1;
if ( i < 0 )
{
s++;
i = -i;
}
while ((i = i / 10)) s++;
return s;
}
void phpfbColumnAsString ( PHPFBResult* result, int column, void* data ,int* length, char** value)
{
FBCMetaData* md = result->metaData;
const FBCDatatypeMetaData* dtmd = fbcmdDatatypeMetaDataAtIndex(md, column);
unsigned dtc = fbcdmdDatatypeCode(dtmd);
switch (dtc)
{
case FB_Boolean:
{
unsigned char v = *((unsigned char*)(data));
if (v == 255)
phpfbestrdup("Unknown",length,value);
else if (v == 0 )
phpfbestrdup("False",length,value);
else
phpfbestrdup("True",length,value);
}
break;
case FB_PrimaryKey:
case FB_Integer:
{
int v = *((int*)data);
char b[128];
sprintf(b,"%d",v);
phpfbestrdup(b,length,value);
}
break;
case FB_SmallInteger:
{
short v = *((short*)data);
char b[128];
sprintf(b,"%d",v);
phpfbestrdup(b,length,value);
}
break;
case FB_Float:
case FB_Real:
case FB_Double:
case FB_Numeric:
case FB_Decimal:
{
double v = *((double*)data);
char b[128];
sprintf(b,"%f",v);
phpfbestrdup(b,length,value);
}
break;
case FB_Character:
case FB_VCharacter:
{
char* v = (char*)data;
phpfbestrdup(v,length,value);
}
break;
case FB_Bit:
case FB_VBit:
{
const FBCColumnMetaData* clmd = fbcmdColumnMetaDataAtIndex(md,column);
struct bitValue
{
unsigned int nBytes;
unsigned char* bytes;
};
struct bitValue* ptr = data;
unsigned nBits = ptr->nBytes * 8;
if (dtc == FB_Bit) nBits = fbcdmdLength(fbccmdDatatype(clmd));
if (nBits %8 == 0 )
{
unsigned i;
unsigned int l = nBits / 8;
*length = l + 5;
if (value)
{
char* r = emalloc(l*2+3+1);
r[0] = 'X';
r[1] = '\'';
for ( i = 0; i < nBits / 8; i++)
{
char c[4];
sprintf(c,"%02x",ptr->bytes[i]);
r[i*2+2] = c[0];
r[i*2+3] = c[1];
}
r[i*2+2] = '\'';
r[i*2+3] = 0;
*value = r;
}
}
else
{
unsigned i;
unsigned int l = nBits;
*length = l + 5;
if (value)
{
char* r = emalloc(l*2+3+1);
r[0] = 'B';
r[1] = '\'';
for ( i = 0; i < nBits; i++)
{
int bit = 0;
if (i/8 < ptr->nBytes) bit = ptr->bytes[i/8] & (1<<(7-(i%8)));
r[i*2+2] = bit?'1':'0';
}
r[i*2+2] = '\'';
r[i*2+3] = 0;
*value = r;
}
}
}
break;
case FB_Date:
case FB_Time:
case FB_TimeTZ:
case FB_Timestamp:
case FB_TimestampTZ:
{
char* v = (char*)data;
phpfbestrdup(v,length,value);
}
break;
case FB_YearMonth:
{
char b[128];
int v = *((unsigned int*)data);
sprintf(b,"%d",v);
phpfbestrdup(b,length,value);
}
break;
case FB_DayTime:
{
char b[128];
double seconds = *((double*)data);
sprintf(b,"%f",seconds);
phpfbestrdup(b,length,value);
}
break;
case FB_CLOB:
case FB_BLOB:
// {
// unsigned char* bytes = (unsigned char*)data;
// if (*bytes == '\1')
// { // Direct
// unsigned int l = *((unsigned int*)(bytes+1));
// unsigned char* ptr = *((unsigned char**)(bytes+5));
// unsigned int i;
// mf(file,"%4d:",l);
// for (i=0; i < l; i++)
// {
// if (i)
// {
// if ((i % 32) == 0) mf(file,"\n %*d:",lw+4,i);
// else if ((i % 4) == 0) mf(file," ");
// }
// mf(file,"%02x",*ptr++);
// }
// }
// else
//{
// mf(file,"%s",bytes+1);
// }
// }
// break;
default:
php_error(E_WARNING,"Unimplemented type");
break;
}
}
void phpfbSqlResult ( INTERNAL_FUNCTION_PARAMETERS, PHPFBResult* result, int rowIndex, int columnIndex )
{
void** row;
if (result->list)
{
FBCPList* columns = (FBCPList*)fbcplValueForKey(result->list,"COLUMNS");
FBCPList* column = (FBCPList*)fbcplValueAtIndex(columns,result->rowIndex);
if ( columnIndex == 0 )
{ // Name
FBCPList* name = (FBCPList*)fbcplValueForKey(column,"NAME");
return_value->type = IS_STRING;
phpfbestrdup(fbcplString(( FBCPList*)name), &return_value->value.str.len, &return_value->value.str.val);
}
else if ( columnIndex == 2 )
{ // Length
FBCPList* name = (FBCPList*)fbcplValueForKey(column,"WIDTH");
return_value->type = IS_STRING;
phpfbestrdup((const char*)fbcplString(name), &return_value->value.str.len, &return_value->value.str.val);
}
else if ( columnIndex == 1 )
{ // Type
FBCPList* name = (FBCPList*)fbcplValueForKey(column,"DATATYPE");
return_value->type = IS_STRING;
phpfbestrdup((const char*)fbcplString(name), &return_value->value.str.len, &return_value->value.str.val);
}
else if ( columnIndex == 3 )
{ // Flags
return_value->type = IS_STRING;
phpfbestrdup("", &return_value->value.str.len, &return_value->value.str.val);
}
else
{
return_value->type = IS_STRING;
phpfbestrdup("", &return_value->value.str.len, &return_value->value.str.val);
}
}
else if (result->array)
{ // Special case for get dbs
phpfbestrdup((char*)fbaObjectAtIndex(result->array,rowIndex), &return_value->value.str.len, &return_value->value.str.val);
return_value->type = IS_STRING;
}
else if (!phpfbFetchRow(result,rowIndex))
{
// php_error(E_WARNING,"No such row %d in result set %d",resultIndex+1,rowIndex);
RETURN_FALSE;
}
else if (columnIndex >= result->columnCount)
{
php_error(E_WARNING,"No such column %d in result set %d",columnIndex,rowIndex);
RETURN_FALSE;
}
else
{
row = fbcrhRowAtIndex(result->rowHandler,rowIndex);
if (row == NULL)
{
RETURN_FALSE;
}
else if (row[columnIndex])
{
phpfbColumnAsString(result,columnIndex,row[columnIndex],&return_value->value.str.len,&return_value->value.str.val);
return_value->type = IS_STRING;
}
else
{
return_value->type = IS_NULL;
}
}
}
// int fbsql_result(int result, int row [, mixed field])
PHP_FUNCTION(fbsql_result)
{
int argc = ARG_COUNT(ht);
pval* argv[3];
PHPFBResult* result;
int resultIndex;
int rowIndex;
int columnIndex;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || (argc > 3 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1],&argv[2])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
rowIndex = result->rowIndex;
if (argc >= 2)
{
convert_to_long(argv[1]);
rowIndex = argv[1]->value.lval;
}
columnIndex = result->columnIndex;
if (argc == 3)
{
if ((argv[2]->type == IS_STRING) && (result->metaData))
{
for (columnIndex =0; columnIndex < result->columnCount; columnIndex ++)
{
const FBCColumnMetaData* cmd = fbcmdColumnMetaDataAtIndex(result->metaData, columnIndex);
const char* lbl = fbccmdLabelName(cmd);
if (strcmp((char*)lbl, argv[2]->value.str.val) == 0 ) break;
}
if (columnIndex == result->columnCount) RETURN_FALSE;
}
else
{
convert_to_long(argv[2]);
columnIndex = argv[2]->value.lval;
if ( columnIndex < 0 )
{
php_error(E_WARNING,"Illegal column index - %d",columnIndex);
RETURN_FALSE;
}
}
}
phpfbSqlResult(INTERNAL_FUNCTION_PARAM_PASSTHRU,result,rowIndex,columnIndex);
FB_SQL_G(resultIndex) = resultIndex;
result->columnIndex++;
if (result->columnIndex == result->columnCount)
{
result->rowIndex++;
result->columnIndex = 0;
}
}
// int fbsql_next_result(int result)
PHP_FUNCTION(fbsql_next_result)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
PHPFBResult* result;
int resultIndex;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
convert_to_long(argv[0]);
result = phpfbGetResult(argv[0]->value.lval);
if (result == NULL) RETURN_FALSE;
result->currentResult++;
if (result->currentResult < result->selectResults) {
if (result->fetchHandle) fbcdcCancelFetch(result->connection, result->fetchHandle);
if (result->rowHandler) fbcrhRelease(result->rowHandler);
result->metaData = (FBCMetaData*)fbcmdMetaDataAtIndex(result->ResultmetaData, result->currentResult);
result->fetchHandle = fbcmdFetchHandle(result->metaData);
result->rowHandler = NULL;
result->batchSize = FB_SQL_G(batchSize);
result->rowCount = 0x7fffffff;
result->columnCount = fbcmdColumnCount(result->metaData);;
result->rowIndex = 0;
result->columnIndex = 0;
result->row = NULL;
result->array = NULL;
result->list = NULL;
if (result->database->link)
result->database->link->affectedRows = fbcmdRowCount(result->metaData);
RETURN_TRUE;
}
else {
RETURN_FALSE;
}
}
// int fbsql_num_rows(int result)
PHP_FUNCTION(fbsql_num_rows)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
int resultIndex;
PHPFBResult* result;
int rowCount;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
rowCount = fbcmdRowCount (result->metaData);
if (rowCount == -1 )
{
phpfbFetchRow(result,0x7fffffff);
rowCount = result->rowCount;
}
return_value->value.lval = rowCount;
return_value->type = IS_LONG;
}
// int fbsql_num_fields(int result)
PHP_FUNCTION(fbsql_num_fields)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
int resultIndex;
PHPFBResult* result;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
return_value->value.lval = result->columnCount;
return_value->type = IS_LONG;
FB_SQL_G(resultIndex) = resultIndex;
}
// object fbsql_fetch_object(int result [, int result_typ])
PHP_FUNCTION(fbsql_fetch_object)
{
PHP_FN(fbsql_fetch_array)(INTERNAL_FUNCTION_PARAM_PASSTHRU);
if (return_value->type==IS_ARRAY)
{
return_value->type=IS_OBJECT;
return_value->value.obj.properties = return_value->value.ht;
return_value->value.obj.ce = &zend_standard_class_def;
}
}
// array fbsql_fetch_row(int result)
PHP_FUNCTION(fbsql_fetch_row)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int i;
int resultIndex;
PHPFBResult* result;
int rowIndex ;
void** row;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || (argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1 ) {
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
rowIndex = result->rowIndex;
if (result->fetchHandle == NULL) {
RETURN_FALSE;
}
if (result->rowCount == 0x7fffffff) {
if (!phpfbFetchRow(result,rowIndex)) {
RETURN_FALSE;
}
}
if (!(row = fbcrhRowAtIndex(result->rowHandler,rowIndex))) {
RETURN_FALSE;
}
if (array_init(return_value)==FAILURE) {
RETURN_FALSE;
}
result->row = row;
for (i=0; i < result->columnCount; i++) {
char* value;
unsigned int length;
if (row[i]) {
phpfbColumnAsString(result,i,row[i],&length,&value);
add_index_stringl(return_value,i,value,length,0);
}
else {
add_index_unset(return_value,i);
}
}
result->rowIndex = rowIndex+1;
result->columnIndex = 0;
FB_SQL_G(resultIndex) = resultIndex;
}
// array fbsql_fetch_array(int result [, int result_typ])
PHP_FUNCTION(fbsql_fetch_array)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int i;
int resultIndex;
PHPFBResult* result;
int rowIndex;
int result_type = FBSQL_BOTH;
void** row;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1)
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
rowIndex = result->rowIndex;
if (argc == 2 )
{
convert_to_long(argv[1]);
result_type = argv[1]->value.lval;
if (((result_type & FBSQL_NUM) != FBSQL_NUM) && ((result_type & FBSQL_ASSOC) != FBSQL_ASSOC))
{
php_error(E_WARNING,"Illegal result type use FBSQL_NUM, FBSQL_ASSOC, or FBSQL_BOTH.");
RETURN_FALSE;
}
}
if (result->fetchHandle == NULL)
{
RETURN_FALSE;
}
if (result->rowCount == 0x7fffffff)
{
phpfbFetchRow(result,result->rowIndex);
}
row = fbcrhRowAtIndex(result->rowHandler,rowIndex);
if (row == NULL)
{
RETURN_FALSE;
}
if (array_init(return_value)==FAILURE)
{
RETURN_FALSE;
}
for (i=0; i < result->columnCount; i++)
{
if (row[i])
{
char* value;
unsigned int length;
unsigned int c = 0;
phpfbColumnAsString(result,i,row[i],&length,&value);
if (result_type & FBSQL_NUM)
{
add_index_stringl(return_value,i,value,length,c);
c = 1;
}
if (result_type & FBSQL_ASSOC)
{
char* key = (char*)fbccmdLabelName(fbcmdColumnMetaDataAtIndex(result->metaData, i));
add_assoc_stringl(return_value,key, value, length, c);
}
}
else
{
if (result_type & FBSQL_NUM)
{
add_index_unset(return_value,i);
}
if (result_type & FBSQL_ASSOC)
{
char* key = (char*)fbccmdLabelName(fbcmdColumnMetaDataAtIndex(result->metaData, i));
add_assoc_unset(return_value,key);
}
}
}
result->rowIndex = result->rowIndex+1;
result->columnIndex = 0;
}
// int fbsql_data_seek(int result, int row_number)
PHP_FUNCTION(fbsql_data_seek)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int rowIndex;
FBSQLLS_FETCH();
if (argc != 2 ) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
convert_to_long(argv[1]);
rowIndex = argv[1]->value.lval;
if (rowIndex < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (result->rowCount == 0x7fffffff) phpfbFetchRow(result,rowIndex);
if (rowIndex > result->rowCount) RETURN_FALSE;
result->rowIndex = rowIndex;
RETURN_TRUE;
}
// array fbsql_fetch_lengths(int result)
PHP_FUNCTION(fbsql_fetch_lengths)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int i;
int resultIndex;
PHPFBResult* result;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || ( argc > 1 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
if (result->row == NULL) RETURN_FALSE;
if (array_init(return_value)==FAILURE) RETURN_FALSE;
for (i=0; i < result->columnCount; i++)
{
unsigned length = 0;
if (result->row[i]) phpfbColumnAsString(result,i, result->row[i],&length,NULL);
add_index_long(return_value, i, length);
}
FB_SQL_G(resultIndex) = resultIndex;
}
// object fbsql_fetch_field(int result [, int field_offset])
PHP_FUNCTION(fbsql_fetch_field)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such column in result",column);
RETURN_FALSE;
}
}
if (object_init(return_value)==FAILURE)
{
RETURN_FALSE;
}
add_property_string(return_value, "name", (char*)fbccmdLabelName(fbcmdColumnMetaDataAtIndex(result->metaData, column)),1);
add_property_string(return_value, "table", (char*)fbccmdTableName(fbcmdColumnMetaDataAtIndex(result->metaData,column)),1);
add_property_long(return_value, "max_length", fbcdmdLength(fbccmdDatatype(fbcmdColumnMetaDataAtIndex(result->metaData,column))));
add_property_string(return_value, "type", (char*)fbcdmdDatatypeString (fbcmdDatatypeMetaDataAtIndex(result->metaData, column)),1);
// Remember to add the rest
// add_property_long(return_value, "not_null",IS_NOT_NULL(mysql_field->flags)?1:0);
// add_property_long(return_value, "primary_key",IS_PRI_KEY(mysql_field->flags)?1:0);
// add_property_long(return_value, "multiple_key",(mysql_field->flags&MULTIPLE_KEY_FLAG?1:0));
// add_property_long(return_value, "unique_key",(mysql_field->flags&UNIQUE_KEY_FLAG?1:0));
// add_property_long(return_value, "numeric",IS_NUM(mysql_field->type)?1:0);
// add_property_long(return_value, "blob",IS_BLOB(mysql_field->flags)?1:0);
// add_property_string(return_value, "type",php_mysql_get_field_name(mysql_field->type), 1);
// add_property_long(return_value, "unsigned",(mysql_field->flags&UNSIGNED_FLAG?1:0));
// add_property_long(return_value, "zerofill",(mysql_field->flags&ZEROFILL_FLAG?1:0));
}
// int fbsql_field_seek(int result, int field_offset)
PHP_FUNCTION(fbsql_field_seek)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || ( argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc>=2)
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
}
if (column < 0 )
{
php_error(E_WARNING,"Illegal column index %d",column);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"No such column %d in result %d",column,resultIndex);
RETURN_FALSE;
}
FB_SQL_G(resultIndex) = resultIndex;
result->columnIndex = column;
RETURN_TRUE;
}
// string mysql_field_name(int result, int field_index)
PHP_FUNCTION(fbsql_field_name)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such row in result",column);
RETURN_FALSE;
}
}
if (result->list)
{
phpfbSqlResult(INTERNAL_FUNCTION_PARAM_PASSTHRU,result,result->rowIndex,0);
}
else if (result->metaData)
{
phpfbestrdup(fbccmdLabelName(fbcmdColumnMetaDataAtIndex(result->metaData, column)),
&return_value->value.str.len,
&return_value->value.str.val);
return_value->type = IS_STRING;
FB_SQL_G(resultIndex) = resultIndex;
result->columnIndex = column;
}
}
// string fbsql_field_table(int result, int field_index)
PHP_FUNCTION(fbsql_field_table)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such row in result",column);
RETURN_FALSE;
}
}
phpfbestrdup(fbccmdTableName(fbcmdColumnMetaDataAtIndex(result->metaData,column)),
&return_value->value.str.len,
&return_value->value.str.val);
return_value->type = IS_STRING;
}
// string fbsql_field_lene(int result, int field_index)
PHP_FUNCTION(fbsql_field_len)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such row in result",column);
RETURN_FALSE;
}
}
if (result->list)
{
phpfbSqlResult(INTERNAL_FUNCTION_PARAM_PASSTHRU,result,result->rowIndex,2);
}
else if (result->metaData)
{
unsigned int length = fbcdmdLength(fbccmdDatatype(fbcmdColumnMetaDataAtIndex(result->metaData,column)));
char buffer[50];
sprintf(buffer,"%d",length);
phpfbestrdup(buffer,
&return_value->value.str.len,
&return_value->value.str.val);
return_value->type = IS_STRING;
}
else
{
RETURN_FALSE;
}
}
// string fbsql_field_type(int result, int field_index)
PHP_FUNCTION(fbsql_field_type)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such column in result",column);
RETURN_FALSE;
}
}
if (result->list)
{
phpfbSqlResult(INTERNAL_FUNCTION_PARAM_PASSTHRU,result,result->rowIndex,1);
}
else if (result->metaData)
{
phpfbestrdup(fbcdmdDatatypeString (fbcmdDatatypeMetaDataAtIndex(result->metaData, column)),
&return_value->value.str.len,
&return_value->value.str.val);
return_value->type = IS_STRING;
}
else
{
RETURN_FALSE;
}
}
// string fbsql_field_flags(int result, int field_index)
PHP_FUNCTION(fbsql_field_flags)
{
int argc = ARG_COUNT(ht);
pval* argv[2];
int resultIndex;
PHPFBResult* result;
int column;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0 ) || (argc > 2 )) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0],&argv[1])==FAILURE) RETURN_FALSE;
if (argc >= 1 )
{
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
column = result->columnIndex;
if (argc >= 2 )
{
convert_to_long(argv[1]);
column = argv[1]->value.lval;
if (column < 0 )
{
php_error(E_WARNING,"Illegal index",resultIndex+1);
RETURN_FALSE;
}
if (column >= result->columnCount)
{
php_error(E_WARNING,"%d no such column in result",column);
RETURN_FALSE;
}
}
if (array_init(return_value)==FAILURE)
{
RETURN_FALSE;
}
// We should create the result -- currently empty
}
// int fbsql_free_result(int result)
PHP_FUNCTION(fbsql_free_result)
{
int argc = ARG_COUNT(ht);
pval* argv[1];
int resultIndex;
PHPFBResult* result;
FBSQLLS_FETCH();
resultIndex = FB_SQL_G(resultIndex);
if ((argc < 0) || (argc > 1)) WRONG_PARAM_COUNT;
if (zend_get_parameters(ht,argc,&argv[0])==FAILURE) RETURN_FALSE;
if (argc >= 1 ) {
convert_to_long(argv[0]);
resultIndex = argv[0]->value.lval;
}
result = phpfbGetResult(resultIndex);
if (result == NULL) RETURN_FALSE;
zend_list_delete(result->index);
FB_SQL_G(resultCount)--;
FB_SQL_G(resultIndex) = 0;
RETURN_TRUE;
}
#endif
Reference in New Issue View Git Blame Copy Permalink