*** empty log message ***

src/interfaces/odbc/windev/README.txt

-This directory is to save the changes about psqlodbc driver under
-win32 while the main development tree(the parent directory) is
-nearly freezed(i.e. during beta, a while after the release until
-the next branch is made etc). The changes would be reflected
-to the main directory later after all. However note that the
-trial binary version would be sometimes made using the source
-and put on the ftp server for download.
-
-	Hiroshi Inoue inoue@postgresql.org

src/interfaces/odbc/windev/bind.c

-/*-------
- * Module:			bind.c
- *
- * Description:		This module contains routines related to binding
- *					columns and parameters.
- *
- * Classes:			BindInfoClass, ParameterInfoClass
- *
- * API functions:	SQLBindParameter, SQLBindCol, SQLDescribeParam, SQLNumParams,
- *					SQLParamOptions(NI)
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *-------
- */
-
-#include "bind.h"
-
-#include "environ.h"
-#include "statement.h"
-#include "qresult.h"
-#include "pgtypes.h"
-#include <stdlib.h>
-#include <string.h>
-
-#include "pgapifunc.h"
-
-
-/*		Bind parameters on a statement handle */
-RETCODE		SQL_API
-PGAPI_BindParameter(
-					HSTMT hstmt,
-					UWORD ipar,
-					SWORD fParamType,
-					SWORD fCType,
-					SWORD fSqlType,
-					UDWORD cbColDef,
-					SWORD ibScale,
-					PTR rgbValue,
-					SDWORD cbValueMax,
-					SDWORD FAR * pcbValue)
-{
-	StatementClass *stmt = (StatementClass *) hstmt;
-	static char *func = "PGAPI_BindParameter";
-
-	mylog("%s: entering...\n", func);
-
-	if (!stmt)
-	{
-		SC_log_error(func, "", NULL);
-		return SQL_INVALID_HANDLE;
-	}
-	SC_clear_error(stmt);
-
-	if (stmt->parameters_allocated < ipar)
-	{
-		ParameterInfoClass *old_parameters;
-		int			i,
-					old_parameters_allocated;
-
-		old_parameters = stmt->parameters;
-		old_parameters_allocated = stmt->parameters_allocated;
-
-		stmt->parameters = (ParameterInfoClass *) malloc(sizeof(ParameterInfoClass) * (ipar));
-		if (!stmt->parameters)
-		{
-			stmt->errornumber = STMT_NO_MEMORY_ERROR;
-			stmt->errormsg = "Could not allocate memory for statement parameters";
-			SC_log_error(func, "", stmt);
-			return SQL_ERROR;
-		}
-
-		stmt->parameters_allocated = ipar;
-
-		/* copy the old parameters over */
-		for (i = 0; i < old_parameters_allocated; i++)
-		{
-			/* a structure copy should work */
-			stmt->parameters[i] = old_parameters[i];
-		}
-
-		/* get rid of the old parameters, if there were any */
-		if (old_parameters)
-			free(old_parameters);
-
-		/*
-		 * zero out the newly allocated parameters (in case they skipped
-		 * some,
-		 */
-		/* so we don't accidentally try to use them later) */
-		for (; i < stmt->parameters_allocated; i++)
-		{
-			stmt->parameters[i].buflen = 0;
-			stmt->parameters[i].buffer = 0;
-			stmt->parameters[i].used = 0;
-			stmt->parameters[i].paramType = 0;
-			stmt->parameters[i].CType = 0;
-			stmt->parameters[i].SQLType = 0;
-			stmt->parameters[i].precision = 0;
-			stmt->parameters[i].scale = 0;
-			stmt->parameters[i].data_at_exec = FALSE;
-			stmt->parameters[i].lobj_oid = 0;
-			stmt->parameters[i].EXEC_used = NULL;
-			stmt->parameters[i].EXEC_buffer = NULL;
-		}
-	}
-
-	/* use zero based column numbers for the below part */
-	ipar--;
-
-	/* store the given info */
-	stmt->parameters[ipar].buflen = cbValueMax;
-	stmt->parameters[ipar].buffer = rgbValue;
-	stmt->parameters[ipar].used = pcbValue;
-	stmt->parameters[ipar].paramType = fParamType;
-	stmt->parameters[ipar].CType = fCType;
-	stmt->parameters[ipar].SQLType = fSqlType;
-	stmt->parameters[ipar].precision = cbColDef;
-	stmt->parameters[ipar].scale = ibScale;
-
-	/*
-	 * If rebinding a parameter that had data-at-exec stuff in it, then
-	 * free that stuff
-	 */
-	if (stmt->parameters[ipar].EXEC_used)
-	{
-		free(stmt->parameters[ipar].EXEC_used);
-		stmt->parameters[ipar].EXEC_used = NULL;
-	}
-
-	if (stmt->parameters[ipar].EXEC_buffer)
-	{
-		if (stmt->parameters[ipar].SQLType != SQL_LONGVARBINARY)
-			free(stmt->parameters[ipar].EXEC_buffer);
-		stmt->parameters[ipar].EXEC_buffer = NULL;
-	}
-
-	/* Data at exec macro only valid for C char/binary data */
-	if (pcbValue && (*pcbValue == SQL_DATA_AT_EXEC ||
-					 *pcbValue <= SQL_LEN_DATA_AT_EXEC_OFFSET))
-		stmt->parameters[ipar].data_at_exec = TRUE;
-	else
-		stmt->parameters[ipar].data_at_exec = FALSE;
-
-	/* Clear premature result */
-	if (stmt->status == STMT_PREMATURE)
-		SC_recycle_statement(stmt);
-
-	mylog("PGAPI_BindParamater: ipar=%d, paramType=%d, fCType=%d, fSqlType=%d, cbColDef=%d, ibScale=%d, rgbValue=%d, *pcbValue = %d, data_at_exec = %d\n", ipar, fParamType, fCType, fSqlType, cbColDef, ibScale, rgbValue, pcbValue ? *pcbValue : -777, stmt->parameters[ipar].data_at_exec);
-
-	return SQL_SUCCESS;
-}
-
-
-/*	Associate a user-supplied buffer with a database column. */
-RETCODE		SQL_API
-PGAPI_BindCol(
-			  HSTMT hstmt,
-			  UWORD icol,
-			  SWORD fCType,
-			  PTR rgbValue,
-			  SDWORD cbValueMax,
-			  SDWORD FAR * pcbValue)
-{
-	StatementClass *stmt = (StatementClass *) hstmt;
-	static char *func = "PGAPI_BindCol";
-
-	mylog("%s: entering...\n", func);
-
-	mylog("**** PGAPI_BindCol: stmt = %u, icol = %d\n", stmt, icol);
-	mylog("**** : fCType=%d rgb=%x valusMax=%d pcb=%x\n", fCType, rgbValue, cbValueMax, pcbValue);
-
-	if (!stmt)
-	{
-		SC_log_error(func, "", NULL);
-		return SQL_INVALID_HANDLE;
-	}
-
-
-	SC_clear_error(stmt);
-
-	if (stmt->status == STMT_EXECUTING)
-	{
-		stmt->errormsg = "Can't bind columns while statement is still executing.";
-		stmt->errornumber = STMT_SEQUENCE_ERROR;
-		SC_log_error(func, "", stmt);
-		return SQL_ERROR;
-	}
-
-	/* If the bookmark column is being bound, then just save it */
-	if (icol == 0)
-	{
-		if (rgbValue == NULL)
-		{
-			stmt->bookmark.buffer = NULL;
-			stmt->bookmark.used = NULL;
-		}
-		else
-		{
-			/* Make sure it is the bookmark data type */
-			if (fCType != SQL_C_BOOKMARK)
-			{
-				stmt->errormsg = "Column 0 is not of type SQL_C_BOOKMARK";
-				stmt->errornumber = STMT_PROGRAM_TYPE_OUT_OF_RANGE;
-				SC_log_error(func, "", stmt);
-				return SQL_ERROR;
-			}
-
-			stmt->bookmark.buffer = rgbValue;
-			stmt->bookmark.used = pcbValue;
-		}
-		return SQL_SUCCESS;
-	}
-
-	/*
-	 * Allocate enough bindings if not already done. Most likely,
-	 * execution of a statement would have setup the necessary bindings.
-	 * But some apps call BindCol before any statement is executed.
-	 */
-	if (icol > stmt->bindings_allocated)
-		extend_bindings(stmt, icol);
-
-	/* check to see if the bindings were allocated */
-	if (!stmt->bindings)
-	{
-		stmt->errormsg = "Could not allocate memory for bindings.";
-		stmt->errornumber = STMT_NO_MEMORY_ERROR;
-		SC_log_error(func, "", stmt);
-		return SQL_ERROR;
-	}
-
-	/* use zero based col numbers from here out */
-	icol--;
-
-	/* Reset for SQLGetData */
-	stmt->bindings[icol].data_left = -1;
-
-	if (rgbValue == NULL)
-	{
-		/* we have to unbind the column */
-		stmt->bindings[icol].buflen = 0;
-		stmt->bindings[icol].buffer = NULL;
-		stmt->bindings[icol].used = NULL;
-		stmt->bindings[icol].returntype = SQL_C_CHAR;
-	}
-	else
-	{
-		/* ok, bind that column */
-		stmt->bindings[icol].buflen = cbValueMax;
-		stmt->bindings[icol].buffer = rgbValue;
-		stmt->bindings[icol].used = pcbValue;
-		stmt->bindings[icol].returntype = fCType;
-
-		mylog("       bound buffer[%d] = %u\n", icol, stmt->bindings[icol].buffer);
-	}
-
-	return SQL_SUCCESS;
-}
-
-
-/*
- *	Returns the description of a parameter marker.
- *	This function is listed as not being supported by SQLGetFunctions() because it is
- *	used to describe "parameter markers" (not bound parameters), in which case,
- *	the dbms should return info on the markers.  Since Postgres doesn't support that,
- *	it is best to say this function is not supported and let the application assume a
- *	data type (most likely varchar).
- */
-RETCODE		SQL_API
-PGAPI_DescribeParam(
-					HSTMT hstmt,
-					UWORD ipar,
-					SWORD FAR * pfSqlType,
-					UDWORD FAR * pcbColDef,
-					SWORD FAR * pibScale,
-					SWORD FAR * pfNullable)
-{
-	StatementClass *stmt = (StatementClass *) hstmt;
-	static char *func = "PGAPI_DescribeParam";
-
-	mylog("%s: entering...\n", func);
-
-	if (!stmt)
-	{
-		SC_log_error(func, "", NULL);
-		return SQL_INVALID_HANDLE;
-	}
-	SC_clear_error(stmt);
-
-	if ((ipar < 1) || (ipar > stmt->parameters_allocated))
-	{
-		stmt->errormsg = "Invalid parameter number for PGAPI_DescribeParam.";
-		stmt->errornumber = STMT_BAD_PARAMETER_NUMBER_ERROR;
-		SC_log_error(func, "", stmt);
-		return SQL_ERROR;
-	}
-
-	ipar--;
-
-	/*
-	 * This implementation is not very good, since it is supposed to
-	 * describe
-	 */
-	/* parameter markers, not bound parameters.  */
-	if (pfSqlType)
-		*pfSqlType = stmt->parameters[ipar].SQLType;
-
-	if (pcbColDef)
-		*pcbColDef = stmt->parameters[ipar].precision;
-
-	if (pibScale)
-		*pibScale = stmt->parameters[ipar].scale;
-
-	if (pfNullable)
-		*pfNullable = pgtype_nullable(stmt, stmt->parameters[ipar].paramType);
-
-	return SQL_SUCCESS;
-}
-
-
-/*	Sets multiple values (arrays) for the set of parameter markers. */
-RETCODE		SQL_API
-PGAPI_ParamOptions(
-				   HSTMT hstmt,
-				   UDWORD crow,
-				   UDWORD FAR * pirow)
-{
-	static char *func = "PGAPI_ParamOptions";
-	StatementClass *stmt = (StatementClass *) hstmt;
-
-	mylog("%s: entering... %d %x\n", func, crow, pirow);
-
-	if (crow == 1)				/* temporary solution and must be
-								 * rewritten later */
-	{
-		if (pirow)
-			*pirow = 1;
-		return SQL_SUCCESS;
-	}
-	stmt->errornumber = CONN_UNSUPPORTED_OPTION;
-	stmt->errormsg = "Function not implemented";
-	SC_log_error(func, "Function not implemented", (StatementClass *) hstmt);
-	return SQL_ERROR;
-}
-
-
-/*
- *	This function should really talk to the dbms to determine the number of
- *	"parameter markers" (not bound parameters) in the statement.  But, since
- *	Postgres doesn't support that, the driver should just count the number of markers
- *	and return that.  The reason the driver just can't say this function is unsupported
- *	like it does for SQLDescribeParam is that some applications don't care and try
- *	to call it anyway.
- *	If the statement does not have parameters, it should just return 0.
- */
-RETCODE		SQL_API
-PGAPI_NumParams(
-				HSTMT hstmt,
-				SWORD FAR * pcpar)
-{
-	StatementClass *stmt = (StatementClass *) hstmt;
-	char		in_quote = FALSE;
-	unsigned int i;
-	static char *func = "PGAPI_NumParams";
-
-	mylog("%s: entering...\n", func);
-
-	if (!stmt)
-	{
-		SC_log_error(func, "", NULL);
-		return SQL_INVALID_HANDLE;
-	}
-	SC_clear_error(stmt);
-
-	if (pcpar)
-		*pcpar = 0;
-	else
-	{
-		SC_log_error(func, "pcpar was null", stmt);
-		return SQL_ERROR;
-	}
-
-
-	if (!stmt->statement)
-	{
-		/* no statement has been allocated */
-		stmt->errormsg = "PGAPI_NumParams called with no statement ready.";
-		stmt->errornumber = STMT_SEQUENCE_ERROR;
-		SC_log_error(func, "", stmt);
-		return SQL_ERROR;
-	}
-	else
-	{
-		for (i = 0; i < strlen(stmt->statement); i++)
-		{
-			if (stmt->statement[i] == '?' && !in_quote)
-				(*pcpar)++;
-			else
-			{
-				if (stmt->statement[i] == '\'')
-					in_quote = (in_quote ? FALSE : TRUE);
-			}
-		}
-		return SQL_SUCCESS;
-	}
-}
-
-
-/*
- *	 Bindings Implementation
- */
-BindInfoClass *
-create_empty_bindings(int num_columns)
-{
-	BindInfoClass *new_bindings;
-	int			i;
-
-	new_bindings = (BindInfoClass *) malloc(num_columns * sizeof(BindInfoClass));
-	if (!new_bindings)
-		return 0;
-
-	for (i = 0; i < num_columns; i++)
-	{
-		new_bindings[i].buflen = 0;
-		new_bindings[i].buffer = NULL;
-		new_bindings[i].used = NULL;
-		new_bindings[i].data_left = -1;
-		new_bindings[i].ttlbuf = NULL;
-		new_bindings[i].ttlbuflen = 0;
-	}
-
-	return new_bindings;
-}
-
-
-void
-extend_bindings(StatementClass *stmt, int num_columns)
-{
-	static char *func = "extend_bindings";
-	BindInfoClass *new_bindings;
-	int			i;
-
-	mylog("%s: entering ... stmt=%u, bindings_allocated=%d, num_columns=%d\n", func, stmt, stmt->bindings_allocated, num_columns);
-
-	/*
-	 * if we have too few, allocate room for more, and copy the old
-	 * entries into the new structure
-	 */
-	if (stmt->bindings_allocated < num_columns)
-	{
-		new_bindings = create_empty_bindings(num_columns);
-		if (!new_bindings)
-		{
-			mylog("%s: unable to create %d new bindings from %d old bindings\n", func, num_columns, stmt->bindings_allocated);
-
-			if (stmt->bindings)
-			{
-				free(stmt->bindings);
-				stmt->bindings = NULL;
-			}
-			stmt->bindings_allocated = 0;
-			return;
-		}
-
-		if (stmt->bindings)
-		{
-			for (i = 0; i < stmt->bindings_allocated; i++)
-				new_bindings[i] = stmt->bindings[i];
-
-			free(stmt->bindings);
-		}
-
-		stmt->bindings = new_bindings;
-		stmt->bindings_allocated = num_columns;
-	}
-
-	/*
-	 * There is no reason to zero out extra bindings if there are more
-	 * than needed.  If an app has allocated extra bindings, let it worry
-	 * about it by unbinding those columns.
-	 */
-
-	/* SQLBindCol(1..) ... SQLBindCol(10...)   # got 10 bindings */
-	/* SQLExecDirect(...)  # returns 5 cols */
-	/* SQLExecDirect(...)  # returns 10 cols  (now OK) */
-
-	mylog("exit extend_bindings\n");
-}

