selecttest7.c

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

/*   create table T1 with two fields,
 *   insert 10 rows into the table ,
 *   call fetch without call execute,it returns NULL.

 *   Author : Jitendra Lenka
 */

#include<AbsSqlStatement.h>
#include<SqlFactory.h>
//#include<Info.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 CHAR(20));");

  int rows=0;
  rv = stmt->prepare(statement);
  if(rv!=OK)
  {
    delete stmt;
    delete con;
    return 1;
 }

 rv  = stmt->execute(rows);
  if(rv!=OK)
  {
    delete stmt;
    delete con;
    return 2;
 }
 stmt->free();
 printf("Table created\n");

 //  insert records

 strcpy(statement,"INSERT INTO T1 VALUES(?,?);");

 int f1var = 1;
 char f2var[20] = "lakshya";
 

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

 int count=0;

 for(int i=0;i<2;i++)
 {
    
   for(int j=0;j<5;j++)
    {	
        f1var = j;
        rv = con->beginTrans();
	if(rv!=OK)break;
	
         	
        stmt->setIntParam(1,f1var);
	stmt->setStringParam(2,f2var);

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

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

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

  
  stmt->bindField(1,&f1var);
  stmt->bindField(2,f2var);
  
  void *ret;
  count = 0;
  rv = con->beginTrans();
  if(rv!=OK)return 5;
  //stmt->execute(rows);
  while(1)
  {
      
      ret = ((char*)stmt->fetch());
      if(ret==NULL)
      {
        printf("Fetch failed without call execute\n");
        strcpy(statement,"DROP TABLE T1;");
        rv = stmt->prepare(statement);
        rv = stmt->execute(rows);
        if(rv==OK){printf("Table dropped successfully\n");}
        stmt->free();
        delete stmt;
        delete con;
        return 0;
      }  
      printf("Test script failed\n");
         
  

   }
  
  stmt->free();

  delete stmt;
  delete con;
  return 7;
}