*
*
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.12 1996/07/31 18:40:09 scrappy Exp $
+ * $Header: /cvsroot/pgsql/src/interfaces/libpq/fe-exec.c,v 1.12.2.1 1996/08/27 17:37:27 scrappy Exp $
*
*-------------------------------------------------------------------------
*/
#define TUPARR_GROW_BY 100
/* keep this in same order as ExecStatusType in pgtclCmds.h */
-char* pgresStatus[] = {
+const char* pgresStatus[] = {
"PGRES_EMPTY_QUERY",
"PGRES_COMMAND_OK",
"PGRES_TUPLES_OK",
char bmap; /* One byte of the bitmap */
int bitcnt = 0; /* number of bits examined in current byte */
int vlen; /* length of the current field value */
- FILE *Pfin = conn->Pfin;
- FILE *Pfdebug = conn->Pfdebug;
+ FILE *pfin = conn->Pfin;
+ FILE *pfdebug = conn->Pfdebug;
PGresAttValue* tup;
if ( (nfields % BYTELEN) > 0)
nbytes++;
- if (pqGetnchar(bitmap, nbytes, Pfin, Pfdebug) == 1){
+ if (pqGetnchar(bitmap, nbytes, pfin, pfdebug) == 1){
sprintf(conn->errorMessage,
"Error reading null-values bitmap from tuple data stream\n");
return NULL;
for (i=0;i<nfields;i++) {
if (!(bmap & 0200)) {
/* if the field value is absent, make it '\0' */
- /* XXX this makes it impossible to distinguish NULL
- attributes from "". Is that OK? */
tup[i].value = (char*)malloc(1);
tup[i].value[0] = '\0';
- tup[i].len = 0;
+ tup[i].len = NULL_LEN;
}
else {
/* get the value length (the first four bytes are for length) */
- pqGetInt(&vlen, VARHDRSZ, Pfin, Pfdebug);
+ pqGetInt(&vlen, VARHDRSZ, pfin, pfdebug);
if (binary == 0) {
vlen = vlen - VARHDRSZ;
}
tup[i].value = (char*) malloc(vlen + 1);
/* read in the value; */
if (vlen > 0)
- pqGetnchar((char*)(tup[i].value), vlen, Pfin, Pfdebug);
+ pqGetnchar((char*)(tup[i].value), vlen, pfin, pfdebug);
tup[i].value[vlen] = '\0';
}
/* get the appropriate bitmap */
PGresAttValue* newTup;
- FILE* Pfin = conn->Pfin;
- FILE* Pfdebug = conn->Pfdebug;
+ FILE* pfin = conn->Pfin;
+ FILE* pfdebug = conn->Pfdebug;
result = makeEmptyPGresult(conn, PGRES_TUPLES_OK);
/* id of the stream is 'T' to start with */
/* the next two bytes are the number of fields */
- if (pqGetInt(&nfields, 2, Pfin, Pfdebug) == 1) {
+ if (pqGetInt(&nfields, 2, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"could not get the number of fields from the 'T' message\n");
goto makePGresult_badResponse_return;
int adtid;
int adtsize;
- if ( pqGets(typName, MAX_MESSAGE_LEN, Pfin, Pfdebug) ||
- pqGetInt(&adtid, 4, Pfin, Pfdebug) ||
- pqGetInt(&adtsize, 2, Pfin, Pfdebug)) {
+ if ( pqGets(typName, MAX_MESSAGE_LEN, pfin, pfdebug) ||
+ pqGetInt(&adtid, 4, pfin, pfdebug) ||
+ pqGetInt(&adtsize, 2, pfin, pfdebug)) {
sprintf(conn->errorMessage,
"error reading type information from the 'T' message\n");
goto makePGresult_badResponse_return;
result->attDescs[i].adtsize = adtsize; /* casting from int to int2 here */
}
- id = pqGetc(Pfin,Pfdebug);
+ id = pqGetc(pfin,pfdebug);
/* process the data stream until we're finished */
while(!done) {
case 'C': /* end of portal tuple stream */
{
char command[MAX_MESSAGE_LEN];
- pqGets(command,MAX_MESSAGE_LEN, Pfin, Pfdebug); /* read the command tag */
+ pqGets(command,MAX_MESSAGE_LEN, pfin, pfdebug); /* read the command tag */
done = 1;
}
break;
case 'E': /* errors */
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"Error return detected from backend, but error message cannot be read");
}
return result;
break;
case 'N': /* notices from the backend */
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"Notice return detected from backend, but error message cannot be read");
} else
break;
}
if (!done)
- id = getc(Pfin);
+ id = getc(pfin);
} /* while (1) */
result->resultStatus = PGRES_TUPLES_OK;
*/
PGresult*
-PQexec(PGconn* conn, char* query)
+PQexec(PGconn* conn, const char* query)
{
PGresult *result;
int id, clear;
char cmdStatus[MAX_MESSAGE_LEN];
char pname[MAX_MESSAGE_LEN]; /* portal name */
PGnotify *newNotify;
- FILE *Pfin, *Pfout, *Pfdebug;
+ FILE *pfin, *pfout, *pfdebug;
pname[0]='\0';
return NULL;
}
- Pfin = conn->Pfin;
- Pfout = conn->Pfout;
- Pfdebug = conn->Pfdebug;
+ pfin = conn->Pfin;
+ pfout = conn->Pfout;
+ pfdebug = conn->Pfdebug;
/*clear the error string */
conn->errorMessage[0] = '\0';
/* check to see if the query string is too long */
if (strlen(query) > MAX_MESSAGE_LEN) {
- sprintf(conn->errorMessage, "PQexec() -- query is too long. Maximum length is %d\n", MAX_MESSAGE_LEN -2 );
+ sprintf(conn->errorMessage, "PQexec() -- query is too long. "
+ "Maximum length is %d\n", MAX_MESSAGE_LEN -2 );
return NULL;
}
+ /* Don't try to send if we know there's no live connection. */
+ if (conn->status != CONNECTION_OK) {
+ sprintf(conn->errorMessage, "PQexec() -- There is no connection "
+ "to the backend.\n");
+ return NULL;
+ }
+
/* the frontend-backend protocol uses 'Q' to designate queries */
sprintf(buffer,"Q%s",query);
/* send the query to the backend; */
- if (pqPuts(buffer,Pfout, Pfdebug) == 1) {
+ if (pqPuts(buffer,pfout, pfdebug) == 1) {
(void) sprintf(conn->errorMessage,
- "PQexec() -- while sending query: %s\n-- fprintf to Pfout failed: errno=%d\n%s\n",
+ "PQexec() -- while sending query: %s\n"
+ "-- fprintf to Pfout failed: errno=%d\n%s\n",
query, errno,strerror(errno));
return NULL;
}
while (1) {
/* read the result id */
- id = pqGetc(Pfin,Pfdebug);
+ id = pqGetc(pfin,pfdebug);
if (id == EOF) {
/* hmm, no response from the backend-end, that's bad */
(void) sprintf(conn->errorMessage,
- "PQexec() -- No response from backend\n");
+ "PQexec() -- Request was sent to backend, but backend "
+ "closed the channel before "
+ "responding. This probably means the backend "
+ "terminated abnormally before or while processing "
+ "the request.\n");
+ conn->status = CONNECTION_BAD; /* No more connection to backend */
return (PGresult*)NULL;
}
switch (id) {
case 'A':
newNotify = (PGnotify*)malloc(sizeof(PGnotify));
- pqGetInt(&(newNotify->be_pid), 4, Pfin, Pfdebug);
- pqGets(newNotify->relname, NAMEDATALEN, Pfin, Pfdebug);
+ pqGetInt(&(newNotify->be_pid), 4, pfin, pfdebug);
+ pqGets(newNotify->relname, NAMEDATALEN, pfin, pfdebug);
DLAddTail(conn->notifyList, DLNewElem(newNotify));
/* async messages are piggy'ed back on other messages,
so we stay in the while loop for other messages */
break;
case 'C': /* portal query command, no tuples returned */
- if (pqGets(cmdStatus, MAX_MESSAGE_LEN, Pfin, Pfdebug) == 1) {
+ if (pqGets(cmdStatus, MAX_MESSAGE_LEN, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"PQexec() -- query command completed, but return message from backend cannot be read");
return (PGresult*)NULL;
*/
clear = 0;
- pqPuts("Q ",Pfout,Pfdebug); /* send an empty query */
+ pqPuts("Q ",pfout,pfdebug); /* send an empty query */
while (!clear)
{
- if (pqGets(buffer,ERROR_MSG_LENGTH,Pfin,Pfdebug) == 1)
+ if (pqGets(buffer,ERROR_MSG_LENGTH,pfin,pfdebug) == 1)
clear = 1;
clear = (buffer[0] == 'I');
}
}
break;
case 'E': /* error return */
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
(void) sprintf(conn->errorMessage,
"PQexec() -- error return detected from backend, but error message cannot be read");
}
/* read the throw away the closing '\0' */
{
int c;
- if ((c = pqGetc(Pfin,Pfdebug)) != '\0') {
+ if ((c = pqGetc(pfin,pfdebug)) != '\0') {
fprintf(stderr,"error!, unexpected character %c following 'I'\n", c);
}
result = makeEmptyPGresult(conn, PGRES_EMPTY_QUERY);
}
break;
case 'N': /* notices from the backend */
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"PQexec() -- error return detected from backend, but error message cannot be read");
return (PGresult*)NULL;
fprintf(stderr,"%s", conn->errorMessage);
break;
case 'P': /* synchronous (normal) portal */
- pqGets(pname,MAX_MESSAGE_LEN,Pfin, Pfdebug); /* read in the portal name*/
+ pqGets(pname,MAX_MESSAGE_LEN,pfin, pfdebug); /* read in the portal name*/
break;
case 'T': /* actual tuple results: */
return makePGresult(conn, pname);
*
*/
void
-PQputline(PGconn *conn, char *s)
+PQputline(PGconn *conn, const char *s)
{
if (conn && (conn->Pfout)) {
(void) fputs(s, conn->Pfout);
PQendcopy(PGconn *conn)
{
char id;
- FILE *Pfin, *Pfdebug;
+ FILE *pfin, *pfdebug;
if (!conn) return (int)NULL;
- Pfin = conn->Pfin;
- Pfdebug = conn->Pfdebug;
+ pfin = conn->Pfin;
+ pfdebug = conn->Pfdebug;
- if ( (id = pqGetc(Pfin,Pfdebug)) > 0)
+ if ( (id = pqGetc(pfin,pfdebug)) > 0)
return(0);
switch (id) {
case 'Z': /* backend finished the copy */
return(1);
case 'E':
case 'N':
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"Error return detected from backend, but error message cannot be read");
}
PQdisplayTuples(PGresult *res,
FILE *fp, /* where to send the output */
int fillAlign, /* pad the fields with spaces */
- char *fieldSep, /* field separator */
+ const char *fieldSep, /* field separator */
int printHeader, /* display headers? */
int quiet
)
int fLength[MAX_FIELDS];
if (fieldSep == NULL)
- fieldSep == DEFAULT_FIELD_SEP;
+ fieldSep = DEFAULT_FIELD_SEP;
/* Get some useful info about the results */
nFields = PQnfields(res);
{
if ((fs_len==1 && (*p==*(po->fieldSep))) || *p=='\\')
*(o++)='\\';
- if (po->align && !((*p >='0' && *p<='9') || *p=='.' || *p=='E' || *p=='e' || *p==' ' || *p=='-'))
+ if (po->align && (*pval=='E' || *pval=='e' ||
+ !((*p>='0' && *p<='9') || *p=='.' || *p=='E' || *p=='e' || *p==' ' || *p=='-')))
fieldNotNum[j]=1;
}
*o='\0';
PQArgBlock *args,
int nargs)
{
- FILE *Pfin, *Pfout, *Pfdebug;
+ FILE *pfin, *pfout, *pfdebug;
int id;
int i;
if (!conn) return NULL;
- Pfin = conn->Pfin;
- Pfout = conn->Pfout;
- Pfdebug = conn->Pfdebug;
+ pfin = conn->Pfin;
+ pfout = conn->Pfout;
+ pfdebug = conn->Pfdebug;
/* clear the error string */
conn->errorMessage[0] = '\0';
- pqPuts("F ",Pfout,Pfdebug); /* function */
- pqPutInt(fnid, 4, Pfout, Pfdebug); /* function id */
- pqPutInt(nargs, 4, Pfout, Pfdebug); /* # of args */
+ pqPuts("F ",pfout,pfdebug); /* function */
+ pqPutInt(fnid, 4, pfout, pfdebug); /* function id */
+ pqPutInt(nargs, 4, pfout, pfdebug); /* # of args */
for (i = 0; i < nargs; ++i) { /* len.int4 + contents */
- pqPutInt(args[i].len, 4, Pfout, Pfdebug);
+ pqPutInt(args[i].len, 4, pfout, pfdebug);
if (args[i].isint) {
- pqPutInt(args[i].u.integer, 4, Pfout, Pfdebug);
+ pqPutInt(args[i].u.integer, 4, pfout, pfdebug);
} else {
- pqPutnchar((char *)args[i].u.ptr, args[i].len, Pfout, Pfdebug);
+ pqPutnchar((char *)args[i].u.ptr, args[i].len, pfout, pfdebug);
}
}
- pqFlush(Pfout, Pfdebug);
+ pqFlush(pfout, pfdebug);
- id = pqGetc(Pfin, Pfdebug);
+ id = pqGetc(pfin, pfdebug);
if (id != 'V') {
if (id == 'E') {
- pqGets(conn->errorMessage,ERROR_MSG_LENGTH,Pfin,Pfdebug);
+ pqGets(conn->errorMessage,ERROR_MSG_LENGTH,pfin,pfdebug);
} else
sprintf(conn->errorMessage,
"PQfn: expected a 'V' from the backend. Got '%c' instead",
return makeEmptyPGresult(conn,PGRES_FATAL_ERROR);
}
- id = pqGetc(Pfin, Pfdebug);
+ id = pqGetc(pfin, pfdebug);
for (;;) {
int c;
switch (id) {
case 'G': /* function returned properly */
- pqGetInt(actual_result_len,4,Pfin,Pfdebug);
+ pqGetInt(actual_result_len,4,pfin,pfdebug);
if (result_is_int) {
- pqGetInt(result_buf,4,Pfin,Pfdebug);
+ pqGetInt(result_buf,4,pfin,pfdebug);
} else {
pqGetnchar((char *) result_buf, *actual_result_len,
- Pfin, Pfdebug);
+ pfin, pfdebug);
}
- c = pqGetc(Pfin, Pfdebug); /* get the last '0'*/
+ c = pqGetc(pfin, pfdebug); /* get the last '0'*/
return makeEmptyPGresult(conn,PGRES_COMMAND_OK);
case 'E':
sprintf(conn->errorMessage,
return makeEmptyPGresult(conn,PGRES_FATAL_ERROR);
case 'N':
/* print notice and go back to processing return values */
- if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, Pfin, Pfdebug) == 1) {
+ if (pqGets(conn->errorMessage, ERROR_MSG_LENGTH, pfin, pfdebug) == 1) {
sprintf(conn->errorMessage,
"Notice return detected from backend, but error message cannot be read");
} else
returns -1 on a bad field name
*/
int
-PQfnumber(PGresult *res, char* field_name)
+PQfnumber(PGresult *res, const char* field_name)
{
int i;
if the last command was an INSERT, return the oid string
if not, return ""
*/
-char* PQoidStatus(PGresult *res) {
+const char* PQoidStatus(PGresult *res) {
if (!res) {
fprintf(stderr, "PQoidStatus() -- pointer to PQresult is null");
return NULL;
"PQgetlength: ERROR! field %d(of %d) of tuple %d(of %d) is not available",
field_num, res->numAttributes - 1, tup_num, res->ntups);
}
-
- return res->tuples[tup_num][field_num].len;
+
+ if (res->tuples[tup_num][field_num].len != NULL_LEN)
+ return res->tuples[tup_num][field_num].len;
+ else
+ return 0;
+ }
+
+/* PQgetisnull:
+ returns the null status of a field value.
+*/
+int
+PQgetisnull(PGresult *res, int tup_num, int field_num)
+{
+ if (!res) {
+ fprintf(stderr, "PQgetisnull() -- pointer to PQresult is null");
+ return (int)NULL;
+ }
+
+ if (tup_num > (res->ntups - 1 )||
+ field_num > (res->numAttributes - 1)) {
+ fprintf(stderr,
+ "PQgetisnull: ERROR! field %d(of %d) of tuple %d(of %d) is not available",
+ field_num, res->numAttributes - 1, tup_num, res->ntups);
+ }
+
+ if (res->tuples[tup_num][field_num].len == NULL_LEN)
+ return 1;
+ else
+ return 0;
}
+
+
projects / postgresql / commitdiff