src/interfaces/odbc/windev/bind.h

-/* File:			bind.h
- *
- * Description:		See "bind.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __BIND_H__
-#define __BIND_H__
-
-#include "psqlodbc.h"
-
-/*
- * BindInfoClass -- stores information about a bound column
- */
-struct BindInfoClass_
-{
-	Int4		buflen;			/* size of buffer */
-	Int4		data_left;		/* amount of data left to read
-								 * (SQLGetData) */
-	char	   *buffer;			/* pointer to the buffer */
-	Int4	   *used;			/* used space in the buffer (for strings
-								 * not counting the '\0') */
-	char	   *ttlbuf;			/* to save the large result */
-	Int4		ttlbuflen;		/* the buffer length */
-	Int2		returntype;		/* kind of conversion to be applied when
-								 * returning (SQL_C_DEFAULT,
-								 * SQL_C_CHAR...) */
-};
-
-/*
- * ParameterInfoClass -- stores information about a bound parameter
- */
-struct ParameterInfoClass_
-{
-	Int4		buflen;
-	char	   *buffer;
-	Int4	   *used;
-	Int2		paramType;
-	Int2		CType;
-	Int2		SQLType;
-	UInt4		precision;
-	Int2		scale;
-	Oid			lobj_oid;
-	Int4	   *EXEC_used;		/* amount of data OR the oid of the large
-								 * object */
-	char	   *EXEC_buffer;	/* the data or the FD of the large object */
-	char		data_at_exec;
-};
-
-BindInfoClass *create_empty_bindings(int num_columns);
-void		extend_bindings(StatementClass *stmt, int num_columns);
-
-#endif

