[irc/quakenet/newserv.git] / pqsql / pqsql-dbapi2.c

#define USE_DBAPI_PGSQL
#define DBAPI2_ADAPTER_NAME "pqsql"
#define DBAPI2_CUSTOM_QUOTESTRING

#include "../dbapi2/dbapi2-adapter.inc"

MODULE_VERSION("");

void _init() {
  if(pqconnected())
    registeradapterprovider();
}

void _fini() {
  deregisteradapterprovider();
}

static int dbapi2_adapter_quotestring(const DBAPIConn *db, char *buf, size_t buflen, const char *data, size_t len) {
  StringBuf b;
  sbinit(&b, buf, buflen);
  char xbuf[len * 2 + 5];
  size_t esclen;

  esclen = dbescapestring(xbuf, (char *)data, len);
  sbaddchar(&b, '\'');
  sbaddstrlen(&b, xbuf, esclen);
  sbaddchar(&b, '\'');

  if(!sbterminate(&b))
    return 0;

  return 1;
}
Commit	Line	Data
39c33a3d CP	1	#define USE_DBAPI_PGSQL
	2	#define DBAPI2_ADAPTER_NAME "pqsql"
	3	#define DBAPI2_CUSTOM_QUOTESTRING
	4
	5	#include "../dbapi2/dbapi2-adapter.inc"
	6
8f072e42 CP	7	MODULE_VERSION("");
8f072e42 CP	8
39c33a3d CP	9	void _init() {
	10	if(pqconnected())
	11	registeradapterprovider();
	12	}
	13
	14	void _fini() {
	15	deregisteradapterprovider();
	16	}
	17
4a532778	18	static int dbapi2_adapter_quotestring(const DBAPIConn db, char buf, size_t buflen, const char *data, size_t len) {
39c33a3d CP	19	StringBuf b;
	20	sbinit(&b, buf, buflen);
	21	char xbuf[len * 2 + 5];
	22	size_t esclen;
	23
	24	esclen = dbescapestring(xbuf, (char *)data, len);
8a2b856f	25	sbaddchar(&b, '\'');
39c33a3d CP	26	sbaddstrlen(&b, xbuf, esclen);
39c33a3d CP	27	sbaddchar(&b, '\'');
2667bceb CP	28
2667bceb CP	29	if(!sbterminate(&b))
39c33a3d	30	return 0;
2667bceb	31
39c33a3d CP	32	return 1;
39c33a3d CP	33	}