1 /* mtest.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>.
14 #define _XOPEN_SOURCE 500 /* srandom(), random() */
20 int main(int argc,char * argv[])
28 MDB_cursor *cursor, *cur2;
35 count = (random()%384) + 64;
36 values = (int *)malloc(count*sizeof(int));
38 for(i = 0;i<count;i++) {
39 values[i] = random()%1024;
42 rc = mdb_env_create(&env);
43 rc = mdb_env_set_mapsize(env, 10485760);
44 rc = mdb_env_open(env, "./testdb", MDB_FIXEDMAP /*|MDB_NOSYNC*/, 0664);
45 rc = mdb_txn_begin(env, NULL, 0, &txn);
46 rc = mdb_open(txn, NULL, 0, &dbi);
48 key.mv_size = sizeof(int);
50 data.mv_size = sizeof(sval);
53 printf("Adding %d values\n", count);
54 for (i=0;i<count;i++) {
55 sprintf(sval, "%03x %d foo bar", values[i], values[i]);
56 rc = mdb_put(txn, dbi, &key, &data, MDB_NOOVERWRITE);
59 data.mv_size = sizeof(sval);
63 if (j) printf("%d duplicates skipped\n", j);
64 rc = mdb_txn_commit(txn);
65 rc = mdb_env_stat(env, &mst);
67 rc = mdb_txn_begin(env, NULL, 1, &txn);
68 rc = mdb_cursor_open(txn, dbi, &cursor);
69 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
70 printf("key: %p %.*s, data: %p %.*s\n",
71 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
72 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
74 mdb_cursor_close(cursor);
79 for (i= count - 1; i > -1; i-= (random()%5)) {
82 rc = mdb_txn_begin(env, NULL, 0, &txn);
83 sprintf(sval, "%03x ", values[i]);
84 rc = mdb_del(txn, dbi, &key, NULL);
89 rc = mdb_txn_commit(txn);
93 printf("Deleted %d values\n", j);
95 rc = mdb_env_stat(env, &mst);
96 rc = mdb_txn_begin(env, NULL, 1, &txn);
97 rc = mdb_cursor_open(txn, dbi, &cursor);
98 printf("Cursor next\n");
99 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
100 printf("key: %.*s, data: %.*s\n",
101 (int) key.mv_size, (char *) key.mv_data,
102 (int) data.mv_size, (char *) data.mv_data);
104 printf("Cursor last\n");
105 rc = mdb_cursor_get(cursor, &key, &data, MDB_LAST);
106 printf("key: %.*s, data: %.*s\n",
107 (int) key.mv_size, (char *) key.mv_data,
108 (int) data.mv_size, (char *) data.mv_data);
109 printf("Cursor prev\n");
110 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_PREV)) == 0) {
111 printf("key: %.*s, data: %.*s\n",
112 (int) key.mv_size, (char *) key.mv_data,
113 (int) data.mv_size, (char *) data.mv_data);
115 printf("Cursor last/prev\n");
116 rc = mdb_cursor_get(cursor, &key, &data, MDB_LAST);
117 printf("key: %.*s, data: %.*s\n",
118 (int) key.mv_size, (char *) key.mv_data,
119 (int) data.mv_size, (char *) data.mv_data);
120 rc = mdb_cursor_get(cursor, &key, &data, MDB_PREV);
121 printf("key: %.*s, data: %.*s\n",
122 (int) key.mv_size, (char *) key.mv_data,
123 (int) data.mv_size, (char *) data.mv_data);
127 printf("Deleting with cursor\n");
128 rc = mdb_txn_begin(env, NULL, 0, &txn);
129 rc = mdb_cursor_open(txn, dbi, &cur2);
130 for (i=0; i<50; i++) {
131 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
132 printf("key: %p %.*s, data: %p %.*s\n",
133 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
134 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
135 rc = mdb_del(txn, dbi, &key, NULL);
138 printf("Restarting cursor in txn\n");
139 rc = mdb_cursor_get(cur2, &key, &data, MDB_FIRST);
140 printf("key: %p %.*s, data: %p %.*s\n",
141 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
142 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
143 for (i=0; i<32; i++) {
144 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
145 printf("key: %p %.*s, data: %p %.*s\n",
146 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
147 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
149 mdb_cursor_close(cur2);
150 rc = mdb_txn_commit(txn);
152 printf("Restarting cursor outside txn\n");
153 rc = mdb_txn_begin(env, NULL, 0, &txn);
154 rc = mdb_cursor_open(txn, dbi, &cursor);
155 rc = mdb_cursor_get(cursor, &key, &data, MDB_FIRST);
156 printf("key: %p %.*s, data: %p %.*s\n",
157 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
158 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
159 for (i=0; i<32; i++) {
160 rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT);
161 printf("key: %p %.*s, data: %p %.*s\n",
162 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
163 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
165 mdb_cursor_close(cursor);