diff --git a/Makefile b/Makefile new file mode 100644 index 0000000..a58340a --- /dev/null +++ b/Makefile @@ -0,0 +1,3 @@ +all: mdbx +mdbx: mdbx.c + gcc mdbx.c -I /usr/include/libmdbx -L /usr/include/libmdbx -Wl,-R/usr/include/libmdbx -lmdbx -lm -o mdbx diff --git a/README.md b/README.md index 7e852e8..981826c 100644 --- a/README.md +++ b/README.md @@ -1,3 +1,25 @@ -# libmdbx +# Простой консольный клиент для libmdbx -Консольный клиент для libmbdx \ No newline at end of file +Libmdbx (https://libmdbx.dqdkfa.ru/) - встраиваемая БД типа ключ-значение российской разработки, продолжающая традиции Tokyo Cabinet и подобных. + + +Base and simple libmbdx cli frontent: + +- Support put, del and get +- Commit changes +- Not support interactive mode +- Not support DUPKEYS + +# Usage + +``` +mdbx [db_path...] [--help] [--del] [--put] [--get] [--info] [--del] + +``` + +Options: + +--put key value +--del key +--get key +--info - database info diff --git a/install.sh b/install.sh new file mode 100755 index 0000000..3bfc373 --- /dev/null +++ b/install.sh @@ -0,0 +1,17 @@ +#!/bin/sh + +MDBX_VERSION="0.11.13" + +set -ex + +DIRNAME="/usr/include/libmdbx" + +if [ -e $DIRNAME ]; then + rm -rf $DIRNAME +fi + +mkdir -p $DIRNAME +wget -P $DIRNAME https://libmdbx.dqdkfa.ru/release/libmdbx-amalgamated-${MDBX_VERSION}.tar.gz +cd /usr/include/libmdbx +tar xvzf libmdbx-amalgamated-${MDBX_VERSION}.tar.gz +make lib diff --git a/mdbx b/mdbx new file mode 100755 index 0000000..b066f01 Binary files /dev/null and b/mdbx differ diff --git a/mdbx.c b/mdbx.c new file mode 100644 index 0000000..6bae2b4 --- /dev/null +++ b/mdbx.c @@ -0,0 +1,168 @@ +/* + * Copyright 2015-2022 Leonid Yuriev . + * Copyright 2017 Ilya Shipitsin . + * Copyright 2012-2015 Howard Chu, Symas Corp. + * Copyright 2024 Zoviet, asustem.ru. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in the file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * . + */ + +#include "mdbx.h" +#include +#include +#include +#include +#include + +void help(void) { + printf("Usage: mdbx [db_path...] [--help] [--del] [--put] [--get] [--info] [--del]\n Options:\n--put key value :put key-value pair\n--del key :delete key\n--get key :get key\n--info :db info\n"); +} + +int main(int argc, char **argv) { + + int rc; + MDBX_env *env = NULL; + MDBX_dbi dbi = 0; + MDBX_val key, data; + MDBX_txn *txn = NULL; + MDBX_cursor *cursor = NULL; + char sval[32]; + +#if UINTPTR_MAX > 0xffffFFFFul || ULONG_MAX > 0xffffFFFFul + const double scale_factor = 1099511627776.0; + const char *const scale_unit = "TiB"; +#else + const double scale_factor = 1073741824.0; + const char *const scale_unit = "GiB"; +#endif + const size_t pagesize_min = mdbx_limits_pgsize_min(); + const size_t pagesize_max = mdbx_limits_pgsize_max(); + const size_t pagesize_default = mdbx_default_pagesize(); + + if(argc <= 1 || !strcmp(argv[1], "--help")) { + help(); + return 0; + } + + rc = mdbx_env_create(&env); + if (rc != MDBX_SUCCESS) { + fprintf(stderr, "mdbx_env_create: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + + rc = mdbx_env_open(env, argv[1], MDBX_NOSUBDIR | MDBX_COALESCE | MDBX_LIFORECLAIM, 0664); + if (rc != MDBX_SUCCESS) { + fprintf(stderr, "mdbx_env_open: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + + rc = mdbx_txn_begin(env, NULL, 0, &txn); + if (rc != MDBX_SUCCESS) { + fprintf(stderr, "mdbx_txn_begin: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + + rc = mdbx_dbi_open(txn, NULL, 0, &dbi); + if (rc != MDBX_SUCCESS) { + fprintf(stderr, "mdbx_dbi_open: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + + if(!strcmp(argv[2], "--put")) { + if(argc <= 4) { + printf("'--put' operation requires two parameters: key and value.\n"); + return 0; + } + key.iov_len = sizeof(argv[3]); + key.iov_base = argv[3]; + data.iov_len = sizeof(char) * (strlen(argv[4]) + 1); + data.iov_base = argv[4]; + rc = mdbx_put(txn, dbi, &key, &data, 0); + if (rc != MDBX_SUCCESS) { + fprintf(stderr, "mdbx_put: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + rc = mdbx_txn_commit(txn); + if (rc) { + fprintf(stderr, "mdbx_txn_commit: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + goto bailout; + } else if (!strcmp(argv[2], "--get")) { + if(argc <= 3) { + printf("'--get' operation requires key.\n"); + return 0; + } + key.iov_len = sizeof(argv[3]); + key.iov_base = argv[3]; + MDBX_val v = {0}; + rc = mdbx_get(txn, dbi, &key, &v); + if (rc != MDBX_SUCCESS) { + if (rc == MDBX_NOTFOUND) { + printf("Key '%s' not found", argv[3]); + goto bailout; + } + fprintf(stderr, "mdbx_put: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + printf("%s", (char *) v.iov_base); + goto bailout; + } else if (!strcmp(argv[2], "--del")) { + if(argc <= 3) { + printf("'--del' operation requires key.\n"); + return 0; + } + key.iov_len = sizeof(argv[3]); + key.iov_base = argv[3]; + rc = mdbx_del(txn, dbi, &key, NULL); + if (rc != MDBX_SUCCESS) { + if (rc == MDBX_EINVAL) { + printf("Key '%s' not found", argv[3]); + goto bailout; + } + fprintf(stderr, "mdbx_put: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + rc = mdbx_txn_commit(txn); + if (rc) { + fprintf(stderr, "mdbx_txn_commit: (%d) %s\n", rc, mdbx_strerror(rc)); + goto bailout; + } + goto bailout; + } else if (!strcmp(argv[2], "--info")) { + printf("\tWrite transaction size: up to %zu (0x%zX) pages (%f %s for default " + "%zuK pagesize, %f %s for %zuK pagesize).\n", + mdbx_limits_txnsize_max(pagesize_min) / pagesize_min, + mdbx_limits_txnsize_max(pagesize_min) / pagesize_min, + mdbx_limits_txnsize_max(-1) / scale_factor, scale_unit, + pagesize_default / 1024, + mdbx_limits_txnsize_max(pagesize_max) / scale_factor, scale_unit, + pagesize_max / 1024); + printf("\tDatabase size: up to %zu pages (%f %s for default %zuK " + "pagesize, %f %s for %zuK pagesize).\n", + mdbx_limits_dbsize_max(pagesize_min) / pagesize_min, + mdbx_limits_dbsize_max(-1) / scale_factor, scale_unit, + pagesize_default / 1024, + mdbx_limits_dbsize_max(pagesize_max) / scale_factor, scale_unit, + pagesize_max / 1024); + } else { + printf("Unknown parameter: '%s'. Type %s --help for help.\n", argv[2], argv[0]); + } + bailout: + if (cursor) + mdbx_cursor_close(cursor); + if (txn) + mdbx_txn_abort(txn); + if (dbi) + mdbx_dbi_close(env, dbi); + if (env) + mdbx_env_close(env); + return (rc != MDBX_SUCCESS) ? EXIT_FAILURE : EXIT_SUCCESS; + }