src/interfaces/odbc/windev/columninfo.c

-/*-------
- * Module:			columninfo.c
- *
- * Description:		This module contains routines related to
- *					reading and storing the field information from a query.
- *
- * Classes:			ColumnInfoClass (Functions prefix: "CI_")
- *
- * API functions:	none
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *-------
- */
-
-#include "pgtypes.h"
-#include "columninfo.h"
-
-#include "connection.h"
-#include "socket.h"
-#include <stdlib.h>
-#include <string.h>
-#include "pgapifunc.h"
-
-ColumnInfoClass *
-CI_Constructor()
-{
-	ColumnInfoClass *rv;
-
-	rv = (ColumnInfoClass *) malloc(sizeof(ColumnInfoClass));
-
-	if (rv)
-	{
-		rv->num_fields = 0;
-		rv->name = NULL;
-		rv->adtid = NULL;
-		rv->adtsize = NULL;
-		rv->display_size = NULL;
-		rv->atttypmod = NULL;
-	}
-
-	return rv;
-}
-
-
-void
-CI_Destructor(ColumnInfoClass *self)
-{
-	CI_free_memory(self);
-
-	free(self);
-}
-
-
-/*
- *	Read in field descriptions.
- *	If self is not null, then also store the information.
- *	If self is null, then just read, don't store.
- */
-char
-CI_read_fields(ColumnInfoClass *self, ConnectionClass *conn)
-{
-	Int2		lf;
-	int			new_num_fields;
-	Oid			new_adtid;
-	Int2		new_adtsize;
-	Int4		new_atttypmod = -1;
-
-	/* MAX_COLUMN_LEN may be sufficient but for safety */
-	char		new_field_name[2 * MAX_COLUMN_LEN + 1];
-	SocketClass *sock;
-	ConnInfo   *ci;
-
-	sock = CC_get_socket(conn);
-	ci = &conn->connInfo;
-
-	/* at first read in the number of fields that are in the query */
-	new_num_fields = (Int2) SOCK_get_int(sock, sizeof(Int2));
-
-	mylog("num_fields = %d\n", new_num_fields);
-
-	if (self)
-		/* according to that allocate memory */
-		CI_set_num_fields(self, new_num_fields);
-
-	/* now read in the descriptions */
-	for (lf = 0; lf < new_num_fields; lf++)
-	{
-		SOCK_get_string(sock, new_field_name, 2 * MAX_COLUMN_LEN);
-		new_adtid = (Oid) SOCK_get_int(sock, 4);
-		new_adtsize = (Int2) SOCK_get_int(sock, 2);
-
-		/* If 6.4 protocol, then read the atttypmod field */
-		if (PG_VERSION_GE(conn, 6.4))
-		{
-			mylog("READING ATTTYPMOD\n");
-			new_atttypmod = (Int4) SOCK_get_int(sock, 4);
-
-			/* Subtract the header length */
-			switch (new_adtid)
-			{
-				case PG_TYPE_DATETIME:
-				case PG_TYPE_TIMESTAMP_NO_TMZONE:
-				case PG_TYPE_TIME:
-				case PG_TYPE_TIME_WITH_TMZONE:
-					break;
-				default:
-					new_atttypmod -= 4;
-			}
-			if (new_atttypmod < 0)
-				new_atttypmod = -1;
-
-		}
-
-		mylog("CI_read_fields: fieldname='%s', adtid=%d, adtsize=%d, atttypmod=%d\n", new_field_name, new_adtid, new_adtsize, new_atttypmod);
-
-		if (self)
-			CI_set_field_info(self, lf, new_field_name, new_adtid, new_adtsize, new_atttypmod);
-	}
-
-	return (SOCK_get_errcode(sock) == 0);
-}
-
-
-void
-CI_free_memory(ColumnInfoClass *self)
-{
-	register Int2 lf;
-	int			num_fields = self->num_fields;
-
-	for (lf = 0; lf < num_fields; lf++)
-	{
-		if (self->name[lf])
-		{
-			free(self->name[lf]);
-			self->name[lf] = NULL;
-		}
-	}
-
-	/* Safe to call even if null */
-	self->num_fields = 0;
-	if (self->name)
-		free(self->name);
-	self->name = NULL;
-	if (self->adtid)
-		free(self->adtid);
-	self->adtid = NULL;
-	if (self->adtsize)
-		free(self->adtsize);
-	self->adtsize = NULL;
-	if (self->display_size)
-		free(self->display_size);
-	self->display_size = NULL;
-
-	if (self->atttypmod)
-		free(self->atttypmod);
-	self->atttypmod = NULL;
-}
-
-
-void
-CI_set_num_fields(ColumnInfoClass *self, int new_num_fields)
-{
-	CI_free_memory(self);		/* always safe to call */
-
-	self->num_fields = new_num_fields;
-
-	self->name = (char **) malloc(sizeof(char *) * self->num_fields);
-	memset(self->name, 0, sizeof(char *) * self->num_fields);
-	self->adtid = (Oid *) malloc(sizeof(Oid) * self->num_fields);
-	self->adtsize = (Int2 *) malloc(sizeof(Int2) * self->num_fields);
-	self->display_size = (Int2 *) malloc(sizeof(Int2) * self->num_fields);
-	self->atttypmod = (Int4 *) malloc(sizeof(Int4) * self->num_fields);
-}
-
-
-void
-CI_set_field_info(ColumnInfoClass *self, int field_num, char *new_name,
-				  Oid new_adtid, Int2 new_adtsize, Int4 new_atttypmod)
-{
-	/* check bounds */
-	if ((field_num < 0) || (field_num >= self->num_fields))
-		return;
-
-	/* store the info */
-	self->name[field_num] = strdup(new_name);
-	self->adtid[field_num] = new_adtid;
-	self->adtsize[field_num] = new_adtsize;
-	self->atttypmod[field_num] = new_atttypmod;
-
-	self->display_size[field_num] = 0;
-}

src/interfaces/odbc/windev/columninfo.h

-/* File:			columninfo.h
- *
- * Description:		See "columninfo.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __COLUMNINFO_H__
-#define __COLUMNINFO_H__
-
-#include "psqlodbc.h"
-
-struct ColumnInfoClass_
-{
-	Int2		num_fields;
-	char	  **name;			/* list of type names */
-	Oid		   *adtid;			/* list of type ids */
-	Int2	   *adtsize;		/* list type sizes */
-	Int2	   *display_size;	/* the display size (longest row) */
-	Int4	   *atttypmod;		/* the length of bpchar/varchar */
-};
-
-#define CI_get_num_fields(self)			(self->num_fields)
-#define CI_get_oid(self, col)			(self->adtid[col])
-#define CI_get_fieldname(self, col)		(self->name[col])
-#define CI_get_fieldsize(self, col)		(self->adtsize[col])
-#define CI_get_display_size(self, col)	(self->display_size[col])
-#define CI_get_atttypmod(self, col)		(self->atttypmod[col])
-
-ColumnInfoClass *CI_Constructor(void);
-void		CI_Destructor(ColumnInfoClass *self);
-void		CI_free_memory(ColumnInfoClass *self);
-char		CI_read_fields(ColumnInfoClass *self, ConnectionClass *conn);
-
-/* functions for setting up the fields from within the program, */
-/* without reading from a socket */
-void		CI_set_num_fields(ColumnInfoClass *self, int new_num_fields);
-void CI_set_field_info(ColumnInfoClass *self, int field_num, char *new_name,
-				  Oid new_adtid, Int2 new_adtsize, Int4 atttypmod);
-
-#endif

src/interfaces/odbc/windev/connection.h

