2015-01-19 21:47:09 +00:00
|
|
|
#include <stdio.h>
|
|
|
|
#include <string.h>
|
|
|
|
|
2015-01-23 04:59:47 +00:00
|
|
|
#include "libretrodb.h"
|
2015-01-19 21:47:09 +00:00
|
|
|
#include "rmsgpack_dom.h"
|
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
int main(int argc, char ** argv)
|
|
|
|
{
|
|
|
|
int rv;
|
|
|
|
libretrodb_t db;
|
|
|
|
libretrodb_cursor_t cur;
|
2015-01-23 04:59:47 +00:00
|
|
|
libretrodb_query_t *q;
|
2015-01-24 03:04:56 +00:00
|
|
|
struct rmsgpack_dom_value item;
|
2015-01-23 04:59:47 +00:00
|
|
|
const char *command, *path, *query_exp, *error;
|
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
if (argc < 3)
|
|
|
|
{
|
|
|
|
printf("Usage: %s <db file> <command> [extra args...]\n", argv[0]);
|
|
|
|
printf("Available Commands:\n");
|
|
|
|
printf("\tlist\n");
|
|
|
|
printf("\tcreate-index <index name> <field name>\n");
|
|
|
|
printf("\tfind <query expression>\n");
|
|
|
|
return 1;
|
|
|
|
}
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
command = argv[2];
|
|
|
|
path = argv[1];
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
if ((rv = libretrodb_open(path, &db)) != 0)
|
|
|
|
{
|
|
|
|
printf("Could not open db file '%s': %s\n", path, strerror(-rv));
|
|
|
|
return 1;
|
|
|
|
}
|
2015-06-14 17:42:25 +00:00
|
|
|
else if (!strcmp(command, "list"))
|
2015-01-24 03:04:56 +00:00
|
|
|
{
|
|
|
|
if ((rv = libretrodb_cursor_open(&db, &cur, NULL)) != 0)
|
|
|
|
{
|
|
|
|
printf("Could not open cursor: %s\n", strerror(-rv));
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (argc != 3)
|
|
|
|
{
|
|
|
|
printf("Usage: %s <db file> list\n", argv[0]);
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
|
|
|
while (libretrodb_cursor_read_item(&cur, &item) == 0)
|
|
|
|
{
|
|
|
|
rmsgpack_dom_value_print(&item);
|
|
|
|
printf("\n");
|
|
|
|
rmsgpack_dom_value_free(&item);
|
|
|
|
}
|
|
|
|
}
|
2015-06-14 17:42:25 +00:00
|
|
|
else if (!strcmp(command, "find"))
|
2015-01-24 03:04:56 +00:00
|
|
|
{
|
|
|
|
if (argc != 4)
|
|
|
|
{
|
|
|
|
printf("Usage: %s <db file> find <query expression>\n", argv[0]);
|
|
|
|
return 1;
|
|
|
|
}
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
query_exp = argv[3];
|
|
|
|
error = NULL;
|
|
|
|
q = libretrodb_query_compile(&db, query_exp, strlen(query_exp), &error);
|
2015-01-23 04:59:47 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
if (error)
|
|
|
|
{
|
|
|
|
printf("%s\n", error);
|
|
|
|
return 1;
|
|
|
|
}
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
if ((rv = libretrodb_cursor_open(&db, &cur, q)) != 0)
|
2015-01-23 04:59:47 +00:00
|
|
|
{
|
2015-01-24 03:04:56 +00:00
|
|
|
printf("Could not open cursor: %s\n", strerror(-rv));
|
|
|
|
return 1;
|
|
|
|
}
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
while (libretrodb_cursor_read_item(&cur, &item) == 0)
|
2015-01-23 04:59:47 +00:00
|
|
|
{
|
2015-01-24 03:04:56 +00:00
|
|
|
rmsgpack_dom_value_print(&item);
|
|
|
|
printf("\n");
|
|
|
|
rmsgpack_dom_value_free(&item);
|
|
|
|
}
|
|
|
|
}
|
2015-06-14 17:42:25 +00:00
|
|
|
else if (!strcmp(command, "create-index"))
|
2015-01-24 03:04:56 +00:00
|
|
|
{
|
|
|
|
const char * index_name, * field_name;
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
if (argc != 5)
|
|
|
|
{
|
|
|
|
printf("Usage: %s <db file> create-index <index name> <field name>\n", argv[0]);
|
|
|
|
return 1;
|
|
|
|
}
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
index_name = argv[3];
|
|
|
|
field_name = argv[4];
|
2015-01-19 21:47:09 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
libretrodb_create_index(&db, index_name, field_name);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
{
|
2015-01-24 07:17:04 +00:00
|
|
|
printf("Unknown command %s\n", argv[2]);
|
2015-01-24 03:04:56 +00:00
|
|
|
return 1;
|
|
|
|
}
|
2015-01-27 03:02:10 +00:00
|
|
|
|
2015-01-24 03:04:56 +00:00
|
|
|
libretrodb_close(&db);
|
2015-01-27 03:02:10 +00:00
|
|
|
return 1;
|
2015-01-19 21:47:09 +00:00
|
|
|
}
|