CREATE TABLE ES_SCHEME (
    SCHEME_ID  PK /* PK = INTEGER NOT NULL */,
    NAME       NAME32 NOT NULL /* NAME32 = VARCHAR(32) */,
    WIDTH      "INT" DEFAULT  1024  NOT NULL /* "INT" = INTEGER */,
    HEIGHT     "INT" DEFAULT  768  NOT NULL /* "INT" = INTEGER */,
    PICTURE    PIC /* PIC = BLOB SUB_TYPE 0 SEGMENT SIZE 4096 */,
    NOTE       NOTE64 /* NOTE64 = VARCHAR(64) */,
    DATE_BEG   DATETIME DEFAULT '1996-01-01 00:00:01' NOT NULL /* DATETIME = TIMESTAMP */,
    DATE_END   DATETIME DEFAULT '2077-12-31 23:59:59.999' NOT NULL /* DATETIME = TIMESTAMP */,
    SID        F_KEY /* F_KEY = INTEGER */
);

int TDataLayer::ESSchemeUPicture(int scheme_id, AnsiString path_picture)
{
  int ret= 0 , s, fsize; char buf;
  string sql;
  IBPP::Blob b;
  ifstream fin;

  sql = "execute procedure ES_SCHEME_U_PICTURE (?,?)";

  fin.open(path_picture.c_str(), ios::binary);
  if (fin.fail()) { return (- 3 ); }

  try
  {
   tr = IBPP::TransactionFactory(db, IBPP::amWrite, IBPP::ilReadCommitted, IBPP::lrNoWait);  // Start transaction for write
   tr->Start();
   b  = IBPP::BlobFactory(db, tr);
   b->Create();

   while(!fin.eof())
   {
    fin.read(&buf,  1 );
    if (fin.good())
      {b->Write(&buf,  1 ); ret++;}
    else
      break;
   }
   b->Close();

   st = IBPP::StatementFactory(db, tr);
   st->Prepare(sql);

   st->Set( 1 , scheme_id);
   st->Set( 2 , b);

   st->Execute();
   tr->Commit();
  }
  catch (IBPP::Exception& e)
  {
   errorstr = e.what();
   ret = - 1 ;
  }
  fin.close();

  return (ret);
}

bool TDataLayer::ESSchemeSImg(TMemoryStream * s, int scheme_id)
{
 bool ret = true;
 string sql;
 IBPP::Blob b; char * buf; int size, largest, segments;

 sql = "select picture ";
 sql +="from es_scheme_s(?, NULL, NULL)";

 try
 {
  tr = IBPP::TransactionFactory(db,IBPP::amRead,IBPP::ilReadCommitted,IBPP::lrNoWait);  // Start transaction for read
  tr->Start();
  st = IBPP::StatementFactory(db, tr);
  st->Prepare(sql);

  st->Set( 1 , scheme_id);

  st->Execute();
  b = IBPP::BlobFactory(db, tr);
  while(st->Fetch())
  {
   st->Get( 1 , b);
   b->Open();
   b->Info(&size, &largest, &segments);
   buf = new char [size];

   int offset =  0 ;
   for (int s= 1 ; s<=segments; s++)
   {
     int r;
     r = b-> Read(&buf[offset], largest);
     offset += r;
   }
   b->Close();

   s->SetSize(size);
   s->Position =  0 ;
   s->Write(&buf[ 0 ], size);
   delete [] buf;
  }

  tr->Commit();
 }
 catch (IBPP::Exception& e)
 {
  errorstr = e.what();
  ret = false;
 }

 return (ret);
}