-/* File:			connection.h
- *
- * Description:		See "connection.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __CONNECTION_H__
-#define __CONNECTION_H__
-
-#include "psqlodbc.h"
-
-#include <stdlib.h>
-#include <string.h>
-
-
-typedef enum
-{
-	CONN_NOT_CONNECTED,			/* Connection has not been established */
-	CONN_CONNECTED,				/* Connection is up and has been
-								 * established */
-	CONN_DOWN,					/* Connection is broken */
-	CONN_EXECUTING				/* the connection is currently executing a
-								 * statement */
-} CONN_Status;
-
-/*	These errors have general sql error state */
-#define CONNECTION_SERVER_NOT_REACHED				101
-#define CONNECTION_MSG_TOO_LONG						103
-#define CONNECTION_COULD_NOT_SEND					104
-#define CONNECTION_NO_SUCH_DATABASE					105
-#define CONNECTION_BACKEND_CRAZY					106
-#define CONNECTION_NO_RESPONSE						107
-#define CONNECTION_SERVER_REPORTED_ERROR			108
-#define CONNECTION_COULD_NOT_RECEIVE				109
-#define CONNECTION_SERVER_REPORTED_WARNING			110
-#define CONNECTION_NEED_PASSWORD					112
-
-/*	These errors correspond to specific SQL states */
-#define CONN_INIREAD_ERROR							201
-#define CONN_OPENDB_ERROR							202
-#define CONN_STMT_ALLOC_ERROR						203
-#define CONN_IN_USE									204
-#define CONN_UNSUPPORTED_OPTION						205
-/* Used by SetConnectoption to indicate unsupported options */
-#define CONN_INVALID_ARGUMENT_NO					206
-/* SetConnectOption: corresponds to ODBC--"S1009" */
-#define CONN_TRANSACT_IN_PROGRES					207
-#define CONN_NO_MEMORY_ERROR						208
-#define CONN_NOT_IMPLEMENTED_ERROR					209
-#define CONN_INVALID_AUTHENTICATION					210
-#define CONN_AUTH_TYPE_UNSUPPORTED					211
-#define CONN_UNABLE_TO_LOAD_DLL						212
-
-#define CONN_OPTION_VALUE_CHANGED					213
-#define CONN_VALUE_OUT_OF_RANGE						214
-
-#define CONN_TRUNCATED								215
-
-/* Conn_status defines */
-#define CONN_IN_AUTOCOMMIT							0x01
-#define CONN_IN_TRANSACTION							0x02
-
-/* AutoCommit functions */
-#define CC_set_autocommit_off(x)	(x->transact_status &= ~CONN_IN_AUTOCOMMIT)
-#define CC_set_autocommit_on(x)		(x->transact_status |= CONN_IN_AUTOCOMMIT)
-#define CC_is_in_autocommit(x)		(x->transact_status & CONN_IN_AUTOCOMMIT)
-
-/* Transaction in/not functions */
-#define CC_set_in_trans(x)	(x->transact_status |= CONN_IN_TRANSACTION)
-#define CC_set_no_trans(x)	(x->transact_status &= ~CONN_IN_TRANSACTION)
-#define CC_is_in_trans(x)	(x->transact_status & CONN_IN_TRANSACTION)
-
-
-/* Authentication types */
-#define AUTH_REQ_OK									0
-#define AUTH_REQ_KRB4								1
-#define AUTH_REQ_KRB5								2
-#define AUTH_REQ_PASSWORD							3
-#define AUTH_REQ_CRYPT								4
-#define AUTH_REQ_MD5								5
-#define AUTH_REQ_SCM_CREDS							6
-
-/*	Startup Packet sizes */
-#define SM_DATABASE									64
-#define SM_USER										32
-#define SM_OPTIONS									64
-#define SM_UNUSED									64
-#define SM_TTY										64
-
-/*	Old 6.2 protocol defines */
-#define NO_AUTHENTICATION							7
-#define PATH_SIZE									64
-#define ARGV_SIZE									64
-#define NAMEDATALEN									16
-
-typedef unsigned int ProtocolVersion;
-
-#define PG_PROTOCOL(major, minor)	(((major) << 16) | (minor))
-#define PG_PROTOCOL_LATEST							PG_PROTOCOL(2, 0)
-#define PG_PROTOCOL_63								PG_PROTOCOL(1, 0)
-#define PG_PROTOCOL_62								PG_PROTOCOL(0, 0)
-
-/*	This startup packet is to support latest Postgres protocol (6.4, 6.3) */
-typedef struct _StartupPacket
-{
-	ProtocolVersion protoVersion;
-	char		database[SM_DATABASE];
-	char		user[SM_USER];
-	char		options[SM_OPTIONS];
-	char		unused[SM_UNUSED];
-	char		tty[SM_TTY];
-} StartupPacket;
-
-
-/*	This startup packet is to support pre-Postgres 6.3 protocol */
-typedef struct _StartupPacket6_2
-{
-	unsigned int authtype;
-	char		database[PATH_SIZE];
-	char		user[NAMEDATALEN];
-	char		options[ARGV_SIZE];
-	char		execfile[ARGV_SIZE];
-	char		tty[PATH_SIZE];
-} StartupPacket6_2;
-
-
-/*	Structure to hold all the connection attributes for a specific
-	connection (used for both registry and file, DSN and DRIVER)
-*/
-typedef struct
-{
-	char		dsn[MEDIUM_REGISTRY_LEN];
-	char		desc[MEDIUM_REGISTRY_LEN];
-	char		driver[MEDIUM_REGISTRY_LEN];
-	char		server[MEDIUM_REGISTRY_LEN];
-	char		database[MEDIUM_REGISTRY_LEN];
-	char		username[MEDIUM_REGISTRY_LEN];
-	char		password[MEDIUM_REGISTRY_LEN];
-	char		conn_settings[LARGE_REGISTRY_LEN];
-	char		protocol[SMALL_REGISTRY_LEN];
-	char		port[SMALL_REGISTRY_LEN];
-	char		onlyread[SMALL_REGISTRY_LEN];
-	char		fake_oid_index[SMALL_REGISTRY_LEN];
-	char		show_oid_column[SMALL_REGISTRY_LEN];
-	char		row_versioning[SMALL_REGISTRY_LEN];
-	char		show_system_tables[SMALL_REGISTRY_LEN];
-	char		translation_dll[MEDIUM_REGISTRY_LEN];
-	char		translation_option[SMALL_REGISTRY_LEN];
-	char		focus_password;
-	char		disallow_premature;
-	char		updatable_cursors;
-	GLOBAL_VALUES drivers;		/* moved from driver's option */
-} ConnInfo;
-
-/*	Macro to determine is the connection using 6.2 protocol? */
-#define PROTOCOL_62(conninfo_)		(strncmp((conninfo_)->protocol, PG62, strlen(PG62)) == 0)
-
-/*	Macro to determine is the connection using 6.3 protocol? */
-#define PROTOCOL_63(conninfo_)		(strncmp((conninfo_)->protocol, PG63, strlen(PG63)) == 0)
-
-/*
- *	Macros to compare the server's version with a specified version
- *		1st parameter: pointer to a ConnectionClass object
- *		2nd parameter: major version number
- *		3rd parameter: minor version number
- */
-#define SERVER_VERSION_GT(conn, major, minor) \
-	((conn)->pg_version_major > major || \
-	((conn)->pg_version_major == major && (conn)->pg_version_minor > minor))
-#define SERVER_VERSION_GE(conn, major, minor) \
-	((conn)->pg_version_major > major || \
-	((conn)->pg_version_major == major && (conn)->pg_version_minor >= minor))
-#define SERVER_VERSION_EQ(conn, major, minor) \
-	((conn)->pg_version_major == major && (conn)->pg_version_minor == minor)
-#define SERVER_VERSION_LE(conn, major, minor) (! SERVER_VERSION_GT(conn, major, minor))
-#define SERVER_VERSION_LT(conn, major, minor) (! SERVER_VERSION_GE(conn, major, minor))
-/*#if ! defined(HAVE_CONFIG_H) || defined(HAVE_STRINGIZE)*/
-#define STRING_AFTER_DOT(string)	(strchr(#string, '.') + 1)
-/*#else
-#define STRING_AFTER_DOT(str)	(strchr("str", '.') + 1)
-#endif*/
-/*
- *	Simplified macros to compare the server's version with a
- *		specified version
- *	Note: Never pass a variable as the second parameter.
- *		  It must be a decimal constant of the form %d.%d .
- */
-#define PG_VERSION_GT(conn, ver) \
- (SERVER_VERSION_GT(conn, (int) ver, atoi(STRING_AFTER_DOT(ver))))
-#define PG_VERSION_GE(conn, ver) \
- (SERVER_VERSION_GE(conn, (int) ver, atoi(STRING_AFTER_DOT(ver))))
-#define PG_VERSION_EQ(conn, ver) \
- (SERVER_VERSION_EQ(conn, (int) ver, atoi(STRING_AFTER_DOT(ver))))
-#define PG_VERSION_LE(conn, ver) (! PG_VERSION_GT(conn, ver))
-#define PG_VERSION_LT(conn, ver) (! PG_VERSION_GE(conn, ver))
-
-/*	This is used to store cached table information in the connection */
-struct col_info
-{
-	QResultClass *result;
-	char		name[MAX_TABLE_LEN + 1];
-};
-
- /* Translation DLL entry points */
-#ifdef WIN32
-#define DLLHANDLE HINSTANCE
-#else
-#define WINAPI CALLBACK
-#define DLLHANDLE void *
-#define HINSTANCE void *
-#endif
-
-typedef BOOL (FAR WINAPI * DataSourceToDriverProc) (UDWORD,
-																SWORD,
-																PTR,
-																SDWORD,
-																PTR,
-																SDWORD,
-															SDWORD FAR *,
-															 UCHAR FAR *,
-																SWORD,
-															SWORD FAR *);
-
-typedef BOOL (FAR WINAPI * DriverToDataSourceProc) (UDWORD,
-																SWORD,
-																PTR,
-																SDWORD,
-																PTR,
-																SDWORD,
-															SDWORD FAR *,
-															 UCHAR FAR *,
-																SWORD,
-															SWORD FAR *);
-
-/*******	The Connection handle	************/
-struct ConnectionClass_
-{
-	HENV		henv;			/* environment this connection was created
-								 * on */
-	StatementOptions stmtOptions;
-	char	   *errormsg;
-	int			errornumber;
-	CONN_Status status;
-	ConnInfo	connInfo;
-	StatementClass **stmts;
-	int			num_stmts;
-	SocketClass *sock;
-	int			lobj_type;
-	int			ntables;
-	COL_INFO  **col_info;
-	long		translation_option;
-	HINSTANCE	translation_handle;
-	DataSourceToDriverProc DataSourceToDriver;
-	DriverToDataSourceProc DriverToDataSource;
-	Int2		driver_version; /* prepared for ODBC3.0 */
-	char		transact_status;/* Is a transaction is currently in
-								 * progress */
-	char		errormsg_created;		/* has an informative error msg
-										 * been created?  */
-	char		pg_version[MAX_INFO_STRING];	/* Version of PostgreSQL
-												 * we're connected to -
-												 * DJP 25-1-2001 */
-	float		pg_version_number;
-	Int2		pg_version_major;
-	Int2		pg_version_minor;
-	char		ms_jet;
-#ifdef	MULTIBYTE
-	char	   *client_encoding;
-	char	   *server_encoding;
-#endif   /* MULTIBYTE */
-};
-
-
-/* Accessor functions */
-#define CC_get_socket(x)					(x->sock)
-#define CC_get_database(x)					(x->connInfo.database)
-#define CC_get_server(x)					(x->connInfo.server)
-#define CC_get_DSN(x)						(x->connInfo.dsn)
-#define CC_get_username(x)					(x->connInfo.username)
-#define CC_is_onlyread(x)					(x->connInfo.onlyread[0] == '1')
-
-
-/*	for CC_DSN_info */
-#define CONN_DONT_OVERWRITE		0
-#define CONN_OVERWRITE			1
-
-
-/*	prototypes */
-ConnectionClass *CC_Constructor(void);
-char		CC_Destructor(ConnectionClass *self);
-int			CC_cursor_count(ConnectionClass *self);
-char		CC_cleanup(ConnectionClass *self);
-char		CC_abort(ConnectionClass *self);
-int			CC_set_translation(ConnectionClass *self);
-char		CC_connect(ConnectionClass *self, char do_password);
-char		CC_add_statement(ConnectionClass *self, StatementClass *stmt);
-char		CC_remove_statement(ConnectionClass *self, StatementClass *stmt);
-char		CC_get_error(ConnectionClass *self, int *number, char **message);
-QResultClass *CC_send_query(ConnectionClass *self, char *query, QueryInfo *qi);
-void		CC_clear_error(ConnectionClass *self);
-char	   *CC_create_errormsg(ConnectionClass *self);
-int			CC_send_function(ConnectionClass *conn, int fnid, void *result_buf, int *actual_result_len, int result_is_int, LO_ARG *argv, int nargs);
-char		CC_send_settings(ConnectionClass *self);
-void		CC_lookup_lo(ConnectionClass *conn);
-void		CC_lookup_pg_version(ConnectionClass *conn);
-void		CC_initialize_pg_version(ConnectionClass *conn);
-void		CC_log_error(char *func, char *desc, ConnectionClass *self);
-int			CC_get_max_query_len(const ConnectionClass *self);
-
-#endif

