X-Git-Url: http://sigaev.ru/git/gitweb.cgi?p=ftsbench.git;a=blobdiff_plain;f=pgdriver.c;fp=pgdriver.c;h=0a373b6e383ae577905c355c4809a2e120bf0915;hp=1ee408aceaba1091b1f42be503746517fa7f5a93;hb=f49cd0e73b63f89a2ace96e341aea51135cbae4b;hpb=4dac833f9fc978646c9202f789e437f175db7215

diff --git a/pgdriver.c b/pgdriver.c
index 1ee408a..0a373b6 100644
--- a/pgdriver.c
+++ b/pgdriver.c
@@ -415,6 +415,13 @@ InsertRow(ftsDB* adb, int id, char *txt) {
 	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));
@@ -436,6 +443,7 @@ PGInit(char * connstr) {
 	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");