test/dbapi/Connection/isotest5.c

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