src/interfaces/odbc/windev/convert.h

-/* File:			convert.h
- *
- * Description:		See "convert.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __CONVERT_H__
-#define __CONVERT_H__
-
-#include "psqlodbc.h"
-
-/* copy_and_convert results */
-#define COPY_OK							0
-#define COPY_UNSUPPORTED_TYPE					1
-#define COPY_UNSUPPORTED_CONVERSION				2
-#define COPY_RESULT_TRUNCATED					3
-#define COPY_GENERAL_ERROR						4
-#define COPY_NO_DATA_FOUND						5
-
-typedef struct
-{
-	int			m;
-	int			d;
-	int			y;
-	int			hh;
-	int			mm;
-	int			ss;
-	int			fr;
-} SIMPLE_TIME;
-
-int			copy_and_convert_field_bindinfo(StatementClass *stmt, Int4 field_type, void *value, int col);
-int copy_and_convert_field(StatementClass *stmt, Int4 field_type, void *value, Int2 fCType,
-					   PTR rgbValue, SDWORD cbValueMax, SDWORD *pcbValue);
-
-int			copy_statement_with_parameters(StatementClass *stmt);
-char	   *convert_escape(char *value);
-BOOL		convert_money(const char *s, char *sout, size_t soutmax);
-char		parse_datetime(char *buf, SIMPLE_TIME *st);
-int			convert_linefeeds(const char *s, char *dst, size_t max, BOOL *changed);
-int			convert_special_chars(const char *si, char *dst, int used);
-
-int			convert_pgbinary_to_char(const char *value, char *rgbValue, int cbValueMax);
-int			convert_from_pgbinary(const unsigned char *value, unsigned char *rgbValue, int cbValueMax);
-int			convert_to_pgbinary(const unsigned char *in, char *out, int len);
-void		encode(const char *in, char *out);
-void		decode(const char *in, char *out);
-int convert_lo(StatementClass *stmt, const void *value, Int2 fCType, PTR rgbValue,
-		   SDWORD cbValueMax, SDWORD *pcbValue);
-
-#endif

src/interfaces/odbc/windev/dlg_specific.h

