- Tcl_AppendResult(interp, " ", PQfname(result,i), NULL);
+ for (i=0;i
+ Tcl_AppendElement(interp, PQfname(result,i));
}
return TCL_OK;
}
else if (strcmp(opt, "-lAttributes") == 0) {
- char buf[512];
- Tcl_ResetResult(interp);
for (i = 0; i < PQnfields(result); i++) {
- sprintf(buf, "{%s} %ld %d", PQfname(result, i),
- (long) PQftype(result, i),
- PQfsize(result, i));
- Tcl_AppendElement(interp, buf);
+ /* start a sublist */
+ if (i > 0)
+ Tcl_AppendResult(interp, " {", 0);
+ else
+ Tcl_AppendResult(interp, "{", 0);
+ Tcl_AppendElement(interp, PQfname(result, i));
+ sprintf(nameBuffer, "%ld", (long) PQftype(result, i));
+ Tcl_AppendElement(interp, nameBuffer);
+ sprintf(nameBuffer, "%ld", (long) PQfsize(result, i));
+ Tcl_AppendElement(interp, nameBuffer);
+ /* end the sublist */
+ Tcl_AppendResult(interp, "}", 0);
}
return TCL_OK;
}
- else if (strcmp(opt, "-numAttrs") == 0) {
- sprintf(interp->result, "%d", PQnfields(result));
- return TCL_OK;
- }
else {
Tcl_AppendResult(interp, "Invalid option",0);
goto Pg_result_errReturn;
"\t-assign arrayVarName\n",
"\t-assignbyidx arrayVarName\n",
"\t-numTuples\n",
+ "\t-numAttrs\n"
"\t-attributes\n"
"\t-lAttributes\n"
- "\t-numAttrs\n"
"\t-getTuple tupleNumber\n",
"\t-tupleArray tupleNumber arrayVarName\n",
"\t-clear\n",
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpgtcl/Attic/pgtclId.c,v 1.11 1998/06/16 04:10:17 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpgtcl/Attic/pgtclId.c,v 1.12 1998/08/17 03:50:26 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
}
/*
- * Called when reading data (via gets) for a copy to stdout
+ * Called when reading data (via gets) for a copy to stdout.
+ *
+ * NOTE: this routine knows way more than it ought to about libpq's
+ * internal buffering mechanisms.
*/
int PgInputProc(DRIVER_INPUT_PROTO)
{
}
/* Try to load any newly arrived data */
- errno = 0;
-
- if (pqReadData(conn) < 0) {
- *errorCodePtr = errno ? errno : EIO;
+ conn->errorMessage[0] = '\0';
+ PQconsumeInput(conn);
+ if (conn->errorMessage[0]) {
+ *errorCodePtr = EIO;
return -1;
}
conn->inCursor = conn->inStart;
avail = bufSize;
- while (avail > 0 &&
- pqGetc(&c, conn) == 0) {
+ while (avail > 0 && conn->inCursor < conn->inEnd) {
+ c = conn->inBuffer[conn->inCursor++];
*buf++ = c;
--avail;
if (c == '\n') {
return -1;
}
- errno = 0;
+ conn->errorMessage[0] = '\0';
- if (pqPutnchar(buf, bufSize, conn)) {
- *errorCodePtr = errno ? errno : EIO;
+ PQputnbytes(conn, buf, bufSize);
+
+ if (conn->errorMessage[0]) {
+ *errorCodePtr = EIO;
return -1;
}
* in a single operation; maybe not such a good assumption?
*/
if (bufSize >= 3 && strncmp(&buf[bufSize-3], "\\.\n", 3) == 0) {
- (void) pqFlush(conn);
if (PgEndCopy(connid, errorCodePtr) == -1)
return -1;
}
*mark = '\0';
conn_chan = Tcl_GetChannel(interp, resid_c, 0);
*mark = '.';
- if(conn_chan && Tcl_GetChannelType(conn_chan) != &Pg_ConnType) {
+ if(conn_chan && Tcl_GetChannelType(conn_chan) == &Pg_ConnType) {
Tcl_SetResult(interp, Tcl_GetChannelName(conn_chan), TCL_VOLATILE);
return TCL_OK;
}
#
#
# IDENTIFICATION
-# $Header: /cvsroot/pgsql/src/interfaces/libpq/Attic/Makefile.in,v 1.25 1998/07/26 04:31:35 scrappy Exp $
+# $Header: /cvsroot/pgsql/src/interfaces/libpq/Attic/Makefile.in,v 1.26 1998/08/17 03:50:29 scrappy Exp $
#
#-------------------------------------------------------------------------
CFLAGS += $(CFLAGS_SL)
endif
-all: libpq.a $(shlib) c.h
+all: libpq.a $(shlib)
libpq.a: $(OBJS)
ifdef MK_NO_LORDER
endif
$(RANLIB) libpq.a
-fe-lobj.o: $(SRCDIR)/backend/fmgr.h
-
# We need to compile this with special options for shared libs,
# so we can't use the object in $(SRCDIR)/backend
dllist.c: $(SRCDIR)/backend/lib/dllist.c
# The following rules cause dependencies in the backend directory to
# get made if they don't exist, but don't cause them to get remade if they
# are out of date.
+fe-lobj.o: $(SRCDIR)/backend/fmgr.h
+
$(SRCDIR)/backend/fmgr.h:
$(MAKE) -C $(SRCDIR)/backend fmgr.h
ln -sf $@ libpq.so
-c.h: $(SRCDIR)/include/c.h
- rm -f c.h
- echo "#undef PORTNAME" > c.h
- echo "#define PORTNAME $(PORTNAME)" >> c.h
- cat $(SRCDIR)/include/c.h >> c.h
-
.PHONY: beforeinstall-headers install-headers
.PHONY: install install-libpq install-shlib-dep
# Many of the headers we install below have nothing to do with libpq,
# so should be installed by someone else.
#
-install-headers: beforeinstall-headers c.h \
+install-headers: beforeinstall-headers $(SRCDIR)/include/c.h \
$(SRCDIR)/include/postgres.h $(SRCDIR)/include/postgres_ext.h \
$(SRCDIR)/include/config.h $(SRCDIR)/include/libpq/pqcomm.h \
$(SRCDIR)/include/libpq/libpq-fs.h $(SRCDIR)/include/lib/dllist.h \
- $(SRCDIR)/include/utils/geo_decls.h libpq-fe.h
+ $(SRCDIR)/include/utils/geo_decls.h libpq-fe.h libpq-int.h
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/os.h \
$(HEADERDIR)/os.h
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/config.h \
$(HEADERDIR)/config.h
+ $(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/c.h \
+ $(HEADERDIR)/c.h
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/postgres.h \
$(HEADERDIR)/postgres.h
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/postgres_ext.h \
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/include/commands/trigger.h \
$(HEADERDIR)/commands/trigger.h
$(INSTALL) $(INSTLOPTS) libpq-fe.h $(HEADERDIR)/libpq-fe.h
+ $(INSTALL) $(INSTLOPTS) libpq-int.h $(HEADERDIR)/libpq-int.h
ifeq ($(PORTNAME), hpux)
$(INSTALL) $(INSTLOPTS) $(SRCDIR)/backend/port/hpux/fixade.h \
$(HEADERDIR)/port/hpux/fixade.h
endif
- $(INSTALL) $(INSTLOPTS) c.h $(HEADERDIR)/c.h
beforeinstall-headers:
@if [ ! -d $(HEADERDIR) ]; then mkdir $(HEADERDIR); fi
@if [ ! -d $(HEADERDIR)/port ]; then mkdir $(HEADERDIR)/port; fi
@if [ ! -d $(HEADERDIR)/port/$(PORTNAME) ]; \
then mkdir $(HEADERDIR)/port/$(PORTNAME); fi
- @if [ ! -d $(HEADERDIR)/include ]; \
- then mkdir $(HEADERDIR)/include; fi
@if [ ! -d $(HEADERDIR)/lib ]; \
then mkdir $(HEADERDIR)/lib; fi
@if [ ! -d $(HEADERDIR)/libpq ]; \
.PHONY: clean
clean:
- rm -f libpq.a $(shlib) $(OBJS) c.h dllist.c libpq.so
+ rm -f libpq.a $(shlib) libpq.so $(OBJS)
+ rm -f dllist.c common.c wchar.c conv.c
ifeq (depend,$(wildcard depend))
include depend
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-auth.c,v 1.21 1998/08/09 02:59:25 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-auth.c,v 1.22 1998/08/17 03:50:31 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
*
*
*/
+
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "fe-auth.h"
+#include "postgres.h"
+
#ifdef WIN32
#include "win32.h"
#else
-#include
#include
#include /* for MAXHOSTNAMELEN on most */
-#include
#ifndef MAXHOSTNAMELEN
#include /* for MAXHOSTNAMELEN on some */
#endif
+#if !defined(NO_UNISTD_H)
#include
+#endif
#endif /* WIN32 */
-#include "postgres.h"
-
-#include "libpq/pqcomm.h"
-
-#include "libpq-fe.h"
-#include "fe-auth.h"
-#include "fe-connect.h"
-
#ifdef HAVE_CRYPT_H
#include
#endif
if (areq == AUTH_REQ_CRYPT)
password = crypt(password, conn->salt);
- return packetSend(conn, password, strlen(password) + 1);
+ return pqPacketSend(conn, password, strlen(password) + 1);
}
/*
*
* Copyright (c) 1994, Regents of the University of California
*
- * $Id: fe-auth.h,v 1.8 1998/01/29 03:24:21 scrappy Exp $
+ * $Id: fe-auth.h,v 1.9 1998/08/17 03:50:33 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
#define FE_AUTH_H
#include "libpq-fe.h"
+#include "libpq-int.h"
/*----------------------------------------------------------------
extern int
fe_sendauth(AuthRequest areq, PGconn *conn, const char *hostname,
- const char *password, char *PQerromsg);
+ const char *password, char *PQerrormsg);
+extern MsgType fe_getauthsvc(char *PQerrormsg);
extern void fe_setauthsvc(const char *name, char *PQerrormsg);
+extern char *fe_getauthname(char *PQerrormsg);
#define PG_KRB4_VERSION "PGVER4.1" /* at most KRB_SENDAUTH_VLEN chars */
#define PG_KRB5_VERSION "PGVER5.1"
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-connect.c,v 1.78 1998/08/09 02:59:26 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-connect.c,v 1.79 1998/08/17 03:50:34 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "fe-auth.h"
+#include "postgres.h"
+
#include
-#include
#ifdef WIN32
#include "win32.h"
#else
-#include
+#if !defined(NO_UNISTD_H)
#include
+#endif
#include
-#include
-#include
#include
#endif
#include
-#include
-#include
#include
#include
#include /* for isspace() */
-#include "postgres.h"
-#include "fe-auth.h"
-#include "fe-connect.h"
-#include "libpq-fe.h"
-
#ifndef HAVE_STRDUP
#include "strdup.h"
#endif
NULL, NULL, 0}
};
-struct EnvironmentOptions
+static struct EnvironmentOptions
{
const char *envName,
*pgName;
struct hostent *hp;
StartupPacket sp;
AuthRequest areq;
- int laddrlen = sizeof(SockAddr);
+ int laddrlen;
int portno,
family;
char beresp;
MemSet((char *) &sp, 0, sizeof(StartupPacket));
- sp.protoVersion = (ProtocolVersion) htonl(PG_PROTOCOL_LATEST);
+ sp.protoVersion = (ProtocolVersion) htonl(PG_PROTOCOL_LIBPQ);
strncpy(sp.user, conn->pguser, SM_USER);
strncpy(sp.database, conn->dbName, SM_DATABASE);
}
/* Fill in the client address */
+ laddrlen = sizeof(conn->laddr);
if (getsockname(conn->sock, &conn->laddr.sa, &laddrlen) < 0)
{
(void) sprintf(conn->errorMessage,
/* Send the startup packet. */
- if (packetSend(conn, (char *) &sp, sizeof(StartupPacket)) != STATUS_OK)
+ if (pqPacketSend(conn, (char *) &sp, sizeof(StartupPacket)) != STATUS_OK)
{
sprintf(conn->errorMessage,
"connectDB() -- couldn't send startup packet: errno=%d\n%s\n",
char setQuery[80]; /* mjl: size okay? XXX */
#ifdef MULTIBYTE
char *envname = "PGCLIENTENCODING";
- char envbuf[64];
+ static char envbuf[64]; /* big enough? */
char *env;
char *encoding = 0;
PGresult *rtn;
{
if (!conn)
return;
- PQclearAsyncResult(conn); /* deallocate result and curTuple */
+ pqClearAsyncResult(conn); /* deallocate result and curTuple */
if (conn->sock >= 0)
#ifdef WIN32
closesocket(conn->sock);
{
/*
* Try to send "close connection" message to backend.
- * BUT: backend might have already closed connection.
- * To avoid being killed by SIGPIPE, we need to detect this before
- * writing. Check for "read ready" condition which indicates EOF.
+ * Ignore any error.
+ * Note: this routine used to go to substantial lengths to avoid
+ * getting SIGPIPE'd if the connection were already closed.
+ * Now we rely on pqFlush to avoid the signal.
*/
- while (pqReadReady(conn)) {
- if (pqReadData(conn) < 0)
- break;
- }
- if (conn->sock >= 0) {
- /* Should be safe now... */
- (void) pqPuts("X", conn);
- (void) pqFlush(conn);
- }
+ (void) pqPuts("X", conn);
+ (void) pqFlush(conn);
}
/*
conn->status = CONNECTION_BAD; /* Well, not really _bad_ - just
* absent */
conn->asyncStatus = PGASYNC_IDLE;
- PQclearAsyncResult(conn); /* deallocate result and curTuple */
+ pqClearAsyncResult(conn); /* deallocate result and curTuple */
if (conn->lobjfuncs)
free(conn->lobjfuncs);
conn->lobjfuncs = NULL;
/*
- * PacketSend() -- send a single-packet message.
+ * pqPacketSend() -- send a single-packet message.
* this is like PacketSend(), defined in backend/libpq/pqpacket.c
*
* RETURNS: STATUS_ERROR if the write fails, STATUS_OK otherwise.
* SIDE_EFFECTS: may block.
*/
int
-packetSend(PGconn *conn, const char *buf, size_t len)
+pqPacketSend(PGconn *conn, const char *buf, size_t len)
{
/* Send the total packet size. */
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.61 1998/08/09 02:59:27 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.62 1998/08/17 03:50:35 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "postgres.h"
+
#ifdef WIN32
#include "win32.h"
+#else
+#if !defined(NO_UNISTD_H)
+#include
+#endif
#endif
#include
-#include
#include
#include
#include
-#if !defined(NO_UNISTD_H)
-#include
-#endif
-#include "postgres.h"
-#include "libpq/pqcomm.h"
-#include "libpq-fe.h"
/* the rows array in a PGresGroup has to grow to accommodate the rows */
#define TUPARR_GROW_BY 100
/* keep this in same order as ExecStatusType in libpq-fe.h */
-const char *pgresStatus[] = {
+const char * const pgresStatus[] = {
"PGRES_EMPTY_QUERY",
"PGRES_COMMAND_OK",
"PGRES_TUPLES_OK",
*/
void
-PQclearAsyncResult(PGconn *conn)
+pqClearAsyncResult(PGconn *conn)
{
/* Get rid of incomplete result and any not-yet-added tuple */
if (conn->result)
return 0;
}
- if (conn->asyncStatus != PGASYNC_IDLE)
- {
- sprintf(conn->errorMessage,
- "PQsendQuery() -- another query already in progress.");
- return 0;
- }
-
- /* Check for pending input (asynchronous Notice or Notify messages);
- * also detect the case that the backend just closed the connection.
- * Note: we have to loop if the first call to pqReadData successfully
- * reads some data, since in that case pqReadData won't notice whether
- * the connection is now closed.
- */
- while (pqReadReady(conn)) {
- if (pqReadData(conn) < 0)
- return 0; /* errorMessage already set */
- parseInput(conn); /* deal with Notice or Notify, if any */
- }
-
/* Don't try to send if we know there's no live connection. */
if (conn->status != CONNECTION_OK)
{
"to the backend.\n");
return 0;
}
+ /* Can't send while already busy, either. */
+ if (conn->asyncStatus != PGASYNC_IDLE)
+ {
+ sprintf(conn->errorMessage,
+ "PQsendQuery() -- another query already in progress.");
+ return 0;
+ }
/* clear the error string */
conn->errorMessage[0] = '\0';
if (pqGets(conn->asyncErrorMessage,ERROR_MSG_LENGTH,conn))
return;
/* delete any partially constructed result */
- PQclearAsyncResult(conn);
+ pqClearAsyncResult(conn);
/* we leave result NULL while setting asyncStatus=READY;
* this signals an error condition to PQgetResult.
*/
/* Discard the unexpected message; good idea?? */
conn->inStart = conn->inEnd;
/* delete any partially constructed result */
- PQclearAsyncResult(conn);
+ pqClearAsyncResult(conn);
conn->asyncStatus = PGASYNC_READY;
return;
} /* switch on protocol character */
{
sprintf(conn->asyncErrorMessage,
"getAnotherTuple() -- null-values bitmap is too large\n");
- PQclearAsyncResult(conn);
+ pqClearAsyncResult(conn);
conn->asyncStatus = PGASYNC_READY;
/* Discard the broken message */
conn->inStart = conn->inEnd;
if (pqWait(TRUE, FALSE, conn) ||
pqReadData(conn) < 0)
{
- PQclearAsyncResult(conn);
+ pqClearAsyncResult(conn);
conn->asyncStatus = PGASYNC_IDLE;
/* conn->errorMessage has been set by pqWait or pqReadData. */
return makeEmptyPGresult(conn, PGRES_FATAL_ERROR);
(void) pqPutnchar(s, strlen(s), conn);
}
+/*
+ * PQputnbytes -- like PQputline, but buffer need not be null-terminated.
+ */
+void
+PQputnbytes(PGconn *conn, const char *buffer, int nbytes)
+{
+ if (conn && conn->sock >= 0)
+ (void) pqPutnchar(buffer, nbytes, conn);
+}
+
/*
* PQendcopy
* After completing the data transfer portion of a copy in/out,
/* Return to active duty */
conn->asyncStatus = PGASYNC_BUSY;
+ conn->errorMessage[0] = '\0';
/* Wait for the completion response */
result = PQgetResult(conn);
*/
PQclear(result);
- sprintf(conn->errorMessage, "PQendcopy: resetting connection\n");
- DONOTICE(conn, conn->errorMessage);
+ if (conn->errorMessage[0])
+ DONOTICE(conn, conn->errorMessage);
+
+ DONOTICE(conn, "PQendcopy: resetting connection\n");
PQreset(conn);
const char *
PQoidStatus(PGresult *res)
{
- static char oidStatus[32] = {0};
+ char *p, *e, *scan;
+ int slen, olen;
if (!res)
return "";
- oidStatus[0] = 0;
+ if (strncmp(res->cmdStatus, "INSERT ", 7) != 0)
+ return "";
- if (strncmp(res->cmdStatus, "INSERT ", 7) == 0)
- {
- char *p = res->cmdStatus + 7;
- char *e;
+ /* The cmdStatus string looks like
+ * INSERT oid count\0
+ * In order to be able to return an ordinary C string without
+ * damaging the result for PQcmdStatus or PQcmdTuples, we copy
+ * the oid part of the string to just after the null, so that
+ * cmdStatus looks like
+ * INSERT oid count\0oid\0
+ * ^ our return value points here
+ * Pretty klugy eh? This routine should've just returned an Oid value.
+ */
- for (e = p; *e != ' ' && *e;)
- e++;
- sprintf(oidStatus, "%.*s", e - p, p);
- }
- return oidStatus;
+ slen = strlen(res->cmdStatus);
+ p = res->cmdStatus + 7; /* where oid is now */
+ e = res->cmdStatus + slen + 1; /* where to put the oid string */
+
+ for (scan = p; *scan && *scan != ' '; )
+ scan++;
+ olen = scan - p;
+ if (slen + olen + 2 > sizeof(res->cmdStatus))
+ return ""; /* something very wrong if it doesn't fit */
+
+ strncpy(e, p, olen);
+ e[olen] = '\0';
+
+ return e;
}
/*
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-lobj.c,v 1.14 1998/07/03 04:24:14 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-lobj.c,v 1.15 1998/08/17 03:50:37 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
+
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "postgres.h"
+
#ifdef WIN32
#include "win32.h"
#include
#else
+#if !defined(NO_UNISTD_H)
#include
#endif
-#include
+#endif
#include
#include
#include
-#include
-#include "postgres.h"
-#include "libpq-fe.h"
-#include "libpq/libpq-fs.h"
+
+#include "libpq/libpq-fs.h" /* must come after sys/stat.h */
+
#define LO_BUFSIZE 1024
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-misc.c,v 1.17 1998/08/09 02:59:29 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-misc.c,v 1.18 1998/08/17 03:50:38 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "postgres.h"
+#include "pqsignal.h"
+
#include
-#include
#include
#include
+#include
#include
#ifdef WIN32
#include "win32.h"
#include
#endif
#endif /* WIN32 */
-#include /* for fd_set stuff */
+
#ifdef HAVE_SYS_SELECT_H
#include
#endif
-#include "postgres.h"
-#include "libpq-fe.h"
#define DONOTICE(conn,message) \
((*(conn)->noticeHook) ((conn)->noticeArg, (message)))
/* --------------------------------------------------------------------- */
/* pqReadReady: is select() saying the file is ready to read?
*/
-int
+static int
pqReadReady(PGconn *conn)
{
fd_set input_mask;
while (len > 0)
{
+ /* Prevent being SIGPIPEd if backend has closed the connection. */
+#ifndef WIN32
+ pqsigfunc oldsighandler = pqsignal(SIGPIPE, SIG_IGN);
+#endif
+
int sent = send(conn->sock, ptr, len, 0);
+
+#ifndef WIN32
+ pqsignal(SIGPIPE, oldsighandler);
+#endif
+
if (sent < 0)
{
/* Anything except EAGAIN or EWOULDBLOCK is trouble */
* didn't really belong there.
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-print.c,v 1.9 1998/08/09 02:59:30 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-print.c,v 1.10 1998/08/17 03:50:39 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
+#include "libpq-fe.h"
+#include "libpq-int.h"
+#include "postgres.h"
+#include "pqsignal.h"
+
#ifdef WIN32
#include "win32.h"
-#endif
-#include
-#include
-#include
-#include
-#ifndef WIN32
+#else
+#if !defined(NO_UNISTD_H)
#include
-#include
#endif
-#include "libpq/pqsignal.h"
-#include "libpq-fe.h"
-#ifndef WIN32
+#include
#ifndef HAVE_TERMIOS_H
#include
#else
#include
#endif
#endif /* WIN32 */
+#include
+#include
+#include
#ifdef MULTIBYTE
#include "mb/pg_wchar.h"
*
* Copyright (c) 1994, Regents of the University of California
*
- * $Id: libpq-fe.h,v 1.37 1998/08/09 02:59:31 momjian Exp $
+ * $Id: libpq-fe.h,v 1.38 1998/08/17 03:50:40 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
#endif
#include
+/* these wouldn't need to be included if PGSockAddr weren't exported: */
+#include
+#include
+#include
/* ----------------
* include stuff common to fe and be
* ----------------
*/
#include "postgres_ext.h"
-#include "libpq/pqcomm.h"
#include "lib/dllist.h"
/* Application-visible enum types */
} ExecStatusType;
/* string descriptions of the ExecStatusTypes */
- extern const char *pgresStatus[];
+ extern const char * const pgresStatus[];
/*
* POSTGRES backend dependent Constants.
/* ERROR_MSG_LENGTH should really be the same as ELOG_MAXLEN in utils/elog.h*/
#define ERROR_MSG_LENGTH 4096
-#define COMMAND_LENGTH 20
-#define REMARK_LENGTH 80
-#define PORTAL_NAME_LENGTH 16
#define CMDSTATUS_LEN 40
/* PGresult and the subsidiary types PGresAttDesc, PGresAttValue
ASCII tuples are guaranteed to be null-terminated
For binary tuples, the first four bytes of the value is the size,
and the bytes afterwards are the value. The binary value is
- not guaranteed to be null-terminated. In fact, it can have embedded nulls*/
+ not guaranteed to be null-terminated. In fact, it can have embedded nulls
+ */
#define NULL_LEN (-1) /* pg_result len for NULL value */
PGASYNC_COPY_OUT /* Copy Out data transfer in progress */
} PGAsyncStatusType;
+/* generic socket address type for PGconn connection information.
+ * Really shouldn't be visible to users */
+ typedef union PGSockAddr
+ {
+ struct sockaddr sa;
+ struct sockaddr_in in;
+ struct sockaddr_un un;
+ } PGSockAddr;
+
/* large-object-access data ... allocated only if large-object code is used.
* Really shouldn't be visible to users */
typedef struct pgLobjfuncs
} PGlobjfuncs;
/* PGconn encapsulates a connection to the backend.
- * XXX contents of this struct really shouldn't be visible to applications
+ * XXX contents of this struct really shouldn't be visible to applications,
+ * but we might break some existing applications if we tried to make it
+ * completely opaque.
*/
typedef struct pg_conn
{
/* Connection data */
int sock; /* Unix FD for socket, -1 if not connected */
- SockAddr laddr; /* Local address */
- SockAddr raddr; /* Remote address */
+ PGSockAddr laddr; /* Local address */
+ PGSockAddr raddr; /* Remote address */
int raddr_len; /* Length of remote address */
/* Miscellaneous stuff */
char asyncErrorMessage[ERROR_MSG_LENGTH];
} PGconn;
- typedef char pqbool;
-
/*
* We can't use the conventional "bool", because we are designed to be
* included in a user's program, and user may already have that type
* defined. Pqbool, on the other hand, is unlikely to be used.
*/
+ typedef char pqbool;
+
/* Print options for PQprint() */
typedef struct _PQprintOpt
} PQArgBlock;
/* ----------------
- * Structure for the conninfo parameter definitions of PQconnectdb()
+ * Structure for the conninfo parameter definitions returned by PQconndefaults
* ----------------
*/
typedef struct _PQconninfoOption
int dispsize; /* Field size in characters for dialog */
} PQconninfoOption;
+/* ----------------
+ * Exported functions of libpq
+ * ----------------
+ */
+
/* === in fe-connect.c === */
+
/* make a new client connection to the backend */
extern PGconn *PQconnectdb(const char *conninfo);
+ extern PGconn *PQsetdbLogin(const char *pghost, const char *pgport,
+ const char *pgoptions, const char *pgtty,
+ const char *dbName,
+ const char *login, const char *pwd);
+#define PQsetdb(M_PGHOST,M_PGPORT,M_PGOPT,M_PGTTY,M_DBNAME) \
+ PQsetdbLogin(M_PGHOST, M_PGPORT, M_PGOPT, M_PGTTY, M_DBNAME, NULL, NULL)
+
+ /* get info about connection options known to PQconnectdb */
extern PQconninfoOption *PQconndefaults(void);
- extern PGconn *PQsetdbLogin(const char *pghost, const char *pgport, const char *pgoptions,
- const char *pgtty, const char *dbName, const char *login, const char *pwd);
-#define PQsetdb(M_PGHOST,M_PGPORT,M_PGOPT,M_PGTTY,M_DBNAME) PQsetdbLogin(M_PGHOST, M_PGPORT, M_PGOPT, M_PGTTY, M_DBNAME, NULL, NULL)
+
/* close the current connection and free the PGconn data structure */
extern void PQfinish(PGconn *conn);
- /* issue a cancel request */
- extern int PQrequestCancel(PGconn *conn);
-
/*
* close the current connection and restablish a new one with the same
* parameters
*/
extern void PQreset(PGconn *conn);
+ /* issue a cancel request */
+ extern int PQrequestCancel(PGconn *conn);
+
/* Accessor functions for PGconn objects */
extern char *PQdb(PGconn *conn);
extern char *PQuser(PGconn *conn);
void *arg);
/* === in fe-exec.c === */
+
/* Simple synchronous query */
extern PGresult *PQexec(PGconn *conn, const char *query);
extern PGnotify *PQnotifies(PGconn *conn);
+
/* Interface for multiple-result or asynchronous queries */
extern int PQsendQuery(PGconn *conn, const char *query);
extern PGresult *PQgetResult(PGconn *conn);
+
/* Routines for managing an asychronous query */
extern int PQisBusy(PGconn *conn);
extern void PQconsumeInput(PGconn *conn);
+
/* Routines for copy in/out */
extern int PQgetline(PGconn *conn, char *string, int length);
extern void PQputline(PGconn *conn, const char *string);
+ extern void PQputnbytes(PGconn *conn, const char *buffer, int nbytes);
extern int PQendcopy(PGconn *conn);
- /* Not really meant for application use: */
+
+ /* "Fast path" interface --- not really recommended for application use */
extern PGresult *PQfn(PGconn *conn,
- int fnid,
- int *result_buf,
- int *result_len,
- int result_is_int,
- PQArgBlock *args,
- int nargs);
- extern void PQclearAsyncResult(PGconn *conn);
+ int fnid,
+ int *result_buf,
+ int *result_len,
+ int result_is_int,
+ PQArgBlock *args,
+ int nargs);
/* Accessor functions for PGresult objects */
extern ExecStatusType PQresultStatus(PGresult *res);
extern char *PQgetvalue(PGresult *res, int tup_num, int field_num);
extern int PQgetlength(PGresult *res, int tup_num, int field_num);
extern int PQgetisnull(PGresult *res, int tup_num, int field_num);
+
/* Delete a PGresult */
extern void PQclear(PGresult *res);
/* === in fe-print.c === */
+
extern void PQprint(FILE *fout, /* output stream */
PGresult *res,
- PQprintOpt *ps /* option structure */
- );
+ PQprintOpt *ps); /* option structure */
+
/* PQdisplayTuples() is a better version of PQprintTuples(),
* but both are obsoleted by PQprint().
*/
* or not */
int terseOutput, /* delimiter bars or
* not? */
- int width /* width of column, if
+ int width); /* width of column, if
* 0, use variable width */
- );
#ifdef MULTIBYTE
extern int PQmblen(unsigned char *s);
#endif
-/* === in fe-auth.c === */
- extern MsgType fe_getauthsvc(char *PQerrormsg);
- extern void fe_setauthsvc(const char *name, char *PQerrormsg);
- extern char *fe_getauthname(char *PQerrormsg);
-
-/* === in fe-misc.c === */
- /* "Get" and "Put" routines return 0 if successful, EOF if not.
- * Note that for Get, EOF merely means the buffer is exhausted,
- * not that there is necessarily any error.
- */
- extern int pqGetc(char *result, PGconn *conn);
- extern int pqGets(char *s, int maxlen, PGconn *conn);
- extern int pqPuts(const char *s, PGconn *conn);
- extern int pqGetnchar(char *s, int len, PGconn *conn);
- extern int pqPutnchar(const char *s, int len, PGconn *conn);
- extern int pqGetInt(int *result, int bytes, PGconn *conn);
- extern int pqPutInt(int value, int bytes, PGconn *conn);
- extern int pqReadData(PGconn *conn);
- extern int pqReadReady(PGconn *conn);
- extern int pqFlush(PGconn *conn);
- extern int pqWait(int forRead, int forWrite, PGconn *conn);
-
/* === in fe-lobj.c === */
+
+ /* Large-object access routines */
extern int lo_open(PGconn *conn, Oid lobjId, int mode);
extern int lo_close(PGconn *conn, int fd);
extern int lo_read(PGconn *conn, int fd, char *buf, int len);
extern Oid lo_import(PGconn *conn, char *filename);
extern int lo_export(PGconn *conn, Oid lobjId, char *filename);
-/* max length of message to send */
-#define MAX_MESSAGE_LEN 8193
-
-/* maximum number of fields in a tuple */
-#define MAX_FIELDS 512
-
-/* bits in a byte */
-#define BYTELEN 8
-
-/* fall back options if they are not specified by arguments or defined
- by environment variables */
-#define DefaultHost "localhost"
-#define DefaultTty ""
-#define DefaultOption ""
-#define DefaultAuthtype ""
-#define DefaultPassword ""
-
-
- typedef void *TUPLE;
-#define palloc malloc
-#define pfree free
-
-#if defined(sun) && defined(sparc) && !defined(__SVR4)
- extern char *sys_errlist[];
-#define strerror(A) (sys_errlist[(A)])
-#endif /* sunos4 */
-
#ifdef __cplusplus
};
-
#endif
#endif /* LIBPQ_FE_H */
DESCRIPTION "Postgres Client Access Library"
EXPORTS
PQconnectdb @ 1
- PQconndefaults @ 2
- PQsetdbLogin @ 3
+ PQsetdbLogin @ 2
+ PQconndefaults @ 3
PQfinish @ 4
PQreset @ 5
- PQdb @ 6
- PQuser @ 7
- PQhost @ 8
- PQoptions @ 9
- PQport @ 10
- PQtty @ 11
- PQstatus @ 12
- PQerrorMessage @ 13
- PQsocket @ 14
- PQtrace @ 15
- PQuntrace @ 16
- PQexec @ 17
- PQnotifies @ 18
- PQsendQuery @ 19
- PQgetResult @ 20
- PQisBusy @ 21
- PQconsumeInput @ 22
- PQrequestCancel @ 23
- PQgetline @ 24
- PQputline @ 25
- PQendcopy @ 26
- PQfn @ 27
- PQclearAsyncResult @ 28
- PQresultStatus @ 29
- PQntuples @ 30
- PQnfields @ 31
- PQfname @ 32
- PQfnumber @ 33
- PQftype @ 34
- PQfsize @ 35
- PQfmod @ 36
- PQcmdStatus @ 37
- PQoidStatus @ 38
- PQcmdTuples @ 39
- PQgetvalue @ 40
- PQgetlength @ 41
- PQgetisnull @ 42
- PQclear @ 43
- PQprint @ 44
- PQdisplayTuples @ 45
- PQprintTuples @ 46
- fe_getauthsvc @ 47
- fe_setauthsvc @ 48
- fe_getauthname @ 49
- pqGetc @ 50
- pqGets @ 51
- pqPuts @ 52
- pqGetnchar @ 53
- pqPutnchar @ 54
- pqGetInt @ 55
- pqPutInt @ 56
- pqReadData @ 57
- pqFlush @ 58
- pqWait @ 59
- lo_open @ 60
- lo_close @ 61
- lo_read @ 62
- lo_write @ 63
- lo_lseek @ 64
- lo_creat @ 65
- lo_tell @ 66
- lo_unlink @ 67
- lo_import @ 68
- lo_export @ 69
-
+ PQrequestCancel @ 6
+ PQdb @ 7
+ PQuser @ 8
+ PQhost @ 9
+ PQoptions @ 10
+ PQport @ 11
+ PQtty @ 12
+ PQstatus @ 13
+ PQerrorMessage @ 14
+ PQsocket @ 15
+ PQtrace @ 16
+ PQuntrace @ 17
+ PQsetNoticeProcessor @ 18
+ PQexec @ 19
+ PQnotifies @ 20
+ PQsendQuery @ 21
+ PQgetResult @ 22
+ PQisBusy @ 23
+ PQconsumeInput @ 24
+ PQgetline @ 25
+ PQputline @ 26
+ PQputnbytes @ 27
+ PQendcopy @ 28
+ PQfn @ 29
+ PQresultStatus @ 30
+ PQntuples @ 31
+ PQnfields @ 32
+ PQfname @ 33
+ PQfnumber @ 34
+ PQftype @ 35
+ PQfsize @ 36
+ PQfmod @ 37
+ PQcmdStatus @ 38
+ PQoidStatus @ 39
+ PQcmdTuples @ 40
+ PQgetvalue @ 41
+ PQgetlength @ 42
+ PQgetisnull @ 43
+ PQclear @ 44
+ PQprint @ 45
+ PQdisplayTuples @ 46
+ PQprintTuples @ 47
+ lo_open @ 48
+ lo_close @ 49
+ lo_read @ 50
+ lo_write @ 51
+ lo_lseek @ 52
+ lo_creat @ 53
+ lo_tell @ 54
+ lo_unlink @ 55
+ lo_import @ 56
+ lo_export @ 57
*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/pqsignal.c,v 1.6 1998/06/15 19:30:26 momjian Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/pqsignal.c,v 1.7 1998/08/17 03:50:43 scrappy Exp $
*
* NOTES
* This shouldn't be in libpq, but the monitor and some other
*-------------------------------------------------------------------------
*/
#include
-
#include
-#include "libpq/pqsignal.h"
+#include "pqsignal.h"
pqsigfunc
pqsignal(int signo, pqsigfunc func)
projects / postgresql.git / commitdiff