test/dbapi/Connection/isotest3.c

   1 #include "common.h"
   2 //READ_COMMITTED Isolation testing
   3 //T1 doing insert and T2 doing select for same tuple
   4
   5 void* runTest1(void *p);
   6 void* runTest2(void *p);
   7 int *p1RetVal = NULL;
   8 int *p2RetVal = NULL;
   9 int main()
  10 {
  11
  12     Connection conn;
  13     DbRetVal rv = conn.open("root", "manager");
  14     if (rv != OK) { printf("Error during connection %d\n", rv); return 1; }
  15     DatabaseManager *dbMgr = conn.getDatabaseManager();
  16     int ret = createTable(dbMgr);
  17     if (ret != 0) { return 1; }
  18
  19     rv = conn.startTransaction();
  20     if (rv != OK) {printf ("Unable to start trans\n"); return 1; }
  21     rv = insert(dbMgr, 100, false);
  22     if (rv != OK) { printf("Unable to insert\n"); return 2; }
  23     conn.commit();
  24     printf("Tuple inserted\n");
  25
  26     pthread_t thr[2];
  27     int *status1, *status2;
  28     pthread_create (&thr[0], NULL, &runTest1,  NULL);
  29     pthread_create (&thr[1], NULL, &runTest2,  NULL);
  30     printf("All threads started\n");
  31
  32     pthread_join(thr[0], (void**)&status1);
  33     pthread_join(thr[1], (void**)&status2);
  34     ret = 0;
  35     if (*status1 != 0 || *status2 != 0) ret = 1;
  36     dbMgr->dropTable("t1");
  37     conn.close();
  38     if (p1RetVal) { delete p1RetVal; p1RetVal = NULL; }
  39     if (p2RetVal) { delete p2RetVal; p2RetVal = NULL; }
  40     return ret;
  41 }
  42 void* runTest1(void *message)
  43 {
  44     Connection conn;
  45     DbRetVal rv = conn.open("root", "manager");
  46     if (rv != OK) { printf("Error during connection %d\n", rv); return NULL; }
  47     DatabaseManager *dbMgr = conn.getDatabaseManager();
  48     if (dbMgr == NULL) { printf("Auth failed\n"); return NULL;}
  49 #ifndef DEFAULT
  50     rv = conn.startTransaction(READ_COMMITTED);
  51 #else
  52     rv = conn.startTransaction();
  53 #endif
  54     if (rv != OK) return NULL;
  55     printf("Thread and pid is %d %lu\n", os::getpid(), os::getthrid());
  56     p1RetVal = new int();
  57     *p1RetVal = 0;
  58     rv = insert(dbMgr, 200, true);
  59     if (rv != OK) { printf("Test Failed:first thread failed to select\n"); *p1RetVal = 1; }
  60
  61     conn.commit();
  62     rv  = conn.close();
  63     pthread_exit(p1RetVal);
  64 }
  65 void* runTest2(void *message)
  66 {
  67     os::sleep(1);
  68     Connection conn;
  69     DbRetVal rv = conn.open("root", "manager");
  70     if (rv != OK) { printf("Error during connection %d\n", rv); return NULL; }
  71     DatabaseManager *dbMgr = conn.getDatabaseManager();
  72     if (dbMgr == NULL) { printf("Auth failed\n"); return NULL;}
  73 #ifndef DEFAULT
  74     rv = conn.startTransaction(READ_COMMITTED);
  75 #else
  76     rv = conn.startTransaction();
  77 #endif
  78
  79     if (rv != OK) return NULL;
  80     printf("Thread and pid is %d %lu\n", os::getpid(), os::getthrid());
  81
  82     p2RetVal = new int();
  83     *p2RetVal = 0;
  84     rv = select(dbMgr, 200, false);
  85     if (rv == OK) { printf("Test Failed:second thread could select\n"); *p2RetVal = 1; }
  86     conn.commit();
  87     conn.close();
  88     pthread_exit(p2RetVal);
  89 }
  90