From cb2a50691fb0cddb64e1b5a9ed242a6a0b42d503 Mon Sep 17 00:00:00 2001
From: Hristo Venev <hristo@venev.name>
Date: Mon, 22 Jun 2020 12:32:11 +0300
Subject: Initial commit.

---
 examples/print.c | 61 ++++++++++++++++++++++++++++++++++++++++
 examples/write.c | 84 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 145 insertions(+)
 create mode 100644 examples/print.c
 create mode 100644 examples/write.c

(limited to 'examples')

diff --git a/examples/print.c b/examples/print.c
new file mode 100644
index 0000000..066d33c
--- /dev/null
+++ b/examples/print.c
@@ -0,0 +1,61 @@
+// SPDX-License-Identifier: LGPL-3.0-or-later
+
+#include <hkvs.h>
+#include <string.h>
+#include <stdio.h>
+#include <fcntl.h>
+
+int main(int argc, char **argv) {
+	argc--;
+	argv++;
+	if(argc % 2 != 0) {
+		return 1;
+	}
+
+	(void)argc;
+	(void)argv;
+
+	int dfd = open("dbdir", O_RDONLY | O_DIRECTORY | O_CLOEXEC);
+	if(dfd < 0) {
+		fprintf(stderr, "Failed to open dbdir: %s\n", strerror(errno));
+		return 1;
+	}
+
+	hkvs_io *io = hkvs_io_new_unsafe_dirfd(dfd);
+	if(!io) {
+		fprintf(stderr, "Failed to create hkvs_io\n");
+		return 1;
+	}
+
+	hkvs *c;
+	int r = hkvs_new(&c, io);
+	if(r < 0) {
+		fprintf(stderr, "Failed to open database: %s\n", strerror(-r));
+		return 1;
+	}
+
+	for(size_t i = 0;; i++) {
+		hkvs_table *t = hkvs_table_at(c, i);
+		if(!t) break;
+		size_t key_size = hkvs_table_key_size(c, t);
+
+		printf("Table %zu: %u [key size = %zu]\n", i, hkvs_table_id(c, t), key_size);
+
+		hkvs_iter it;
+		hkvs_iter_open(c, t, &it);
+		const char *key;
+		for(hkvs_rid rid; hkvs_rid_ok((rid = hkvs_iter_next(c, t, &it, &key)));) {
+			char *val;
+			size_t val_size;
+			r = hkvs_record_value(c, t, rid, &val, &val_size);
+			if(r < 0) {
+				fprintf(stderr, "Error: %s\n", strerror(-r));
+				return 1;
+			}
+
+			printf("[%llu] %.*s: [%zu] %.*s\n", (unsigned long long)rid.id, (int)key_size, key, val_size, (int)val_size, val);
+		}
+	}
+
+	hkvs_free(c);
+}
diff --git a/examples/write.c b/examples/write.c
new file mode 100644
index 0000000..456fb8e
--- /dev/null
+++ b/examples/write.c
@@ -0,0 +1,84 @@
+// SPDX-License-Identifier: LGPL-3.0-or-later
+
+#include <hkvs.h>
+#include <string.h>
+#include <stdio.h>
+#include <fcntl.h>
+
+int main(int argc, char **argv) {
+	argc--;
+	argv++;
+	if(argc % 2 != 0) {
+		return 1;
+	}
+
+	(void)argc;
+	(void)argv;
+
+	int dfd = open("dbdir", O_RDONLY | O_DIRECTORY | O_CLOEXEC);
+	if(dfd < 0) {
+		fprintf(stderr, "Failed to open dbdir: %s\n", strerror(errno));
+		return 1;
+	}
+
+	hkvs_io *io = hkvs_io_new_unsafe_dirfd(dfd);
+	if(!io) {
+		fprintf(stderr, "Failed to create hkvs_io\n");
+		return 1;
+	}
+
+	hkvs *c;
+	int r = hkvs_new(&c, io);
+	if(r < 0) {
+		fprintf(stderr, "Failed to open database: %s\n", strerror(-r));
+		return 1;
+	}
+
+	hkvs_table *t;
+	r = hkvs_table_create(c, &t, 42, 4, 1);
+	if(r < 0) {
+		fprintf(stderr, "Failed to open table: %s\n", strerror(-r));
+		return 1;
+	}
+	if(r) {
+		printf("Created table\n");
+	}
+
+	while(argc) {
+		const char *key = *argv++;
+		const char *val = *argv++;
+		argc -= 2;
+		if(strlen(key) != 4) {
+			fprintf(stderr, "Bad arg length\n");
+			return 1;
+		}
+
+		hkvs_rid id = hkvs_record_find(c, t, key);
+		if(hkvs_rid_ok(id)) {
+			char *cur_val;
+			size_t cur_len;
+			r = hkvs_record_value(c, t, id, &cur_val, &cur_len);
+			if(r < 0) {
+				fprintf(stderr, "Failed to get record value: %s\n", strerror(-r));
+				return 1;
+			}
+			printf("%s: id=%llu [%zu] %.*s\n", key, (unsigned long long)id.id, cur_len, (int)cur_len, (const char*)cur_val);
+		} else {
+			printf("%s: not found\n", key);
+		}
+
+		if(!!strcmp(val, "-")) {
+			r = hkvs_record_update(c, t, &id, key, val, strlen(val));
+			if(r < 0) {
+				fprintf(stderr, "Failed to update record: %s\n", strerror(-r));
+				return 1;
+			}
+			printf("%s: wrote id=%llu\n", key, (unsigned long long)id.id);
+		} else if(hkvs_rid_ok(id)) {
+			hkvs_record_delete(c, t, id);
+			printf("%s: deleted\n", key);
+		}
+	}
+
+	hkvs_free(c);
+}
-- 
cgit