Add close() call

[ftsbench.git] / mysqldriver.c

diff --git a/mysqldriver.c b/mysqldriver.c
index be64aa4..034a37a 100644 (file)
--- a/mysqldriver.c
+++ b/mysqldriver.c
@@ -215,6 +215,13 @@ InsertRow(ftsDB *adb, int id, char *txt) {
        }
 }
 
+static void
+Close(ftsDB* adb) {  
+    ftsMY *db = (ftsMY*)adb;
+
+       mysql_close(db->conn);
+}
+
 ftsDB* 
 MYInit(char * connstr) {
        ftsMY   *db = (ftsMY*)malloc(sizeof(ftsMY));
@@ -232,6 +239,7 @@ MYInit(char * connstr) {
        db->db.startCreateScheme = startCreateScheme;
        db->db.finishCreateScheme = finishCreateScheme;
        db->db.InsertRow = InsertRow;
+       db->db.Close = Close;
        
        return (ftsDB*)db;
 }