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

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

MySQL数据库

开发平台：

Visual C++

celloDb.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. /* ***************************************************
  19.        BASIC TEST 1
  20.        Test basic functions and status of NDB
  22.        Arguments:
  23.         none 
  25.        Returns:
  26.         0 - Test passed
  27.        -1 - Test failed
  28.         1 - Invalid arguments
  29. flexBench
  30.  * *************************************************** */
  32. #include <NdbApi.hpp>
  33. #include <NdbMain.h>
  35. #define MAXATTR 4
  36. #define MAXTABLES 4
  37. #define PAGESIZE 8192
  38. #define OVERHEAD 0.02
  39. #define NUMBEROFRECORDS 10
  40. #define PKSIZE 1
  41. #define ATTRNAMELEN 16
  44. static void  createTable_IPACCT(Ndb*);
  45. static void  createTable_RPACCT(Ndb*);
  46. static void  createTable_SBMCALL(Ndb*);
  47. static void  createTable_TODACCT(Ndb*);
  49. static void  error_handler(const char*);
  50. static bool  error_handler2(const char*, int) ;
  52. static void  setAttrNames(void);
  53. static void  setTableNames(void);
  54. static void  create_table(Ndb*);
  55. static void  insert_rows(Ndb*);
  56. static void  update_rows(Ndb*);
  57. static void  delete_rows(Ndb*);
  58. static void  verify_deleted(Ndb*);
  59. static void  read_and_verify_rows(Ndb*);
  61. static void  insert_IPACCT(Ndb*, Uint32, Uint32, Uint32, Uint32, Uint32); //3 for Pk, and two data. just to test;
  63. static void read_IPACCT(Ndb* , Uint32 , Uint32  , Uint32 );
  65. static  int         tAttributeSize;
  66. static  int             bTestPassed;
  68. static  char     tableName[MAXTABLES][ATTRNAMELEN];static  char     attrName[MAXATTR][ATTRNAMELEN];
  69. static  int         attrValue[NUMBEROFRECORDS];
  70. static  int                 pkValue[NUMBEROFRECORDS];
  71. static int     failed = 0 ;
  72. #include <NdbOut.hpp>
  74. NDB_COMMAND(celloDb, "celloDb", "celloDb", "celloDb", 65535)
  75. {
  76.   ndb_init();
  78.   int                   tTableId;
  79.   int                   i;
  80.   Ndb        MyNdb( "CELLO-SESSION-DB" );
  82.   MyNdb.init();
  84.   // Assume test passed
  85.   bTestPassed = 0;
  86.   /*
  87.   // Initialize global variables
  88.   for (i = 0; i < NUMBEROFRECORDS; i ++)
  89.      pkValue[i] = i; 
  90.   
  91.   for (i = 0; i < NUMBEROFRECORDS; i ++)
  92.      attrValue[i] = i;
  93.   */
  94.   tAttributeSize = 1;
  96.   // Wait for Ndb to become ready
  97.   if (MyNdb.waitUntilReady() == 0) {
  98.     ndbout << endl << "Cello session db - Starting " << endl;
  99.     ndbout << "Test basic functions and status of NDB" << endl;
  100.     
  102.       
  103.     createTable_SBMCALL (&MyNdb );
  104.     createTable_RPACCT (&MyNdb );
  105.     createTable_TODACCT (&MyNdb );
  106.     createTable_IPACCT (&MyNdb );
  107.     
  108.     insert_IPACCT(&MyNdb, 1,2,1,2,2);
  109.     read_IPACCT(&MyNdb, 1, 2 , 1);
  110.     /*
  111.       insert_rows(&MyNdb);
  113.       read_and_verify_rows(&MyNdb);
  116.       // Create some new values to use for update
  117.       for (i = 0; i < NUMBEROFRECORDS; i++)
  118.   attrValue[i] = NUMBEROFRECORDS-i;
  120.       update_rows(&MyNdb);
  122.       read_and_verify_rows(&MyNdb);
  124.       delete_rows(&MyNdb);
  126.       verify_deleted(&MyNdb);
  127.       */
  128.     }
  129.     else {
  130. bTestPassed = -1;
  131.       }
  134.   if (bTestPassed == 0)
  135.     {
  136.       // Test passed
  137.       ndbout << "OK - Test passed" << endl;
  138.     }
  139.   else
  140.     {
  141.       // Test failed
  142.       ndbout << "FAIL - Test failed" << endl;
  143.       exit(-1);
  144.     }
  145.   return NULL;
  146. }
  148. static void 
  149. error_handler(const char* errorText)
  150. {
  151.   // Test failed 
  152.   ndbout << endl << "ErrorMessage: " << errorText << endl;
  153.   bTestPassed = -1;
  154. }
  156. static void
  157. createTable_SBMCALL ( Ndb* pMyNdb )
  158. {
  159.   /****************************************************************
  160.    * Create table and attributes. 
  161.    *
  162.    *    create table SBMCALL(
  163.    *      for attribs, see the REQ SPEC for cello session DB
  164.    *     )
  165.    *  
  166.    ***************************************************************/ 
  168.   const char* tname = "SBMCALL";
  169.   Uint32 recordsize = 244; //including 12 byte overhead
  170.   Uint32 pksize = 8; //size of total prim. key. in bytes. sum of entire composite PK.
  171.   Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
  172.   
  173.   if (tTableId == -1) {    
  174.     Uint32              check; 
  175.     Uint32              i;
  176.     NdbSchemaCon       *MySchemaTransaction;
  177.     NdbSchemaOp         *MySchemaOp;
  178.     
  179.     ndbout << "Creating " << tname << "..." << endl;
  180.     
  181.     MySchemaTransaction = pMyNdb->startSchemaTransaction();
  182.     if( ( MySchemaTransaction == NULL ) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  183.       exit (-1) ;
  184.     
  185.     MySchemaOp = MySchemaTransaction->getNdbSchemaOp();
  186.     if( ( MySchemaOp == NULL ) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  187.       exit (-1) ;
  188.     
  189.         
  190.     // Createtable
  192.     Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
  193.     Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
  194.     
  195.     ndbout << "table size " << tablesize << "for table name " << tname << endl;
  196.     
  197.     check = MySchemaOp->createTable( tname,
  198.                       tablesize, // Table Size
  199.      TupleKey, // Key Type
  200.      noPages, // Nr of Pages
  201.      All,
  202.      6,
  203.      78,
  204.      80,
  205.      1,
  206.      true
  207.      );
  208.     
  209.     if( check == -1 ) {
  210.       error_handler(MySchemaTransaction->getNdbErrorString());
  211.       exit(-1);
  212.     }
  213.     
  215.     
  216.     // Create first column, primary key 
  217.     check = MySchemaOp->createAttribute( "SPBBOARDID",
  218.  TupleKey,
  219.  32,
  220.  PKSIZE,
  221.  UnSigned,
  222.  MMBased,
  223.  NotNullAttribute );
  225.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  226.       exit (-1) ;
  227.     
  229.     // Create second column, primary key 
  230.     check = MySchemaOp->createAttribute( "CALLID",
  231.  TupleKey,
  232.  32,
  233.  PKSIZE,
  234.  UnSigned,
  235.  MMBased,
  236.  NotNullAttribute );
  237.     
  238.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  239.       exit (-1) ;
  240.     
  242.     // Creat thrid column, RP Session info, byte[16] represented as (String, 16)
  243.     check = MySchemaOp->createAttribute( "RPSESS",
  244.  NoKey,
  245.  32,
  246.  16,
  247.  String,
  248.  MMBased,
  249.  NullAttribute );
  250.     
  251.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  252.       exit (-1) ;
  253.     
  254. // Creat fourth column, GRE Tunnel info, byte[16] represented as (String, 16)
  255.     check = MySchemaOp->createAttribute( "GRETUNNEL",
  256.  NoKey,
  257.  32,
  258.  16,
  259.  String,
  260.  MMBased,
  261.  NullAttribute );
  262.     
  263.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  264.       exit (-1) ;
  265.     
  266. // Creat fifth column, PPP Session info, byte[24] represented as (String, 24)
  267.     check = MySchemaOp->createAttribute( "PPPSESS",
  268.  NoKey,
  269.  32,
  270.  24,
  271.  String,
  272.  MMBased,
  273.  NullAttribute );
  274.     
  275.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  276.       exit (-1) ;
  278.     
  279.     if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  280.       exit (-1) ;
  281.     
  282.     pMyNdb->closeSchemaTransaction(MySchemaTransaction);
  283.     ndbout << "done" << endl;
  284.     
  285.     
  286.   } //if 
  287.   
  288.   //else table already created , proceed
  289. }
  293. static void
  294. createTable_RPACCT(Ndb*pMyNdb)
  295. {
  296.   
  297.   /****************************************************************
  298.    * Create table and attributes. 
  299.    *
  300.    *    create table RPACCT(
  301.    *      for attribs, see the REQ SPEC for cello session DB
  302.    *     )
  303.    *  
  304.    ***************************************************************/ 
  305.  
  306.  const char* tname = "RPACCT";
  307.  Uint32 recordsize = 380; //including 12 byte overhead
  308.  Uint32 pksize = 8; //size of total prim. key. in bytes.
  309.  Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
  310.  
  311.  if (tTableId == -1) {    
  312.    Uint32              check; 
  313.    Uint32              i;
  314.    NdbSchemaCon       *MySchemaTransaction;
  315.    NdbSchemaOp         *MySchemaOp;
  316.    
  317.    ndbout << "Creating " << tname << "..." << endl;
  318.    
  319.    MySchemaTransaction = pMyNdb->startSchemaTransaction();
  320.    if( MySchemaTransaction == NULL )
  321.      error_handler(MySchemaTransaction->getNdbErrorString());
  322.    
  323.    MySchemaOp = MySchemaTransaction->getNdbSchemaOp();
  324.    if( MySchemaOp == NULL ) 
  325.       error_handler(MySchemaTransaction->getNdbErrorString());
  326.    
  327.    // Createtable
  328.    
  329.    Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
  330.    Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
  331.    
  332.    ndbout << "table size " << tablesize << "for table name " << tname << endl;
  333.    
  334.    check = MySchemaOp->createTable( tname,
  335.     tablesize, // Table Size
  336.     TupleKey, // Key Type
  337.      noPages // Nr of Pages
  338.     );
  339.    
  340.    if( check == -1 ) 
  341.      error_handler(MySchemaTransaction->getNdbErrorString());
  342.    
  343.    
  344.    
  345.    // Create first column, primary key 
  346.    check = MySchemaOp->createAttribute( "SPBBOARDID",
  347. TupleKey,
  348. 32,
  349. PKSIZE,
  350.  UnSigned,
  351. MMBased,
  352. NotNullAttribute );
  353.    
  354.    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  355.      exit (-1) ;
  356.    
  357.    
  358.    // Create second column, primary key 
  359.    check = MySchemaOp->createAttribute( "CALLID",
  360. TupleKey,
  361. 32,
  362. PKSIZE,
  363.  UnSigned,
  364.  MMBased,
  365.  NotNullAttribute );
  366.     
  367.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  368.       exit (-1) ;
  369.     
  371.     // Creat thrid column MS ID, 4 byte unsigned
  372.     check = MySchemaOp->createAttribute( "MSID",
  373.  NoKey,
  374.  32,
  375.  1,
  376.  UnSigned,
  377.  MMBased,
  378.  NullAttribute );
  379.     
  380.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  381.       exit (-1) ;
  382.     
  384.     // Create PDSN FA Address, 4 byte unsigned
  385.     check = MySchemaOp->createAttribute( "PDSN",
  386.  NoKey,
  387.  32,
  388.  1,
  389.  UnSigned,
  390.  MMBased,
  391.  NullAttribute );
  392.     
  393.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  394.       exit (-1) ;
  395.     
  397.     // Create Serving PCF, 4 byte unsigned
  398.     check = MySchemaOp->createAttribute( "SPCF",
  399.  NoKey,
  400.  32,
  401.  1,
  402.  UnSigned,
  403.  MMBased,
  404.  NullAttribute );
  405.     
  406.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  407.       exit (-1) ;
  408.     
  411.     // Create BS ID, 12 byte char, represented as String,12
  412.     check = MySchemaOp->createAttribute( "BSID",
  413.  NoKey,
  414.  32,
  415.  12,
  416.  String,
  417.  MMBased,
  418.  NullAttribute );
  419.     
  420.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  421.       exit (-1) ;
  422.     
  427.     // Create User Zone, 4 byte unsigned
  428.     check = MySchemaOp->createAttribute( "UZ",
  429.  NoKey,
  430.  32,
  431.  1,
  432.  UnSigned,
  433.  MMBased,
  434.  NullAttribute );
  435.     
  436.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  437.       exit (-1) ;
  438.     
  440.     // Create Forward Multiplex, 4 byte unsigned
  441.     check = MySchemaOp->createAttribute( "FMO",
  442.  NoKey,
  443.  32,
  444.  1,
  445.  UnSigned,
  446.  MMBased,
  447.  NullAttribute );
  448.     
  449.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  450.       exit (-1) ;
  451.     
  453.     // Create Reverse Multiplex, 4 byte unsigned
  454.     check = MySchemaOp->createAttribute( "RMO",
  455.  NoKey,
  456.  32,
  457.  1,
  458.  UnSigned,
  459.  MMBased,
  460.  NullAttribute );
  461.     
  462.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  463.       exit (-1) ;
  466.     // Create Forward Fund rate, 4 byte unsigned
  467.     check = MySchemaOp->createAttribute( "FFR",
  468.  NoKey,
  469.  32,
  470.  1,
  471.  UnSigned,
  472.  MMBased,
  473.  NullAttribute );
  474.     
  475.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  476.       exit (-1) ;
  478.     
  479.  // Create Reverse Fund rate, 4 byte unsigned
  480.     check = MySchemaOp->createAttribute( "RFR",
  481.  NoKey,
  482.  32,
  483.  1,
  484.  UnSigned,
  485.  MMBased,
  486.  NullAttribute );
  487.     
  488.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  489.       exit (-1) ;
  492.     
  493.  // Create Service Option, 4 byte unsigned
  494.     check = MySchemaOp->createAttribute( "SO",
  495.  NoKey,
  496.  32,
  497.  1,
  498.  UnSigned,
  499.  MMBased,
  500.  NullAttribute );
  501.     
  502.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  503.       exit (-1) ;
  508.  // Create Forward Traffic Type, 4 byte unsigned
  509.     check = MySchemaOp->createAttribute( "FTT",
  510.  NoKey,
  511.  32,
  512.  1,
  513.  UnSigned,
  514.  MMBased,
  515.  NullAttribute );
  516.     
  517.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  518.       exit (-1) ;
  522. // Create Reverse Traffic Type, 4 byte unsigned
  523.     check = MySchemaOp->createAttribute( "RTT",
  524.  NoKey,
  525.  32,
  526.  1,
  527.  UnSigned,
  528.  MMBased,
  529.  NullAttribute );
  530.     
  531.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  532.       exit (-1) ;
  536. // Create Fund Frame Size, 4 byte unsigned
  537.     check = MySchemaOp->createAttribute( "FFS",
  538.  NoKey,
  539.  32,
  540.  1,
  541.  UnSigned,
  542.  MMBased,
  543.  NullAttribute );
  544.     
  545.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  546.       exit (-1) ;
  550. // Create Forware Fund RC, 4 byte unsigned
  551.     check = MySchemaOp->createAttribute( "FFRC",
  552.  NoKey,
  553.  32,
  554.  1,
  555.  UnSigned,
  556.  MMBased,
  557.  NullAttribute );
  558.     
  559.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  560.       exit (-1) ;
  564.     // Create Reverse Fund RC, 4 byte unsigned
  565.     check = MySchemaOp->createAttribute( "RFRC",
  566.  NoKey,
  567.  32,
  568.  1,
  569.  UnSigned,
  570.  MMBased,
  571.  NullAttribute );
  572.     
  573.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  574.       exit (-1) ;
  575.     
  577.     // Create DCCH Frame Format, 4 byte unsigned
  578.     check = MySchemaOp->createAttribute( "DCCH",
  579.  NoKey,
  580.  32,
  581.  1,
  582.  UnSigned,
  583.  MMBased,
  584.  NullAttribute );
  585.     
  586.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  587.       exit (-1) ;
  588.     
  589.     
  590.     // Create Airlink QOS, 4 byte unsigned
  591.     check = MySchemaOp->createAttribute( "AQOS",
  592.  NoKey,
  593.  32,
  594.  1,
  595.  UnSigned,
  596.  MMBased,
  597.  NullAttribute );
  598.     
  599.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  600.       exit (-1) ;
  604. // Create Bad PPP Frame Count , 4 byte unsigned
  605.     check = MySchemaOp->createAttribute( "BPPPFC",
  606.  NoKey,
  607.  32,
  608.  1,
  609.  UnSigned,
  610.  MMBased,
  611.  NullAttribute );
  612.     
  613.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  614.       exit (-1) ;
  619. // Create Active Time , 4 byte unsigned
  620.     check = MySchemaOp->createAttribute( "AT",
  621.  NoKey,
  622.  32,
  623.  1,
  624.  UnSigned,
  625.  MMBased,
  626.  NullAttribute );
  627.     
  628.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  629.       exit (-1) ;
  633. // Create Nb Active Transitions , 4 byte unsigned
  634.     check = MySchemaOp->createAttribute( "NBAT",
  635.  NoKey,
  636.  32,
  637.  1,
  638.  UnSigned,
  639.  MMBased,
  640.  NullAttribute );
  641.     
  642.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  643.       exit (-1) ;
  646. // Create SDB Octet Count In , 4 byte unsigned
  647.     check = MySchemaOp->createAttribute( "SDBOCI",
  648.  NoKey,
  649.  32,
  650.  1,
  651.  UnSigned,
  652.  MMBased,
  653.  NullAttribute );
  654.     
  655.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  656.       exit (-1) ;
  659.     
  661. // Create Nb SDB In, 4 byte unsigned
  662.     check = MySchemaOp->createAttribute( "NBSDBI",
  663.  NoKey,
  664.  32,
  665.  1,
  666.  UnSigned,
  667.  MMBased,
  668.  NullAttribute );
  669.     
  670.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  671.       exit (-1) ;
  676. // Create Nb SDB Out, 4 byte unsigned
  677.     check = MySchemaOp->createAttribute( "NBSDBO",
  678.  NoKey,
  679.  32,
  680.  1,
  681.  UnSigned,
  682.  MMBased,
  683.  NullAttribute );
  684.     
  685.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  686.       exit (-1) ;
  691. // Create HDLC Bytes received, 4 byte unsigned
  692.     check = MySchemaOp->createAttribute( "HDLC",
  693.  NoKey,
  694.  32,
  695.  1,
  696.  UnSigned,
  697.  MMBased,
  698.  NullAttribute );
  699.     
  700.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  701.       exit (-1) ;
  702.     
  704.     
  705.     if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  706.       exit (-1) ;
  707.     
  708.     pMyNdb->closeSchemaTransaction(MySchemaTransaction);
  709.     ndbout << "done" << endl;
  710.     
  711.  } //if 
  712.   
  713.  //else table already created , proceed
  714.   }
  715.  
  717. static void
  718. createTable_IPACCT(Ndb* pMyNdb)
  719. {
  722.   /****************************************************************
  723.    * Create table and attributes. 
  724.    *
  725.    *    create table IPACCT(
  726.    *      for attribs, see the REQ SPEC for cello session DB
  727.    *     )
  728.    *  
  729.    ***************************************************************/ 
  731.   const char* tname = "IPACCT";
  732.   Uint32 recordsize = 70; //including 12 byte overhead
  733.   Uint32 pksize = 12; //size of total prim. key. in bytes.
  734.   Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
  735.   
  736.   if (tTableId == -1) {    
  737.     Uint32              check; 
  738.     Uint32              i;
  739.     NdbSchemaCon       *MySchemaTransaction;
  740.     NdbSchemaOp         *MySchemaOp;
  741.     
  742.     ndbout << "Creating " << tname << "..." << endl;
  743.     
  744.     MySchemaTransaction = pMyNdb->startSchemaTransaction();
  745.     if( MySchemaTransaction == NULL )
  746.       error_handler(MySchemaTransaction->getNdbErrorString());
  747.     
  748.     MySchemaOp = MySchemaTransaction->getNdbSchemaOp();
  749.     if( MySchemaOp == NULL ) 
  750.       error_handler(MySchemaTransaction->getNdbErrorString());
  751.     
  752.     // Createtable
  754.     Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
  755.     Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
  756.     
  757.     ndbout << "table size " << tablesize << "for table name " << tname << endl;
  758.     
  759.     check = MySchemaOp->createTable( tname,
  760.                       tablesize, // Table Size
  761.      TupleKey, // Key Type
  762.      noPages // Nr of Pages
  763.      );
  764.     
  765.     if( check == -1 ) 
  766.       error_handler(MySchemaTransaction->getNdbErrorString());
  767.     
  770.     // Create first column, primary key 
  771.     check = MySchemaOp->createAttribute( "SPBBOARDID",
  772.  TupleKey,
  773.  32,
  774.  PKSIZE,
  775.  UnSigned,
  776.  MMBased,
  777.  NotNullAttribute );
  779.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  780.       exit (-1) ;
  781.     
  783.     // Create second column, primary key 
  784.     check = MySchemaOp->createAttribute( "CALLID",
  785.  TupleKey,
  786.  32,
  787.  PKSIZE,
  788.  UnSigned,
  789.  MMBased,
  790.  NotNullAttribute );
  791.     
  792.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  793.       exit (-1) ;
  795.    // Create third column, primary key 
  796.     check = MySchemaOp->createAttribute( "IPADDR",
  797.  TupleKey,
  798.  32,
  799.  PKSIZE,
  800.  String,
  801.  MMBased,
  802.  NotNullAttribute );
  803.     
  804.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  805.       exit (-1) ;
  808.      
  810. // Create Acct session id  4 byte unsigned
  811.     check = MySchemaOp->createAttribute( "ASID",
  812.  NoKey,
  813.  32,
  814.  1,
  815.  UnSigned,
  816.  MMBased,
  817.  NullAttribute );
  818.     
  819.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  820.       exit (-1) ;
  823. // Create Correlation ID, 4 byte unsigned
  824.     check = MySchemaOp->createAttribute( "CID",
  825.  NoKey,
  826.  32,
  827.  1,
  828.  UnSigned,
  829.  MMBased,
  830.  NullAttribute );
  831.     
  832.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  833.       exit (-1) ;
  836. // Create MIP HA Address, 4 byte unsigned
  837.     check = MySchemaOp->createAttribute( "MIPHA",
  838.  NoKey,
  839.  32,
  840.  1,
  841.  UnSigned,
  842.  MMBased,
  843.  NullAttribute );
  844.     
  845.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  846.       exit (-1) ;
  849.     
  851.     
  852. // Create IP technology, 4 byte unsigned
  853.     check = MySchemaOp->createAttribute( "IPT",
  854.  NoKey,
  855.  32,
  856.  1,
  857.  UnSigned,
  858.  MMBased,
  859.  NullAttribute );
  860.     
  861.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  862.       exit (-1) ;
  866. // Create Compuls Tunnel ID, 4 byte unsigned
  867.     check = MySchemaOp->createAttribute( "CTID",
  868.  NoKey,
  869.  32,
  870.  1,
  871.  UnSigned,
  872.  MMBased,
  873.  NullAttribute );
  874.     
  875.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  876.       exit (-1) ;
  878. // Create IP QOS, 4 byte unsigned
  879.     check = MySchemaOp->createAttribute( "IPQOS",
  880.  NoKey,
  881.  32,
  882.  1,
  883.  UnSigned,
  884.  MMBased,
  885.  NullAttribute );
  886.     
  887.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  888.       exit (-1) ;
  890.     
  891.     // Create Data octet count in, 4 byte unsigned
  892.     check = MySchemaOp->createAttribute( "DOCI",
  893.  NoKey,
  894.  32,
  895.  1,
  896.  UnSigned,
  897.  MMBased,
  898.  NullAttribute );
  899.     
  900.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  901.       exit (-1) ;
  903.     // Create Data octet count out, 4 byte unsigned
  904.     check = MySchemaOp->createAttribute( "DOCO",
  905.  NoKey,
  906.  32,
  907.  1,
  908.  UnSigned,
  909.  MMBased,
  910.  NullAttribute );
  911.     
  912.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  913.       exit (-1) ;
  915.     // Create Event time, 4 byte unsigned
  916.     check = MySchemaOp->createAttribute( "ET",
  917.  NoKey,
  918.  32,
  919.  1,
  920.  UnSigned,
  921.  MMBased,
  922.  NullAttribute );
  923.     
  924.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  925.       exit (-1) ;
  927.      // Create In mip sig count, 4 byte unsigned
  928.     check = MySchemaOp->createAttribute( "IMSC",
  929.  NoKey,
  930.  32,
  931.  1,
  932.  UnSigned,
  933.  MMBased,
  934.  NullAttribute );
  935.     
  936.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  937.       exit (-1) ;
  939. // Create Out mip sig count, 4 byte unsigned
  940.     check = MySchemaOp->createAttribute( "OMSC",
  941.  NoKey,
  942.  32,
  943.  1,
  944.  UnSigned,
  945.  MMBased,
  946.  NullAttribute );
  947.     
  948.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  949.       exit (-1) ;
  951.     
  952.     if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  953.       exit (-1) ;
  954.     
  955.     pMyNdb->closeSchemaTransaction(MySchemaTransaction);
  956.     ndbout << "done" << endl;
  957.     
  960.   } //if 
  962.   //else table already created , proceed
  963. }
  966. static void
  967. createTable_TODACCT(Ndb* pMyNdb)
  968. {
  971.   /****************************************************************
  972.    * Create table and attributes. 
  973.    *
  974.    *    create table TODACCT(
  975.    *      for attribs, see the REQ SPEC for cello session DB
  976.    *     )
  977.    *  
  978.    ***************************************************************/ 
  979.   
  980.   const char* tname = "TODACCT";
  981.   Uint32 recordsize = 92; //including 12 byte overhead
  982.   Uint32 pksize = 12; //size of total prim. key. in bytes.
  983.   Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
  984.   
  985.   if (tTableId == -1) {    
  986.     Uint32              check; 
  987.     Uint32              i;
  988.     NdbSchemaCon       *MySchemaTransaction;
  989.     NdbSchemaOp         *MySchemaOp;
  990.     
  991.     ndbout << "Creating " << tname << "..." << endl;
  992.     
  993.     MySchemaTransaction = pMyNdb->startSchemaTransaction();
  994.     if( MySchemaTransaction == NULL )
  995.       error_handler(MySchemaTransaction->getNdbErrorString());
  996.     
  997.     MySchemaOp = MySchemaTransaction->getNdbSchemaOp();
  998.     if( MySchemaOp == NULL ) 
  999.       error_handler(MySchemaTransaction->getNdbErrorString());
  1000.     
  1001.     // Createtable
  1002.     
  1003.     Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
  1004.     Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
  1005.     
  1006.     ndbout << "table size " << tablesize << "for table name " << tname << endl;
  1007.     
  1008.     check = MySchemaOp->createTable( tname,
  1009.                       tablesize, // Table Size
  1010.      TupleKey, // Key Type
  1011.      noPages // Nr of Pages
  1012.      );
  1013.     
  1014.     if( check == -1 ) 
  1015.       error_handler(MySchemaTransaction->getNdbErrorString());
  1016.     
  1019.     // Create first column, primary key 
  1020.     check = MySchemaOp->createAttribute( "SPBBOARDID",
  1021.  TupleKey,
  1022.  32,
  1023.  PKSIZE,
  1024.  UnSigned,
  1025.  MMBased,
  1026.  NotNullAttribute );
  1028.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1029.       exit (-1) ;
  1030.     
  1032.     // Create second column, primary key 
  1033.     check = MySchemaOp->createAttribute( "CALLID",
  1034.  TupleKey,
  1035.  32,
  1036.  PKSIZE,
  1037.  UnSigned,
  1038.  MMBased,
  1039.  NotNullAttribute );
  1040.     
  1041.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1042.       exit (-1) ;
  1044.    // Create third column, primary key 
  1045.     check = MySchemaOp->createAttribute( "IPADDR",
  1046.  TupleKey,
  1047.  32,
  1048.  PKSIZE,
  1049.  String,
  1050.  MMBased,
  1051.  NotNullAttribute );
  1052.     
  1053.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1054.       exit (-1) ;
  1058.    // Create third column, primary key 
  1059.     check = MySchemaOp->createAttribute( "INDEX",
  1060.  TupleKey,
  1061.  32,
  1062.  PKSIZE,
  1063.  UnSigned,
  1064.  MMBased,
  1065.  NotNullAttribute );
  1066.     
  1067.     if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1068.       exit (-1) ;
  1071.      
  1073. // Create Acct session id  4 byte unsigned
  1074.     check = MySchemaOp->createAttribute( "TOD",
  1075.  NoKey,
  1076.  32,
  1077.  16,
  1078.  String,
  1079.  MMBased,
  1080.  NullAttribute );
  1083.    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1084.       exit (-1) ;
  1087.      
  1088.    if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
  1089.      exit (-1) ;
  1090.    
  1091.    pMyNdb->closeSchemaTransaction(MySchemaTransaction);
  1092.    ndbout << "done" << endl;
  1093.    
  1094.   } //if 
  1095.   
  1096.  //else table already created , proceed
  1097. }
  1104. static void  read_IPACCT(Ndb* pMyNdb, Uint32 CALLID, Uint32 SPBBOARDID , Uint32 IPADDR)
  1105. {
  1108.   int                   check;
  1109.   int                   loop_count_ops;
  1110.   int count;
  1111.   int                   count_attributes;
  1112.   char* value;
  1113.   NdbConnection *MyTransaction;
  1114.   NdbOperation *MyOperation;
  1115.   NdbRecAttr*           tTmp;
  1116.   
  1117.   
  1118.   
  1119.   MyTransaction = pMyNdb->startTransaction();
  1120.   if (MyTransaction == NULL)
  1121.     error_handler(pMyNdb->getNdbErrorString());
  1122.   
  1123.   MyOperation = MyTransaction->getNdbOperation("IPACCT");
  1124.   if (MyOperation == NULL) 
  1125.     error_handler( MyTransaction->getNdbErrorString());
  1126.   
  1127.   check = MyOperation->readTuple();
  1128.   if( check == -1 ) 
  1129.     error_handler( MyTransaction->getNdbErrorString());
  1130.   
  1131.   check = MyOperation->equal( "SPBBOARDID",SPBBOARDID );
  1132.   if( check == -1 ) 
  1133.     error_handler( MyTransaction->getNdbErrorString());
  1134.   
  1136.   check = MyOperation->equal( "IPADDR","IPADDR" );
  1137.   if( check == -1 ) 
  1138.     error_handler( MyTransaction->getNdbErrorString());
  1139.   
  1141.   check = MyOperation->equal( "CALLID",CALLID );
  1142.   if( check == -1 ) 
  1143.     error_handler( MyTransaction->getNdbErrorString());
  1148.   tTmp = MyOperation->getValue("IPQOS", NULL );
  1149.   if( tTmp == NULL ) 
  1150.     error_handler( MyTransaction->getNdbErrorString());
  1151.   ndbout << " tTmp " << tTmp->isNULL() << endl;
  1152.   MyTransaction->execute(Commit);
  1153.   
  1154.   ndbout << " value read " << tTmp->int32_value() << endl;
  1155.   
  1156. }
  1160. static void  insert_IPACCT(Ndb* pMyNdb, Uint32 CALLID, Uint32 SPBBOARDID , Uint32 IPADDR, Uint32 ASID, Uint32 IPQOS)
  1161. {
  1162.   /****************************************************************
  1163.    * Insert rows 
  1164.    *
  1165.    ***************************************************************/
  1167.   int                   check;
  1168.   int                   loop_count_ops;
  1169.   int count;
  1170.   int                   i;
  1171.   NdbConnection *MyTransaction;
  1172.   NdbOperation *MyOperation;
  1173.  
  1174.   ndbout << "Inserting records..."  << flush;
  1175.    
  1176.   MyTransaction = pMyNdb->startTransaction();
  1177.   if (MyTransaction == NULL)   
  1178.     error_handler(pMyNdb->getNdbErrorString());
  1179.   
  1180.   MyOperation = MyTransaction->getNdbOperation("IPACCT");
  1181.   if (MyOperation == NULL) 
  1182.     error_handler(MyTransaction->getNdbErrorString());
  1183.  
  1185.  
  1186.   check = MyOperation->insertTuple();
  1187.   if( check == -1 ) 
  1188.     error_handler(MyTransaction->getNdbErrorString());
  1189.   
  1190.   ndbout << "insertTuple"  << endl;  
  1191.   
  1192.   check = MyOperation->equal("CALLID",CALLID );
  1193.   if( check == -1 ) 
  1194.     error_handler(MyTransaction->getNdbErrorString());
  1195.   ndbout << "equal"  << endl;  
  1196.   
  1198.   check = MyOperation->equal("SPBBOARDID",SPBBOARDID );
  1199.   if( check == -1 ) 
  1200.     error_handler(MyTransaction->getNdbErrorString());
  1201.   ndbout << "equal"  << endl;  
  1204.   check = MyOperation->equal("IPADDR","IPADDR" );
  1205.   if( check == -1 ) 
  1206.     error_handler(MyTransaction->getNdbErrorString());
  1207.   ndbout << "equal"  << endl;  
  1210.   check = MyOperation->setValue( "IPQOS", IPQOS);
  1211.   if( check == -1 ) 
  1212.     error_handler(MyTransaction->getNdbErrorString());
  1213.   ndbout << "Set Value"  << endl;
  1214.   
  1217.   check = MyOperation->setValue( "ASID", ASID);
  1218.   if( check == -1 ) 
  1219.     error_handler(MyTransaction->getNdbErrorString());
  1220.   ndbout << "Set Value"  << endl;
  1221.   
  1223.   check = MyTransaction->execute( Commit ); 
  1224.   if(check == -1 ) {
  1225.     ndbout << "error at commit"  << endl;
  1226.     error_handler(MyTransaction->getNdbErrorString());
  1227.   }
  1228.   else
  1229.     ;//ndbout << ".";
  1230.   
  1231.   pMyNdb->closeTransaction(MyTransaction);
  1232.   
  1233.   
  1234.       
  1235.   ndbout << "OK" << endl;
  1236.   
  1237.   return;
  1238. }
  1240. static void  
  1241. update_rows(Ndb* pMyNdb){
  1242.  /****************************************************************
  1243.    * Update rows in SimpleTable 
  1244.    *
  1245.    ***************************************************************/
  1247.   int                   check;
  1248.   int                   loop_count_ops;
  1249.   int count;
  1250.   int                   i;
  1251.   NdbConnection *MyTransaction;
  1252.   NdbOperation *MyOperation;
  1254.    ndbout << "Updating records..." << flush;
  1255.    
  1256.    loop_count_ops = NUMBEROFRECORDS;
  1258.    for (count=0 ; count < loop_count_ops ; count++)    {
  1260.       MyTransaction = pMyNdb->startTransaction();
  1261.       if (MyTransaction == NULL)
  1262.   error_handler( pMyNdb->getNdbErrorString() );
  1264.       MyOperation = MyTransaction->getNdbOperation(tableName[0]);
  1265.       if (MyOperation == NULL) 
  1266.         error_handler(MyTransaction->getNdbErrorString());
  1268.       check = MyOperation->updateTuple();
  1269.       if( check == -1 ) 
  1270.         error_handler(MyTransaction->getNdbErrorString());
  1271.  
  1272.       check = MyOperation->equal( attrName[0], (char*)&pkValue[count] );
  1273.       if( check == -1 ) 
  1274.          error_handler(MyTransaction->getNdbErrorString());
  1276.       for (i = 1; i < MAXATTR; i++)
  1277. {
  1278.           check = MyOperation->setValue( attrName[i], (char*)&attrValue[count]);
  1279.           if( check == -1 ) 
  1280.              error_handler(MyTransaction->getNdbErrorString());
  1281. }
  1283.       if( MyTransaction->execute( Commit ) == -1 )
  1284.          error_handler(MyTransaction->getNdbErrorString());
  1285.       else
  1286. ;//ndbout << ".";
  1287.         
  1288.       pMyNdb->closeTransaction(MyTransaction);
  1290.     }
  1292.    ndbout << "OK" << endl;
  1293.   return;
  1295. };
  1297. static void  
  1298. delete_rows(Ndb* pMyNdb){
  1300.   /****************************************************************
  1301.    * Delete rows from SimpleTable 
  1302.    *
  1303.    ***************************************************************/
  1305.   int                   check;
  1306.   int                   loop_count_ops;
  1307.   int count;
  1308.   NdbConnection *MyTransaction;
  1309.   NdbOperation *MyOperation;
  1311.    ndbout << "Deleting records..."<< flush;
  1312.    
  1313.    loop_count_ops = NUMBEROFRECORDS;
  1315.    for (count=0 ; count < loop_count_ops ; count++)    {
  1317.       MyTransaction = pMyNdb->startTransaction();
  1318.       if (MyTransaction == NULL)
  1319.   error_handler( pMyNdb->getNdbErrorString() );
  1321.       MyOperation = MyTransaction->getNdbOperation(tableName[0]);
  1322.       if (MyOperation == NULL) 
  1323.         error_handler(MyTransaction->getNdbErrorString());
  1326.       check = MyOperation->deleteTuple();
  1327.       if( check == -1 ) 
  1328.         error_handler(MyTransaction->getNdbErrorString());
  1329.  
  1330.       check = MyOperation->equal( attrName[0], (char*)&pkValue[count] );
  1331.       if( check == -1 ) 
  1332.          error_handler(MyTransaction->getNdbErrorString());
  1335.       if( MyTransaction->execute( Commit ) == -1 )
  1336.          error_handler(MyTransaction->getNdbErrorString());
  1337.       else
  1338. ;// ndbout << ".";
  1339.         
  1340.       pMyNdb->closeTransaction(MyTransaction);
  1342.     }
  1344.    ndbout << "OK" << endl;
  1345.   return;
  1347. };
  1349. static void 
  1350. verify_deleted(Ndb* pMyNdb){
  1351.   int                   check;
  1352.   int                   loop_count_ops;
  1353.   int count;
  1354.   NdbConnection *MyTransaction;
  1355.   NdbOperation *MyOperation;
  1357.   ndbout << "Verifying deleted records..."<< flush;
  1358.     
  1359.   loop_count_ops = NUMBEROFRECORDS;
  1361.   for (count=0 ; count < loop_count_ops ; count++)
  1362.   {
  1363.      MyTransaction = pMyNdb->startTransaction();
  1364.      if (MyTransaction == NULL)
  1365.         error_handler(pMyNdb->getNdbErrorString());
  1367.      MyOperation = MyTransaction->getNdbOperation(tableName[0]);
  1368.      if (MyOperation == NULL) 
  1369.         error_handler( MyTransaction->getNdbErrorString());
  1370.        
  1371.      check = MyOperation->readTuple();
  1372.      if( check == -1 ) 
  1373.        error_handler( MyTransaction->getNdbErrorString());
  1375.      check = MyOperation->equal( attrName[0],(char*)&pkValue[count] );
  1376.      if( check == -1 ) 
  1377.         error_handler( MyTransaction->getNdbErrorString());
  1379.      // Exepect to receive an error
  1380.       if( MyTransaction->execute( Commit ) != -1 ) 
  1381.          error_handler(MyTransaction->getNdbErrorString());
  1382.       else
  1383.       {
  1384.         ;//ndbout << ".";
  1385.       }
  1386.      
  1387.       pMyNdb->closeTransaction(MyTransaction);
  1389.     }
  1391.    ndbout << "OK" << endl;
  1392.   return;
  1393. };
  1395. static void 
  1396. read_and_verify_rows(Ndb* pMyNdb)
  1397. {
  1399.   int                   check;
  1400.   int                   loop_count_ops;
  1401.   int count;
  1402.   int                   count_attributes;
  1404.   NdbConnection *MyTransaction;
  1405.   NdbOperation *MyOperation;
  1406.   NdbRecAttr*           tTmp;
  1408.   int readValue[MAXATTR];
  1410.   ndbout << "Verifying records..."<< flush;
  1411.     
  1412.   loop_count_ops = NUMBEROFRECORDS;
  1414.   for (count=0 ; count < loop_count_ops ; count++)
  1415.   {
  1416.      MyTransaction = pMyNdb->startTransaction();
  1417.      if (MyTransaction == NULL)
  1418.         error_handler(pMyNdb->getNdbErrorString());
  1420.      MyOperation = MyTransaction->getNdbOperation(tableName[0]);
  1421.      if (MyOperation == NULL) 
  1422.         error_handler( MyTransaction->getNdbErrorString());
  1423.        
  1424.      check = MyOperation->readTuple();
  1425.      if( check == -1 ) 
  1426.         error_handler( MyTransaction->getNdbErrorString());
  1428.      check = MyOperation->equal( attrName[0],(char*)&pkValue[count] );
  1429.      if( check == -1 ) 
  1430.         error_handler( MyTransaction->getNdbErrorString());
  1432.      for (count_attributes = 1; count_attributes < MAXATTR; count_attributes++)
  1433.      {
  1434.         tTmp = MyOperation->getValue( (char*)attrName[count_attributes], (char*)&readValue[count_attributes] );
  1435.         if( tTmp == NULL ) 
  1436.            error_handler( MyTransaction->getNdbErrorString());
  1437.       }
  1439.       if( MyTransaction->execute( Commit ) == -1 ) 
  1440.          error_handler(MyTransaction->getNdbErrorString());
  1441.       else
  1442.       {
  1443. // Check value in db against value in mem     
  1445. //ndbout << readValue[1] << " == " << attrValue[count] << endl;
  1446.            
  1447.    if ( readValue[1]!=attrValue[count] )
  1448.              error_handler("Verification error!");
  1449.            else
  1450.    if ( readValue[2]!=attrValue[count] )
  1451.              error_handler("Verification error!");
  1452.            else
  1453.    if ( readValue[3]!=attrValue[count] )
  1454.              error_handler("Verification error!");
  1455.            else
  1456.    {
  1457.      ;//ndbout << ".";
  1458.    }
  1459. }
  1460.         pMyNdb->closeTransaction(MyTransaction);
  1462.     }
  1464.    ndbout << "OK" << endl;
  1465.   return;
  1467.  
  1469. };
  1472. static void
  1473. setAttrNames()
  1474. {
  1475.   int i;
  1477.   for (i = 0; i < MAXATTR ; i++)
  1478.   {
  1479.     sprintf(&attrName[i][0], "Col%d", i);
  1480.   }
  1481. }
  1483. static void
  1484. setTableNames()
  1485. {
  1486.   int i;
  1488.   sprintf(&tableName[0][0], "SBMCALL", 0);
  1489.   sprintf(&tableName[1][0], "RPACCT", 0);
  1490.   sprintf(&tableName[2][0], "IPACCT", 0);
  1491.   sprintf(&tableName[3][0], "TODACCT", 0);
  1493. }
  1496. bool error_handler2(const char* error_string, int error_int) {
  1497.   failed++ ;
  1498.   ndbout << error_string << endl ;
  1499.   if ( 4008==error_int || 721==error_int || 266==error_int ){
  1500.     ndbout << endl << "Attempting to recover and continue now..." << endl ;
  1501.     return true ; // return true to retry
  1502.   }
  1503.   return false ; // return false to abort
  1504. }