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, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
54 mdb_cursor_close(cursor);
58 for (i= count - 1; i > -1; i-= (random()%5)) {
61 rc = mdb_txn_begin(env, 0, &txn);
62 sprintf(sval, "%03x ", values[i]);
63 rc = mdb_del(db, txn, &key, NULL);
68 rc = mdb_txn_commit(txn);
72 printf("Deleted %d values\n", j);
74 rc = mdbenv_stat(env, &mst);
75 rc = mdb_cursor_open(db, NULL, &cursor);
76 while (rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT) == 0) {
77 printf("key: %.*s, data: %.*s\n",
78 key.mv_size, key.mv_data, data.mv_size, data.mv_data);
81 /* write ops aren't coordinated with cursors,
82 * this stuff all breaks
84 printf("Deleting with cursor\n");
85 rc = mdb_txn_begin(env, 0, &txn);
86 rc = mdb_cursor_open(db, txn, &cur2);
87 for (i=0; i<50; i++) {
88 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
89 printf("key: %p %.*s, data: %p %.*s\n",
90 key.mv_data, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
91 rc = mdb_del(db, txn, &key, NULL);
94 printf("Restarting cursor in txn\n");
95 rc = mdb_cursor_get(cur2, &key, &data, MDB_FIRST);
96 printf("key: %p %.*s, data: %p %.*s\n",
97 key.mv_data, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
98 for (i=0; i<32; i++) {
99 rc = mdb_cursor_get(cur2, &key, &data, MDB_NEXT);
100 printf("key: %p %.*s, data: %p %.*s\n",
101 key.mv_data, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
103 mdb_cursor_close(cur2);
104 rc = mdb_txn_commit(txn);
105 mdb_cursor_close(cursor);
106 printf("Restarting cursor outside txn\n");
107 rc = mdb_cursor_open(db, NULL, &cursor);
108 rc = mdb_cursor_get(cursor, &key, &data, MDB_FIRST);
109 printf("key: %p %.*s, data: %p %.*s\n",
110 key.mv_data, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
111 for (i=0; i<32; i++) {
112 rc = mdb_cursor_get(cursor, &key, &data, MDB_NEXT);
113 printf("key: %p %.*s, data: %p %.*s\n",
114 key.mv_data, key.mv_size, key.mv_data, data.mv_data, data.mv_size, data.mv_data);
117 mdb_cursor_close(cursor);