/* gcc example.c -o example $(pkg-config --cflags --libs libmongoc-1.0) */

/* ./example-client [CONNECTION_STRING [COLLECTION_NAME]] */

#include <mongoc.h>
#include <stdio.h>
#include <stdlib.h>

#include <unistd.h>

#define TEST_NUM 1000000

int
main (int   argc,
      char *argv[])
{
   int i = 0;
   int fail = 0;

   mongoc_client_t *client;
   mongoc_collection_t *collection;
   mongoc_cursor_t *cursor;
   bson_error_t error;
   const bson_t *doc;
   const char *uristr = "mongodb://127.0.0.1/";
   const char *collection_name = "test";
   bson_t query;
   char *str;

   mongoc_init ();

   for (i = 0; i < TEST_NUM; i++){
      printf("%d/%d/%d\n", i, fail, TEST_NUM);

      client = mongoc_client_new (uristr);

      if (!client) {
         fprintf (stderr, "Failed to parse URI.\n");
         return EXIT_FAILURE;
      }

      bson_init (&query);

      collection = mongoc_client_get_collection (client, "test", collection_name);
      cursor = mongoc_collection_find (collection,
                                       MONGOC_QUERY_NONE,
                                       0,
                                       0,
                                       0,
                                       &query,
                                       NULL,  /* Fields, NULL for all. */
                                       NULL); /* Read Prefs, NULL for default */

      while (mongoc_cursor_next (cursor, &doc)) {
         str = bson_as_json (doc, NULL);
         fprintf (stdout, "%s\n", str);
         bson_free (str);
      }

      if (mongoc_cursor_error (cursor, &error)) {
         fprintf (stderr, "Cursor Failure: %s\n", error.message);
         fail++;
         //return EXIT_FAILURE;
      }

      bson_destroy (&query);
      mongoc_cursor_destroy (cursor);
      mongoc_collection_destroy (collection);
      mongoc_client_destroy (client);

      usleep(1000);
   }

   mongoc_cleanup ();

   return EXIT_SUCCESS;
}