Add a directory to save the changes until 7.3-tree is branched.

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.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/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/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;
+}