Shows how to access a database with multiple threads.
#include "test_util.h"
static const char *home;
#define NUM_THREADS 10
static WT_THREAD_RET
scan_thread(void *conn_arg)
{
int ret;
const char *key, *value;
conn = conn_arg;
error_check(conn->
open_session(conn, NULL, NULL, &session));
session, "table:access", NULL, NULL, &cursor));
while ((ret = cursor->
next(cursor)) == 0) {
error_check(cursor->
get_key(cursor, &key));
error_check(cursor->
get_value(cursor, &value));
printf("Got record: %s : %s\n", key, value);
}
fprintf(stderr,
"WT_CURSOR.next: %s\n", session->
strerror(session, ret));
return (WT_THREAD_RET_VALUE);
}
int
main(int argc, char *argv[])
{
wt_thread_t threads[NUM_THREADS];
int i;
home = example_setup(argc, argv);
error_check(conn->
open_session(conn, NULL, NULL, &session));
error_check(session->
create(session,
"table:access",
"key_format=S,value_format=S"));
session, "table:access", NULL, "overwrite", &cursor));
error_check(cursor->
insert(cursor));
error_check(session->
close(session, NULL));
for (i = 0; i < NUM_THREADS; i++)
error_check(
__wt_thread_create(NULL, &threads[i], scan_thread, conn));
for (i = 0; i < NUM_THREADS; i++)
error_check(__wt_thread_join(NULL, threads[i]));
error_check(conn->
close(conn, NULL));
return (EXIT_SUCCESS);
}