-/* File:			dlg_specific.h
- *
- * Description:		See "dlg_specific.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __DLG_SPECIFIC_H__
-#define __DLG_SPECIFIC_H__
-
-#include "psqlodbc.h"
-#include "connection.h"
-
-#ifdef WIN32
-#include  <windowsx.h>
-#include "resource.h"
-#endif
-
-/*	Unknown data type sizes */
-#define UNKNOWNS_AS_MAX					0
-#define UNKNOWNS_AS_DONTKNOW			1
-#define UNKNOWNS_AS_LONGEST				2
-
-/* ODBC initialization files */
-#ifndef WIN32
-#define ODBC_INI						".odbc.ini"
-#define ODBCINST_INI					"odbcinst.ini"
-#else
-#define ODBC_INI						"ODBC.INI"
-#define ODBCINST_INI					"ODBCINST.INI"
-#endif
-
-
-#define INI_DSN							DBMS_NAME		/* Name of default
-														 * Datasource in ini
-														 * file (not used?) */
-#define INI_KDESC						"Description"	/* Data source
-														 * description */
-#define INI_SERVER						"Servername"	/* Name of Server
-														 * running the Postgres
-														 * service */
-#define INI_PORT						"Port"	/* Port on which the
-												 * Postmaster is listening */
-#define INI_DATABASE					"Database"		/* Database Name */
-#define INI_USER						"Username"		/* Default User Name */
-#define INI_PASSWORD					"Password"		/* Default Password */
-#define INI_DEBUG						"Debug" /* Debug flag */
-#define INI_FETCH						"Fetch" /* Fetch Max Count */
-#define INI_SOCKET						"Socket"		/* Socket buffer size */
-#define INI_READONLY					"ReadOnly"		/* Database is read only */
-#define INI_COMMLOG						"CommLog"		/* Communication to
-														 * backend logging */
-#define INI_PROTOCOL					"Protocol"		/* What protocol (6.2) */
-#define INI_OPTIMIZER					"Optimizer"		/* Use backend genetic
-														 * optimizer */
-#define INI_KSQO						"Ksqo"	/* Keyset query
-												 * optimization */
-#define INI_CONNSETTINGS				 "ConnSettings" /* Anything to send to
-														 * backend on successful
-														 * connection */
-#define INI_UNIQUEINDEX					"UniqueIndex"	/* Recognize unique
-														 * indexes */
-#define INI_UNKNOWNSIZES				"UnknownSizes"	/* How to handle unknown
-														 * result set sizes */
-
-#define INI_CANCELASFREESTMT			"CancelAsFreeStmt"
-
-#define INI_USEDECLAREFETCH				"UseDeclareFetch"		/* Use Declare/Fetch
-																 * cursors */
-
-/*	More ini stuff */
-#define INI_TEXTASLONGVARCHAR			"TextAsLongVarchar"
-#define INI_UNKNOWNSASLONGVARCHAR		"UnknownsAsLongVarchar"
-#define INI_BOOLSASCHAR					"BoolsAsChar"
-#define INI_MAXVARCHARSIZE				"MaxVarcharSize"
-#define INI_MAXLONGVARCHARSIZE			"MaxLongVarcharSize"
-
-#define INI_FAKEOIDINDEX				"FakeOidIndex"
-#define INI_SHOWOIDCOLUMN				"ShowOidColumn"
-#define INI_ROWVERSIONING				"RowVersioning"
-#define INI_SHOWSYSTEMTABLES			"ShowSystemTables"
-#define INI_LIE							"Lie"
-#define INI_PARSE						"Parse"
-#define INI_EXTRASYSTABLEPREFIXES		"ExtraSysTablePrefixes"
-
-#define INI_TRANSLATIONNAME				"TranslationName"
-#define INI_TRANSLATIONDLL				"TranslationDLL"
-#define INI_TRANSLATIONOPTION			"TranslationOption"
-#define INI_DISALLOWPREMATURE			"DisallowPremature"
-#define INI_UPDATABLECURSORS			"UpdatableCursors"
-
-
-/*	Connection Defaults */
-#define DEFAULT_PORT					"5432"
-#define DEFAULT_READONLY				0
-#define DEFAULT_PROTOCOL				"6.4"	/* the latest protocol is
-												 * the default */
-#define DEFAULT_USEDECLAREFETCH			0
-#define DEFAULT_TEXTASLONGVARCHAR		1
-#define DEFAULT_UNKNOWNSASLONGVARCHAR	0
-#define DEFAULT_BOOLSASCHAR				1
-#define DEFAULT_OPTIMIZER				1		/* disable */
-#define DEFAULT_KSQO					1		/* on */
-#define DEFAULT_UNIQUEINDEX				1		/* dont recognize */
-#define DEFAULT_COMMLOG					0		/* dont log */
-#define DEFAULT_DEBUG					0
-#define DEFAULT_UNKNOWNSIZES			UNKNOWNS_AS_MAX
-
-
-#define DEFAULT_FAKEOIDINDEX			0
-#define DEFAULT_SHOWOIDCOLUMN			0
-#define DEFAULT_ROWVERSIONING			0
-#define DEFAULT_SHOWSYSTEMTABLES		0		/* dont show system tables */
-#define DEFAULT_LIE						0
-#define DEFAULT_PARSE					0
-
-#define DEFAULT_CANCELASFREESTMT		0
-
-#define DEFAULT_EXTRASYSTABLEPREFIXES	"dd_;"
-
-/*	prototypes */
-void		getCommonDefaults(const char *section, const char *filename, ConnInfo *ci);
-
-#ifdef WIN32
-void		SetDlgStuff(HWND hdlg, const ConnInfo *ci);
-void		GetDlgStuff(HWND hdlg, ConnInfo *ci);
-
-int CALLBACK driver_optionsProc(HWND hdlg,
-				   WORD wMsg,
-				   WPARAM wParam,
-				   LPARAM lParam);
-int CALLBACK ds_optionsProc(HWND hdlg,
-			   WORD wMsg,
-			   WPARAM wParam,
-			   LPARAM lParam);
-#endif   /* WIN32 */
-
-void		updateGlobals(void);
-void		writeDSNinfo(const ConnInfo *ci);
-void		getDSNdefaults(ConnInfo *ci);
-void		getDSNinfo(ConnInfo *ci, char overwrite);
-void		makeConnectString(char *connect_string, const ConnInfo *ci, UWORD);
-void		copyAttributes(ConnInfo *ci, const char *attribute, const char *value);
-void		copyCommonAttributes(ConnInfo *ci, const char *attribute, const char *value);
-
-#endif

src/interfaces/odbc/windev/drvconn.c

