import org.lmdbjava.Cursor;
import org.lmdbjava.Dbi;
import org.lmdbjava.DbiFlags;
import org.lmdbjava.Env;
import org.lmdbjava.EnvFlags;
import org.lmdbjava.Txn;

import java.io.File;
import java.io.IOException;
import java.nio.ByteBuffer;

import static java.nio.charset.StandardCharsets.UTF_8;

public class EfficentTest {
    public static void main(String[] args) throws IOException
    {
        final File path = new File("/foo");

        if (!path.mkdirs() && !path.exists())
        {
            throw new IOException("Unable to create: " + path);
        }

        Env<ByteBuffer> env = Env.create()
                .setMapSize(1L << 31)
                .setMaxDbs(2)
                .open(path, EnvFlags.MDB_NOSYNC);

        final Dbi<ByteBuffer> names = env.openDbi("names", DbiFlags.MDB_CREATE);

        final ByteBuffer key = ByteBuffer.allocateDirect(4);
        final ByteBuffer val = ByteBuffer.allocateDirect(1024);

        final long t0 = System.currentTimeMillis();
        long tn = t0;
        for( int i = 0; i < 1000000 ; i++) {
            try (Txn<ByteBuffer> txn = env.txnWrite()) {
                final Cursor<ByteBuffer> c = names.openCursor(txn);
                key.putInt(0, i);
                val.put("Hello world".getBytes(UTF_8)).flip();
                c.put(key,val);
                txn.commit();
            }

            if (i % 1000 == 0)
            {
                long taken = System.currentTimeMillis() - tn;
                System.out.printf("Inserted: %d rows at %,2f vals/sec%n", i, (1000 * 1000D) / taken);
                tn = System.currentTimeMillis();
            }
        }
        final long t1 = System.currentTimeMillis();
        System.out.printf("Time to load db: %,dms%n", (t1 - t0));
    }
}