parser3/src/sql/pgsql/parser3pgsql.C - diff

Return to parser3pgsql.C CVS log

Up to [parser3project] / parser3 / src / sql / pgsql

Diff for /parser3/src/sql/pgsql/Attic/parser3pgsql.C between versions 1.7 and 1.13

version 1.7, 2001/08/01 07:41:37	version 1.13, 2001/09/05 08:57:43
Line 14 static const char *RCSId="$Id$";	Line 14 static const char *RCSId="$Id$";
#include "pa_sql_driver.h"	#include "pa_sql_driver.h"

#include <libpq-fe.h>	#include <libpq-fe.h>
#include <libpq-fs.h>	#include <libpq/libpq-fs.h>

// #include <catalog/pg_type.h>	// OIDOID from catalog/pg_type.h
#define OIDOID 26	#define OIDOID 26
#define LO_BUFSIZE 0x1000/8192/	// LO_BUFSIZE from interfaces\libpq\fe-lobj.c = 8192 (0x2000)
	// actually writing chunks of that size failed, reduced it twice
	#define LO_BUFSIZE 0x1000
	// from postgres_ext.h
	#define InvalidOid ((Oid) 0)


#include "ltdl.h"	#include "ltdl.h"
Line 63 public:	Line 67 public:
return dlopen_file_spec?	return dlopen_file_spec?
dlink(dlopen_file_spec):"client library column is empty";	dlink(dlopen_file_spec):"client library column is empty";
}	}

	#define throwPQerror services._throw(PQerrorMessage(conn))

/** connect	/** connect
@param used_only_in_connect_url	@param used_only_in_connect_url
format: @b user:pass@host[:port]\|[local]/database	format: @b user:pass@host[:port]\|[local]/database
3.23.22b
Currently the only option for @b character_set_name is cp1251_koi8.
WARNING: must be used only to connect, for buffer doesn't live long
*/	*/
void connect(	void connect(
char *used_only_in_connect_url,	char *used_only_in_connect_url,
Line 81 public:	Line 85 public:
char *pwd=lsplit(user, ':');	char *pwd=lsplit(user, ':');
char *port=lsplit(host, ':');	char *port=lsplit(host, ':');

// _asm int 3;
PGconn *conn=PQsetdbLogin(	PGconn *conn=PQsetdbLogin(
strcasecmp(host, "local")==0?NULL/* local Unix domain socket */:host, port,	strcasecmp(host, "local")==0?NULL/* local Unix domain socket */:host, port,
NULL, NULL, db, user, pwd);	NULL, NULL, db, user, pwd);
if(!conn)	if(!conn)
services._throw("PQsetdbLogin failed");	services._throw("PQsetdbLogin failed");
if(PQstatus(conn)!=CONNECTION_OK)	if(PQstatus(conn)!=CONNECTION_OK)
services._throw(PQerrorMessage(conn));	throwPQerror;

(PGconn *)connection=conn;	(PGconn *)connection=conn;
begin_transaction(services, conn);	begin_transaction(services, conn);
}	}
void disconnect(SQL_Driver_services&, void *connection) {	void disconnect(void *connection) {
// _asm int 3;
PQfinish((PGconn *)connection);	PQfinish((PGconn *)connection);
}	}
void commit(SQL_Driver_services& services, void *connection) {	void commit(SQL_Driver_services& services, void *connection) {
// _asm int 3;
PGconn conn=(PGconn )connection;	PGconn conn=(PGconn )connection;
if(PGresult *res=PQexec(conn, "COMMIT"))	if(PGresult *res=PQexec(conn, "COMMIT"))
PQclear(res);	PQclear(res);
else	else
services._throw(PQerrorMessage(conn));	throwPQerror;
begin_transaction(services, conn);	begin_transaction(services, conn);
}	}
void rollback(SQL_Driver_services& services, void *connection) {	void rollback(SQL_Driver_services& services, void *connection) {
// _asm int 3;
PGconn conn=(PGconn )connection;	PGconn conn=(PGconn )connection;
if(PGresult *res=PQexec(conn, "ROLLBACK"))	if(PGresult *res=PQexec(conn, "ROLLBACK"))
PQclear(res);	PQclear(res);
else	else
services._throw(PQerrorMessage(conn));	throwPQerror;
begin_transaction(services, conn);	begin_transaction(services, conn);
}	}

Line 158 public:	Line 158 public:

PGresult *res=PQexec(conn, statement);	PGresult *res=PQexec(conn, statement);
if(!res)	if(!res)
services._throw(PQerrorMessage(conn));	throwPQerror;

switch(PQresultStatus(res)) {	switch(PQresultStatus(res)) {
case PGRES_EMPTY_QUERY:	case PGRES_EMPTY_QUERY:
Line 198 public:	Line 198 public:
void *ptr;	void *ptr;
if(PQftype(res, i)==OIDOID) {	if(PQftype(res, i)==OIDOID) {
// ObjectID column, read object bytes	// ObjectID column, read object bytes
// _asm int 3;

char *error_pos=0;	char *error_pos=0;
Oid oid=cell?atoi(cell):0;	Oid oid=cell?atoi(cell):0;
Line 227 public:	Line 226 public:
} else	} else
PQclear_throwPQerror;	PQclear_throwPQerror;
} else {	} else {
// normal column, read it as ASCII string	// normal column, read it normally
size=(size_t)PQgetlength(res, r, i);	size=(size_t)PQgetlength(res, r, i);
if(size) {	if(size) {
ptr=services.malloc(size);	ptr=services.malloc(size);
Line 248 private: // private funcs	Line 247 private: // private funcs
if(PGresult *res=PQexec(conn, "BEGIN"))	if(PGresult *res=PQexec(conn, "BEGIN"))
PQclear(res);	PQclear(res);
else	else
services._throw(PQerrorMessage(conn));	throwPQerror;
}	}

const char preprocess_statement(SQL_Driver_services& services, PGconn conn,	const char preprocess_statement(SQL_Driver_services& services, PGconn conn,
const char *astatement, unsigned long offset, unsigned long limit) {	const char *astatement, unsigned long offset, unsigned long limit) {
size_t statement_size=strlen(astatement);	size_t statement_size=strlen(astatement);
//_asm int 3;

#define throwPQerror services._throw(PQerrorMessage(conn))

char result=(char )services.malloc(statement_size	char result=(char )services.malloc(statement_size
+MAX_NUMBER*2+15 // limit # offset #	+MAX_NUMBER*2+15 // limit # offset #
Line 427 private: // conn client library funcs li	Line 423 private: // conn client library funcs li

};	};

extern "C" SQL_Driver *create() {	extern "C" SQL_Driver *SQL_DRIVER_CREATE_FUNC_NAME() {
return new PgSQL_Driver();	return new PgSQL_Driver();
}	}

E-mail:

Removed from v.1.7
changed lines
	Added in v.1.13