-/*-------
-  Module:			drvconn.c
- *
- * Description:		This module contains only routines related to
- *					implementing SQLDriverConnect.
- *
- * Classes:			n/a
- *
- * API functions:	SQLDriverConnect
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *-------
- */
-
-#include "psqlodbc.h"
-
-#include <stdio.h>
-#include <stdlib.h>
-
-#include "connection.h"
-
-#ifndef WIN32
-#include <sys/types.h>
-#include <sys/socket.h>
-#define NEAR
-#else
-#include <winsock.h>
-#endif
-
-#include <string.h>
-
-#ifdef WIN32
-#include <windowsx.h>
-#include "resource.h"
-#endif
-#include "pgapifunc.h"
-
-#ifndef TRUE
-#define TRUE	(BOOL)1
-#endif
-#ifndef FALSE
-#define FALSE	(BOOL)0
-#endif
-
-#include "dlg_specific.h"
-
-/* prototypes */
-void		dconn_get_connect_attributes(const UCHAR FAR * connect_string, ConnInfo *ci);
-static void dconn_get_common_attributes(const UCHAR FAR * connect_string, ConnInfo *ci);
-
-#ifdef WIN32
-BOOL FAR PASCAL dconn_FDriverConnectProc(HWND hdlg, UINT wMsg, WPARAM wParam, LPARAM lParam);
-RETCODE		dconn_DoDialog(HWND hwnd, ConnInfo *ci);
-
-extern HINSTANCE NEAR s_hModule;	/* Saved module handle. */
-#endif
-
-
-RETCODE		SQL_API
-PGAPI_DriverConnect(
-					HDBC hdbc,
-					HWND hwnd,
-					UCHAR FAR * szConnStrIn,
-					SWORD cbConnStrIn,
-					UCHAR FAR * szConnStrOut,
-					SWORD cbConnStrOutMax,
-					SWORD FAR * pcbConnStrOut,
-					UWORD fDriverCompletion)
-{
-	static char *func = "PGAPI_DriverConnect";
-	ConnectionClass *conn = (ConnectionClass *) hdbc;
-	ConnInfo   *ci;
-
-#ifdef WIN32
-	RETCODE		dialog_result;
-#endif
-	RETCODE		result;
-	char		connStrIn[MAX_CONNECT_STRING];
-	char		connStrOut[MAX_CONNECT_STRING];
-	int			retval;
-	char		password_required = FALSE;
-	int			len = 0;
-	SWORD		lenStrout;
-
-
-	mylog("%s: entering...\n", func);
-
-	if (!conn)
-	{
-		CC_log_error(func, "", NULL);
-		return SQL_INVALID_HANDLE;
-	}
-
-	make_string(szConnStrIn, cbConnStrIn, connStrIn);
-
-	mylog("**** PGAPI_DriverConnect: fDriverCompletion=%d, connStrIn='%s'\n", fDriverCompletion, connStrIn);
-	qlog("conn=%u, PGAPI_DriverConnect( in)='%s', fDriverCompletion=%d\n", conn, connStrIn, fDriverCompletion);
-
-	ci = &(conn->connInfo);
-
-	/* Parse the connect string and fill in conninfo for this hdbc. */
-	dconn_get_connect_attributes(connStrIn, ci);
-
-	/*
-	 * If the ConnInfo in the hdbc is missing anything, this function will
-	 * fill them in from the registry (assuming of course there is a DSN
-	 * given -- if not, it does nothing!)
-	 */
-	getDSNinfo(ci, CONN_DONT_OVERWRITE);
-	dconn_get_common_attributes(connStrIn, ci);
-	logs_on_off(1, ci->drivers.debug, ci->drivers.commlog);
-
-	/* Fill in any default parameters if they are not there. */
-	getDSNdefaults(ci);
-	/* initialize pg_version */
-	CC_initialize_pg_version(conn);
-
-#ifdef WIN32
-dialog:
-#endif
-	ci->focus_password = password_required;
-
-	switch (fDriverCompletion)
-	{
-#ifdef WIN32
-		case SQL_DRIVER_PROMPT:
-			dialog_result = dconn_DoDialog(hwnd, ci);
-			if (dialog_result != SQL_SUCCESS)
-				return dialog_result;
-			break;
-
-		case SQL_DRIVER_COMPLETE_REQUIRED:
-
-			/* Fall through */
-
-		case SQL_DRIVER_COMPLETE:
-
-			/* Password is not a required parameter. */
-			if (ci->username[0] == '\0' ||
-				ci->server[0] == '\0' ||
-				ci->database[0] == '\0' ||
-				ci->port[0] == '\0' ||
-				password_required)
-			{
-				dialog_result = dconn_DoDialog(hwnd, ci);
-				if (dialog_result != SQL_SUCCESS)
-					return dialog_result;
-			}
-			break;
-#else
-		case SQL_DRIVER_PROMPT:
-		case SQL_DRIVER_COMPLETE:
-		case SQL_DRIVER_COMPLETE_REQUIRED:
-#endif
-		case SQL_DRIVER_NOPROMPT:
-			break;
-	}
-
-	/*
-	 * Password is not a required parameter unless authentication asks for
-	 * it. For now, I think it's better to just let the application ask
-	 * over and over until a password is entered (the user can always hit
-	 * Cancel to get out)
-	 */
-	if (ci->username[0] == '\0' ||
-		ci->server[0] == '\0' ||
-		ci->database[0] == '\0' ||
-		ci->port[0] == '\0')
-	{
-		/* (password_required && ci->password[0] == '\0')) */
-
-		return SQL_NO_DATA_FOUND;
-	}
-
-	/* do the actual connect */
-	retval = CC_connect(conn, password_required);
-	if (retval < 0)
-	{							/* need a password */
-		if (fDriverCompletion == SQL_DRIVER_NOPROMPT)
-		{
-			CC_log_error(func, "Need password but Driver_NoPrompt", conn);
-			return SQL_ERROR;	/* need a password but not allowed to
-								 * prompt so error */
-		}
-		else
-		{
-#ifdef WIN32
-			password_required = TRUE;
-			goto dialog;
-#else
-			return SQL_ERROR;	/* until a better solution is found. */
-#endif
-		}
-	}
-	else if (retval == 0)
-	{
-		/* error msg filled in above */
-		CC_log_error(func, "Error from CC_Connect", conn);
-		return SQL_ERROR;
-	}
-
-	/*
-	 * Create the Output Connection String
-	 */
-	result = SQL_SUCCESS;
-
-	lenStrout = cbConnStrOutMax;
-	if (conn->ms_jet && lenStrout > 255)
-		lenStrout = 255;
-	makeConnectString(connStrOut, ci, lenStrout);
-	len = strlen(connStrOut);
-
-	if (szConnStrOut)
-	{
-		/*
-		 * Return the completed string to the caller. The correct method
-		 * is to only construct the connect string if a dialog was put up,
-		 * otherwise, it should just copy the connection input string to
-		 * the output. However, it seems ok to just always construct an
-		 * output string.  There are possible bad side effects on working
-		 * applications (Access) by implementing the correct behavior,
-		 * anyway.
-		 */
-		strncpy_null(szConnStrOut, connStrOut, cbConnStrOutMax);
-
-		if (len >= cbConnStrOutMax)
-		{
-			int			clen;
-
-			for (clen = strlen(szConnStrOut) - 1; clen >= 0 && szConnStrOut[clen] != ';'; clen--)
-				szConnStrOut[clen] = '\0';
-			result = SQL_SUCCESS_WITH_INFO;
-			conn->errornumber = CONN_TRUNCATED;
-			conn->errormsg = "The buffer was too small for the ConnStrOut.";
-		}
-	}
-
-	if (pcbConnStrOut)
-		*pcbConnStrOut = len;
-
-	mylog("szConnStrOut = '%s' len=%d,%d\n", szConnStrOut, len, cbConnStrOutMax);
-	qlog("conn=%u, PGAPI_DriverConnect(out)='%s'\n", conn, szConnStrOut);
-
-
-	mylog("PGAPI_DRiverConnect: returning %d\n", result);
-	return result;
-}
-
-
-#ifdef WIN32
-RETCODE
-dconn_DoDialog(HWND hwnd, ConnInfo *ci)
-{
-	int			dialog_result;
-
-	mylog("dconn_DoDialog: ci = %u\n", ci);
-
-	if (hwnd)
-	{
-		dialog_result = DialogBoxParam(s_hModule, MAKEINTRESOURCE(DLG_CONFIG),
-							hwnd, dconn_FDriverConnectProc, (LPARAM) ci);
-		if (!dialog_result || (dialog_result == -1))
-			return SQL_NO_DATA_FOUND;
-		else
-			return SQL_SUCCESS;
-	}
-
-	return SQL_ERROR;
-}
-
-
-BOOL FAR	PASCAL
-dconn_FDriverConnectProc(
-						 HWND hdlg,
-						 UINT wMsg,
-						 WPARAM wParam,
-						 LPARAM lParam)
-{
-	ConnInfo   *ci;
-
-	switch (wMsg)
-	{
-		case WM_INITDIALOG:
-			ci = (ConnInfo *) lParam;
-
-			/* Change the caption for the setup dialog */
-			SetWindowText(hdlg, "PostgreSQL Connection");
-
-			SetWindowText(GetDlgItem(hdlg, IDC_DATASOURCE), "Connection");
-
-			/* Hide the DSN and description fields */
-			ShowWindow(GetDlgItem(hdlg, IDC_DSNAMETEXT), SW_HIDE);
-			ShowWindow(GetDlgItem(hdlg, IDC_DSNAME), SW_HIDE);
-			ShowWindow(GetDlgItem(hdlg, IDC_DESCTEXT), SW_HIDE);
-			ShowWindow(GetDlgItem(hdlg, IDC_DESC), SW_HIDE);
-
-			SetWindowLong(hdlg, DWL_USER, lParam);		/* Save the ConnInfo for
-														 * the "OK" */
-			SetDlgStuff(hdlg, ci);
-
-			if (ci->database[0] == '\0')
-				;				/* default focus */
-			else if (ci->server[0] == '\0')
-				SetFocus(GetDlgItem(hdlg, IDC_SERVER));
-			else if (ci->port[0] == '\0')
-				SetFocus(GetDlgItem(hdlg, IDC_PORT));
-			else if (ci->username[0] == '\0')
-				SetFocus(GetDlgItem(hdlg, IDC_USER));
-			else if (ci->focus_password)
-				SetFocus(GetDlgItem(hdlg, IDC_PASSWORD));
-			break;
-
-		case WM_COMMAND:
-			switch (GET_WM_COMMAND_ID(wParam, lParam))
-			{
-				case IDOK:
-					ci = (ConnInfo *) GetWindowLong(hdlg, DWL_USER);
-
-					GetDlgStuff(hdlg, ci);
-
-				case IDCANCEL:
-					EndDialog(hdlg, GET_WM_COMMAND_ID(wParam, lParam) == IDOK);
-					return TRUE;
-
-				case IDC_DRIVER:
-					ci = (ConnInfo *) GetWindowLong(hdlg, DWL_USER);
-					DialogBoxParam(s_hModule, MAKEINTRESOURCE(DLG_OPTIONS_DRV),
-								   hdlg, driver_optionsProc, (LPARAM) ci);
-					break;
-
-				case IDC_DATASOURCE:
-					ci = (ConnInfo *) GetWindowLong(hdlg, DWL_USER);
-					DialogBoxParam(s_hModule, MAKEINTRESOURCE(DLG_OPTIONS_DS),
-								   hdlg, ds_optionsProc, (LPARAM) ci);
-					break;
-			}
-	}
-
-	return FALSE;
-}
-#endif   /* WIN32 */
-
-
-void
-dconn_get_connect_attributes(const UCHAR FAR * connect_string, ConnInfo *ci)
-{
-	char	   *our_connect_string;
-	char	   *pair,
-			   *attribute,
-			   *value,
-			   *equals;
-	char	   *strtok_arg;
-
-	memset(ci, 0, sizeof(ConnInfo));
-#ifdef	DRIVER_CURSOR_IMPLEMENT
-	ci->updatable_cursors = 1;
-#endif   /* DRIVER_CURSOR_IMPLEMENT */
-
-	our_connect_string = strdup(connect_string);
-	strtok_arg = our_connect_string;
-
-	mylog("our_connect_string = '%s'\n", our_connect_string);
-
-	while (1)
-	{
-		pair = strtok(strtok_arg, ";");
-		if (strtok_arg)
-			strtok_arg = 0;
-		if (!pair)
-			break;
-
-		equals = strchr(pair, '=');
-		if (!equals)
-			continue;
-
-		*equals = '\0';
-		attribute = pair;		/* ex. DSN */
-		value = equals + 1;		/* ex. 'CEO co1' */
-
-		mylog("attribute = '%s', value = '%s'\n", attribute, value);
-
-		if (!attribute || !value)
-			continue;
-
-		/* Copy the appropriate value to the conninfo  */
-		copyAttributes(ci, attribute, value);
-
-	}
-
-	free(our_connect_string);
-}
-
-static void
-dconn_get_common_attributes(const UCHAR FAR * connect_string, ConnInfo *ci)
-{
-	char	   *our_connect_string;
-	char	   *pair,
-			   *attribute,
-			   *value,
-			   *equals;
-	char	   *strtok_arg;
-
-	our_connect_string = strdup(connect_string);
-	strtok_arg = our_connect_string;
-
-	mylog("our_connect_string = '%s'\n", our_connect_string);
-
-	while (1)
-	{
-		pair = strtok(strtok_arg, ";");
-		if (strtok_arg)
-			strtok_arg = 0;
-		if (!pair)
-			break;
-
-		equals = strchr(pair, '=');
-		if (!equals)
-			continue;
-
-		*equals = '\0';
-		attribute = pair;		/* ex. DSN */
-		value = equals + 1;		/* ex. 'CEO co1' */
-
-		mylog("attribute = '%s', value = '%s'\n", attribute, value);
-
-		if (!attribute || !value)
-			continue;
-
-		/* Copy the appropriate value to the conninfo  */
-		copyCommonAttributes(ci, attribute, value);
-
-	}
-
-	free(our_connect_string);
-}

