开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
acid2.cpp
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：22k
源码类别：

MySQL数据库

开发平台：

Visual C++

acid2.cpp：源码内容
  1. /* Copyright (C) 2003 MySQL AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  18. #include <NdbApi.hpp>
  19. #include <NdbOut.hpp>
  20. #include <NdbThread.h>
  21. #include <NdbSleep.h>
  22. #include <NdbMutex.h>
  24. #include "TraceNdbApi.hpp"
  25. #include "VerifyNdbApi.hpp"
  28. #define Ndb CTraceNdb
  29. #define NdbSchemaCon CTraceNdbSchemaCon
  30. #define NdbSchemaOp CTraceNdbSchemaOp
  31. #define NdbConnection CTraceNdbConnection
  32. #define NdbOperation CTraceNdbOperation
  33. #define NdbIndexOperation CTraceNdbIndexOperation
  34. #define NdbRecAttr CTraceNdbRecAttr
  35. #define Table CTraceTable
  36. #define Index CTraceIndex
  37. #define Column CTraceColumn
  38. #define NdbDictionary CTraceNdbDictionary
  40. /*
  41. #define Ndb CVerifyNdb
  42. #define NdbSchemaCon CVerifyNdbSchemaCon
  43. #define NdbSchemaOp CVerifyNdbSchemaOp
  44. #define NdbConnection CVerifyNdbConnection
  45. #define NdbOperation CVerifyNdbOperation
  46. #define NdbIndexOperation CVerifyNdbIndexOperation
  47. #define NdbRecAttr CVerifyNdbRecAttr
  48. #define Table CVerifyTable
  49. #define Index CVerifyIndex
  50. #define Column CVerifyColumn
  51. #define NdbDictionary CVerifyNdbDictionary
  52. */
  54. NdbMutex* g_pNdbMutexStop = 0;
  55. Uint32 g_nPart = 1;
  56. Uint32 g_nTable = 1;
  57. Uint32 g_nTuple = 1;
  58. Uint32 g_nAttribute = 1;
  59. char* g_szTable = 0;
  60. char* g_szIndex = 0;
  61. char* g_szAttribute = 0;
  62. bool g_bVerify = false;
  63. bool g_bUseIndex = false;
  67. #define N 624
  68. #define M 397
  69. #define MATRIX_A 0x9908b0df
  70. #define UPPER_MASK 0x80000000
  71. #define LOWER_MASK 0x7fffffff
  73. #define TEMPERING_MASK_B 0x9d2c5680
  74. #define TEMPERING_MASK_C 0xefc60000
  75. #define TEMPERING_SHIFT_U(y)  (y >> 11)
  76. #define TEMPERING_SHIFT_S(y)  (y << 7)
  77. #define TEMPERING_SHIFT_T(y)  (y << 15)
  78. #define TEMPERING_SHIFT_L(y)  (y >> 18)
  81. class MT19937
  82. {
  83. public:
  84.     MT19937(void);
  85.     void sgenrand(unsigned long seed);
  86.     unsigned long genrand(void);
  88. private:
  89.     unsigned long mt[N];
  90.     int mti;
  91.     unsigned long mag01[2];
  92. };
  95. MT19937::MT19937(void)
  96. {
  97.     mti = N+1;
  98.     mag01[0] = 0x0;
  99.     mag01[1] = MATRIX_A;
  100.     sgenrand(4357);
  101. }
  104. void MT19937::sgenrand(unsigned long seed)
  105. {
  106.     mt[0]= seed & 0xffffffff;
  107.     for (mti=1; mti<N; mti++)
  108.         mt[mti] = (69069 * mt[mti-1]) & 0xffffffff;
  109. }
  112. unsigned long MT19937::genrand(void)
  113. {
  114.     unsigned long y;
  115.     if (mti >= N) {
  116.         int kk;
  117.         if (mti == N+1)
  118.         {
  119.             sgenrand(4357);
  120.         }
  121.         for (kk=0;kk<N-M;kk++) {
  122.             y = (mt[kk]&UPPER_MASK)|(mt[kk+1]&LOWER_MASK);
  123.             mt[kk] = mt[kk+M] ^ (y >> 1) ^ mag01[y & 0x1];
  124.         }
  125.         for (;kk<N-1;kk++) {
  126.             y = (mt[kk]&UPPER_MASK)|(mt[kk+1]&LOWER_MASK);
  127.             mt[kk] = mt[kk+(M-N)] ^ (y >> 1) ^ mag01[y & 0x1];
  128.         }
  129.         y = (mt[N-1]&UPPER_MASK)|(mt[0]&LOWER_MASK);
  130.         mt[N-1] = mt[M-1] ^ (y >> 1) ^ mag01[y & 0x1];
  131.         mti = 0;
  132.     }
  133.     y = mt[mti++];
  134.     y ^= TEMPERING_SHIFT_U(y);
  135.     y ^= TEMPERING_SHIFT_S(y) & TEMPERING_MASK_B;
  136.     y ^= TEMPERING_SHIFT_T(y) & TEMPERING_MASK_C;
  137.     y ^= TEMPERING_SHIFT_L(y);
  138.     return y; 
  139. }
  145. void CreateTables(Ndb* pNdb)
  146. {
  147.     for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  148.     {
  149.         NdbDictionary::Dictionary* pDictionary = pNdb->getDictionary();
  151.         NdbDictionary::Table table;
  152.         table.setName(g_szTable+iTable*4);
  154.         NdbDictionary::Index index;
  155.         index.setName(g_szIndex+iTable*4);
  156.         index.setTable(table.getName());
  157.         index.setType(NdbDictionary::Index::UniqueHashIndex);
  159.         NdbDictionary::Column columnPK;
  160.         columnPK.setName("PK");
  161.         columnPK.setTupleKey(true);
  162.         table.addColumn(columnPK);
  163.         index.addIndexColumn(columnPK.getName());
  165.         for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  166.         {
  167.             NdbDictionary::Column columnAttr;
  168.             columnAttr.setName(g_szAttribute+iAttr*4);
  169.             columnAttr.setTupleKey(false);
  170.             table.addColumn(columnAttr);
  171.         }
  173.         pDictionary->createTable(table);
  174.         pDictionary->createIndex(index);
  176.         /*
  177.         NdbSchemaCon* pNdbSchemaCon = pNdb->startSchemaTransaction();
  178.         NdbSchemaOp* pNdbSchemaOp = pNdbSchemaCon->getNdbSchemaOp();
  179.         pNdbSchemaOp->createTable(g_szTable+iTable*4);
  180.         pNdbSchemaOp->createAttribute("PK", TupleKey);
  181.         for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  182.         {
  183.         pNdbSchemaOp->createAttribute(g_szAttribute+iAttr*4, NoKey);
  184.         }
  186.         pNdbSchemaCon->execute();
  187.         pNdb->closeSchemaTransaction(pNdbSchemaCon);
  188.         */
  189.     }
  190. }
  193. int InsertTransaction(Ndb* pNdb, const Uint32 iPart, const bool bIndex)
  194. {
  195.     int iExec = -1;
  196.     int iCode = -1;
  197.     NdbConnection* pNdbConnection = pNdb->startTransaction();
  198.     if(pNdbConnection)
  199.     {
  200.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  201.         {
  202.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  203.             {
  204.                 if(bIndex)
  205.                 {
  206.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  207.                     pNdbIndexOperation->insertTuple();
  208.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  209.                     pNdbIndexOperation->equal("PK", nPK);
  210.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  211.                     {
  212.                         Uint32 nValue = ((iPart*g_nTable+iTable)*g_nTuple+iTuple)*g_nAttribute+iAttr;
  213.                         pNdbIndexOperation->setValue(g_szAttribute+iAttr*4, nValue);
  214.                     }
  215.                 }
  216.                 else
  217.                 {
  218.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  219.                     pNdbOperation->insertTuple();
  220.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  221.                     pNdbOperation->equal("PK", nPK);
  222.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  223.                     {
  224.                         Uint32 nValue = ((iPart*g_nTable+iTable)*g_nTuple+iTuple)*g_nAttribute+iAttr;
  225.                         pNdbOperation->setValue(g_szAttribute+iAttr*4, nValue);
  226.                     }
  227.                 }
  228.             }
  229.         }
  230.         iExec = pNdbConnection->execute_ok(Commit);
  231.         if (iExec == -1) 
  232.         {
  233.             ndbout << pNdbConnection->getNdbError() << endl;
  234.         }
  235.         pNdb->closeTransaction(pNdbConnection);
  236.     }
  237.     return 0;
  238. }
  241. int UpdateGetAndSetTransaction(Ndb* pNdb, const Uint32 iPart, const bool bIndex)
  242. {
  243.     int iExec = -1;
  244.     int iCode = -1;
  245.     NdbRecAttr** ppNdbRecAttr = new NdbRecAttr*[g_nTable*g_nTuple*g_nAttribute];
  246.     NdbConnection* pNdbConnection = pNdb->startTransaction();
  247.     if(pNdbConnection)
  248.     {
  249.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  250.         {
  251.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  252.             {
  253.                 if(bIndex)
  254.                 {
  255.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  256.                     pNdbIndexOperation->readTupleExclusive();
  257.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  258.                     pNdbIndexOperation->equal("PK", nPK);
  259.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  260.                     {
  261.                         ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr] 
  262.                         = pNdbIndexOperation->getValue(g_szAttribute+iAttr*4);
  263.                     }
  264.                 }
  265.                 else
  266.                 {
  267.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  268.                     pNdbOperation->readTupleExclusive();
  269.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  270.                     pNdbOperation->equal("PK", nPK);
  271.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  272.                     {
  273.                         ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr] 
  274.                         = pNdbOperation->getValue(g_szAttribute+iAttr*4);
  275.                     }
  276.                 }
  277.             }
  278.         }
  279.         iExec = pNdbConnection->execute_ok(NoCommit);
  280.         if( iExec == -1)
  281.         {
  282.             ndbout << pNdbConnection->getNdbError() << endl;
  283.         }
  284.     }
  285.     iCode = pNdbConnection->getNdbError().code;
  286.     if(iExec==0)
  287.     {
  288.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  289.         {
  290.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  291.             {
  292.                 if(bIndex)
  293.                 {
  294.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  295.                     pNdbIndexOperation->updateTuple();
  296.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  297.                     pNdbIndexOperation->equal("PK", nPK);
  298.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  299.                     {
  300.                         NdbRecAttr* pNdbRecAttr
  301.                             = ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr];
  302.                         Uint32 nValue = pNdbRecAttr->u_32_value() + 1;
  303.                         pNdbIndexOperation->setValue(g_szAttribute+iAttr*4, nValue);
  304.                     }
  305.                 }
  306.                 else
  307.                 {
  308.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  309.                     pNdbOperation->updateTuple();
  310.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  311.                     pNdbOperation->equal("PK", nPK);
  312.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  313.                     {
  314.                         NdbRecAttr* pNdbRecAttr
  315.                             = ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr];
  316.                         Uint32 nValue = pNdbRecAttr->u_32_value() + 1;
  317.                         pNdbOperation->setValue(g_szAttribute+iAttr*4, nValue);
  318.                     }
  319.                 }
  320.             }
  321.         }
  322.         iExec = pNdbConnection->execute(Commit);
  323.         if (iExec == -1) 
  324.         {
  325.             ndbout << pNdbConnection->getNdbError() << endl;
  326.         }
  327.         pNdb->closeTransaction(pNdbConnection);
  328.     }
  329.     delete[] ppNdbRecAttr;
  330.     return 0;
  331. }
  334. int UpdateInterpretedTransaction(Ndb* pNdb, const Uint32 iPart, const bool bIndex)
  335. {
  336.     int iExec = -1;
  337.     int iCode = -1;
  338.     NdbConnection* pNdbConnection = pNdb->startTransaction();
  339.     if(pNdbConnection)
  340.     {
  341.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  342.         {
  343.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  344.             {
  345.                 if(bIndex)
  346.                 {
  347.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  348.                     pNdbIndexOperation->interpretedUpdateTuple();
  349.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  350.                     pNdbIndexOperation->equal("PK", nPK);
  351.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  352.                     {
  353.                         pNdbIndexOperation->incValue(g_szAttribute+iAttr*4, (Uint32)1);
  354.                     }
  355.                 }
  356.                 else
  357.                 {
  358.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  359.                     pNdbOperation->interpretedUpdateTuple();
  360.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  361.                     pNdbOperation->equal("PK", nPK);
  362.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  363.                     {
  364.                         pNdbOperation->incValue(g_szAttribute+iAttr*4, (Uint32)1);
  365.                     }
  366.                 }
  367.             }
  368.         }
  369.         iExec = pNdbConnection->execute_ok(Commit);
  371.         if (iExec == -1) 
  372.         {
  373.             ndbout << pNdbConnection->getNdbError() << endl;
  374.         }
  375.         pNdb->closeTransaction(pNdbConnection);
  376.     }
  377.     return 0;
  378. }
  381. void ReportInconsistency (const Uint32 iPart,
  382.                           const Uint32 iTable,
  383.                           const Uint32 iTuple,
  384.                           const Uint32 iAttr,
  385.                           const Uint32 nValue,
  386.                           const Uint32 nExpected )
  387. {
  388.     ndbout << "INCONSISTENCY: ";
  389.     ndbout << "Part " << iPart;
  390.     ndbout << ", Table " << iTable;
  391.     ndbout << ", Tuple " << iTuple;
  392.     ndbout << ", Attr " << iAttr;
  393.     ndbout << ", Value " << nValue;
  394.     ndbout << ", Expected " << nExpected;
  395.     ndbout << endl;
  396. }
  399. int ReadTransaction(Ndb* pNdb, const Uint32 iPart, const bool bIndex)
  400. {
  401.     int iExec = -1;
  402.     int iCode = -1;
  403.     NdbRecAttr** ppNdbRecAttr = new NdbRecAttr*[g_nTable*g_nTuple*g_nAttribute];
  404.     NdbConnection* pNdbConnection = pNdb->startTransaction();
  405.     if(pNdbConnection)
  406.     {
  407.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  408.         {
  409.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  410.             {
  411.                 if(bIndex)
  412.                 {
  413.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  414.                     pNdbIndexOperation->readTuple();
  415.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  416.                     pNdbIndexOperation->equal("PK", nPK);
  417.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  418.                     {
  419.                         ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr]
  420.                         = pNdbIndexOperation->getValue(g_szAttribute+iAttr*4);
  421.                     }
  422.                 }
  423.                 else
  424.                 {
  425.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  426.                     pNdbOperation->readTuple();
  427.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  428.                     pNdbOperation->equal("PK", nPK);
  429.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  430.                     {
  431.                         ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr]
  432.                         = pNdbOperation->getValue(g_szAttribute+iAttr*4);
  433.                     }
  434.                 }
  435.             }
  436.         }
  437.         iExec = pNdbConnection->execute_ok(Commit);
  438.         if (iExec == -1) 
  439.         {
  440.             ndbout << pNdbConnection->getNdbError() << endl;
  441.         }
  442.         if(iExec==0)
  443.         {
  444.             Uint32 nValue0 = ppNdbRecAttr[0]->u_32_value();
  445.             for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  446.             {
  447.                 for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  448.                 {
  449.                     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  450.                     {
  451.                         Uint32 nValue = ppNdbRecAttr[(iTable*g_nTuple+iTuple)*g_nAttribute+iAttr]->u_32_value();
  452.                         Uint32 nExpected = nValue0 + (iTable*g_nTuple+iTuple)*g_nAttribute+iAttr;
  453.                         if(nValue!=nExpected)
  454.                         {
  455.                             ReportInconsistency(iPart, iTable, iTuple, iAttr, nValue, nExpected);
  456.                         }
  457.                     }
  458.                 }
  459.             }
  460.         }
  461.         pNdb->closeTransaction(pNdbConnection);
  462.     }
  463.     return 0;
  464. }
  467. int DeleteTransaction(Ndb* pNdb, const Uint32 iPart, const bool bIndex)
  468. {
  469.     int iExec = -1;
  470.     int iCode = -1;
  471.     NdbConnection* pNdbConnection = pNdb->startTransaction();
  472.     if(pNdbConnection)
  473.     {
  474.         for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  475.         {
  476.             for(Uint32 iTuple=0; iTuple<g_nTuple; ++iTuple)
  477.             {
  478.                 if(bIndex)
  479.                 {
  480.                     NdbIndexOperation* pNdbIndexOperation = pNdbConnection->getNdbIndexOperation(g_szIndex+iTable*4, g_szTable+iTable*4);
  481.                     pNdbIndexOperation->deleteTuple();
  482.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  483.                     pNdbIndexOperation->equal("PK", nPK);
  484.                 }
  485.                 else
  486.                 {
  487.                     NdbOperation* pNdbOperation = pNdbConnection->getNdbOperation(g_szTable+iTable*4);
  488.                     pNdbOperation->deleteTuple();
  489.                     Uint32 nPK = iPart*g_nTuple + iTuple;
  490.                     pNdbOperation->equal("PK", nPK);
  491.                 }
  492.             }
  493.         }
  494.         iExec = pNdbConnection->execute_ok(Commit);
  496.         if (iExec == -1) 
  497.         {
  498.             ndbout << pNdbConnection->getNdbError() << endl;
  499.         }
  500.         pNdb->closeTransaction(pNdbConnection);
  501.     }
  502.     return 0;
  503. }
  506. extern "C" void* ThreadFunc(void*)
  507. {
  508.     Ndb* pNdb = new Ndb("TEST_DB");
  509.     pNdb->init();
  510.     pNdb->waitUntilReady();
  512.     MT19937 rndgen;
  513.     rndgen.sgenrand((unsigned long)pNdb);
  515.     Uint32 nInsertError = 0;
  516.     Uint32 nInsertCommit = 0;
  517.     Uint32 nInsertRollback = 0;
  518.     Uint32 nUpdateGetAndSetError = 0;
  519.     Uint32 nUpdateGetAndSetCommit = 0;
  520.     Uint32 nUpdateGetAndSetRollback = 0;
  521.     Uint32 nReadError = 0;
  522.     Uint32 nReadCommit = 0;
  523.     Uint32 nReadRollback = 0;
  524.     Uint32 nUpdateInterpretedError = 0;
  525.     Uint32 nUpdateInterpretedCommit = 0;
  526.     Uint32 nUpdateInterpretedRollback = 0;
  527.     Uint32 nDeleteError = 0;
  528.     Uint32 nDeleteCommit = 0;
  529.     Uint32 nDeleteRollback = 0;
  531.     if (g_bVerify)
  532.     {
  533.         for (Uint32 iPart = 0; iPart < g_nPart; iPart++)
  534.         {
  535.             switch(ReadTransaction(pNdb, iPart, false))
  536.             {
  537.             case -1: ++nReadError; break;
  538.             case 0: ++nReadCommit; break;
  539.             case 1: ++nReadRollback; break;
  540.             }
  541.         }
  542.     }
  543.     else
  544.         while(NdbMutex_Trylock(g_pNdbMutexStop))
  545.         {
  546.             Uint32 iPart = rndgen.genrand() % g_nPart;
  547.             Uint32 iTrans = rndgen.genrand() % 5;
  548.             bool bIndex = ((rndgen.genrand() & 1) ? true : false);
  549.             switch(iTrans)
  550.             {
  551.             case 0: 
  552.                 switch(InsertTransaction(pNdb, iPart, bIndex))
  553.                 {
  554.                 case -1: ++nInsertError; break;
  555.                 case 0: ++nInsertCommit; break;
  556.                 case 1: ++nInsertRollback; break;
  557.                 }
  558.                 break;
  560.             case 1: 
  561.                 switch(UpdateGetAndSetTransaction(pNdb, iPart, bIndex))
  562.                 {
  563.                 case -1: ++nUpdateGetAndSetError; break;
  564.                 case 0: ++nUpdateGetAndSetCommit; break;
  565.                 case 1: ++nUpdateGetAndSetRollback; break;
  566.                 }
  567.                 break;
  569.             case 2: 
  570.                 switch(ReadTransaction(pNdb, iPart, bIndex))
  571.                 {
  572.                 case -1: ++nReadError; break;
  573.                 case 0: ++nReadCommit; break;
  574.                 case 1: ++nReadRollback; break;
  575.                 }
  576.                 break;
  578.             case 3: 
  579.                 switch(UpdateInterpretedTransaction(pNdb, iPart, bIndex))
  580.                 {
  581.                 case -1: ++nUpdateInterpretedError; break;
  582.                 case 0: ++nUpdateInterpretedCommit; break;
  583.                 case 1: ++nUpdateInterpretedRollback; break;
  584.                 }
  585.                 break;
  587.             case 4: 
  588.                 switch(DeleteTransaction(pNdb, iPart, bIndex))
  589.                 {
  590.                 case -1: ++nDeleteError; break;
  591.                 case 0: ++nDeleteCommit; break;
  592.                 case 1: ++nDeleteRollback; break;
  593.                 }
  594.                 break;
  595.             }
  596.         }
  598.         ndbout << "I:" << nInsertError << ":" << nInsertCommit << ":" << nInsertRollback;
  599.         ndbout << " UG:" << nUpdateGetAndSetError << ":" << nUpdateGetAndSetCommit << ":" << nUpdateGetAndSetRollback;
  600.         ndbout << " R:" << nReadError << ":" << nReadCommit << ":" << nReadRollback;
  601.         ndbout << " UI:" << nUpdateInterpretedError << ":" << nUpdateInterpretedCommit << ":" << nUpdateInterpretedRollback;
  602.         ndbout << " D:" << nDeleteError << ":" << nDeleteCommit << ":" << nDeleteRollback << endl;
  603.         ndbout << endl;
  605.         NdbMutex_Unlock(g_pNdbMutexStop);
  606.         delete pNdb;
  607.         return 0;
  608. }
  611. int main(int argc, char* argv[])
  612. {
  613.     ndb_init();
  614.     Uint32 nSeconds = 1;
  615.     Uint32 nThread = 1;
  617.     for(int iArg=1; iArg<argc; ++iArg)
  618.     {
  619.         if(argv[iArg][0]=='-')
  620.         {
  621.             switch(argv[iArg][1])
  622.             {
  623.             case 'p': g_nPart = atol(argv[iArg]+2); break;
  624.             case 'b': g_nTable = atol(argv[iArg]+2); break;
  625.             case 'u': g_nTuple = atol(argv[iArg]+2); break;
  626.             case 'a': g_nAttribute = atol(argv[iArg]+2); break;
  627.             case 'v': g_bVerify = true; break;
  628.             case 't': nThread = atol(argv[iArg]+2); break;
  629.             case 's': nSeconds = atol(argv[iArg]+2); break;
  630.             case 'i': g_bUseIndex = true; break;
  631.             }
  632.         }
  633.     }
  634.     ndbout << argv[0];
  635.     ndbout << " -p" << g_nPart;
  636.     ndbout << " -b" << g_nTable;
  637.     ndbout << " -u" << g_nTuple;
  638.     ndbout << " -a" << g_nAttribute;
  639.     if (g_bVerify)
  640.         ndbout << " -v";
  641.     ndbout << " -t" << nThread;
  642.     ndbout << " -s" << nSeconds;
  643.     ndbout << endl;
  645.     g_szTable = new char[g_nTable*4];
  646.     for(Uint32 iTable=0; iTable<g_nTable; ++iTable)
  647.     {
  648.         sprintf(g_szTable+iTable*4, "T%02d", iTable);
  649.     }
  651.     g_szIndex = new char[g_nTable*4];
  652.     for(Uint32 iIndex=0; iIndex<g_nTable; ++iIndex)
  653.     {
  654.         sprintf(g_szIndex+iIndex*4, "I%02d", iIndex);
  655.     }
  657.     g_szAttribute = new char[g_nAttribute*4];
  658.     for(Uint32 iAttr=0; iAttr<g_nAttribute; ++iAttr)
  659.     {
  660.         sprintf(g_szAttribute+iAttr*4, "A%02d", iAttr);
  661.     }
  664.     Ndb* pNdb = new Ndb("TEST_DB");
  665.     pNdb->init();
  666.     pNdb->waitUntilReady();
  668.     if (!g_bVerify) CreateTables(pNdb);
  669.     g_pNdbMutexStop = NdbMutex_Create();
  670.     NdbMutex_Lock(g_pNdbMutexStop);
  672.     NdbThread_SetConcurrencyLevel(nThread+1);
  673.     NdbThread** ppNdbThread = new NdbThread*[nThread];
  674.     for(Uint32 iThread=0; iThread<nThread; ++iThread)
  675.     {
  676.         ppNdbThread[iThread] = NdbThread_Create(ThreadFunc, 0, 0, "ThreadFunc", NDB_THREAD_PRIO_MEAN);
  677.     }
  679.     NdbSleep_SecSleep(nSeconds);
  680.     NdbMutex_Unlock(g_pNdbMutexStop);
  682.     for(Uint32 iThread=0; iThread<nThread; ++iThread)
  683.     {
  684.         void* status;
  685.         NdbThread_WaitFor(ppNdbThread[iThread], &status);
  686.     }
  688.     NdbMutex_Destroy(g_pNdbMutexStop);
  689.     g_pNdbMutexStop = 0;
  690.     delete pNdb;
  691. }