fbsql.c
No OneTemporary
Actions

Size

21 KB

Referenced Files

None

Subscribers

None

fbsql.c
View Options


	/* FastBase MySQL + TCL interface program; created 22nd Sept 2000 */
	/* This program was written after extensive use of the various mysql-tcl */
	/* interface programs around, hopefully this program addresses some of */
	/* the issues I had with those programs - especially in relation to */
	/* writing the FastBase accounting system which utilises large queries */
	/* and requires the highest performance levels available */

	/* fbsql provides simple access to the mysql database, the commands are */
	/* very similar to the other tcl-mysql interfaces */
	/* added support for handling large queries without using client memory */
	/* added support for transferring results to arrays for convenience/speed */

	/* Modified to handle "high" characters (> 0x7f) */

	/* Copyright 2003, Peter Campbell Software Ltd. http://www.fastbase.co.nz, mailto:pc@acs.co.nz */

	/* Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met: */

	/* Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer. */
	/* Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer */
	/* in the documentation and/or other materials provided with the distribution. */
	/* Neither the name of Peter Campbell Software nor the names of its contributors may be used to endorse or promote products */
	/* derived from this software without specific prior written permission. */
	/* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED */
	/* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A */
	/* PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR */
	/* ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, */
	/* PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) */
	/* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT */
	/* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED */
	/* OF THE POSSIBILITY OF SUCH DAMAGE. */

	#include <stdlib.h>
	#include <string.h>

	#ifdef WINDOWS
	#include <WINDOWS.H>
	#include <winsock.h>
	#endif

	#include <mysql.h>
	#include <tcl.h>

	char errormsg[1000];
	int done;

	#define SQL_COMMANDS 11
	#define UTF_ENCODING 0

	struct mysql_connect
	{
	int CONNECTED;
	int query_flag;
	int NUMROWS;
	int use_array;
	int field_count;
	MYSQL mysql;
	MYSQL_RES *result;
	char array_name[100];
	} connection[SQL_COMMANDS];

	/*******************************************************************/
	/* miscellaneous support routines (error handling etc) */
	/*******************************************************************/

	void output_error(Tcl_Interp *interp, int sql_number) {
	sprintf(errormsg,"Error %u (%s)",mysql_errno(&connection[sql_number].mysql),mysql_error(&connection[sql_number].mysql));
	Tcl_SetResult(interp,errormsg,TCL_STATIC);
	}

	/*******************************************************************/
	/* sql connect */
	/*******************************************************************/

	int fbsql_connect(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	char *host = NULL;
	char *user = NULL;
	char *passwd = NULL;
	char *db = NULL;
	unsigned int port = 0;

	/* check not already connected? */
	if (connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "sql connect; already connected.", TCL_STATIC);
	return TCL_ERROR;
	}

	/* updated command line options: fbsql_connect host user password [database] [port] */
	if (argc > 0 && argv[0]) { host = argv[0]; }
	if (argc > 1 && argv[1]) { user = argv[1]; }
	if (argc > 2 && argv[2]) { passwd = argv[2]; }
	if (argc > 3 && argv[3]) { db = argv[3]; }
	if (argc > 4 && argv[4]) { port = atol(argv[4]); }

	mysql_init(&connection[sql_number].mysql);

	if (!(mysql_real_connect(&connection[sql_number].mysql,host,user,passwd,db,port,NULL,0))) {
	output_error(interp,sql_number);
	return TCL_ERROR;
	} else {
	connection[sql_number].CONNECTED = 1;
	return TCL_OK;
	}
	}

	int fbsql_disconnect(Tcl_Interp *interp, int sql_number) {
	/* check that we are connected? */
	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "sql disconnect; not connected.", TCL_STATIC);
	return TCL_ERROR;
	}

	mysql_close(&connection[sql_number].mysql);
	connection[sql_number].CONNECTED = 0;
	return TCL_OK;
	}

	/*******************************************************************/
	/* sql general commands */
	/*******************************************************************/

	int fbsql_selectdb(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	char *database = NULL;

	/* check a database name argument has been specified */
	if (argc <= 0 \|\| argv[0] == NULL) {
	Tcl_SetResult(interp, "sql selectdb database_name; no database name was specified.", TCL_STATIC);
	return TCL_ERROR;
	}

	/* check that we are connected to a mysql server */
	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "sql query statement; you are not connected to a mysql server yet (sql connect).", TCL_STATIC);
	return TCL_ERROR;
	}

	database = argv[0];

	if (mysql_select_db(&connection[sql_number].mysql,database)) {
	output_error(interp,sql_number);
	return TCL_ERROR;
	} else {
	return TCL_OK;
	}
	}

	int fbsql_numrows(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	Tcl_Obj *obj_result;

	/* set result object pointer */
	obj_result = Tcl_GetObjResult(interp);
	Tcl_SetIntObj(obj_result,connection[sql_number].NUMROWS);

	return TCL_OK;
	}

	int determine_field_type(int type) {
	/* 0 = char, 1 = numeric, 2 = datetime */
	switch (type) {

	case FIELD_TYPE_BLOB:
	case FIELD_TYPE_NULL:
	case FIELD_TYPE_SET:
	case FIELD_TYPE_STRING:
	case FIELD_TYPE_TIME:
	case FIELD_TYPE_TIMESTAMP:
	case FIELD_TYPE_VAR_STRING:
	return 0;
	break;

	case FIELD_TYPE_DECIMAL:
	case FIELD_TYPE_DOUBLE:
	case FIELD_TYPE_ENUM:
	case FIELD_TYPE_FLOAT:
	case FIELD_TYPE_INT24:
	case FIELD_TYPE_LONG:
	case FIELD_TYPE_LONGLONG:
	case FIELD_TYPE_SHORT:
	case FIELD_TYPE_TINY:
	case FIELD_TYPE_YEAR:
	return 1;
	break;

	case FIELD_TYPE_DATE:
	case FIELD_TYPE_DATETIME:
	return 2;
	break;
	}

	/* return 0 by default, to keep compiler warnings away */
	return 0;
	}

	/*******************************************************************/
	/* sql query command(s) */
	/*******************************************************************/

	int fbsql_query(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	char *query = NULL;
	int i, length, field_count;
	MYSQL_RES *result;
	MYSQL_ROW row;
	Tcl_Obj *obj_result;
	Tcl_Obj *obj_row;
	Tcl_Obj *obj_col;
	#if UTF_ENCODING
	Tcl_DString ds;
	#endif

	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "sql query statement; you are not connected to a mysql server yet (sql connect).", TCL_STATIC);
	return TCL_ERROR;
	}

	/* check there is no other active query? */
	if (connection[sql_number].query_flag) {
	Tcl_SetResult(interp, "Another query cannot be made until the current query has been finished with \"sql endquery\".", TCL_STATIC);
	return TCL_ERROR;
	}

	if (argc <= 0 \|\| argv[0] == NULL) {
	Tcl_SetResult(interp, "sql query statement; no sql query was specified.", TCL_STATIC);
	return TCL_ERROR;
	}

	#if UTF_ENCODING
	Tcl_DStringInit(&ds);
	Tcl_UtfToExternalDString(NULL, argv[0], strlen(argv[0]), &ds);
	query = Tcl_DStringValue(&ds);

	/* execute the sql query statement */
	if (mysql_query(&connection[sql_number].mysql,query)) {
	output_error(interp,sql_number);
	Tcl_DStringFree(&ds);
	return TCL_ERROR;
	}

	Tcl_DStringFree(&ds);
	#else
	query = argv[0];

	/* execute the sql query statement */
	if (mysql_query(&connection[sql_number].mysql,query)) {
	output_error(interp,sql_number);
	return TCL_ERROR;
	}
	#endif

	result = mysql_use_result(&connection[sql_number].mysql);
	field_count = mysql_field_count(&connection[sql_number].mysql);

	/* if no results were found and none expected then all ok */
	/* otherwise we assume the query worked ok, now get the results */
	if (result == NULL) {
	if (field_count) {
	output_error(interp,sql_number);
	return TCL_ERROR;
	}
	connection[sql_number].NUMROWS = (int)mysql_affected_rows(&connection[sql_number].mysql);
	return TCL_OK;
	} else {
	/* set result object pointer */
	obj_result = Tcl_GetObjResult(interp);

	/* process all rows from query */
	while ((row = mysql_fetch_row(result)) != NULL) {
	obj_row = Tcl_NewListObj(0,NULL);
	for (i = 0; i < field_count; i++) {
	if (row[i] == NULL) {
	length = 0;
	} else {
	length = strlen(row[i]);
	}
	#if UTF_ENCODING
	Tcl_DStringInit(&ds);
	Tcl_ExternalToUtfDString(NULL, row[i], length, &ds);
	obj_col = Tcl_NewStringObj(Tcl_DStringValue(&ds),
	Tcl_DStringLength(&ds));
	Tcl_ListObjAppendElement(interp, obj_row, obj_col);
	Tcl_DStringFree(&ds);
	#else
	obj_col = Tcl_NewStringObj(row[i],length);
	Tcl_ListObjAppendElement(interp,obj_row,obj_col);
	#endif
	}
	Tcl_ListObjAppendElement(interp,obj_result,obj_row);
	}
	connection[sql_number].NUMROWS = (int)mysql_num_rows(result);
	mysql_free_result(result);
	return TCL_OK;
	}
	}

	/*******************************************************************/
	/* sql query command(s) - non standard enhancements for FastBase */
	/*******************************************************************/

	int fbsql_startquery(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	char *query = NULL;
	int i;
	int sql_huge = 0;
	#if UTF_ENCODING
	Tcl_DString ds;
	#endif

	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "sql startquery statement; you are not connected to a mysql server yet (sql connect).", TCL_STATIC);
	return TCL_ERROR;
	}

	/* check there is no other active query? */
	if (connection[sql_number].query_flag) {
	Tcl_SetResult(interp, "Another query cannot be made until the current query has been finished with \"sql endquery\".", TCL_STATIC);
	return TCL_ERROR;
	}

	if (argc <= 0 \|\| argv[0] == NULL) {
	Tcl_SetResult(interp, "sql startquery statement; no sql query was specified.", TCL_STATIC);
	return TCL_ERROR;
	}

	connection[sql_number].use_array = 0;

	/* process additional "command-line" options */
	for (i = 1; i < argc; i++) {
	if (argv[i] != NULL) {
	if (strcmp(argv[i],"-huge") == 0) {
	sql_huge = 1;
	} else if (strcmp(argv[i],"-array") == 0) {
	if (argc <= i \|\| argv[i + 1] == NULL) {
	Tcl_SetResult(interp, "sql startquery; no array name specified with -array option.", TCL_STATIC);
	return TCL_ERROR;
	}
	connection[sql_number].use_array = 1;
	strcpy(connection[sql_number].array_name,argv[i+1]);
	i++;
	} else {
	Tcl_SetResult(interp, "sql startquery; invalid option on command line.", TCL_STATIC);
	return TCL_ERROR;
	}
	}
	}

	#if UTF_ENCODING
	Tcl_DStringInit(&ds);
	Tcl_UtfToExternalDString(NULL, argv[0], strlen(argv[0]), &ds);
	query = Tcl_DStringValue(&ds);
	#else
	query = argv[0];
	#endif

	/* execute the sql query statement */
	if (mysql_query(&connection[sql_number].mysql,query)) {
	output_error(interp,sql_number);
	#if UTF_ENCODING
	Tcl_DStringFree(&ds);
	#endif
	return TCL_ERROR;
	}

	#if UTF_ENCODING
	Tcl_DStringFree(&ds);
	#endif

	/* use or store the result? */
	/* the default is to store it locally */
	/* for large queries use "-huge" option */
	if (sql_huge) {
	connection[sql_number].result = mysql_use_result(&connection[sql_number].mysql);
	} else {
	connection[sql_number].result = mysql_store_result(&connection[sql_number].mysql);
	connection[sql_number].NUMROWS = (int)mysql_num_rows(connection[sql_number].result);
	}
	connection[sql_number].field_count = mysql_field_count(&connection[sql_number].mysql);

	/* if no results were found and none expected then all ok */
	/* otherwise we assume the query worked ok, now get the results */
	if (connection[sql_number].result == NULL) {
	if (connection[sql_number].field_count) {
	output_error(interp,sql_number);
	return TCL_ERROR;
	}
	Tcl_SetResult(interp, "sql startquery; query executed ok but returned no results.", TCL_STATIC);
	return TCL_ERROR;
	}

	/* return all ok now, see fetchrow & endquery for more details */
	connection[sql_number].query_flag = 1;
	return TCL_OK;
	}

	int fbsql_fetchrow(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	int i, field_type, length;
	MYSQL_ROW row;
	MYSQL_FIELD *field;
	Tcl_Obj *obj_result;
	Tcl_Obj *obj_col;
	Tcl_Obj *obj_array;
	Tcl_Obj *obj_element;
	#if UTF_ENCODING
	Tcl_DString ds;
	#endif

	/* check we are connected? */
	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "Not connected to a server.", TCL_STATIC);
	return TCL_ERROR;
	}
	/* check we had a query started? */
	if (!connection[sql_number].query_flag) {
	Tcl_SetResult(interp, "No query has been started.", TCL_STATIC);
	return TCL_ERROR;
	}

	/* fetch some data? */
	row = mysql_fetch_row(connection[sql_number].result);

	if (row == NULL) {
	/* if we come to the end of the data return nothing */
	/* if using an array set the array elements to default/NULL values */
	if (connection[sql_number].use_array) {
	obj_array = Tcl_NewStringObj(connection[sql_number].array_name,strlen(connection[sql_number].array_name));

	for (i = 0; i < connection[sql_number].field_count; i++) {
	/* get field information */
	field = mysql_fetch_field_direct(connection[sql_number].result,i);
	if (field == NULL) continue;

	obj_element = Tcl_NewStringObj(field->name,strlen(field->name));

	/* 0 = char, 1 = numeric, 2 = datetime */
	field_type = determine_field_type(field->type);
	/* if the type is numeric then store 0.00 as the result */
	if (field_type == 1) {
	obj_col = Tcl_NewDoubleObj(0);
	} else {
	obj_col = Tcl_NewStringObj(NULL,0);
	}

	Tcl_ObjSetVar2(interp,obj_array,obj_element,obj_col,0);
	/* we no longer have any use for the element object */
	Tcl_DecrRefCount(obj_element);
	}
	/* we no longer have any use for the array object */
	Tcl_DecrRefCount(obj_array);
	}
	return TCL_OK;
	}

	/* if an array name was specified on the sql command line then we */
	/* transfer all results to that array - special FastBase conversions */
	/* otherwise return the row as a list of columns */
	if (connection[sql_number].use_array) {
	obj_array = Tcl_NewStringObj(connection[sql_number].array_name,strlen(connection[sql_number].array_name));

	for (i = 0; i < connection[sql_number].field_count; i++) {
	/* get field information */
	field = mysql_fetch_field_direct(connection[sql_number].result,i);
	if (field == NULL) continue;

	obj_element = Tcl_NewStringObj(field->name,strlen(field->name));

	/* 0 = char, 1 = numeric, 2 = datetime */
	field_type = determine_field_type(field->type);

	if (row[i] == NULL) {
	/* if the field is NULL and the type is numeric then store 0.00 as the result */
	if (field_type == 1) {
	obj_col = Tcl_NewDoubleObj(0);
	} else {
	obj_col = Tcl_NewStringObj(NULL,0);
	}
	} else {
	/* if date field check for the value "0000-00-00" */
	/* replace this with NULL */
	if (field_type == 2 && strlen(row[i]) >= 10) {
	if (strncmp(row[i],"0000-00-00",10) == 0) {
	obj_col = Tcl_NewStringObj(NULL,0);
	} else {
	obj_col = Tcl_NewStringObj(row[i],strlen(row[i]));
	}
	} else {
	#if UTF_ENCODING
	Tcl_DStringInit(&ds);
	Tcl_ExternalToUtfDString(NULL, row[i], strlen(row[i]), &ds);
	obj_col = Tcl_NewStringObj(Tcl_DStringValue(&ds),
	Tcl_DStringLength(&ds));
	Tcl_DStringFree(&ds);
	#else
	obj_col = Tcl_NewStringObj(row[i],strlen(row[i]));
	#endif
	}
	}

	Tcl_ObjSetVar2(interp,obj_array,obj_element,obj_col,0);
	/* we no longer have any use for the element object */
	Tcl_DecrRefCount(obj_element);
	}
	/* we no longer have any use for the array object */
	Tcl_DecrRefCount(obj_array);
	/* set result object pointer */
	obj_result = Tcl_GetObjResult(interp);
	/* return result = array name */
	Tcl_SetStringObj(obj_result,connection[sql_number].array_name,strlen(connection[sql_number].array_name));
	return TCL_OK;
	} else {
	/* set result object pointer */
	obj_result = Tcl_GetObjResult(interp);
	/* process all columns from query row */
	for (i = 0; i < connection[sql_number].field_count; i++) {
	if (row[i] == NULL) {
	length = 0;
	} else {
	length = strlen(row[i]);
	}
	#if UTF_ENCODING
	Tcl_DStringInit(&ds);
	Tcl_ExternalToUtfDString(NULL, row[i], length, &ds);
	obj_col = Tcl_NewStringObj(Tcl_DStringValue(&ds),
	Tcl_DStringLength(&ds));
	Tcl_ListObjAppendElement(interp, obj_result, obj_col);
	Tcl_DStringFree(&ds);
	#else
	obj_col = Tcl_NewStringObj(row[i],length);
	Tcl_ListObjAppendElement(interp,obj_result,obj_col);
	#endif
	}
	return TCL_OK;
	}
	}

	int fbsql_endquery(Tcl_Interp interp, int sql_number, int argc, char *argv) {
	/* check we are connected? */
	if (!connection[sql_number].CONNECTED) {
	Tcl_SetResult(interp, "Not connected to a server.", TCL_STATIC);
	return TCL_ERROR;
	}
	/* check we had a query started? */
	if (!connection[sql_number].query_flag) {
	Tcl_SetResult(interp, "No query has been started.", TCL_STATIC);
	return TCL_ERROR;
	}

	connection[sql_number].NUMROWS = (int)mysql_num_rows(connection[sql_number].result);
	mysql_free_result(connection[sql_number].result);
	connection[sql_number].query_flag = 0;
	return TCL_OK;
	}

	/*******************************************************************/
	/* tcl sql command */
	/*******************************************************************/

	int SqlCmd (ClientData sql_word, Tcl_Interp interp, int argc, char *argv) {
	int sql_number = (int)sql_word;

	/* any command specified */
	if (argc <= 1) {
	Tcl_SetResult(interp, "Usage: sql connect\|selectdb\|query\|numrows\|disconnect\|version; please try again.", TCL_STATIC);
	return TCL_ERROR;
	}

	/* check command list */
	if (strcmp(argv[1],"connect") == 0) {
	return fbsql_connect(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"selectdb") == 0) {
	return fbsql_selectdb(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"query") == 0) {
	return fbsql_query(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"numrows") == 0) {
	return fbsql_numrows(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"disconnect") == 0) {
	return fbsql_disconnect(interp,sql_number);
	} else if (strcmp(argv[1],"version") == 0) {
	Tcl_SetResult(interp, "FastBase MySQL Interface for Tcl; version 1.06", TCL_STATIC);
	return TCL_OK;
	} else if (strcmp(argv[1],"startquery") == 0) {
	return fbsql_startquery(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"fetchrow") == 0) {
	return fbsql_fetchrow(interp,sql_number,argc-2,argv+2);
	} else if (strcmp(argv[1],"endquery") == 0) {
	return fbsql_endquery(interp,sql_number,argc-2,argv+2);
	} else {
	/* assume query command shortform: sql STATEMENT */
	return fbsql_query(interp,sql_number,argc-1,argv+1);
	}
	}

	/*******************************************************************/
	/* tcl fbwait command */
	/*******************************************************************/

	static char * WaitVariableProc _ANSI_ARGS_((ClientData clientData,
	Tcl_Interp interp, char name1, char *name2,
	int flags));

	static char *
	WaitVariableProc(clientData, interp, name1, name2, flags)
	ClientData clientData; /* Pointer to integer to set to 1. */
	Tcl_Interp interp; / Interpreter containing variable. */
	char name1; / Name of variable. */
	char name2; / Second part of variable name. */
	int flags; /* Information about what happened. */
	{
	done = 1;
	return (char *) NULL;
	}

	int fbWaitCmd(clientData, interp, argc, argv)
	ClientData clientData; /* Main window associated with interpreter. */
	Tcl_Interp interp; / Current interpreter. */
	int argc; /* Number of arguments. */
	char *argv; / Argument strings. */
	{
	if (argc != 2) {
	Tcl_AppendResult(interp, "wrong # args: should be \"",
	argv[0], " variable_name\" (based on tkwait var name)", (char *) NULL);
	return TCL_ERROR;
	}

	if (Tcl_TraceVar(interp, argv[1],
	TCL_GLOBAL_ONLY\|TCL_TRACE_WRITES\|TCL_TRACE_UNSETS,
	WaitVariableProc,
	(ClientData) 0) != TCL_OK) {
	return TCL_ERROR;
	}

	done = 0;
	while (!done) {
	/* process file and timer events only, ie: exclude window and idle */
	Tcl_DoOneEvent(TCL_FILE_EVENTS \| TCL_TIMER_EVENTS);
	}

	Tcl_UntraceVar(interp, argv[1],
	TCL_GLOBAL_ONLY\|TCL_TRACE_WRITES\|TCL_TRACE_UNSETS,
	WaitVariableProc,
	(ClientData) 0);

	/* Clear out the interpreter's result, since it may have been set by event handlers */
	Tcl_ResetResult(interp);

	return TCL_OK;
	}

	/*******************************************************************/
	/* define the TCL initialisation code to create the "fbsql" command */
	/*******************************************************************/

	/* haven't tested this yet (for building on Unix) */
	#ifdef WINDOWS
	extern __declspec(dllexport) int Fbsql_Init(Tcl_Interp *interp);
	#else
	extern int Fbsql_Init(Tcl_Interp *interp);
	#endif

	int Fbsql_Init(Tcl_Interp *interp) {
	int i;
	char command_name[10];

	/* stubs? */
	if (Tcl_InitStubs(interp, "8.1", 0) == NULL) {
	return TCL_ERROR;
	}

	/* create the main "sql" command */
	Tcl_CreateCommand (interp, "sql", SqlCmd, (ClientData) 0, (Tcl_CmdDeleteProc*) NULL);

	/* create new "fbwait" command */
	Tcl_CreateCommand (interp, "fbwait", fbWaitCmd, (ClientData) 0, (Tcl_CmdDeleteProc*) NULL);

	/* initialise the connection structure */
	for (i = 0; i < SQL_COMMANDS; i++) {
	connection[i].CONNECTED = 0;
	connection[i].query_flag = 0;
	if (i > 0) {
	/* create the extra commands "sql1, sql2, sql3, sql4, sql5" */
	/* these commands are the same as "sql" but use separate mysql connections */
	sprintf(command_name,"sql%d",i);
	Tcl_CreateCommand (interp, command_name, SqlCmd, (ClientData) i, (Tcl_CmdDeleteProc*) NULL);
	}
	}

	return (Tcl_PkgProvide(interp,"Fbsql","1.06") == TCL_ERROR ? TCL_ERROR : TCL_OK);
	}

File Metadata

Mime Type: text/x-c
Expires: Wed, Mar 18, 11:43 (14 h, 14 m)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 3529927
Default Alt Text: fbsql.c (21 KB)

fbsql.cNo OneTemporaryActions

fbsql.cView Options

File Metadata

Event Timeline

fbsql.c
No OneTemporary
Actions

fbsql.c
View Options