fflush(stdout);
db->finishCreateScheme(db);
printf("done\n");
+ db->Close(db);
} else {
ftsDB **dbs = initConnections(rdbms, nclients, dbname);
pthread_t *tid = (pthread_t*)malloc( sizeof(pthread_t) * nclients);
elapsed = elapsedtime(&begin);
pthread_mutex_unlock( &mutexFinish );
- for(i=0;i<nclients;i++)
+ for(i=0;i<nclients;i++) {
pthread_join(tid[i], NULL);
+ dbs[i]->Close(dbs[i]);
+ }
printf("\r%d(%.02f%%) queries proceed\n", total, (100.0*(float)total)/(nclients * n));
printf("Total time: %.02f sec, Queries per second: %.02f\n", elapsed, total/elapsed);