Skip to content

GitLab

Commit 7bcaa92d authored by Carsten Schlote's avatar Carsten Schlote
Browse files

Initial release

parents
Expand all Hide whitespace changes
Inline Side-by-side
.gitignore 0 → 100644
View file @ 7bcaa92d
.dub
docs.json
__dummy.html
lmdb-d
lmdb-d.so
lmdb-d.dylib
lmdb-d.dll
liblmdb-d.a
lmdb-d.lib
lmdb-d-test-*
*.exe
*.o
*.obj
*.lst
*~
.vscode/launch.json 0 → 100644
View file @ 7bcaa92d
{
// Use IntelliSense to learn about possible attributes.
// Hover to view descriptions of existing attributes.
// For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
"version": "0.2.0",
"configurations": [
{
"type": "gdb",
"request": "launch",
"name": "Launch Program (gdb)",
"target": "./lmdb-d",
"cwd": "${workspaceRoot}",
"preLaunchTask": "build-host",
"arguments": "-v"
},
{
"name": "Launch Program (lldb)",
"type": "lldb-mi",
"request": "launch",
"target": "./lmdb-d",
"preLaunchTask": "build-host",
"cwd": "${workspaceRoot}",
"arguments": "-v"
}
]
}
\ No newline at end of file
.vscode/tasks.json 0 → 100644
View file @ 7bcaa92d
{
// See https://go.microsoft.com/fwlink/?LinkId=733558
// for the documentation about the tasks.json format
"version": "2.0.0",
"tasks": [
{
// Requires dub and ldc to be installed on host
"label": "build-host",
"type": "shell",
"command": "dub build --compiler=ldc2 -v",
"group": {
"kind": "build",
"isDefault": true
},
"problemMatcher": [
"$gcc"
]
},
{
// Requires dub and ldc to be installed on host
"label": "test-host",
"type": "shell",
"command": "dub test --compiler=ldc2 -v",
"group": {
"kind": "build",
"isDefault": false
},
"problemMatcher": [
"$gcc"
]
},
{
// See https://wiki.dlang.org/Programming_in_D_tutorial_on_Embedded_Linux_ARM_devices
"label": "build-arm",
"type": "shell",
"command": "dub build --compiler=ldc-arm -v",
"group": {
"kind": "build",
"isDefault": false
},
"problemMatcher": [
"$gcc"
]
},
{
// See https://wiki.dlang.org/Programming_in_D_tutorial_on_Embedded_Linux_ARM_devices
"label": "test-arm",
"type": "shell",
"command": "dub test --compiler=ldc-arm -v",
"group": {
"kind": "build",
"isDefault": false
},
"problemMatcher": [
"$gcc"
]
},
{
"label": "clean",
"type": "shell",
"command": "dub clean -v",
"group": {
"kind": "build",
"isDefault": false
},
"problemMatcher": [
"$gcc"
]
},
{
"label": "build-doxygen",
"type": "shell",
"command": "dub clean -v",
"group": {
"kind": "build",
"isDefault": false
},
"problemMatcher": [
"$gcc"
]
}
]
}
\ No newline at end of file
Doxyfile 0 → 100644
View file @ 7bcaa92d
This diff is collapsed.
docs/.gitignore 0 → 100644
View file @ 7bcaa92d
html/
latex/
docs/lmdb++.h 0 → 100644
View file @ 7bcaa92d
This diff is collapsed.
docs/lmdb-d-demo/.gitignore 0 → 100644
View file @ 7bcaa92d
.dub
docs.json
__dummy.html
docs/
lmdb-d-demo.so
lmdb-d-demo.dylib
lmdb-d-demo.dll
lmdb-d-demo.a
lmdb-d-demo.lib
lmdb-d-demo-test-*
*.exe
*.o
*.obj
*.lst
docs/lmdb-d-demo/dub.json 0 → 100644
View file @ 7bcaa92d
{
"description": "Some example code for the lmdb binding.",
"license": "Public Domain",
"authors": [
"Carsten Schlote"
],
"copyright": "Created © 2018, Carsten Schlote",
"dependencies": {
"lmdb_d":"0.2.0"
},
"name": "lmdb-d-demo"
}
\ No newline at end of file
docs/lmdb-d-demo/dub.selections.json 0 → 100644
View file @ 7bcaa92d
{
"fileVersion": 1,
"versions": {
"lmdb-d": "0.1.0"
}
}
docs/lmdb-d-demo/source/main.d 0 → 100644
View file @ 7bcaa92d
/** lmdb bining test executable
* @file
*/
import core.stdc.string;
import std.bitmanip;
import std.conv;
import std.random;
import std.stdio;
import std.string;
import lmdb_d;
void main(const string[] args)
{
int major, minor, patch;
char* vstr_c = mdb_version(&major, &minor, &patch);
const string vstr = to!string(vstr_c);
writefln("The installed lmdb version is %s", vstr);
lmdb_toy1(args);
try {
lmdb_toy2(args);
lmdb_toy3(args);
}
catch (Exception ex) {
writeln("Catched exeception :", ex.msg);
}
}
bool check_rc(int rc, string msg, int line = __LINE__)
{
if (rc != 0)
{
writefln("%d:%s, rc = %s", line, msg, to!string(mdb_strerror(rc)) );
return false;
}
return true;
}
import lmdb;
/** Simple test for the low-level C library calls
*
*/
void lmdb_toy1(const string[] args)
{
int rc;
MDB_env* env;
MDB_dbi dbi;
MDB_val key, data;
MDB_txn* txn;
MDB_cursor* cursor;
uint dbi_flags;
int[] items;
const bool verbose = args.length >= 2 && args[1] == "-v" ? true : false;
/* Note: Most error checking omitted for simplicity */
rc = mdb_env_create(&env);
if (!check_rc(rc, "Can't create MDB env")) goto leave2;
rc = mdb_env_open(env, "./testdb", 0, std.conv.octal!664);
if (!check_rc(rc, "Can't open MDB file")) goto leave2;
rc = mdb_txn_begin(env, null, 0, &txn);
if (!check_rc(rc, "Can't start the MDB transaction")) goto leave;
rc = mdb_dbi_open(txn, null, 0, &dbi);
if (!check_rc(rc, "Can't open MDB index")) goto leave;
rc = mdb_drop(txn,dbi,0);
if (!check_rc(rc, "Can't drop MDB table")) goto leave;
rc = mdb_dbi_flags(txn, dbi, &dbi_flags);
if (!check_rc(rc, "Can't read MDB flags")) goto leave;
foreach (i; 0 .. 5)
{
ubyte[4] kval;
ubyte[32] dval;
key.assign!(ubyte[4])(&kval, kval.sizeof);
data.assign!(ubyte[32])(&dval, dval.sizeof);
kval = nativeToBigEndian(i);
foreach (j; 0 .. dval.length)
{
dval[j] = to!ubyte(uniform!("[)", int, int)(0, 2 ^^ 8));
}
if (verbose)
writefln("PUT: key: %x %s, data: %x %s", key.mv_data,
key.mv_data[0 .. key.mv_size], data.mv_data, data.mv_data[0 .. data.mv_size]);
rc = mdb_put(txn, dbi, &key, &data, 0);
if (!check_rc(rc, "Can't put MDB data")) goto leave;
}
rc = mdb_txn_commit(txn);
if (!check_rc(rc, "Can't commit MDB transaction")) goto leave;
rc = mdb_txn_begin(env, null, MDB_RDONLY, &txn);
if (!check_rc(rc, "Can't start the MDB transaction")) goto leave;
rc = mdb_cursor_open(txn, dbi, &cursor);
if (!check_rc(rc, "Can't open MDB index")) goto leave;
while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_cursor_op.MDB_NEXT)) == 0)
{
ubyte[4] tmp = key.data!ubyte()[0..4];
auto kv = bigEndianToNative!(int, 4)(tmp);
items ~= kv;
if (verbose)
writefln("GET: key: %x %s, data: %x %s", key.mv_data,
key.mv_data[0 .. key.mv_size], data.mv_data, data.mv_data[0 .. data.mv_size]);
mdb_cursor_close(cursor);
}
mdb_txn_abort(txn);
rc = mdb_txn_begin(env, null, 0, &txn);
if (!check_rc(rc, "Can't start the MDB transaction")) goto leave;
rc = mdb_cursor_open(txn, dbi, &cursor);
if (!check_rc(rc, "Can't open MDB index")) goto leave;
foreach (i; items) {
auto kval = nativeToBigEndian(i);
key.assign!(ubyte[4])(&kval, kval.length);
writefln("DEL: key: %x %s", key.mv_data, kval);
rc = mdb_del(txn, dbi, &key, null);
if (!check_rc(rc, "Can't open MDB index")) goto leave;
}
// while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_cursor_op.MDB_FIRST)) == 0)
// {
// if (verbose)
// writefln("DEL: key: %x %s, data: %x %s", key.mv_data,
// key.mv_data[0 .. key.mv_size], data.mv_data, data.mv_data[0 .. data.mv_size]);
// // rc = mdb_cursor_del(cursor, 0);
// rc = mdb_del(txn, dbi, &key, null);
// if (!check_rc(rc, "Can't delete MDB index")) goto leave;
// }
mdb_cursor_close(cursor);
if (!check_rc(rc, "Can't del MDB item")) goto leave;
mdb_txn_commit(txn);
rc = mdb_txn_begin(env, null, MDB_RDONLY, &txn);
if (!check_rc(rc, "Can't start the MDB transaction")) goto leave;
rc = mdb_cursor_open(txn, dbi, &cursor);
if (!check_rc(rc, "Can't open MDB index")) goto leave;
while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_cursor_op.MDB_NEXT)) == 0)
{
ubyte[4] tmp = key.data!ubyte()[0..4];
auto kv = bigEndianToNative!(int, 4)(tmp);
items ~= kv;
if (verbose)
writefln("GET: key: %x %s, data: %x %s", key.mv_data,
key.mv_data[0 .. key.mv_size], data.mv_data, data.mv_data[0 .. data.mv_size]);
mdb_cursor_close(cursor);
}
mdb_txn_abort(txn);
leave:
mdb_dbi_close(env, dbi);
leave2:
mdb_env_close(env);
}
/* ------------------------------------------------------------------ */
import lmdb_oo;
/** Simple test for the D OO-layer classes and operation
*/
void lmdb_toy2(const string[] args)
{
int rc;
bool verbose = args.length >= 2 && args[1] == "-v" ? true : false;
/* Note: Most error checking omitted for simplicity */
auto env = MdbEnv.create();
env.open("./testdb", 0, std.conv.octal!664);
auto txn = MdbTxn.begin(env.handle());
auto dbi = MdbDbi.open(txn.handle());
writeln("Create data items in DB.");
MdbVal key, data;
foreach (i; 0 .. 5)
{
ubyte[4] kval = nativeToBigEndian(i);
ubyte[32] dval = void;
foreach (j; 0 .. dval.length) { dval[j] = to!ubyte(uniform!("[)", int, int)(0, 2 ^^ 8)); }
key = new MdbVal(cast(void*)kval, kval.length);
data = new MdbVal(cast(void*)dval, dval.length);
if (verbose)
writefln("PUT: key: %s, data: %s", key, data);
rc = dbi.put(txn.handle(), key, data);
}
txn.commit();
MdbVal[] items;
MdbCursor cursor;
writeln("List of data items in DB. Remember items for deletion");
lmdb_toy2_iterate_readonly(env, txn, dbi, cursor, (MdbVal x) { items ~= new MdbVal(x); return true; }, verbose);
writefln("Delete %d remembered items", items.length);
txn = MdbTxn.begin(env.handle(), null, 0);
cursor = MdbCursor.open(txn.handle(), dbi.handle());
foreach (i; items)
{
if (verbose)
writefln("DEL: key: %s", i);
rc = dbi.del(txn.handle(), i);
}
cursor.close();
txn.commit();
writeln("List of all remaining data items in DB.");
lmdb_toy2_iterate_readonly(env, txn, dbi, cursor, null, verbose);
dbi.close(env);
env.close();
}
/** Iterate through all nodes in RW mode, execute a delegate for each node.
* @param env Reference to MdbEnv class
* @param tcn Reference to MdbTxn class
* @param cursor Reference to MdbCursor class
* @param fkt Delegate with reference to an MdbVal object. Returns bool=false to bereak loop.
*/
void lmdb_toy2_iterate_readwrite(MdbEnv env, MdbTxn txn, MdbDbi dbi, MdbCursor cursor, bool delegate (MdbVal) fkt,
string opname = "PUT", bool verbose = true)
{
int itemcount; bool fkt_rc;
MdbVal key = new MdbVal(), data = new MdbVal();
txn = MdbTxn.begin(env.handle(), null, 0);
cursor = MdbCursor.open(txn.handle(), dbi.handle());
while (cursor.get(key, data, MDB_cursor_op.MDB_NEXT))
{
itemcount++;
if (verbose)
writefln("%s: key: %s, data: %s", opname, key, data);
if (fkt !is null) fkt_rc = fkt(key);
if (!fkt_rc) break;
}
if (!itemcount)
writeln("DEL: Database seems to be empty.");
txn.abort();
}
/** Iterate through all nodes in RO mode, execute a delegate for each node.
* @param env Reference to MdbEnv class
* @param tcn Reference to MdbTxn class
* @param cursor Reference to MdbCursor class
* @param fkt Delegate with reference to an MdbVal object. Returns bool=false to bereak loop.
*/
void lmdb_toy2_iterate_readonly(MdbEnv env, MdbTxn txn, MdbDbi dbi, MdbCursor cursor, bool delegate (MdbVal) fkt, bool verbose = true)
{
int itemcount; bool fkt_rc;
MdbVal key = new MdbVal(), data = new MdbVal();
txn = MdbTxn.begin(env.handle(), null, MDB_RDONLY);
cursor = MdbCursor.open(txn.handle(), dbi.handle());
while (cursor.get(key, data, MDB_cursor_op.MDB_NEXT))
{
itemcount++;
if (verbose)
writefln("GET: key: %s, data: %s", key, data);
if (fkt !is null) fkt_rc = fkt(key);
if (!fkt_rc) break;
}
if (!itemcount)
writeln("GET: Database seems to be empty.");
txn.abort();
}
/* ------------------------------------------------------------------------- */
import std.bitmanip;
import std.format;
struct myDataTable {
uint field0;
uint field1;
uint field2;
uint field3;
char[10] field4;
float field5;
}
void lmdb_toy3(const string[] args)
{
int rc;
bool verbose = args.length >= 2 && args[1] == "-v" ? true : false;
/* Note: Most error checking omitted for simplicity */
auto env = MdbEnv.create();
env.open("./testdb", 0, std.conv.octal!664);
auto txn = MdbTxn.begin(env.handle());
auto dbi = MdbDbi.open(txn.handle(), null, MDB_INTEGERKEY);
writeln("Create data items in DB.");
MdbVal key, data;
foreach (uint i; 0 .. 5)
{
ubyte[4] kval ; kval[0..4].write!uint(i, 0);
myDataTable table = { 42, 23, 17, i, };
table.field4[].sformat("Idx=%d\0", table.field3);
table.field5 = 3.14 * i;
key = new MdbVal(cast(void*)kval, kval.length);
data = new MdbVal(cast(void*)&table, table.sizeof);
if (verbose)
writefln("PUT: key: %s, data: %s", key, data);
rc = dbi.put(txn.handle(), key, data);
}
txn.commit();
MdbVal[] items;
MdbCursor cursor;
writeln("List of data items in DB. Remember items for deletion");
lmdb_toy2_iterate_readonly(env, txn, dbi, cursor, (MdbVal x) { items ~= new MdbVal(x); return true; }, verbose);
writefln("Delete %d remembered items", items.length);
txn = MdbTxn.begin(env.handle(), null, 0);
cursor = MdbCursor.open(txn.handle(), dbi.handle());
foreach (i; items)
{
if (verbose)
writefln("DEL: key: %s", i);
rc = dbi.del(txn.handle(), i);
}
cursor.close();
txn.commit();
writeln("List of all remaining data items in DB.");
lmdb_toy2_iterate_readonly(env, txn, dbi, cursor, null, verbose);
dbi.close(env);
env.close();
}
\ No newline at end of file
docs/lmdb.h 0 → 100644
View file @ 7bcaa92d
This diff is collapsed.
docs/readme.md 0 → 100644
View file @ 7bcaa92d
This directory contains the original header files for liblmdb, which were
used to create the D bindings.
lmdb.h is part of the liblmdb package and was created by Howard Chu,
Symas Corporation. See his license on <http://www.OpenLDAP.org/license.html>.
lmdb++.h is part of a C++ binding written by Arto Bendiken <arto@bendiken.net>.
See https://sourceforge.net/projects/lmdbxx/ for reference and license.
As the D bindings are derived work, they are published under the same license
restrictions as the original work.
dub.json 0 → 100644
View file @ 7bcaa92d
{
"description": "A binding to the lmdb library.",
"license": "public domain",
"authors": [
"Carsten Schlote"
],
"copyright": "Copyright © 2018, Carsten Schlote",
"name": "lmdb_d",
"targetType": "autodetect",
"lflags": [
"-llmdb"
]
}
\ No newline at end of file
dub.selections.json 0 → 100644
View file @ 7bcaa92d
{
"fileVersion": 1,
"versions": {
}
}
source/lmdb.d 0 → 100644
View file @ 7bcaa92d
This diff is collapsed.
source/lmdb_oo.d 0 → 100644
View file @ 7bcaa92d
This diff is collapsed.
source/package.d 0 → 100644
View file @ 7bcaa92d
import lmdb;
import lmdb_oo;
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment