projects
/
ftsbench.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Add close() call
[ftsbench.git]
/
pgdriver.c
diff --git
a/pgdriver.c
b/pgdriver.c
index
1ee408a
..
0a373b6
100644
(file)
--- a/
pgdriver.c
+++ b/
pgdriver.c
@@
-415,6
+415,13
@@
InsertRow(ftsDB* adb, int id, char *txt) {
db->db.nquery++;
}
db->db.nquery++;
}
+static void
+Close(ftsDB* adb) {
+ ftsPG *db = (ftsPG*)adb;
+
+ PQfinish(db->conn);
+}
+
ftsDB*
PGInit(char * connstr) {
ftsPG *db = (ftsPG*)malloc(sizeof(ftsPG));
ftsDB*
PGInit(char * connstr) {
ftsPG *db = (ftsPG*)malloc(sizeof(ftsPG));
@@
-436,6
+443,7
@@
PGInit(char * connstr) {
db->db.startCreateScheme = startCreateScheme;
db->db.finishCreateScheme = finishCreateScheme;
db->db.InsertRow = InsertRow;
db->db.startCreateScheme = startCreateScheme;
db->db.finishCreateScheme = finishCreateScheme;
db->db.InsertRow = InsertRow;
+ db->db.Close = Close;
db->socket = PQsocket(db->conn);
if ( db->socket < 0 ) {
fprintf(stderr,"Socket error\n");
db->socket = PQsocket(db->conn);
if ( db->socket < 0 ) {
fprintf(stderr,"Socket error\n");