mirrors/php-src
0
0
Fork 0
mirror of https://github.com/php/php-src.git synced 2024-12-22 08:20:23 +08:00
Code Issues Packages Projects Releases Wiki Activity
aecf5485e3
php-src/ext/mssql/php_mssql.c
Felipe Pena 4e19825281 - Year++
2012-01-01 13:15:04 +00:00

2280 lines
64 KiB
C
Raw Blame History

/*
+----------------------------------------------------------------------+
| PHP Version 5 |
+----------------------------------------------------------------------+
| Copyright (c) 1997-2012 The PHP Group |
+----------------------------------------------------------------------+
| This source file is subject to version 3.01 of the PHP license, |
| that is bundled with this package in the file LICENSE, and is |
| available through the world-wide-web at the following url: |
| http://www.php.net/license/3_01.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. |
+----------------------------------------------------------------------+
| Author: Frank M. Kromann <frank@kromann.info> |
+----------------------------------------------------------------------+
*/
/* $Id$ */
#ifdef COMPILE_DL_MSSQL
#define HAVE_MSSQL 1
#endif
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include "php.h"
#include "php_globals.h"
#include "ext/standard/php_standard.h"
#include "ext/standard/info.h"
#include "php_mssql.h"
#include "php_ini.h"
#if HAVE_MSSQL
#define SAFE_STRING(s) ((s)?(s):"")
#define MSSQL_ASSOC 1<<0
#define MSSQL_NUM 1<<1
#define MSSQL_BOTH (MSSQL_ASSOC|MSSQL_NUM)
static int le_result, le_link, le_plink, le_statement;
static void php_mssql_get_column_content_with_type(mssql_link *mssql_ptr,int offset,zval *result, int column_type TSRMLS_DC);
static void php_mssql_get_column_content_without_type(mssql_link *mssql_ptr,int offset,zval *result, int column_type TSRMLS_DC);
static void _mssql_bind_hash_dtor(void *data);
/* {{{ arginfo */
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_connect, 0, 0, 0)
ZEND_ARG_INFO(0, servername)
ZEND_ARG_INFO(0, username)
ZEND_ARG_INFO(0, password)
ZEND_ARG_INFO(0, newlink)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_close, 0, 0, 0)
ZEND_ARG_INFO(0, link_identifier)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_select_db, 0, 0, 1)
ZEND_ARG_INFO(0, database_name)
ZEND_ARG_INFO(0, link_identifier)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_query, 0, 0, 1)
ZEND_ARG_INFO(0, query)
ZEND_ARG_INFO(0, link_identifier)
ZEND_ARG_INFO(0, batch_size)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_fetch_batch, 0, 0, 1)
ZEND_ARG_INFO(0, result)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_rows_affected, 0, 0, 1)
ZEND_ARG_INFO(0, link_identifier)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO(arginfo_mssql_get_last_message, 0)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_fetch_field, 0, 0, 1)
ZEND_ARG_INFO(0, result)
ZEND_ARG_INFO(0, field_offset)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_fetch_array, 0, 0, 1)
ZEND_ARG_INFO(0, result)
ZEND_ARG_INFO(0, result_type)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_fetch_assoc, 0, 0, 1)
ZEND_ARG_INFO(0, result_id)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_field_length, 0, 0, 1)
ZEND_ARG_INFO(0, result)
ZEND_ARG_INFO(0, offset)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_data_seek, 0, 0, 2)
ZEND_ARG_INFO(0, result_identifier)
ZEND_ARG_INFO(0, row_number)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_result, 0, 0, 3)
ZEND_ARG_INFO(0, result)
ZEND_ARG_INFO(0, row)
ZEND_ARG_INFO(0, field)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_min_error_severity, 0, 0, 1)
ZEND_ARG_INFO(0, severity)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_init, 0, 0, 1)
ZEND_ARG_INFO(0, sp_name)
ZEND_ARG_INFO(0, link_identifier)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_bind, 0, 0, 4)
ZEND_ARG_INFO(0, stmt)
ZEND_ARG_INFO(0, param_name)
ZEND_ARG_INFO(1, var)
ZEND_ARG_INFO(0, type)
ZEND_ARG_INFO(0, is_output)
ZEND_ARG_INFO(0, is_null)
ZEND_ARG_INFO(0, maxlen)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_execute, 0, 0, 1)
ZEND_ARG_INFO(0, stmt)
ZEND_ARG_INFO(0, skip_results)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_free_statement, 0, 0, 1)
ZEND_ARG_INFO(0, stmt)
ZEND_END_ARG_INFO()
ZEND_BEGIN_ARG_INFO_EX(arginfo_mssql_guid_string, 0, 0, 1)
ZEND_ARG_INFO(0, binary)
ZEND_ARG_INFO(0, short_format)
ZEND_END_ARG_INFO()
/* }}} */
/* {{{ mssql_functions
*/
const zend_function_entry mssql_functions[] = {
PHP_FE(mssql_connect, arginfo_mssql_connect)
PHP_FE(mssql_pconnect, arginfo_mssql_connect)
PHP_FE(mssql_close, arginfo_mssql_close)
PHP_FE(mssql_select_db, arginfo_mssql_select_db)
PHP_FE(mssql_query, arginfo_mssql_query)
PHP_FE(mssql_fetch_batch, arginfo_mssql_fetch_batch)
PHP_FE(mssql_rows_affected, arginfo_mssql_rows_affected)
PHP_FE(mssql_free_result, arginfo_mssql_fetch_batch)
PHP_FE(mssql_get_last_message, arginfo_mssql_get_last_message)
PHP_FE(mssql_num_rows, arginfo_mssql_fetch_batch)
PHP_FE(mssql_num_fields, arginfo_mssql_fetch_batch)
PHP_FE(mssql_fetch_field, arginfo_mssql_fetch_field)
PHP_FE(mssql_fetch_row, arginfo_mssql_fetch_batch)
PHP_FE(mssql_fetch_array, arginfo_mssql_fetch_array)
PHP_FE(mssql_fetch_assoc, arginfo_mssql_fetch_assoc)
PHP_FE(mssql_fetch_object, arginfo_mssql_fetch_batch)
PHP_FE(mssql_field_length, arginfo_mssql_field_length)
PHP_FE(mssql_field_name, arginfo_mssql_field_length)
PHP_FE(mssql_field_type, arginfo_mssql_field_length)
PHP_FE(mssql_data_seek, arginfo_mssql_data_seek)
PHP_FE(mssql_field_seek, arginfo_mssql_fetch_field)
PHP_FE(mssql_result, arginfo_mssql_result)
PHP_FE(mssql_next_result, arginfo_mssql_fetch_assoc)
PHP_FE(mssql_min_error_severity, arginfo_mssql_min_error_severity)
PHP_FE(mssql_min_message_severity, arginfo_mssql_min_error_severity)
PHP_FE(mssql_init, arginfo_mssql_init)
PHP_FE(mssql_bind, arginfo_mssql_bind)
PHP_FE(mssql_execute, arginfo_mssql_execute)
PHP_FE(mssql_free_statement, arginfo_mssql_free_statement)
PHP_FE(mssql_guid_string, arginfo_mssql_guid_string)
PHP_FE_END
};
/* }}} */
ZEND_DECLARE_MODULE_GLOBALS(mssql)
static PHP_GINIT_FUNCTION(mssql);
/* {{{ mssql_module_entry
*/
zend_module_entry mssql_module_entry =
{
STANDARD_MODULE_HEADER,
"mssql",
mssql_functions,
PHP_MINIT(mssql),
PHP_MSHUTDOWN(mssql),
PHP_RINIT(mssql),
PHP_RSHUTDOWN(mssql),
PHP_MINFO(mssql),
NO_VERSION_YET,
PHP_MODULE_GLOBALS(mssql),
PHP_GINIT(mssql),
NULL,
NULL,
STANDARD_MODULE_PROPERTIES_EX
};
/* }}} */
#ifdef COMPILE_DL_MSSQL
ZEND_GET_MODULE(mssql)
#endif
#define CHECK_LINK(link) { if (link==-1) { php_error_docref(NULL TSRMLS_CC, E_WARNING, "A link to the server could not be established"); RETURN_FALSE; } }
/* {{{ PHP_INI_DISP
*/
static PHP_INI_DISP(display_text_size)
{
char *value;
TSRMLS_FETCH();
if (type == PHP_INI_DISPLAY_ORIG && ini_entry->modified) {
value = ini_entry->orig_value;
} else if (ini_entry->value) {
value = ini_entry->value;
} else {
value = NULL;
}
if (atoi(value) == -1) {
PUTS("Server default");
} else {
php_printf("%s", value);
}
}
/* }}} */
/* {{{ PHP_INI
*/
PHP_INI_BEGIN()
STD_PHP_INI_BOOLEAN("mssql.allow_persistent", "1", PHP_INI_SYSTEM, OnUpdateBool, allow_persistent, zend_mssql_globals, mssql_globals)
STD_PHP_INI_ENTRY_EX("mssql.max_persistent", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_persistent, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX("mssql.max_links", "-1", PHP_INI_SYSTEM, OnUpdateLong, max_links, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX("mssql.min_error_severity", "10", PHP_INI_ALL, OnUpdateLong, cfg_min_error_severity, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX("mssql.min_message_severity", "10", PHP_INI_ALL, OnUpdateLong, cfg_min_message_severity, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_BOOLEAN("mssql.compatability_mode", "0", PHP_INI_ALL, OnUpdateBool, compatability_mode, zend_mssql_globals, mssql_globals)
STD_PHP_INI_ENTRY_EX("mssql.connect_timeout", "5", PHP_INI_ALL, OnUpdateLong, connect_timeout, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX("mssql.timeout", "60", PHP_INI_ALL, OnUpdateLong, timeout, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_ENTRY_EX("mssql.textsize", "-1", PHP_INI_ALL, OnUpdateLong, textsize, zend_mssql_globals, mssql_globals, display_text_size)
STD_PHP_INI_ENTRY_EX("mssql.textlimit", "-1", PHP_INI_ALL, OnUpdateLong, textlimit, zend_mssql_globals, mssql_globals, display_text_size)
STD_PHP_INI_ENTRY_EX("mssql.batchsize", "0", PHP_INI_ALL, OnUpdateLong, batchsize, zend_mssql_globals, mssql_globals, display_link_numbers)
STD_PHP_INI_BOOLEAN("mssql.datetimeconvert", "1", PHP_INI_ALL, OnUpdateBool, datetimeconvert, zend_mssql_globals, mssql_globals)
STD_PHP_INI_BOOLEAN("mssql.secure_connection", "0", PHP_INI_SYSTEM, OnUpdateBool, secure_connection, zend_mssql_globals, mssql_globals)
STD_PHP_INI_ENTRY_EX("mssql.max_procs", "-1", PHP_INI_ALL, OnUpdateLong, max_procs, zend_mssql_globals, mssql_globals, display_link_numbers)
#ifdef HAVE_FREETDS
STD_PHP_INI_ENTRY("mssql.charset", "", PHP_INI_ALL, OnUpdateString, charset, zend_mssql_globals, mssql_globals)
#endif
PHP_INI_END()
/* }}} */
/* error handler */
static int php_mssql_error_handler(DBPROCESS *dbproc, int severity, int dberr, int oserr, char *dberrstr, char *oserrstr)
{
TSRMLS_FETCH();
if (severity >= MS_SQL_G(min_error_severity)) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s (severity %d)", dberrstr, severity);
}
return INT_CANCEL;
}
/* {{{ php_mssql_message_handler
*/
/* message handler */
static int php_mssql_message_handler(DBPROCESS *dbproc, DBINT msgno,int msgstate, int severity,char *msgtext,char *srvname, char *procname,DBUSMALLINT line)
{
TSRMLS_FETCH();
if (severity >= MS_SQL_G(min_message_severity)) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "message: %s (severity %d)", msgtext, severity);
}
if (MS_SQL_G(server_message)) {
STR_FREE(MS_SQL_G(server_message));
MS_SQL_G(server_message) = NULL;
}
MS_SQL_G(server_message) = estrdup(msgtext);
return 0;
}
/* }}} */
/* {{{ _clean_invalid_results
*/
static int _clean_invalid_results(zend_rsrc_list_entry *le TSRMLS_DC)
{
if (Z_TYPE_P(le) == le_result) {
mssql_link *mssql_ptr = ((mssql_result *) le->ptr)->mssql_ptr;
if (!mssql_ptr->valid) {
return 1;
}
}
return 0;
}
/* }}} */
/* {{{ _free_result
*/
static void _free_result(mssql_result *result, int free_fields)
{
int i,j;
if (result->data) {
for (i=0; i<result->num_rows; i++) {
if (result->data[i]) {
for (j=0; j<result->num_fields; j++) {
zval_dtor(&result->data[i][j]);
}
efree(result->data[i]);
}
}
efree(result->data);
result->data = NULL;
result->blocks_initialized = 0;
}
if (free_fields && result->fields) {
for (i=0; i<result->num_fields; i++) {
STR_FREE(result->fields[i].name);
STR_FREE(result->fields[i].column_source);
}
efree(result->fields);
}
}
/* }}} */
/* {{{ _free_mssql_statement
*/
static void _free_mssql_statement(zend_rsrc_list_entry *rsrc TSRMLS_DC)
{
mssql_statement *statement = (mssql_statement *)rsrc->ptr;
if (statement->binds) {
zend_hash_destroy(statement->binds);
efree(statement->binds);
}
efree(statement);
}
/* }}} */
/* {{{ _free_mssql_result
*/
static void _free_mssql_result(zend_rsrc_list_entry *rsrc TSRMLS_DC)
{
mssql_result *result = (mssql_result *)rsrc->ptr;
_free_result(result, 1);
dbcancel(result->mssql_ptr->link);
efree(result);
}
/* }}} */
/* {{{ php_mssql_set_defaullt_link
*/
static void php_mssql_set_default_link(int id TSRMLS_DC)
{
if (MS_SQL_G(default_link)!=-1) {
zend_list_delete(MS_SQL_G(default_link));
}
MS_SQL_G(default_link) = id;
zend_list_addref(id);
}
/* }}} */
/* {{{ _close_mssql_link
*/
static void _close_mssql_link(zend_rsrc_list_entry *rsrc TSRMLS_DC)
{
mssql_link *mssql_ptr = (mssql_link *)rsrc->ptr;
mssql_ptr->valid = 0;
zend_hash_apply(&EG(regular_list),(apply_func_t) _clean_invalid_results TSRMLS_CC);
dbclose(mssql_ptr->link);
dbfreelogin(mssql_ptr->login);
efree(mssql_ptr);
MS_SQL_G(num_links)--;
}
/* }}} */
/* {{{ _close_mssql_plink
*/
static void _close_mssql_plink(zend_rsrc_list_entry *rsrc TSRMLS_DC)
{
mssql_link *mssql_ptr = (mssql_link *)rsrc->ptr;
dbclose(mssql_ptr->link);
dbfreelogin(mssql_ptr->login);
free(mssql_ptr);
MS_SQL_G(num_persistent)--;
MS_SQL_G(num_links)--;
}
/* }}} */
/* {{{ _mssql_bind_hash_dtor
*/
static void _mssql_bind_hash_dtor(void *data)
{
mssql_bind *bind= (mssql_bind *) data;
zval_ptr_dtor(&(bind->zval));
}
/* }}} */
/* {{{ PHP_GINIT_FUNCTION
*/
static PHP_GINIT_FUNCTION(mssql)
{
long compatability_mode;
mssql_globals->num_persistent = 0;
mssql_globals->get_column_content = php_mssql_get_column_content_with_type;
if (cfg_get_long("mssql.compatability_mode", &compatability_mode) == SUCCESS) {
if (compatability_mode) {
mssql_globals->get_column_content = php_mssql_get_column_content_without_type;
}
}
}
/* }}} */
/* {{{ PHP_MINIT_FUNCTION
*/
PHP_MINIT_FUNCTION(mssql)
{
REGISTER_INI_ENTRIES();
le_statement = zend_register_list_destructors_ex(_free_mssql_statement, NULL, "mssql statement", module_number);
le_result = zend_register_list_destructors_ex(_free_mssql_result, NULL, "mssql result", module_number);
le_link = zend_register_list_destructors_ex(_close_mssql_link, NULL, "mssql link", module_number);
le_plink = zend_register_list_destructors_ex(NULL, _close_mssql_plink, "mssql link persistent", module_number);
Z_TYPE(mssql_module_entry) = type;
if (dbinit()==FAIL) {
return FAILURE;
}
/* BEGIN MSSQL data types for mssql_bind */
REGISTER_LONG_CONSTANT("MSSQL_ASSOC", MSSQL_ASSOC, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("MSSQL_NUM", MSSQL_NUM, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("MSSQL_BOTH", MSSQL_BOTH, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLTEXT",SQLTEXT, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLVARCHAR",SQLVARCHAR, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLCHAR",SQLCHAR, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLINT1",SQLINT1, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLINT2",SQLINT2, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLINT4",SQLINT4, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLBIT",SQLBIT, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLFLT4",SQLFLT4, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLFLT8",SQLFLT8, CONST_CS | CONST_PERSISTENT);
REGISTER_LONG_CONSTANT("SQLFLTN",SQLFLTN, CONST_CS | CONST_PERSISTENT);
/* END MSSQL data types for mssql_bind */
return SUCCESS;
}
/* }}} */
/* {{{ PHP_MSHUTDOWN_FUNCTION
*/
PHP_MSHUTDOWN_FUNCTION(mssql)
{
UNREGISTER_INI_ENTRIES();
#ifndef HAVE_FREETDS
dbwinexit();
#else
dbexit();
#endif
return SUCCESS;
}
/* }}} */
/* {{{ PHP_RINIT_FUNCTION
*/
PHP_RINIT_FUNCTION(mssql)
{
MS_SQL_G(default_link) = -1;
MS_SQL_G(num_links) = MS_SQL_G(num_persistent);
MS_SQL_G(appname) = estrndup("PHP 5", 5);
MS_SQL_G(server_message) = NULL;
MS_SQL_G(min_error_severity) = MS_SQL_G(cfg_min_error_severity);
MS_SQL_G(min_message_severity) = MS_SQL_G(cfg_min_message_severity);
if (MS_SQL_G(connect_timeout) < 1) MS_SQL_G(connect_timeout) = 1;
if (MS_SQL_G(timeout) < 0) MS_SQL_G(timeout) = 60;
if (MS_SQL_G(max_procs) != -1) {
dbsetmaxprocs((TDS_SHORT)MS_SQL_G(max_procs));
}
return SUCCESS;
}
/* }}} */
/* {{{ PHP_RSHUTDOWN_FUNCTION
*/
PHP_RSHUTDOWN_FUNCTION(mssql)
{
STR_FREE(MS_SQL_G(appname));
MS_SQL_G(appname) = NULL;
if (MS_SQL_G(server_message)) {
STR_FREE(MS_SQL_G(server_message));
MS_SQL_G(server_message) = NULL;
}
return SUCCESS;
}
/* }}} */
/* {{{ PHP_MINFO_FUNCTION
*/
PHP_MINFO_FUNCTION(mssql)
{
char buf[32];
php_info_print_table_start();
php_info_print_table_header(2, "MSSQL Support", "enabled");
snprintf(buf, sizeof(buf), "%ld", MS_SQL_G(num_persistent));
php_info_print_table_row(2, "Active Persistent Links", buf);
snprintf(buf, sizeof(buf), "%ld", MS_SQL_G(num_links));
php_info_print_table_row(2, "Active Links", buf);
php_info_print_table_row(2, "Library version", MSSQL_VERSION);
php_info_print_table_end();
DISPLAY_INI_ENTRIES();
}
/* }}} */
/* {{{ php_mssql_do_connect
*/
static void php_mssql_do_connect(INTERNAL_FUNCTION_PARAMETERS, int persistent)
{
char *host = NULL, *user = NULL, *passwd = NULL;
int host_len = 0, user_len = 0, passwd_len = 0;
zend_bool new_link = 0;
char *hashed_details;
int hashed_details_length;
mssql_link mssql, *mssql_ptr;
char buffer[40];
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|sssb", &host, &host_len, &user, &user_len, &passwd, &passwd_len, &new_link) == FAILURE) {
return;
}
/* Limit strings to 255 chars to prevent overflow issues in underlying libraries */
if(host_len>255) {
host[255] = '\0';
}
if(user_len>255) {
user[255] = '\0';
}
if(passwd_len>255) {
passwd[255] = '\0';
}
switch(ZEND_NUM_ARGS())
{
case 0:
/* defaults */
hashed_details_length=5+3;
hashed_details = (char *) emalloc(hashed_details_length+1);
strcpy(hashed_details, "mssql___");
break;
case 1:
hashed_details_length = spprintf(&hashed_details, 0, "mssql_%s__", host);
break;
case 2:
hashed_details_length = spprintf(&hashed_details, 0, "mssql_%s_%s_", host, user);
break;
case 3:
case 4:
hashed_details_length = spprintf(&hashed_details, 0, "mssql_%s_%s_%s", host, user, passwd);
break;
}
if (hashed_details == NULL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Out of memory");
RETURN_FALSE;
}
dbsetlogintime(MS_SQL_G(connect_timeout));
dbsettime(MS_SQL_G(timeout));
/* set a DBLOGIN record */
if ((mssql.login = dblogin()) == NULL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to allocate login record");
RETURN_FALSE;
}
DBERRHANDLE(mssql.login, (EHANDLEFUNC) php_mssql_error_handler);
DBMSGHANDLE(mssql.login, (MHANDLEFUNC) php_mssql_message_handler);
#ifndef HAVE_FREETDS
if (MS_SQL_G(secure_connection)){
DBSETLSECURE(mssql.login);
}
else {
#endif
if (user) {
DBSETLUSER(mssql.login,user);
}
if (passwd) {
DBSETLPWD(mssql.login,passwd);
}
#ifndef HAVE_FREETDS
}
#endif
#ifdef HAVE_FREETDS
if (MS_SQL_G(charset) && strlen(MS_SQL_G(charset))) {
DBSETLCHARSET(mssql.login, MS_SQL_G(charset));
}
#endif
DBSETLAPP(mssql.login,MS_SQL_G(appname));
mssql.valid = 1;
#ifndef HAVE_FREETDS
DBSETLVERSION(mssql.login, DBVER60);
#endif
/* DBSETLTIME(mssql.login, TIMEOUT_INFINITE); */
if (!MS_SQL_G(allow_persistent)) {
persistent=0;
}
if (persistent) {
zend_rsrc_list_entry *le;
/* try to find if we already have this link in our persistent list */
if (new_link || zend_hash_find(&EG(persistent_list), hashed_details, hashed_details_length + 1, (void **) &le)==FAILURE) { /* we don't */
zend_rsrc_list_entry new_le;
if (MS_SQL_G(max_links) != -1 && MS_SQL_G(num_links) >= MS_SQL_G(max_links)) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MS_SQL_G(num_links));
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
if (MS_SQL_G(max_persistent) != -1 && MS_SQL_G(num_persistent) >= MS_SQL_G(max_persistent)) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open persistent links (%ld)", MS_SQL_G(num_persistent));
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
/* create the link */
if ((mssql.link = dbopen(mssql.login, host)) == FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to server: %s", (host == NULL ? "" : host));
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
if (DBSETOPT(mssql.link, DBBUFFER, "2")==FAIL) {
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
#ifndef HAVE_FREETDS
if (MS_SQL_G(textlimit) != -1) {
snprintf(buffer, sizeof(buffer), "%li", MS_SQL_G(textlimit));
if (DBSETOPT(mssql.link, DBTEXTLIMIT, buffer)==FAIL) {
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
}
#endif
if (MS_SQL_G(textsize) != -1) {
snprintf(buffer, sizeof(buffer), "SET TEXTSIZE %li", MS_SQL_G(textsize));
dbcmd(mssql.link, buffer);
dbsqlexec(mssql.link);
dbresults(mssql.link);
}
/* hash it up */
mssql_ptr = (mssql_link *) malloc(sizeof(mssql_link));
if (!mssql_ptr) {
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
memcpy(mssql_ptr, &mssql, sizeof(mssql_link));
Z_TYPE(new_le) = le_plink;
new_le.ptr = mssql_ptr;
if (zend_hash_update(&EG(persistent_list), hashed_details, hashed_details_length + 1, &new_le, sizeof(zend_rsrc_list_entry), NULL)==FAILURE) {
free(mssql_ptr);
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
MS_SQL_G(num_persistent)++;
MS_SQL_G(num_links)++;
} else { /* we do */
if (Z_TYPE_P(le) != le_plink) {
#if BROKEN_MSSQL_PCONNECTS
log_error("PHP/MS SQL: Hashed persistent link is not a MS SQL link!",php_rqst->server);
#endif
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Hashed persistent link is not a MS SQL link!");
efree(hashed_details);
RETURN_FALSE;
}
mssql_ptr = (mssql_link *) le->ptr;
/* test that the link hasn't died */
if (DBDEAD(mssql_ptr->link) == TRUE) {
dbclose(mssql_ptr->link);
#if BROKEN_MSSQL_PCONNECTS
log_error("PHP/MS SQL: Persistent link died, trying to reconnect...",php_rqst->server);
#endif
if ((mssql_ptr->link=dbopen(mssql_ptr->login,host))==NULL) {
#if BROKEN_MSSQL_PCONNECTS
log_error("PHP/MS SQL: Unable to reconnect!",php_rqst->server);
#endif
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Link to server lost, unable to reconnect");
zend_hash_del(&EG(persistent_list), hashed_details, hashed_details_length+1);
efree(hashed_details);
dbfreelogin(mssql_ptr->login);
RETURN_FALSE;
}
#if BROKEN_MSSQL_PCONNECTS
log_error("PHP/MS SQL: Reconnect successful!",php_rqst->server);
#endif
if (DBSETOPT(mssql_ptr->link, DBBUFFER, "2")==FAIL) {
#if BROKEN_MSSQL_PCONNECTS
log_error("PHP/MS SQL: Unable to set required options",php_rqst->server);
#endif
zend_hash_del(&EG(persistent_list), hashed_details, hashed_details_length + 1);
efree(hashed_details);
dbfreelogin(mssql_ptr->login);
dbclose(mssql_ptr->link);
RETURN_FALSE;
}
}
}
ZEND_REGISTER_RESOURCE(return_value, mssql_ptr, le_plink);
} else { /* non persistent */
zend_rsrc_list_entry *index_ptr, new_index_ptr;
/* first we check the hash for the hashed_details key. if it exists,
* it should point us to the right offset where the actual mssql link sits.
* if it doesn't, open a new mssql link, add it to the resource list,
* and add a pointer to it with hashed_details as the key.
*/
if (!new_link && zend_hash_find(&EG(regular_list), hashed_details, hashed_details_length + 1,(void **) &index_ptr)==SUCCESS) {
int type,link;
void *ptr;
if (Z_TYPE_P(index_ptr) != le_index_ptr) {
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
link = (int) index_ptr->ptr;
ptr = zend_list_find(link,&type); /* check if the link is still there */
if (ptr && (type==le_link || type==le_plink)) {
zend_list_addref(link);
Z_LVAL_P(return_value) = link;
php_mssql_set_default_link(link TSRMLS_CC);
Z_TYPE_P(return_value) = IS_RESOURCE;
dbfreelogin(mssql.login);
efree(hashed_details);
return;
} else {
zend_hash_del(&EG(regular_list), hashed_details, hashed_details_length + 1);
}
}
if (MS_SQL_G(max_links) != -1 && MS_SQL_G(num_links) >= MS_SQL_G(max_links)) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Too many open links (%ld)", MS_SQL_G(num_links));
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
if ((mssql.link=dbopen(mssql.login, host))==NULL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to connect to server: %s", (host == NULL ? "" : host));
efree(hashed_details);
dbfreelogin(mssql.login);
RETURN_FALSE;
}
if (DBSETOPT(mssql.link, DBBUFFER,"2")==FAIL) {
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
#ifndef HAVE_FREETDS
if (MS_SQL_G(textlimit) != -1) {
snprintf(buffer, sizeof(buffer), "%li", MS_SQL_G(textlimit));
if (DBSETOPT(mssql.link, DBTEXTLIMIT, buffer)==FAIL) {
efree(hashed_details);
dbfreelogin(mssql.login);
dbclose(mssql.link);
RETURN_FALSE;
}
}
#endif
if (MS_SQL_G(textsize) != -1) {
snprintf(buffer, sizeof(buffer), "SET TEXTSIZE %li", MS_SQL_G(textsize));
dbcmd(mssql.link, buffer);
dbsqlexec(mssql.link);
dbresults(mssql.link);
}
/* add it to the list */
mssql_ptr = (mssql_link *) emalloc(sizeof(mssql_link));
memcpy(mssql_ptr, &mssql, sizeof(mssql_link));
ZEND_REGISTER_RESOURCE(return_value, mssql_ptr, le_link);
/* add it to the hash */
new_index_ptr.ptr = (void *) Z_LVAL_P(return_value);
Z_TYPE(new_index_ptr) = le_index_ptr;
if (zend_hash_update(&EG(regular_list), hashed_details, hashed_details_length + 1,(void *) &new_index_ptr, sizeof(zend_rsrc_list_entry),NULL)==FAILURE) {
efree(hashed_details);
RETURN_FALSE;
}
MS_SQL_G(num_links)++;
}
efree(hashed_details);
php_mssql_set_default_link(Z_LVAL_P(return_value) TSRMLS_CC);
}
/* }}} */
/* {{{ php_mssql_get_default_link
*/
static int php_mssql_get_default_link(INTERNAL_FUNCTION_PARAMETERS)
{
if (MS_SQL_G(default_link)==-1) { /* no link opened yet, implicitly open one */
ht = 0;
php_mssql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU,0);
}
return MS_SQL_G(default_link);
}
/* }}} */
/* {{{ proto int mssql_connect([string servername [, string username [, string password [, bool new_link]]]])
Establishes a connection to a MS-SQL server */
PHP_FUNCTION(mssql_connect)
{
php_mssql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU,0);
}
/* }}} */
/* {{{ proto int mssql_pconnect([string servername [, string username [, string password [, bool new_link]]]])
Establishes a persistent connection to a MS-SQL server */
PHP_FUNCTION(mssql_pconnect)
{
php_mssql_do_connect(INTERNAL_FUNCTION_PARAM_PASSTHRU,1);
}
/* }}} */
/* {{{ proto bool mssql_close([resource conn_id])
Closes a connection to a MS-SQL server */
PHP_FUNCTION(mssql_close)
{
zval *mssql_link_index = NULL;
int id = -1;
mssql_link *mssql_ptr;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|r", &mssql_link_index) == FAILURE) {
return;
}
if (mssql_link_index == NULL) {
id = php_mssql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
CHECK_LINK(id);
}
ZEND_FETCH_RESOURCE2(mssql_ptr, mssql_link *, &mssql_link_index, id, "MS SQL-Link", le_link, le_plink);
if (mssql_link_index) {
zend_list_delete(Z_RESVAL_P(mssql_link_index));
} else {
zend_list_delete(id);
}
RETURN_TRUE;
}
/* }}} */
/* {{{ proto bool mssql_select_db(string database_name [, resource conn_id])
Select a MS-SQL database */
PHP_FUNCTION(mssql_select_db)
{
char *db;
zval *mssql_link_index = NULL;
int db_len;
int id = -1;
mssql_link *mssql_ptr;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &db, &db_len, &mssql_link_index) == FAILURE) {
return;
}
if (mssql_link_index == NULL) {
id = php_mssql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
CHECK_LINK(id);
}
ZEND_FETCH_RESOURCE2(mssql_ptr, mssql_link *, &mssql_link_index, id, "MS SQL-Link", le_link, le_plink);
if (dbuse(mssql_ptr->link, db)==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to select database: %s", db);
RETURN_FALSE;
} else {
RETURN_TRUE;
}
}
/* }}} */
/* {{{ php_mssql_get_column_content_with_type
*/
static void php_mssql_get_column_content_with_type(mssql_link *mssql_ptr,int offset,zval *result, int column_type TSRMLS_DC)
{
if (dbdata(mssql_ptr->link,offset) == NULL && dbdatlen(mssql_ptr->link,offset) == 0) {
ZVAL_NULL(result);
return;
}
switch (column_type)
{
case SQLBIT:
case SQLINT1:
case SQLINT2:
case SQLINT4:
case SQLINTN: {
ZVAL_LONG(result, (long) anyintcol(offset));
break;
}
case SQLCHAR:
case SQLVARCHAR:
case SQLTEXT: {
int length;
char *data = charcol(offset);
length=dbdatlen(mssql_ptr->link,offset);
#if ilia_0
while (length>0 && data[length-1] == ' ') { /* nuke trailing whitespace */
length--;
}
#endif
ZVAL_STRINGL(result, data, length, 1);
break;
}
case SQLFLT4:
ZVAL_DOUBLE(result, (double) floatcol4(offset));
break;
case SQLMONEY:
case SQLMONEY4:
case SQLMONEYN: {
DBFLT8 res_buf;
dbconvert(NULL, column_type, dbdata(mssql_ptr->link,offset), 8, SQLFLT8, (LPBYTE)&res_buf, -1);
ZVAL_DOUBLE(result, res_buf);
}
break;
case SQLFLT8:
ZVAL_DOUBLE(result, (double) floatcol8(offset));
break;
#ifdef SQLUNIQUE
case SQLUNIQUE: {
#else
case 36: { /* FreeTDS hack */
#endif
char *data = charcol(offset);
/* uniqueidentifier is a 16-byte binary number */
ZVAL_STRINGL(result, data, 16, 1);
}
break;
case SQLVARBINARY:
case SQLBINARY:
case SQLIMAGE: {
int res_length = dbdatlen(mssql_ptr->link, offset);
if (!res_length) {
ZVAL_NULL(result);
} else {
ZVAL_STRINGL(result, (char *)dbdata(mssql_ptr->link, offset), res_length, 1);
}
}
break;
case SQLNUMERIC:
default: {
if (dbwillconvert(column_type,SQLCHAR)) {
char *res_buf;
DBDATEREC dateinfo;
int res_length = dbdatlen(mssql_ptr->link,offset);
if (res_length == -1) {
res_length = 255;
}
if ((column_type != SQLDATETIME && column_type != SQLDATETIM4) || MS_SQL_G(datetimeconvert)) {
switch (column_type) {
case SQLDATETIME :
case SQLDATETIM4 :
res_length += 20;
break;
case SQLMONEY :
case SQLMONEY4 :
case SQLMONEYN :
case SQLDECIMAL :
case SQLNUMERIC :
res_length += 5;
case 127 :
res_length += 20;
break;
}
res_buf = (unsigned char *) emalloc(res_length+1);
res_length = dbconvert(NULL,coltype(offset),dbdata(mssql_ptr->link,offset), res_length, SQLCHAR,res_buf,-1);
res_buf[res_length] = '\0';
} else {
if (column_type == SQLDATETIM4) {
DBDATETIME temp;
dbconvert(NULL, SQLDATETIM4, dbdata(mssql_ptr->link,offset), -1, SQLDATETIME, (LPBYTE) &temp, -1);
dbdatecrack(mssql_ptr->link, &dateinfo, &temp);
} else {
dbdatecrack(mssql_ptr->link, &dateinfo, (DBDATETIME *) dbdata(mssql_ptr->link,offset));
}
res_length = 19;
spprintf(&res_buf, 0, "%d-%02d-%02d %02d:%02d:%02d" , dateinfo.year, dateinfo.month, dateinfo.day, dateinfo.hour, dateinfo.minute, dateinfo.second);
}
ZVAL_STRINGL(result, res_buf, res_length, 0);
} else {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "column %d has unknown data type (%d)", offset, coltype(offset));
ZVAL_FALSE(result);
}
}
}
}
/* }}} */
/* {{{ php_mssql_get_column_content_without_type
*/
static void php_mssql_get_column_content_without_type(mssql_link *mssql_ptr,int offset,zval *result, int column_type TSRMLS_DC)
{
if (dbdatlen(mssql_ptr->link,offset) == 0) {
ZVAL_NULL(result);
return;
}
if (column_type == SQLVARBINARY ||
column_type == SQLBINARY ||
column_type == SQLIMAGE) {
DBBINARY *bin;
unsigned char *res_buf;
int res_length = dbdatlen(mssql_ptr->link, offset);
if (res_length == 0) {
ZVAL_NULL(result);
return;
} else if (res_length < 0) {
ZVAL_FALSE(result);
return;
}
res_buf = (unsigned char *) emalloc(res_length+1);
bin = ((DBBINARY *)dbdata(mssql_ptr->link, offset));
res_buf[res_length] = '\0';
memcpy(res_buf, bin, res_length);
ZVAL_STRINGL(result, res_buf, res_length, 0);
}
else if (dbwillconvert(coltype(offset),SQLCHAR)) {
unsigned char *res_buf;
DBDATEREC dateinfo;
int res_length = dbdatlen(mssql_ptr->link,offset);
if ((column_type != SQLDATETIME && column_type != SQLDATETIM4) || MS_SQL_G(datetimeconvert)) {
switch (column_type) {
case SQLDATETIME :
case SQLDATETIM4 :
res_length += 20;
break;
case SQLMONEY :
case SQLMONEY4 :
case SQLMONEYN :
case SQLDECIMAL :
case SQLNUMERIC :
res_length += 5;
case 127 :
res_length += 20;
break;
}
res_buf = (unsigned char *) emalloc(res_length+1);
res_length = dbconvert(NULL,coltype(offset),dbdata(mssql_ptr->link,offset), res_length, SQLCHAR, res_buf, -1);
res_buf[res_length] = '\0';
} else {
if (column_type == SQLDATETIM4) {
DBDATETIME temp;
dbconvert(NULL, SQLDATETIM4, dbdata(mssql_ptr->link,offset), -1, SQLDATETIME, (LPBYTE) &temp, -1);
dbdatecrack(mssql_ptr->link, &dateinfo, &temp);
} else {
dbdatecrack(mssql_ptr->link, &dateinfo, (DBDATETIME *) dbdata(mssql_ptr->link,offset));
}
res_length = 19;
spprintf(&res_buf, 0, "%d-%02d-%02d %02d:%02d:%02d" , dateinfo.year, dateinfo.month, dateinfo.day, dateinfo.hour, dateinfo.minute, dateinfo.second);
}
ZVAL_STRINGL(result, res_buf, res_length, 0);
} else {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "column %d has unknown data type (%d)", offset, coltype(offset));
ZVAL_FALSE(result);
}
}
/* }}} */
/* {{{ _mssql_get_sp_result
*/
static void _mssql_get_sp_result(mssql_link *mssql_ptr, mssql_statement *statement TSRMLS_DC)
{
int i, num_rets, type;
char *parameter;
mssql_bind *bind;
/* Now to fetch RETVAL and OUTPUT values*/
num_rets = dbnumrets(mssql_ptr->link);
if (num_rets!=0) {
for (i = 1; i <= num_rets; i++) {
parameter = (char*)dbretname(mssql_ptr->link, i);
type = dbrettype(mssql_ptr->link, i);
if (statement->binds != NULL) { /* Maybe a non-parameter sp */
if (zend_hash_find(statement->binds, parameter, strlen(parameter), (void**)&bind)==SUCCESS) {
if (!dbretlen(mssql_ptr->link,i)) {
ZVAL_NULL(bind->zval);
}
else {
switch (type) {
case SQLBIT:
case SQLINT1:
case SQLINT2:
case SQLINT4:
convert_to_long_ex(&bind->zval);
/* FIXME this works only on little endian machine !!! */
Z_LVAL_P(bind->zval) = *((int *)(dbretdata(mssql_ptr->link,i)));
break;
case SQLFLT4:
case SQLFLT8:
case SQLFLTN:
case SQLMONEY4:
case SQLMONEY:
case SQLMONEYN:
convert_to_double_ex(&bind->zval);
Z_DVAL_P(bind->zval) = *((double *)(dbretdata(mssql_ptr->link,i)));
break;
case SQLCHAR:
case SQLVARCHAR:
case SQLTEXT:
convert_to_string_ex(&bind->zval);
Z_STRLEN_P(bind->zval) = dbretlen(mssql_ptr->link,i);
Z_STRVAL_P(bind->zval) = estrndup(dbretdata(mssql_ptr->link,i),Z_STRLEN_P(bind->zval));
break;
/* TODO binary */
}
}
}
else {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "An output parameter variable was not provided");
}
}
}
}
if (statement->binds != NULL) { /* Maybe a non-parameter sp */
if (zend_hash_find(statement->binds, "RETVAL", 6, (void**)&bind)==SUCCESS) {
if (dbhasretstat(mssql_ptr->link)) {
convert_to_long_ex(&bind->zval);
Z_LVAL_P(bind->zval)=dbretstatus(mssql_ptr->link);
}
else {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "stored procedure has no return value. Nothing was returned into RETVAL");
}
}
}
}
/* }}} */
/* {{{ _mssql_fetch_batch
*/
static int _mssql_fetch_batch(mssql_link *mssql_ptr, mssql_result *result, int retvalue TSRMLS_DC)
{
int i, j = 0;
char computed_buf[16];
if (!result->have_fields) {
for (i=0; i<result->num_fields; i++) {
char *source = NULL;
char *fname = (char *)dbcolname(mssql_ptr->link,i+1);
if (*fname) {
result->fields[i].name = estrdup(fname);
} else {
if (j>0) {
snprintf(computed_buf,16,"computed%d",j);
} else {
strcpy(computed_buf,"computed");
}
result->fields[i].name = estrdup(computed_buf);
j++;
}
result->fields[i].max_length = dbcollen(mssql_ptr->link,i+1);
source = (char *)dbcolsource(mssql_ptr->link,i+1);
if (source) {
result->fields[i].column_source = estrdup(source);
}
else {
result->fields[i].column_source = STR_EMPTY_ALLOC();
}
result->fields[i].type = coltype(i+1);
/* set numeric flag */
switch (result->fields[i].type) {
case SQLINT1:
case SQLINT2:
case SQLINT4:
case SQLINTN:
case SQLFLT4:
case SQLFLT8:
case SQLNUMERIC:
case SQLDECIMAL:
result->fields[i].numeric = 1;
break;
case SQLCHAR:
case SQLVARCHAR:
case SQLTEXT:
default:
result->fields[i].numeric = 0;
break;
}
}
result->have_fields = 1;
}
i=0;
if (!result->data) {
result->data = (zval **) safe_emalloc(sizeof(zval *), MSSQL_ROWS_BLOCK*(++result->blocks_initialized), 0);
}
while (retvalue!=FAIL && retvalue!=NO_MORE_ROWS) {
result->num_rows++;
if (result->num_rows > result->blocks_initialized*MSSQL_ROWS_BLOCK) {
result->data = (zval **) erealloc(result->data,sizeof(zval *)*MSSQL_ROWS_BLOCK*(++result->blocks_initialized));
}
result->data[i] = (zval *) safe_emalloc(sizeof(zval), result->num_fields, 0);
for (j=0; j<result->num_fields; j++) {
INIT_ZVAL(result->data[i][j]);
MS_SQL_G(get_column_content(mssql_ptr, j+1, &result->data[i][j], result->fields[j].type TSRMLS_CC));
}
if (i<result->batchsize || result->batchsize==0) {
i++;
dbclrbuf(mssql_ptr->link,DBLASTROW(mssql_ptr->link));
retvalue=dbnextrow(mssql_ptr->link);
}
else
break;
result->lastresult = retvalue;
}
if (result->statement && (retvalue == NO_MORE_RESULTS || retvalue == NO_MORE_RPC_RESULTS)) {
_mssql_get_sp_result(mssql_ptr, result->statement TSRMLS_CC);
}
return i;
}
/* }}} */
/* {{{ proto int mssql_fetch_batch(resource result_index)
Returns the next batch of records */
PHP_FUNCTION(mssql_fetch_batch)
{
zval *mssql_result_index;
mssql_result *result;
mssql_link *mssql_ptr;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
if (Z_RESVAL_P(mssql_result_index) == 0) {
RETURN_FALSE;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
mssql_ptr = result->mssql_ptr;
_free_result(result, 0);
result->cur_row=result->num_rows=0;
result->num_rows = _mssql_fetch_batch(mssql_ptr, result, result->lastresult TSRMLS_CC);
RETURN_LONG(result->num_rows);
}
/* }}} */
/* {{{ proto resource mssql_query(string query [, resource conn_id [, int batch_size]])
Perform an SQL query on a MS-SQL server database */
PHP_FUNCTION(mssql_query)
{
char *query;
zval *mssql_link_index = NULL;
int query_len, retvalue, batchsize, num_fields;
long zbatchsize = 0;
mssql_link *mssql_ptr;
mssql_result *result;
int id = -1;
dbsettime(MS_SQL_G(timeout));
batchsize = MS_SQL_G(batchsize);
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|rl", &query, &query_len, &mssql_link_index, &zbatchsize) == FAILURE) {
return;
}
switch(ZEND_NUM_ARGS()) {
case 1:
id = php_mssql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
CHECK_LINK(id);
break;
case 3:
batchsize = (int) zbatchsize;
break;
}
ZEND_FETCH_RESOURCE2(mssql_ptr, mssql_link *, &mssql_link_index, id, "MS SQL-Link", le_link, le_plink);
if (dbcmd(mssql_ptr->link, query)==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to set query");
RETURN_FALSE;
}
if (dbsqlexec(mssql_ptr->link)==FAIL || (retvalue = dbresults(mssql_ptr->link))==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Query failed");
dbcancel(mssql_ptr->link);
RETURN_FALSE;
}
/* Skip results not returning any columns */
while ((num_fields = dbnumcols(mssql_ptr->link)) <= 0 && retvalue == SUCCEED) {
retvalue = dbresults(mssql_ptr->link);
}
if (num_fields <= 0) {
RETURN_TRUE;
}
retvalue=dbnextrow(mssql_ptr->link);
if (retvalue==FAIL) {
dbcancel(mssql_ptr->link);
RETURN_FALSE;
}
result = (mssql_result *) emalloc(sizeof(mssql_result));
result->statement = NULL;
result->num_fields = num_fields;
result->blocks_initialized = 1;
result->batchsize = batchsize;
result->data = NULL;
result->blocks_initialized = 0;
result->mssql_ptr = mssql_ptr;
result->cur_field=result->cur_row=result->num_rows=0;
result->have_fields = 0;
result->fields = (mssql_field *) safe_emalloc(sizeof(mssql_field), result->num_fields, 0);
result->num_rows = _mssql_fetch_batch(mssql_ptr, result, retvalue TSRMLS_CC);
ZEND_REGISTER_RESOURCE(return_value, result, le_result);
}
/* }}} */
/* {{{ proto int mssql_rows_affected(resource conn_id)
Returns the number of records affected by the query */
PHP_FUNCTION(mssql_rows_affected)
{
zval *mssql_link_index;
mssql_link *mssql_ptr;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_link_index) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE2(mssql_ptr, mssql_link *, &mssql_link_index, -1, "MS SQL-Link", le_link, le_plink);
RETURN_LONG(DBCOUNT(mssql_ptr->link));
}
/* }}} */
/* {{{ proto bool mssql_free_result(resource result_index)
Free a MS-SQL result index */
PHP_FUNCTION(mssql_free_result)
{
zval *mssql_result_index;
mssql_result *result;
int retvalue;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
if (Z_RESVAL_P(mssql_result_index) == 0) {
RETURN_FALSE;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
/* Release remaining results */
do {
dbcanquery(result->mssql_ptr->link);
retvalue = dbresults(result->mssql_ptr->link);
} while (retvalue == SUCCEED);
zend_list_delete(Z_RESVAL_P(mssql_result_index));
RETURN_TRUE;
}
/* }}} */
/* {{{ proto string mssql_get_last_message(void)
Gets the last message from the MS-SQL server */
PHP_FUNCTION(mssql_get_last_message)
{
if (zend_parse_parameters_none() == FAILURE) {
return;
}
if (MS_SQL_G(server_message)) {
RETURN_STRING(MS_SQL_G(server_message),1);
} else {
RETURN_STRING("",1);
}
}
/* }}} */
/* {{{ proto int mssql_num_rows(resource mssql_result_index)
Returns the number of rows fetched in from the result id specified */
PHP_FUNCTION(mssql_num_rows)
{
zval *mssql_result_index;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
RETURN_LONG(result->num_rows);
}
/* }}} */
/* {{{ proto int mssql_num_fields(resource mssql_result_index)
Returns the number of fields fetched in from the result id specified */
PHP_FUNCTION(mssql_num_fields)
{
zval *mssql_result_index;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
RETURN_LONG(result->num_fields);
}
/* }}} */
/* {{{ php_mssql_fetch_hash
*/
static void php_mssql_fetch_hash(INTERNAL_FUNCTION_PARAMETERS, int result_type)
{
zval *mssql_result_index;
mssql_result *result;
int i;
long resulttype = 0;
switch (result_type) {
case MSSQL_NUM:
case MSSQL_ASSOC:
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
break;
case MSSQL_BOTH:
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &mssql_result_index, &resulttype) == FAILURE) {
return;
}
result_type = (resulttype > 0 && (resulttype & MSSQL_BOTH)) ? resulttype : result_type;
break;
default:
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (MS_SQL_G(server_message)) {
STR_FREE(MS_SQL_G(server_message));
MS_SQL_G(server_message) = NULL;
}
if (result->cur_row >= result->num_rows) {
RETURN_FALSE;
}
array_init(return_value);
for (i=0; i<result->num_fields; i++) {
if (Z_TYPE(result->data[result->cur_row][i]) != IS_NULL) {
char *data;
int data_len;
if (Z_TYPE(result->data[result->cur_row][i]) == IS_STRING) {
data = Z_STRVAL(result->data[result->cur_row][i]);
data_len = Z_STRLEN(result->data[result->cur_row][i]);
if (result_type & MSSQL_NUM) {
add_index_stringl(return_value, i, data, data_len, 1);
}
if (result_type & MSSQL_ASSOC) {
add_assoc_stringl(return_value, result->fields[i].name, data, data_len, 1);
}
}
else if (Z_TYPE(result->data[result->cur_row][i]) == IS_LONG) {
if (result_type & MSSQL_NUM)
add_index_long(return_value, i, Z_LVAL(result->data[result->cur_row][i]));
if (result_type & MSSQL_ASSOC)
add_assoc_long(return_value, result->fields[i].name, Z_LVAL(result->data[result->cur_row][i]));
}
else if (Z_TYPE(result->data[result->cur_row][i]) == IS_DOUBLE) {
if (result_type & MSSQL_NUM)
add_index_double(return_value, i, Z_DVAL(result->data[result->cur_row][i]));
if (result_type & MSSQL_ASSOC)
add_assoc_double(return_value, result->fields[i].name, Z_DVAL(result->data[result->cur_row][i]));
}
}
else
{
if (result_type & MSSQL_NUM)
add_index_null(return_value, i);
if (result_type & MSSQL_ASSOC)
add_assoc_null(return_value, result->fields[i].name);
}
}
result->cur_row++;
}
/* }}} */
/* {{{ proto array mssql_fetch_row(resource result_id)
Returns an array of the current row in the result set specified by result_id */
PHP_FUNCTION(mssql_fetch_row)
{
php_mssql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MSSQL_NUM);
}
/* }}} */
/* {{{ proto object mssql_fetch_object(resource result_id)
Returns a pseudo-object of the current row in the result set specified by result_id */
PHP_FUNCTION(mssql_fetch_object)
{
php_mssql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MSSQL_ASSOC);
if (Z_TYPE_P(return_value)==IS_ARRAY) {
object_and_properties_init(return_value, ZEND_STANDARD_CLASS_DEF_PTR, Z_ARRVAL_P(return_value));
}
}
/* }}} */
/* {{{ proto array mssql_fetch_array(resource result_id [, int result_type])
Returns an associative array of the current row in the result set specified by result_id */
PHP_FUNCTION(mssql_fetch_array)
{
php_mssql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MSSQL_BOTH);
}
/* }}} */
/* {{{ proto array mssql_fetch_assoc(resource result_id)
Returns an associative array of the current row in the result set specified by result_id */
PHP_FUNCTION(mssql_fetch_assoc)
{
php_mssql_fetch_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MSSQL_ASSOC);
}
/* }}} */
/* {{{ proto bool mssql_data_seek(resource result_id, int offset)
Moves the internal row pointer of the MS-SQL result associated with the specified result identifier to pointer to the specified row number */
PHP_FUNCTION(mssql_data_seek)
{
zval *mssql_result_index;
long offset;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &mssql_result_index, &offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (offset < 0 || offset >= result->num_rows) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad row offset");
RETURN_FALSE;
}
result->cur_row = offset;
RETURN_TRUE;
}
/* }}} */
/* {{{ php_mssql_get_field_name
*/
static char *php_mssql_get_field_name(int type)
{
switch (type) {
case SQLBINARY:
case SQLVARBINARY:
return "blob";
break;
case SQLCHAR:
case SQLVARCHAR:
return "char";
break;
case SQLTEXT:
return "text";
break;
case SQLDATETIME:
case SQLDATETIM4:
case SQLDATETIMN:
return "datetime";
break;
case SQLDECIMAL:
case SQLFLT4:
case SQLFLT8:
case SQLFLTN:
return "real";
break;
case SQLINT1:
case SQLINT2:
case SQLINT4:
case SQLINTN:
return "int";
break;
case SQLNUMERIC:
return "numeric";
break;
case SQLMONEY:
case SQLMONEY4:
case SQLMONEYN:
return "money";
break;
case SQLBIT:
return "bit";
break;
case SQLIMAGE:
return "image";
break;
#ifdef SQLUNIQUE
case SQLUNIQUE:
return "uniqueidentifier";
break;
#endif
default:
return "unknown";
break;
}
}
/* }}} */
/* {{{ proto object mssql_fetch_field(resource result_id [, int offset])
Gets information about certain fields in a query result */
PHP_FUNCTION(mssql_fetch_field)
{
zval *mssql_result_index;
long field_offset = -1;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &mssql_result_index, &field_offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (field_offset==-1) {
field_offset = result->cur_field;
result->cur_field++;
}
if (field_offset<0 || field_offset >= result->num_fields) {
if (ZEND_NUM_ARGS()==2) { /* field specified explicitly */
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset");
}
RETURN_FALSE;
}
object_init(return_value);
add_property_string(return_value, "name",result->fields[field_offset].name, 1);
add_property_long(return_value, "max_length",result->fields[field_offset].max_length);
add_property_string(return_value, "column_source",result->fields[field_offset].column_source, 1);
add_property_long(return_value, "numeric", result->fields[field_offset].numeric);
add_property_string(return_value, "type", php_mssql_get_field_name(Z_TYPE(result->fields[field_offset])), 1);
}
/* }}} */
/* {{{ proto int mssql_field_length(resource result_id [, int offset])
Get the length of a MS-SQL field */
PHP_FUNCTION(mssql_field_length)
{
zval *mssql_result_index;
long field_offset = -1;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &mssql_result_index, &field_offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (field_offset==-1) {
field_offset = result->cur_field;
result->cur_field++;
}
if (field_offset<0 || field_offset >= result->num_fields) {
if (ZEND_NUM_ARGS()==2) { /* field specified explicitly */
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset");
}
RETURN_FALSE;
}
RETURN_LONG(result->fields[field_offset].max_length);
}
/* }}} */
/* {{{ proto string mssql_field_name(resource result_id [, int offset])
Returns the name of the field given by offset in the result set given by result_id */
PHP_FUNCTION(mssql_field_name)
{
zval *mssql_result_index;
long field_offset = -1;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &mssql_result_index, &field_offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (field_offset==-1) {
field_offset = result->cur_field;
result->cur_field++;
}
if (field_offset<0 || field_offset >= result->num_fields) {
if (ZEND_NUM_ARGS()==2) { /* field specified explicitly */
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset");
}
RETURN_FALSE;
}
RETURN_STRINGL(result->fields[field_offset].name, strlen(result->fields[field_offset].name), 1);
}
/* }}} */
/* {{{ proto string mssql_field_type(resource result_id [, int offset])
Returns the type of a field */
PHP_FUNCTION(mssql_field_type)
{
zval *mssql_result_index;
long field_offset = -1;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|l", &mssql_result_index, &field_offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (field_offset==-1) {
field_offset = result->cur_field;
result->cur_field++;
}
if (field_offset<0 || field_offset >= result->num_fields) {
if (ZEND_NUM_ARGS()==2) { /* field specified explicitly */
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset");
}
RETURN_FALSE;
}
RETURN_STRINGL(php_mssql_get_field_name(Z_TYPE(result->fields[field_offset])), strlen(php_mssql_get_field_name(Z_TYPE(result->fields[field_offset]))), 1);
}
/* }}} */
/* {{{ proto bool mssql_field_seek(resource result_id, int offset)
Seeks to the specified field offset */
PHP_FUNCTION(mssql_field_seek)
{
zval *mssql_result_index;
long field_offset;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rl", &mssql_result_index, &field_offset) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (field_offset<0 || field_offset >= result->num_fields) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset");
RETURN_FALSE;
}
result->cur_field = field_offset;
RETURN_TRUE;
}
/* }}} */
/* {{{ proto string mssql_result(resource result_id, int row, mixed field)
Returns the contents of one cell from a MS-SQL result set */
PHP_FUNCTION(mssql_result)
{
zval **field, *mssql_result_index;
long row;
int field_offset=0;
mssql_result *result;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rlZ", &mssql_result_index, &row, &field) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
if (row < 0 || row >= result->num_rows) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad row offset (%ld)", row);
RETURN_FALSE;
}
switch(Z_TYPE_PP(field)) {
case IS_STRING: {
int i;
for (i=0; i<result->num_fields; i++) {
if (!strcasecmp(result->fields[i].name, Z_STRVAL_PP(field))) {
field_offset = i;
break;
}
}
if (i>=result->num_fields) { /* no match found */
php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s field not found in result", Z_STRVAL_PP(field));
RETURN_FALSE;
}
break;
}
default:
convert_to_long_ex(field);
field_offset = Z_LVAL_PP(field);
if (field_offset<0 || field_offset>=result->num_fields) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Bad column offset specified");
RETURN_FALSE;
}
break;
}
*return_value = result->data[row][field_offset];
zval_copy_ctor(return_value);
}
/* }}} */
/* {{{ proto bool mssql_next_result(resource result_id)
Move the internal result pointer to the next result */
PHP_FUNCTION(mssql_next_result)
{
zval *mssql_result_index;
int retvalue;
mssql_result *result;
mssql_link *mssql_ptr;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_result_index) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(result, mssql_result *, &mssql_result_index, -1, "MS SQL-result", le_result);
mssql_ptr = result->mssql_ptr;
retvalue = dbresults(mssql_ptr->link);
while (dbnumcols(mssql_ptr->link) <= 0 && retvalue == SUCCEED) {
retvalue = dbresults(mssql_ptr->link);
}
if (retvalue == FAIL) {
RETURN_FALSE;
}
else if (retvalue == NO_MORE_RESULTS || retvalue == NO_MORE_RPC_RESULTS) {
if (result->statement) {
_mssql_get_sp_result(mssql_ptr, result->statement TSRMLS_CC);
}
RETURN_FALSE;
}
else {
_free_result(result, 1);
result->cur_row=result->num_fields=result->num_rows=0;
dbclrbuf(mssql_ptr->link,DBLASTROW(mssql_ptr->link));
retvalue = dbnextrow(mssql_ptr->link);
result->num_fields = dbnumcols(mssql_ptr->link);
result->fields = (mssql_field *) safe_emalloc(sizeof(mssql_field), result->num_fields, 0);
result->have_fields = 0;
result->num_rows = _mssql_fetch_batch(mssql_ptr, result, retvalue TSRMLS_CC);
RETURN_TRUE;
}
}
/* }}} */
/* {{{ proto void mssql_min_error_severity(int severity)
Sets the lower error severity */
PHP_FUNCTION(mssql_min_error_severity)
{
long severity;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &severity) == FAILURE) {
return;
}
MS_SQL_G(min_error_severity) = severity;
}
/* }}} */
/* {{{ proto void mssql_min_message_severity(int severity)
Sets the lower message severity */
PHP_FUNCTION(mssql_min_message_severity)
{
long severity;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "l", &severity) == FAILURE) {
return;
}
MS_SQL_G(min_message_severity) = severity;
}
/* }}} */
/* {{{ proto int mssql_init(string sp_name [, resource conn_id])
Initializes a stored procedure or a remote stored procedure */
PHP_FUNCTION(mssql_init)
{
char *sp_name;
int sp_name_len;
zval *mssql_link_index = NULL;
mssql_link *mssql_ptr;
mssql_statement *statement;
int id = -1;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|r", &sp_name, &sp_name_len, &mssql_link_index) == FAILURE) {
return;
}
if (mssql_link_index == NULL) {
id = php_mssql_get_default_link(INTERNAL_FUNCTION_PARAM_PASSTHRU);
CHECK_LINK(id);
}
ZEND_FETCH_RESOURCE2(mssql_ptr, mssql_link *, &mssql_link_index, id, "MS SQL-Link", le_link, le_plink);
if (dbrpcinit(mssql_ptr->link, sp_name,0)==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "unable to init stored procedure");
RETURN_FALSE;
}
statement=NULL;
statement = ecalloc(1,sizeof(mssql_statement));
statement->link = mssql_ptr;
statement->executed=FALSE;
statement->id = zend_list_insert(statement,le_statement TSRMLS_CC);
RETURN_RESOURCE(statement->id);
}
/* }}} */
/* {{{ proto bool mssql_bind(resource stmt, string param_name, mixed var, int type [, bool is_output [, bool is_null [, int maxlen]]])
Adds a parameter to a stored procedure or a remote stored procedure */
PHP_FUNCTION(mssql_bind)
{
char *param_name;
int param_name_len, datalen;
int status = 0;
long type = 0, maxlen = -1;
zval *stmt, **var;
zend_bool is_output = 0, is_null = 0;
mssql_link *mssql_ptr;
mssql_statement *statement;
mssql_bind bind,*bindp;
LPBYTE value = NULL;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "rsZl|bbl", &stmt, &param_name, &param_name_len, &var, &type, &is_output, &is_null, &maxlen) == FAILURE) {
return;
}
if (ZEND_NUM_ARGS() == 7 && !is_output) {
maxlen = -1;
}
ZEND_FETCH_RESOURCE(statement, mssql_statement *, &stmt, -1, "MS SQL-Statement", le_statement);
if (statement==NULL) {
RETURN_FALSE;
}
mssql_ptr=statement->link;
/* modify datalen and maxlen according to dbrpcparam documentation */
if ( (type==SQLVARCHAR) || (type==SQLCHAR) || (type==SQLTEXT) ) { /* variable-length type */
if (is_null) {
maxlen=0;
datalen=0;
} else {
convert_to_string_ex(var);
datalen=Z_STRLEN_PP(var);
value=(LPBYTE)Z_STRVAL_PP(var);
}
} else {
/* fixed-length type */
if (is_null) {
datalen=0;
} else {
datalen=-1;
}
maxlen=-1;
switch (type) {
case SQLFLT4:
case SQLFLT8:
case SQLFLTN:
convert_to_double_ex(var);
value=(LPBYTE)(&Z_DVAL_PP(var));
break;
case SQLBIT:
case SQLINT1:
case SQLINT2:
case SQLINT4:
convert_to_long_ex(var);
value=(LPBYTE)(&Z_LVAL_PP(var));
break;
default:
php_error_docref(NULL TSRMLS_CC, E_WARNING, "unsupported type");
RETURN_FALSE;
break;
}
}
if (is_output) {
status=DBRPCRETURN;
}
/* hashtable of binds */
if (! statement->binds) {
ALLOC_HASHTABLE(statement->binds);
zend_hash_init(statement->binds, 13, NULL, _mssql_bind_hash_dtor, 0);
}
if (zend_hash_exists(statement->binds, param_name, param_name_len)) {
RETURN_FALSE;
}
else {
memset((void*)&bind,0,sizeof(mssql_bind));
zend_hash_add(statement->binds, param_name, param_name_len, &bind, sizeof(mssql_bind), (void **)&bindp);
if( NULL == bindp ) RETURN_FALSE;
bindp->zval=*var;
zval_add_ref(var);
/* no call to dbrpcparam if RETVAL */
if ( strcmp("RETVAL", param_name)!=0 ) {
if (dbrpcparam(mssql_ptr->link, param_name, (BYTE)status, type, maxlen, datalen, (LPBYTE)value)==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "Unable to set parameter");
RETURN_FALSE;
}
}
}
RETURN_TRUE;
}
/* }}} */
/* {{{ proto mixed mssql_execute(resource stmt [, bool skip_results = false])
Executes a stored procedure on a MS-SQL server database */
PHP_FUNCTION(mssql_execute)
{
zval *stmt;
zend_bool skip_results = 0;
int retvalue, retval_results;
mssql_link *mssql_ptr;
mssql_statement *statement;
mssql_result *result;
int num_fields;
int batchsize;
int exec_retval;
batchsize = MS_SQL_G(batchsize);
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r|b", &stmt, &skip_results) == FAILURE) {
return;
}
ZEND_FETCH_RESOURCE(statement, mssql_statement *, &stmt, -1, "MS SQL-Statement", le_statement);
mssql_ptr=statement->link;
exec_retval = dbrpcexec(mssql_ptr->link);
if (exec_retval == FAIL || dbsqlok(mssql_ptr->link) == FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "stored procedure execution failed");
if (exec_retval == FAIL) {
dbcancel(mssql_ptr->link);
}
RETURN_FALSE;
}
retval_results=dbresults(mssql_ptr->link);
if (retval_results==FAIL) {
php_error_docref(NULL TSRMLS_CC, E_WARNING, "could not retrieve results");
dbcancel(mssql_ptr->link);
RETURN_FALSE;
}
/* The following is just like mssql_query, fetch all rows from the first result
* set into the row buffer.
*/
result=NULL;
if (retval_results == SUCCEED) {
if (skip_results) {
do {
dbcanquery(mssql_ptr->link);
retval_results = dbresults(mssql_ptr->link);
} while (retval_results == SUCCEED);
}
else {
/* Skip results not returning any columns */
while ((num_fields = dbnumcols(mssql_ptr->link)) <= 0 && retval_results == SUCCEED) {
retval_results = dbresults(mssql_ptr->link);
}
if ((num_fields = dbnumcols(mssql_ptr->link)) > 0) {
retvalue = dbnextrow(mssql_ptr->link);
result = (mssql_result *) emalloc(sizeof(mssql_result));
result->batchsize = batchsize;
result->blocks_initialized = 1;
result->data = (zval **) safe_emalloc(sizeof(zval *), MSSQL_ROWS_BLOCK, 0);
result->mssql_ptr = mssql_ptr;
result->cur_field=result->cur_row=result->num_rows=0;
result->num_fields = num_fields;
result->have_fields = 0;
result->fields = (mssql_field *) safe_emalloc(sizeof(mssql_field), num_fields, 0);
result->statement = statement;
result->num_rows = _mssql_fetch_batch(mssql_ptr, result, retvalue TSRMLS_CC);
}
}
}
if (retval_results == NO_MORE_RESULTS || retval_results == NO_MORE_RPC_RESULTS) {
_mssql_get_sp_result(mssql_ptr, statement TSRMLS_CC);
}
if (result==NULL) {
RETURN_TRUE; /* no recordset returned ...*/
}
else {
ZEND_REGISTER_RESOURCE(return_value, result, le_result);
}
}
/* }}} */
/* {{{ proto bool mssql_free_statement(resource result_index)
Free a MS-SQL statement index */
PHP_FUNCTION(mssql_free_statement)
{
zval *mssql_statement_index;
mssql_statement *statement;
int retvalue;
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "r", &mssql_statement_index) == FAILURE) {
return;
}
if (Z_RESVAL_P(mssql_statement_index) == 0) {
RETURN_FALSE;
}
ZEND_FETCH_RESOURCE(statement, mssql_statement *, &mssql_statement_index, -1, "MS SQL-statement", le_statement);
/* Release remaining results */
do {
dbcanquery(statement->link->link);
retvalue = dbresults(statement->link->link);
} while (retvalue == SUCCEED);
zend_list_delete(Z_RESVAL_P(mssql_statement_index));
RETURN_TRUE;
}
/* }}} */
/* {{{ proto string mssql_guid_string(string binary [,bool short_format])
Converts a 16 byte binary GUID to a string */
PHP_FUNCTION(mssql_guid_string)
{
char *binary;
int binary_len;
zend_bool sf = 0;
char buffer[32+1];
char buffer2[36+1];
if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|b", &binary, &binary_len, &sf) == FAILURE) {
return;
}
dbconvert(NULL, SQLBINARY, (BYTE*) binary, MIN(16, binary_len), SQLCHAR, buffer, -1);
if (sf) {
php_strtoupper(buffer, 32);
RETURN_STRING(buffer, 1);
}
else {
int i;
/* FIXME this works only on little endian machine */
for (i=0; i<4; i++) {
buffer2[2*i] = buffer[6-2*i];
buffer2[2*i+1] = buffer[7-2*i];
}
buffer2[8] = '-';
for (i=0; i<2; i++) {
buffer2[9+2*i] = buffer[10-2*i];
buffer2[10+2*i] = buffer[11-2*i];
}
buffer2[13] = '-';
for (i=0; i<2; i++) {
buffer2[14+2*i] = buffer[14-2*i];
buffer2[15+2*i] = buffer[15-2*i];
}
buffer2[18] = '-';
for (i=0; i<4; i++) {
buffer2[19+i] = buffer[16+i];
}
buffer2[23] = '-';
for (i=0; i<12; i++) {
buffer2[24+i] = buffer[20+i];
}
buffer2[36] = 0;
php_strtoupper(buffer2, 36);
RETURN_STRING(buffer2, 1);
}
}
/* }}} */
#endif
Reference in New Issue View Git Blame Copy Permalink