1 /* mtest5.c - memory-mapped database tester/toy */
3 * Copyright 2011 Howard Chu, Symas Corp.
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted only as authorized by the OpenLDAP
10 * A copy of this license is available in the file LICENSE in the
11 * top-level directory of the distribution or, alternatively, at
12 * <http://www.OpenLDAP.org/license.html>.
15 /* Tests for sorted duplicate DBs using cursor_put */
16 #define _XOPEN_SOURCE 500 /* srandom(), random() */
23 int main(int argc,char * argv[])
35 char kval[sizeof(int)];
39 memset(sval, 0, sizeof(sval));
41 count = (random()%384) + 64;
42 values = (int *)malloc(count*sizeof(int));
44 for(i = 0;i<count;i++) {
45 values[i] = random()%1024;
48 rc = mdb_env_create(&env);
49 rc = mdb_env_set_mapsize(env, 10485760);
50 rc = mdb_env_set_maxdbs(env, 4);
51 rc = mdb_env_open(env, "./testdb", MDB_FIXEDMAP|MDB_NOSYNC, 0664);
52 rc = mdb_txn_begin(env, 0, &txn);
53 rc = mdb_open(txn, "id2", MDB_CREATE|MDB_DUPSORT, &dbi);
54 rc = mdb_cursor_open(txn, dbi, &cursor);
56 key.mv_size = sizeof(int);
58 data.mv_size = sizeof(sval);
61 printf("Adding %d values\n", count);
62 for (i=0;i<count;i++) {
64 sprintf(kval, "%03x", values[i]);
65 sprintf(sval, "%03x %d foo bar", values[i], values[i]);
66 rc = mdb_cursor_put(cursor, &key, &data, MDB_NODUPDATA);
69 if (j) printf("%d duplicates skipped\n", j);
70 mdb_cursor_close(cursor);
71 rc = mdb_txn_commit(txn);
72 rc = mdb_env_stat(env, &mst);
74 rc = mdb_txn_begin(env, 1, &txn);
75 rc = mdb_cursor_open(txn, dbi, &cursor);
76 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
77 printf("key: %p %.*s, data: %p %.*s\n",
78 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
79 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
81 mdb_cursor_close(cursor);
86 for (i= count - 1; i > -1; i-= (random()%5)) {
89 rc = mdb_txn_begin(env, 0, &txn);
90 sprintf(kval, "%03x", values[i & ~0x0f]);
91 sprintf(sval, "%03x %d foo bar", values[i], values[i]);
92 key.mv_size = sizeof(int);
94 data.mv_size = sizeof(sval);
96 rc = mdb_del(txn, dbi, &key, &data);
101 rc = mdb_txn_commit(txn);
105 printf("Deleted %d values\n", j);
107 rc = mdb_env_stat(env, &mst);
108 rc = mdb_txn_begin(env, 1, &txn);
109 rc = mdb_cursor_open(txn, dbi, &cursor);
110 printf("Cursor next\n");
111 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
112 printf("key: %.*s, data: %.*s\n",
113 (int) key.mv_size, (char *) key.mv_data,
114 (int) data.mv_size, (char *) data.mv_data);
116 printf("Cursor prev\n");
117 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_PREV)) == 0) {
118 printf("key: %.*s, data: %.*s\n",
119 (int) key.mv_size, (char *) key.mv_data,
120 (int) data.mv_size, (char *) data.mv_data);
122 mdb_cursor_close(cursor);