Page MenuHomeDevCentral
Files F32064423

No OneTemporary
Actions

View Options

This document is not UTF8. It was detected as Shift JIS and converted to UTF8 for display.
diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..1232249
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,25 @@
+# path to libmysqlclient.a :
+MYSQLLIBDIR = /usr/lib/mysql
+# path to header files of mysql:
+MYSQLINCDIR = /usr/include/mysql
+# donｴt forget mysql-3.22.26a.tar.gz for example from www.sunfreeware.com :
+MYSQLINCDIR2 = /home/users/wbo/projects/Tools/mysql-3.22.26a/include
+# a different compiler :
+CC = gcc
+PIC = -fPIC
+INCLUDES = -I/home/local/include -I$(MYSQLINCDIR) -I$(MYSQLINCDIR2)
+CFLAGS += -Wall $(PIC) $(INCLUDES)
+
+# For Solaris8 :
+LDFLAGS = -lz -G -L $(MYSQLLIBDIR) -l mysqlclient
+
+all: fbsql.so
+
+fbsql.so: fbsql.o
+ $(LD) -o $@ $< $(LDFLAGS)
+
+clean:
+ -rm -f core *.o
+
+clobber: clean
+ -rm -f fbsql.so
diff --git a/fbsql.c b/fbsql.c
new file mode 100644
index 0000000..79ab165
--- /dev/null
+++ b/fbsql.c
@@ -0,0 +1,685 @@
+
+/* 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-diff
Expires
Mon, Jun 8, 09:03 (1 d, 14 h)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3792905
Default Alt Text
(23 KB)

Event Timeline

Nasqueron DevCentral · If it had been much bigger the moon would have had a core of ice. · Powered by Phabricator