6 int main(int argc,char * argv[])
14 MDB_cursor *cursor, *cur2;
21 count = (random()%384) + 64;
22 values = (int *)malloc(count*sizeof(int));
24 for(i = 0;i<count;i++) {
25 values[i] = random()%1024;
28 rc = mdbenv_create(&env);
29 rc = mdbenv_set_mapsize(env, 10485760);
30 rc = mdbenv_open(env, "./testdb", MDB_FIXEDMAP|MDB_NOSYNC, 0664);
31 rc = mdb_txn_begin(env, 0, &txn);
32 rc = mdb_open(env, txn, NULL, 0, &db);
34 key.mv_size = sizeof(int);
36 data.mv_size = sizeof(sval);
39 printf("Adding %d values\n", count);
40 for (i=0;i<count;i++) {
41 sprintf(sval, "%03x %d foo bar", values[i], values[i]);
42 rc = mdb_put(db, txn, &key, &data, MDB_NOOVERWRITE);
45 if (j) printf("%d duplicates skipped\n", j);
46 rc = mdb_txn_commit(txn);
47 rc = mdbenv_stat(env, &mst);
49 rc = mdb_cursor_open(db, NULL, &cursor);
50 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
51 printf("key: %p %.*s, data: %p %.*s\n",
52 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
53 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
55 mdb_cursor_close(cursor);
59 for (i= count - 1; i > -1; i-= (random()%5)) {
62 rc = mdb_txn_begin(env, 0, &txn);
63 sprintf(sval, "%03x ", values[i]);
64 rc = mdb_del(db, txn, &key, NULL);
69 rc = mdb_txn_commit(txn);
73 printf("Deleted %d values\n", j);
75 rc = mdbenv_stat(env, &mst);
76 rc = mdb_cursor_open(db, NULL, &cursor);
77 while ((rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT)) == 0) {
78 printf("key: %.*s, data: %.*s\n",
79 (int) key.mv_size, (char *) key.mv_data,
80 (int) data.mv_size, (char *) data.mv_data);
83 /* write ops aren't coordinated with cursors,
84 * this stuff all breaks
86 printf("Deleting with cursor\n");
87 rc = mdb_txn_begin(env, 0, &txn);
88 rc = mdb_cursor_open(db, txn, &cur2);
89 for (i=0; i<50; i++) {
90 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
91 printf("key: %p %.*s, data: %p %.*s\n",
92 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
93 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
94 rc = mdb_del(db, txn, &key, NULL);
97 printf("Restarting cursor in txn\n");
98 rc = mdb_cursor_get(cur2, &key, &data, MDB_FIRST);
99 printf("key: %p %.*s, data: %p %.*s\n",
100 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
101 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
102 for (i=0; i<32; i++) {
103 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
104 printf("key: %p %.*s, data: %p %.*s\n",
105 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
106 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
108 mdb_cursor_close(cur2);
109 rc = mdb_txn_commit(txn);
110 mdb_cursor_close(cursor);
111 printf("Restarting cursor outside txn\n");
112 rc = mdb_cursor_open(db, NULL, &cursor);
113 rc = mdb_cursor_get(cursor, &key, &data, MDB_FIRST);
114 printf("key: %p %.*s, data: %p %.*s\n",
115 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
116 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
117 for (i=0; i<32; i++) {
118 rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT);
119 printf("key: %p %.*s, data: %p %.*s\n",
120 key.mv_data, (int) key.mv_size, (char *) key.mv_data,
121 data.mv_data, (int) data.mv_size, (char *) data.mv_data);
124 mdb_cursor_close(cursor);