src/interfaces/odbc/windev/environ.h

-/* File:			environ.h
- *
- * Description:		See "environ.c"
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *
- */
-
-#ifndef __ENVIRON_H__
-#define __ENVIRON_H__
-
-#include "psqlodbc.h"
-
-#define ENV_ALLOC_ERROR 1
-
-/**********		Environment Handle	*************/
-struct EnvironmentClass_
-{
-	char	   *errormsg;
-	int			errornumber;
-};
-
-/*	Environment prototypes */
-EnvironmentClass *EN_Constructor(void);
-char		EN_Destructor(EnvironmentClass *self);
-char		EN_get_error(EnvironmentClass *self, int *number, char **message);
-char		EN_add_connection(EnvironmentClass *self, ConnectionClass *conn);
-char		EN_remove_connection(EnvironmentClass *self, ConnectionClass *conn);
-void		EN_log_error(char *func, char *desc, EnvironmentClass *self);
-
-#endif

src/interfaces/odbc/windev/iodbc.h

-#ifndef _IODBC_H
-#define _IODBC_H
-
-#if    !defined(WIN32) && !defined(WIN32_SYSTEM)
-#define   _UNIX_
-
-#include  <stdlib.h>
-#include  <sys/types.h>
-
-#define   MEM_ALLOC(size)	(malloc((size_t)(size)))
-#define   MEM_FREE(ptr) \
-do { \
-	if(ptr) \
-		free(ptr); \
-} while (0)
-
-#define   STRCPY(t, s)		(strcpy((char*)(t), (char*)(s)))
-#define   STRNCPY(t,s,n)	(strncpy((char*)(t), (char*)(s), (size_t)(n)))
-#define   STRCAT(t, s)		(strcat((char*)(t), (char*)(s)))
-#define   STRNCAT(t,s,n)	(strncat((char*)(t), (char*)(s), (size_t)(n)))
-#define   STREQ(a, b)		(strcmp((char*)(a), (char*)(b)) == 0)
-#define   STRLEN(str)		((str)? strlen((char*)(str)):0)
-
-#define   EXPORT
-#define   CALLBACK
-#define   FAR
-
-typedef signed short SSHOR;
-typedef short WORD;
-typedef long DWORD;
-
-typedef WORD WPARAM;
-typedef DWORD LPARAM;
-typedef void *HWND;
-typedef int BOOL;
-#endif   /* _UNIX_ */
-
-#if    defined(WIN32) || defined(WIN32_SYSTEM)
-
-#include  <windows.h>
-#include  <windowsx.h>
-
-#ifdef	  _MSVC_
-#define  MEM_ALLOC(size)	(fmalloc((size_t)(size)))
-#define  MEM_FREE(ptr)		((ptr)? ffree((PTR)(ptr)):0))
-#define  STRCPY(t, s)		(fstrcpy((char FAR*)(t), (char FAR*)(s)))
-#define  STRNCPY(t,s,n)		(fstrncpy((char FAR*)(t), (char FAR*)(s), (size_t)(n)))
-#define  STRLEN(str)		((str)? fstrlen((char FAR*)(str)):0)
-#define  STREQ(a, b)		(fstrcmp((char FAR*)(a), (char FAR*)(b) == 0)
-#endif
-
-#ifdef	  _BORLAND_
-#define  MEM_ALLOC(size)	(farmalloc((unsigned long)(size))
-#define  MEM_FREE(ptr)		((ptr)? farfree((void far*)(ptr)):0)
-#define  STRCPY(t, s)		(_fstrcpy((char FAR*)(t), (char FAR*)(s)))
-#define  STRNCPY(t,s,n)		(_fstrncpy((char FAR*)(t), (char FAR*)(s), (size_t)(n)))
-#define  STRLEN(str)		((str)? _fstrlen((char FAR*)(str)):0)
-#define  STREQ(a, b)		(_fstrcmp((char FAR*)(a), (char FAR*)(b) == 0)
-#endif
-#endif   /* WIN32 */
-
-#define    SYSERR			(-1)
-
-#ifndef    NULL
-#define  NULL				((void FAR*)0UL)
-#endif
-
-#endif

src/interfaces/odbc/windev/lobj.c

-/*--------
- * Module:			lobj.c
- *
- * Description:		This module contains routines related to manipulating
- *					large objects.
- *
- * Classes:			none
- *
- * API functions:	none
- *
- * Comments:		See "notice.txt" for copyright and license information.
- *--------
- */
-
-#include "lobj.h"
-
-#include "connection.h"
-
-
-Oid
-lo_creat(ConnectionClass *conn, int mode)
-{
-	LO_ARG		argv[1];
-	int			retval,
-				result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = mode;
-
-	if (!CC_send_function(conn, LO_CREAT, &retval, &result_len, 1, argv, 1))
-		return 0;				/* invalid oid */
-	else
-		return retval;
-}
-
-
-int
-lo_open(ConnectionClass *conn, int lobjId, int mode)
-{
-	int			fd;
-	int			result_len;
-	LO_ARG		argv[2];
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = lobjId;
-
-	argv[1].isint = 1;
-	argv[1].len = 4;
-	argv[1].u.integer = mode;
-
-	if (!CC_send_function(conn, LO_OPEN, &fd, &result_len, 1, argv, 2))
-		return -1;
-
-	if (fd >= 0 && lo_lseek(conn, fd, 0L, SEEK_SET) < 0)
-		return -1;
-
-	return fd;
-}
-
-
-int
-lo_close(ConnectionClass *conn, int fd)
-{
-	LO_ARG		argv[1];
-	int			retval,
-				result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = fd;
-
-	if (!CC_send_function(conn, LO_CLOSE, &retval, &result_len, 1, argv, 1))
-		return -1;
-	else
-		return retval;
-}
-
-
-int
-lo_read(ConnectionClass *conn, int fd, char *buf, int len)
-{
-	LO_ARG		argv[2];
-	int			result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = fd;
-
-	argv[1].isint = 1;
-	argv[1].len = 4;
-	argv[1].u.integer = len;
-
-	if (!CC_send_function(conn, LO_READ, (int *) buf, &result_len, 0, argv, 2))
-		return -1;
-	else
-		return result_len;
-}
-
-
-int
-lo_write(ConnectionClass *conn, int fd, char *buf, int len)
-{
-	LO_ARG		argv[2];
-	int			retval,
-				result_len;
-
-	if (len <= 0)
-		return 0;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = fd;
-
-	argv[1].isint = 0;
-	argv[1].len = len;
-	argv[1].u.ptr = (char *) buf;
-
-	if (!CC_send_function(conn, LO_WRITE, &retval, &result_len, 1, argv, 2))
-		return -1;
-	else
-		return retval;
-}
-
-
-int
-lo_lseek(ConnectionClass *conn, int fd, int offset, int whence)
-{
-	LO_ARG		argv[3];
-	int			retval,
-				result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = fd;
-
-	argv[1].isint = 1;
-	argv[1].len = 4;
-	argv[1].u.integer = offset;
-
-	argv[2].isint = 1;
-	argv[2].len = 4;
-	argv[2].u.integer = whence;
-
-	if (!CC_send_function(conn, LO_LSEEK, &retval, &result_len, 1, argv, 3))
-		return -1;
-	else
-		return retval;
-}
-
-
-int
-lo_tell(ConnectionClass *conn, int fd)
-{
-	LO_ARG		argv[1];
-	int			retval,
-				result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = fd;
-
-	if (!CC_send_function(conn, LO_TELL, &retval, &result_len, 1, argv, 1))
-		return -1;
-	else
-		return retval;
-}
-
-
-int
-lo_unlink(ConnectionClass *conn, Oid lobjId)
-{
-	LO_ARG		argv[1];
-	int			retval,
-				result_len;
-
-	argv[0].isint = 1;
-	argv[0].len = 4;
-	argv[0].u.integer = lobjId;
-
-	if (!CC_send_function(conn, LO_UNLINK, &retval, &result_len, 1, argv, 1))
-		return -1;
-	else
-		return retval;
-}