paratest3.c

b树实现源码,linux和unix下运行,速度快,极好用

/*  create table T1 with 10 fields.
 *  insert some records into it.
 *  delete records from T1 with where clause
 *  select * from T1;
 
 *  Author : Jitendra Lenka.
 */

#include<AbsSqlStatement.h>
#include<SqlFactory.h>

int main()
{
  DbRetVal rv = OK;
  AbsSqlConnection *con =  SqlFactory :: createConnection(CSqlAdapter);
  rv = con->connect("root","manager");
  if(rv!=OK)return 1;

  AbsSqlStatement *stmt = SqlFactory :: createStatement(CSqlAdapter);
  stmt->setConnection(con);
  char statement[200];
  strcpy(statement,"CREATE TABLE T1(F1 INT,F2 SMALLINT,F3 CHAR(30),F4 FLOAT,F5 FLOAT,F6 DATE,F7 TIME,F8 TIMESTAMP,F9 INT,F10 BIGINT);");
  
   int rows = 0;
   rv = stmt->prepare(statement);
   if(rv!=OK)
   {
     delete stmt;
     delete con;
     return 2;
   }

   rv = stmt->execute(rows);
   if(rv!=OK)
   {
     delete stmt;
     delete con;
     return 3;
   }

   stmt->free();
   printf("Table T1 created\n");

   // insert into table

   strcpy(statement,"INSERT INTO T1 VALUES(?,?,?,?,?,?,?,?,?,?);");
   
   int f1var = 0;
   short int f2var = 1;
   char f3var[20]="jitendra";
   float f4var = 5.5;
   float f5var = 10.50;
   Date f6var;
   f6var.set(2007,01,21);
   
   Time f7var;
   f7var.set(12,29,30);     
   
   TimeStamp f8var;
   f8var.setDate(2007,01,21);
   f8var.setTime(12,29,30);

   int f9var = 20;
   long long f10var = 12000;

   rv = stmt->prepare(statement);
   if(rv!=OK)
   {
     delete stmt;
     delete con;
     return 4;
   }

   int count=0;
   
   for(int i=0;i<10;i++) 
   {	
	rv  = con->beginTrans();
	if(rv!=OK) break;
	f1var=i;
        stmt->setIntParam(1,f1var);
        stmt->setShortParam(2,f2var);
        stmt->setStringParam(3,f3var);
        stmt->setFloatParam(4,f4var);
        stmt->setFloatParam(5,f5var);
        stmt->setDateParam(6,f6var);
        stmt->setTimeParam(7,f7var);
        stmt->setTimeStampParam(8,f8var);
        stmt->setIntParam(9,f9var);
        stmt->setLongLongParam(10,f10var);

        rv = stmt->execute(rows);
        if(rv!=OK)break;
    	rv = con->commit();
	if(rv!=OK)break;
        count++;
    }
    printf("Total rows inserted %d\n",count);
    
    
    stmt->free();
   //*********************************************************
   //  delete records from the T1
   strcpy(statement,"DELETE FROM T1 WHERE F10=? AND F9=? AND F8=? AND F7=? AND F6=? AND F5=? AND F4=? AND F3=? AND F2=? AND F1=?;");
  
   rv = stmt->prepare(statement);
   if(rv!=OK){delete stmt;delete con;return -1;}

  /* stmt->bindField(1,&f10var);
   stmt->bindField(2,&f9var);
   stmt->bindField(3,&f8var);
   stmt->bindField(4,&f7var);
   stmt->bindField(5,&f6var);
   stmt->bindField(6,&f5var);
   stmt->bindField(7,&f4var);
   stmt->bindField(8,f3var);
   stmt->bindField(9,&f2var);
   stmt->bindField(10,&f1var);*/ 
    
   short int f2var1=1;
   char f3var1[20] ="jitendra";
   float f4var1 = 5.5;
   float f5var1 = 10.50;
   Date f6var1;
   f6var1.set(2007,1,21);

   Time f7var1;
   f7var1.set(12,29,30);
   
   TimeStamp f8var1;
   f8var1.setDate(2007,1,21);
   f8var1.setTime(12,29,30);

   int f9var1=20;
   long long f10var1=12000;
   count=0;

   for(int i=5;i<10;i++)
   {
      rv = con->beginTrans();
      if(rv!=OK)break;

      stmt->setLongLongParam(1,f10var1);
      stmt->setIntParam(2,f9var1);
      stmt->setTimeStampParam(3,f8var1);
      stmt->setTimeParam(4,f7var1);
      stmt->setDateParam(5,f6var1);
      stmt->setFloatParam(6,f5var1);
      stmt->setFloatParam(7,f4var1);
      stmt->setStringParam(8,f3var1);
      stmt->setShortParam(9,f2var1);
      stmt->setIntParam(10,i);

      rv = stmt->execute(rows);
      if(rv!=OK)break;
      rv = con->commit();
      if(rv!=OK)break;
      count++;
   }
   stmt->free();
   printf("Total row deleted=%d\n",count); 	




   //**********************************************************

    // SELECT * FROM T1;
    strcpy(statement,"SELECT * FROM T1;");
    rv = stmt->prepare(statement);
    if(rv!=OK)
    {
      delete stmt;
      delete con;
      return 5;
    }

    stmt->bindField(1,&f1var);
    stmt->bindField(2,&f2var);
    stmt->bindField(3,f3var);
    stmt->bindField(4,&f4var);
    stmt->bindField(5,&f5var);
    stmt->bindField(6,&f6var);
    stmt->bindField(7,&f7var);
    stmt->bindField(8,&f8var);
    stmt->bindField(9,&f9var);
    stmt->bindField(10,&f10var);

    count=0;
    rv = con->beginTrans();
    if(rv!=OK)return 6;
    stmt->execute(rows);
    while(stmt->fetch() !=NULL)
    {
      
        printf("F1=%d | F2=%hd | F3=%s | F4=%f | F5=%f | DATE=%d-%d-%d | TIME=%d:%d:%d | TIMESTAMP=%d-%d-%d %d:%d:%d | F9=%d | F10=%lld  \n",f1var,f2var,f3var,f4var,f5var,f6var.year(),f6var.month(),f6var.dayOfMonth(),f7var.hours(),f7var.minutes(),f7var.seconds(),f8var.year(),f8var.month(),f8var.dayOfMonth(),f8var.hours(),f8var.minutes(),f8var.seconds(),f9var,f10var);

       count++;
    }

    stmt->close();
    rv = con->commit();
    if(rv !=OK)
    {
      delete stmt;
      delete con;
      return 7;
    }

    printf("Total row fetched=%d\n",count);
    stmt->free();
    

    strcpy(statement,"DROP TABLE T1;");
    rv = stmt->prepare(statement);
    if(rv!=OK)
    {
      delete stmt;
      delete con;
      return 8;
    }
    rv = stmt->execute(rows);
    if(rv!=OK)
     {
      delete stmt;
      delete con;
      return 9;
    }
    stmt->free();
    printf("Table dropped\n");
    
    delete stmt;
    delete con;
    return 0;
}