test/performance/DMLThroughput.c

   1 #include<CSql.h>
   2 #include<NanoTimer.h>
   3 #include<TableImpl.h>
   4 //MAX_SYS_DB_SIZE=10485760
   5 //MAX_DB_SIZE=335544320
   6 //you may have to set the kernel.shmmax kernel paremeter(login as root) using
   7 //$sysctl -w kernel.shmmax=1000000000
   8 #define LOAD 0
   9 int main()
  10 {
  11
  12     Connection conn;
  13     DbRetVal rv = conn.open("root", "manager");
  14     if (rv != OK)
  15     {
  16        printf("Error during connection %d\n", rv);
  17        return -1;
  18     }
  19
  20
  21     DatabaseManager *dbMgr = conn.getDatabaseManager();
  22     if (dbMgr == NULL) { printf("Auth failed\n"); return -1;}
  23     TableDef tabDef;
  24     tabDef.addField("f1", typeInt, 0, NULL, true );
  25     tabDef.addField("f2", typeString, 6);
  26     rv = dbMgr->createTable("t1", tabDef);
  27     if (rv != OK) { printf("Table creation failed\n"); return -1; }
  28     printf("Table created\n");
  29     HashIndexInitInfo *idxInfo = new HashIndexInitInfo();
  30     strcpy(idxInfo->tableName, "t1");
  31     idxInfo->list.append("f1");
  32     idxInfo->indType = hashIndex;
  33     idxInfo->bucketSize = 100007;
  34     rv = dbMgr->createIndex("indx1", idxInfo);
  35     if (rv != OK) { printf("Index creation failed\n"); return -1; }
  36     printf("Index created\n");
  37     delete idxInfo;
  38     Table *table = dbMgr->openTable("t1");
  39     if (table == NULL) { printf("Unable to open table\n"); return -1; }
  40     int id = 0;
  41     char name[6] = "PRABA";
  42     table->bindFld("f1", &id);
  43     table->bindFld("f2", name);
  44     char *tuple;
  45     int ret;
  46     int i;
  47     int icount =0;
  48     i = 0;
  49     NanoTimer timer;
  50     icount =0;
  51     for(i = 0; i < 20; i++)
  52     {
  53         timer.start();
  54         for (int j =0; j < 100000; j++)
  55         {
  56             rv = conn.startTransaction();
  57             //if (rv != OK) exit(1);
  58             if (rv != OK) {
  59                 dbMgr->closeTable(table);
  60                 dbMgr->dropTable("t1");
  61                 conn.close();
  62                 return 1;
  63             }
  64             id= i*100000+j;
  65             strcpy(name, "KARAN");
  66             ret = table->insertTuple();
  67             if (ret != 0) break;
  68             icount++;
  69             conn.commit();
  70         }
  71         timer.stop();
  72         printf("Insert: %d %lld\n", icount, timer.last());
  73     }
  74    printf("%d rows inserted %lld %lld %lld\n",icount, timer.min(), timer.max(), timer.avg());
  75
  76     int offset1= os::align(sizeof(int));
  77     Condition p1;
  78     int val1 = 0;
  79     p1.setTerm("f1", OpEquals, &val1);
  80     table->setCondition(&p1);
  81     icount=0;
  82
  83
  84     timer.reset();
  85     for(i = 0; i< 20; i++)
  86     {
  87         timer.start();
  88         for (int j=0 ; j <100000; j++)
  89         {
  90             rv =conn.startTransaction();
  91             if (rv != OK) exit(1);
  92             val1 = i *100000 + j;
  93             table->execute();
  94             tuple = (char*)table->fetch() ;
  95             if (tuple == NULL) {printf("loop break in %d\n", i);table->closeScan();break;}
  96     //    printf(" %d tuple value is %d %s \n", i, *((int*)tuple), tuple+offset1);
  97             table->closeScan();
  98             icount++;
  99             conn.commit();
 100         }
 101         timer.stop();
 102         printf("Select: %d %lld\n", icount, timer.last());
 103     }
 104     printf("%d rows selected %lld %lld %lld\n", icount, timer.min(), timer.max(), timer.avg());
 105     timer.reset();
 106
 107     dbMgr->closeTable(table);
 108     dbMgr->dropTable("t1");
 109     printf("Table dropped\n");
 110
 111
 112     conn.close();
 113     return 0;
 114 }