2 //READ_UNCOMMITTED isolation testing
4 // -------------------------
8 // T1 second read should fail saying "tuple not found"
9 void* runTest1(void *p
);
10 void* runTest2(void *p
);
17 DbRetVal rv
= conn
.open("root", "manager");
18 if (rv
!= OK
) { printf("Error during connection %d\n", rv
); return 1; }
19 DatabaseManager
*dbMgr
= conn
.getDatabaseManager();
20 int ret
= createTable(dbMgr
);
21 if (ret
!= 0) { return 1; }
23 rv
= conn
.startTransaction();
24 if (rv
!= OK
) {printf ("Unable to start trans\n"); return 1; }
25 rv
= insert(dbMgr
, 100, false);
26 if (rv
!= OK
) { printf("Unable to insert\n"); return 2; }
28 printf("Tuple inserted\n");
31 int *status1
, *status2
;
32 pthread_create (&thr
[0], NULL
, &runTest1
, NULL
);
33 pthread_create (&thr
[1], NULL
, &runTest2
, NULL
);
34 printf("All threads started\n");
36 pthread_join(thr
[0], (void**)&status1
);
37 pthread_join(thr
[1], (void**)&status2
);
39 if (*status1
!= 0 || *status2
!= 0) ret
= 1;
40 dbMgr
->dropTable("t1");
42 if (p1RetVal
) { delete p1RetVal
; p1RetVal
= NULL
; }
43 if (p2RetVal
) { delete p2RetVal
; p2RetVal
= NULL
; }
46 void* runTest1(void *message
)
49 DbRetVal rv
= conn
.open("root", "manager");
50 if (rv
!= OK
) { printf("Error during connection %d\n", rv
); return NULL
; }
51 DatabaseManager
*dbMgr
= conn
.getDatabaseManager();
52 if (dbMgr
== NULL
) { printf("Auth failed\n"); return NULL
;}
53 rv
= conn
.startTransaction(READ_UNCOMMITTED
);
54 if (rv
!= OK
) return NULL
;
55 printf("Thread and pid is %d %lu\n", os::getpid(), os::getthrid());
58 rv
= select(dbMgr
, 100, true);
59 if (rv
!= OK
) { printf("Test Failed:first thread failed to select\n"); *p1RetVal
= 1; }
61 rv
= select(dbMgr
, 100, true);
62 if (rv
== OK
) { printf("Test Failed:first thread read succeeded \n"); *p1RetVal
= 1; }
65 pthread_exit(p1RetVal
);
67 void* runTest2(void *message
)
71 DbRetVal rv
= conn
.open("root", "manager");
72 if (rv
!= OK
) { printf("Error during connection %d\n", rv
); return NULL
; }
73 DatabaseManager
*dbMgr
= conn
.getDatabaseManager();
74 if (dbMgr
== NULL
) { printf("Auth failed\n"); return NULL
;}
75 rv
= conn
.startTransaction(READ_UNCOMMITTED
);
76 if (rv
!= OK
) return NULL
;
77 printf("Thread and pid is %d %lu\n", os::getpid(), os::getthrid());
81 rv
= remove(dbMgr
, 100, true);
82 if (rv
!= OK
) { printf("Test Failed:second thread failed to delete\n"); *p2RetVal
= 1; }
85 pthread_exit(p2RetVal
);