selecttest4.c

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

/*   create table T1 with two fields,
 *   insert 10 rows into the table ,
 *   select with  nonexisting fields.

 *   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 INT);");

  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;
 int  f2var= 110; 

 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->setIntParam(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 F3 ,F2  FROM T1;");
  rv = stmt->prepare(statement);
  
  if(rv !=OK)
  {
     printf("Test script passed\n");

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