init
This commit is contained in:
parent
d4e92b9608
commit
ef6f07e5a0
3
Makefile
Normal file
3
Makefile
Normal file
@ -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
|
||||||
26
README.md
26
README.md
@ -1,3 +1,25 @@
|
|||||||
# libmdbx
|
# Простой консольный клиент для libmdbx
|
||||||
|
|
||||||
Консольный клиент для libmbdx
|
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
|
||||||
|
|||||||
17
install.sh
Executable file
17
install.sh
Executable file
@ -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
|
||||||
168
mdbx.c
Normal file
168
mdbx.c
Normal file
@ -0,0 +1,168 @@
|
|||||||
|
/*
|
||||||
|
* Copyright 2015-2022 Leonid Yuriev <leo@yuriev.ru>.
|
||||||
|
* Copyright 2017 Ilya Shipitsin <chipitsine@gmail.com>.
|
||||||
|
* 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
|
||||||
|
* <http://www.OpenLDAP.org/license.html>.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#include "mdbx.h"
|
||||||
|
#include <limits.h>
|
||||||
|
#include <stdint.h>
|
||||||
|
#include <stdio.h>
|
||||||
|
#include <stdlib.h>
|
||||||
|
#include <string.h>
|
||||||
|
|
||||||
|
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;
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user