table.hpp

联通接收发送新程序

/* Copyright(C) 1999, 2000 by JiangSu Bell Software CO.,LTD. */
/*
  Name: table.hpp                      Version: 2.0.0
  Created by HanBing                   Date: 2000-08-08
  Comment: Our group defining all base-class sets
  Modified:
2)  2000-08-28	HanBing	-	Modifed the class CTable for array operate;
1)  2000-08-08	HanBing	-	Create;
*/

#ifndef __TABLE__
#define __TABLE__

/*  Indicate the operate on a table  */
typedef enum
{
  op_null = 0,
  op_query,
  op_insert,
  op_update,
  op_delete
} OpTable;

/*
  Class: CTable                        Version: 2.0
  Created by HanBing                   Date: 2000-08-08
  Implementation File: table.cpp
  Comment:
  Modified
2)  2000-08-28	HanBing	-	Modifed for array operate;
1)  2000-08-08	HanBing	-	Create;
*/
class CTable
{
  public:
    /*
      Name: CTable() - constructor
      Comment:
      Parameters:   conn    - input - the XW_Connection to be used
                    size    - input - the row array size
      Return Value:
      Modified:
    2) 2000-08-28	HanBing	-	Added parameter size for array operate;
    1) 2000-08-08	HanBing	-	Create;
    */
    CTable( XW_Connection& conn = DefaultConnect, uint size = 1 )
    {
      connect   = &conn;
      TableName = NULL;
      op_tab    = op_null;
      is_query  = false;
      BatSize   = size;
      CurPos    = 0;
      nRow      = 0;
      pcIndex   = NULL;
    }

    CTable( CTable& Tab )
    {
      connect   = &Tab.Connect();
      BatSize   = Tab.Size();
      op_tab    = op_null;
      is_query  = false;
      CurPos    = 0;
      nRow      = 0;
      pcIndex   = NULL;
      TableName = new char [ strlen( Tab.Name() ) + 1 ];
      strcpy( TableName, Tab.Name() );
    }

    CTable( uint size )
    {
      CTable( DefaultConnect, size );
    }
    /*
      Name: ~CTable() - destructor
      Comment:
      Parameters:
      Return Value:
      Modified:
    1) 2000-08-08	HanBing	-	Create;
    */
    ~CTable()
    {
      if ( TableName )
        delete TableName;
      if ( pcIndex )
        delete pcIndex;
    }


    uint Clear( bool flag = true )
    {
      FirstCol();
      while ( CurCol() )
      {
        CurCol()->Clear( flag );
        NextCol();
      }
      return ( CurPos = 0 );
    }

/*  functions for access columns  */
    long Flush( bool b_do = true, bool b_end = true )
    {
      if ( !TableName || !strlen( TableName ) )
        return -1;
      else if ( CurPos == 0 )
        return 1;
      long l_ret = 0;
      if ( op_tab == op_null || !b_do )  /*  no operate needed  */
        l_ret = Clear();
      else if ( op_tab == op_insert )
        l_ret = InsertTab();
      else if ( op_tab == op_update )
        l_ret = UpdateTab();
      else if ( op_tab == op_delete )
        l_ret = DeleteTab();
      if ( b_end )
        op_tab = op_null;
      if ( BatSize > 1 && b_end )
        Clear();
      else
        Clear( false );
      return l_ret;
    }

    /*  go to next row in the array  */
    /*
      Name: Next()
      Comment:      go to next row in the array;
      Parameters:
      Return Value: the current position
      Modified:
    1) 2000-08-28	HanBing	-	Create;
    */
    inline long Next()
    {
      long l_ret = 0;
      if ( op_tab == op_null )
        l_ret = Clear();
      else if ( op_tab == op_query )
        l_ret = QueryNext();
      else if ( ++CurPos >= BatSize )
        l_ret = Flush( true, false );
      else
      {
        FirstCol();
        while ( CurCol() )
        {
          CurCol()->Next();
          NextCol();
        }
        l_ret = CurPos;
      }
      if ( BatSize == 1 && is_query )
        op_tab = op_query;
      return l_ret;
    }

/*  functions for query rows  */
    long Query( const char *condition = NULL );
    long QuerybyIndex( T_LIST< CField >& Ind );

/*  functions for modify data  */

    inline long Insert()
    {
      if ( BatSize > 1 )
        Assert( ( op_tab == op_insert || op_tab == op_null ), "Can't Insert Now!" );
      op_tab = op_insert;
      return Next();
    }

    inline long Update()
    {
      if ( BatSize > 1 )
        Assert( ( op_tab == op_update || op_tab == op_null ), "Can't Update Now!" );
      op_tab = op_update;
      return Next();
    }

    inline long Delete()
    {
      if ( BatSize > 1 )
        Assert( ( op_tab == op_delete || op_tab == op_null ), "Can't Delete Now!" );
      op_tab = op_delete;
      return Next();
    }

/*  functions for set or get table attribute  */
    inline void SetTableName( const char* name )
    {
      if ( !name || !strlen( name ) || ( TableName && !strcmp( TableName, name ) ) )
        return;
      if ( TableName )
        delete TableName;
      TableName = new char [ strlen( name ) + 1 ];
      strcpy( TableName, name );
      QueryCursor.Close();
      InsertCursor.Close();
      UpdateCursor.Close();
      DeleteCursor.Close();
    }

    inline const char* Name()
    {
      return TableName;
    };
    inline uint Size()
    {
      return BatSize;
    };

    /*  functions for get the field's value  */
    inline CField& Field( const char* name )
    {
      FirstCol();
      while ( CurCol() && strcmp( name, CurCol()->Name() ) )
      {
        NextCol();
      }
      Assert( CurCol() != NULL, name );
      return *CurCol();
    }

/*  functions for access columns  */
    inline void FirstCol()
    {
      Fields.GoHead();
    };
    inline CField* NextCol()
    {
      return Fields.Next();
    };
    inline CField* CurCol()
    {
      return Fields.Current();
    };

    void PrintName();
    /*  Display the Fields in the current Buffer  */
    void Print();

    inline XW_Connection& Connect()  { return *connect; };

	inline SetConnection( XW_Connection& conn = DefaultConnect )
	{
		connect = &conn;
	}

  protected:
    CTable& operator = ( CTable& Tab )
    {
      FirstCol();
      Tab.FirstCol();
      while ( CurCol() && Tab.CurCol() )
      {
        *CurCol() = *Tab.CurCol();
        NextCol();
        Tab.NextCol();
      }
      return *this;
    }

    T_LIST< CField > Fields;
  private:
    XW_Connection *connect;
    Cursor  QueryCursor;
    Cursor  InsertCursor;
    Cursor  UpdateCursor;
    Cursor  DeleteCursor;

    /*  clear the array buffer  */
    /*
      Name: Clear()
      Comment:      clear the array buffer
      Parameters:
      Return Value:
      Modified:
    1) 2000-08-28	HanBing	-	Create;
    */
    long    InsertTab();
    long    UpdateTab();
    long    DeleteTab();
    bool    ParseQuery( const char* );
    long    QueryNext();

    OpTable op_tab;
    bool    is_query;
    uint    BatSize;
    uint    CurPos;
    long    CurSize;
    long    nRow;
    char    *TableName;
    char    *pcIndex;
	//hyl on 20030922
	char pcSQL[ 1024 ];
	//
};

#endif //__TABLE__