GDBMS_for_documentation/tr_twin_ht.cpp

Go to the documentation of this file.

#include "maininclude.h"
#include "listi.h"
#include "settings.h"
#include "hash_table.h"
#include "tr_twin_ht.h"
#include "file_semaphore.h"
#include "some_functions.h"
#include "initial_mode_commands.h"
#include "session_mode_commands.h"
#include "transaction_mode_commands.h"
#include "transaction_mode_commands_types.h"
#include "transaction_mode_commands_nodes.h"
#include "transaction_mode_commands_edges.h"
#include "transaction_mode_commands_find.h"

using namespace std;

tr_twin_ht::tr_twin_ht(char* table_name, char* folder_name, int columns_nr, char* columns, char* columns_searchby, char* unique, int tr_id, char* tr_folder, hash_table *rt): hash_table(table_name, tr_folder, columns_nr, columns, columns_searchby, unique)
{
  this->trans_id=tr_id;
  this->trans_folder=tr_folder;
  this->real_table=rt;
}
tr_twin_ht::tr_twin_ht(char* table_name, char* folder_name, char* columns, char* columns_searchby, char* unique, int tr_id, char* tr_folder, hash_table *rt): hash_table(table_name, tr_folder, columns, columns_searchby, unique)
{
  this->trans_id=tr_id;
  this->trans_folder=tr_folder;
  this->real_table=rt;
}




void tr_twin_ht::AddRecord(char* column_names, char* values)
{
  
    int i=this->getMAXID();
    char *maxid_str=strtoint(i);
    
    char *bbuf=0;
    bbuf=inttostr(i);
    string trf;
    trf+=MAINFOLDER;
    trf+=this->trans_folder;
    trf+="/trans_changed_ids_";
    trf+=this->tblname;
    trf+=".xml";
    XMLNode x1, x2, x3;
    x1=XMLNode::parseFile(trf.c_str());
    x2=x1.getChildNode("ids");
    x3=x2.addChild("id");
    x3.addText(bbuf);
    x3.addAttribute("add", "1");
    x3.addAttribute("myid", bbuf);
    x1.writeToFile(trf.c_str());
    hash_table::AddRecord(column_names, values);
    if(bbuf)
      delete bbuf;
    
}

void tr_twin_ht::DeleteRecord(char* column_name, char* value)
{
    
    char *bbuf=0;
    string trf;
    trf+=MAINFOLDER;
    trf+=this->trans_folder;
    trf+="/trans_changed_ids_";
    trf+=this->tblname;
    trf+=".xml";
    bbuf=hash_table::FindRecord(column_name, value, "id");
    if(bbuf){
      XMLNode x, x1, x2;
      int i, j;
      x=XMLNode::parseFile(trf.c_str());
      x1=x.getChildNode("ids");
      int nnum=x1.nChildNode();
      for(i=0; i<nnum; i++){
        x2=x1.getChildNode("id");
        char *buf1=0;
        bool quit=false;
        
        buf1=x2.getText();
        if(!strcmp(buf1, bbuf)){
          x2.deleteNodeContent();
          x.writeToFile(trf.c_str());
          quit=true;
        }
        
        if(buf1)
          delete buf1;
        if(quit)
          break;
      }
      
      hash_table::DeleteRecord("id", bbuf);
    }else{
      char *buf1=0;
      buf1=real_table->FindRecord(column_name, value, "id");
      if(buf1){
        //tuk trqbva da se blokira zapisa za drugi potrebiteli i da se vidi dali ne e blokiran ot drugi
        this->blockrecord(buf1);
        
        XMLNode x, x1, x2;
        x=XMLNode::parseFile(trf.c_str());
        x1=x.getChildNode("ids");
        x2=x1.addChild("id");
        x2.addAttribute("del", "1");
        x2.addText(buf1);
        x.writeToFile(trf.c_str());
        
        
      }
      
      if(buf1)
        delete buf1;
      
    }
      
  
       
    
    
    if(bbuf)
      delete bbuf;
}
char* tr_twin_ht::FindRecord(char* where_column_name, char* where_column_value, char* find_column)
{
    char *buf=0;
    
    buf = hash_table::FindRecord(where_column_name, where_column_value, find_column);
    if(!buf)
      buf = real_table ->FindRecord(where_column_name, where_column_value, find_column);
    
    
    return buf;
}
void tr_twin_ht::UpdateRecord(char* where_column, char* where_value, char* column_names, char* column_values)
{
  string trf;
  trf+=MAINFOLDER;
  trf+=this->trans_folder;
  trf+="/trans_changed_ids_";
  trf+=this->tblname;
  trf+=".xml";
  char *buf=0;
  buf = hash_table::FindRecord(where_column, where_value, "id");
  if(buf){
    hash_table::UpdateRecord(where_column, where_value, column_names, column_values);
    
  }else{
    buf=real_table->FindRecord(where_column, where_value, "id");
    if(buf){
      //tuk trqbva da se blokira za drugi potrebiteli i da se vidi dali ne e blokirano ot tqh
        this->blockrecord(buf);
        XMLNode x, x1, x2;
        x=XMLNode::parseFile(trf.c_str());
        x1=x.getChildNode("ids");
        x2=x1.addChild("id");
        x2.addAttribute("upd", "1");
        x2.addText(buf);
        int myid=this->getMAXID();
        char *myid_str=inttostr(myid);
        string cols, vals;
        real_table->FindByIdAndReturnColNamesAndValues(buf, cols, vals, myid_str);
        x2.addAttribute("myid", myid_str);
        //x2.addAttribute("updcols", column_names);
        //x2.addAttribute("updvals", column_values);
        x.writeToFile(trf.c_str());
        hash_table::AddRecord(cols.c_str(), vals.c_str());
        
    }
  }
  
  
    
  if(buf)
    delete buf;
}
int tr_twin_ht::begin_transaction()
{
  XMLNode x1, x2;
  x1=XMLNode::createXMLTopNode("xml");
  x2=x1.addChild("ids");
  string trf;
  trf+=MAINFOLDER;
  trf+=this->trans_folder;
  trf+="/trans_changed_ids_";
  trf+=this->tblname;
  
  trf+=".xml";
  x1.writeToFile(trf.c_str());
  return 0;
}




int tr_twin_ht::end_transaction()
{
  string trf;
  trf+=MAINFOLDER;
  trf+=this->trans_folder;
  trf+="/trans_changed_ids_";
  trf+=this->tblname;
  trf+=".xml";
  
  string realfolder;
  realfolder+=MAINFOLDER;
  realfolder+=this->real_table->table_folder;
  
  XMLNode x, x1, x2;
  XMLNode y, y1, y2;
  int i, j, ntr=0;
  x=XMLNode::parseFile(trf.c_str());
  x1=x.getChildNode("ids");
  //finish updated records
  ntr=x1.nChildNode();
  for(i=0; i<ntr; i++){
    x2=x1.getChildNode("id");
    char *buf1=0;
    buf1=x2.getAttribute("upd");
    if(buf1){
      if(!strstr(buf1, "1")){
        char *buf2=0;
        buf2=x2.getAttribute("myid");
        if(buf2){
          char *buf3=x2.getText();
          if(buf3){
           string cols, vals;
           this->FindByIdAndReturnColNamesAndValues(buf2, cols, vals, buf3);
           x2.addAttribute("real_id", buf3);
           real_table->UpdateRecord("id", buf3, cols.c_str(), vals.c_str()); 
           delete buf3; 
          }
          
          
        }
        
        if(buf2)
          delete buf2;
      }
      
    }
    
    
    if(buf1)
      delete buf1;
    
  }
  x.writeToFile(trf.c_str());
  //x=XMLNode::writeToFile(trf.c_str());
  //finish deleted records
  x=XMLNode::parseFile(trf.c_str());
  x1=x.getChildNode("ids");
  ntr=x1.nChildNode();
  for(i=0; i<ntr; i++){
    x2=x1.getChildNode("id");
    char *buf1=0;
    char *buf2=0;
    buf1=x2.getAttribute("del");
    buf2=x2.getText();
    
    if(buf1&&buf2){
      real_table->DeleteRecord("id", buf2);
      //x2.deleteNodeContent();
    }
    
    if(buf2)
      delete buf2;
    
    if(buf1)
      delete buf1;
    
  }
  //finish added records
  x=XMLNode::parseFile(trf.c_str());
  x1=x.getChildNode("ids");
  ntr=x1.nChildNode();
  for(i=0; i<ntr; i++){
    string cls;
    string vls;
    char *buf1=0;
    x2=x1.getChildNode("id");
    buf1=x2.getAttribute("add");
    if(buf1){
      char *buf2=0;
      buf2=x2.getText();
      
      if(buf2){
        int realid=real_table->getMAXID();
        char *buf3=0;
        buf3=inttostr(realid);
        if(buf3){
          
          this->FindByIdAndReturnColNamesAndValues(buf2, cls, vls, buf3);
          real_table->AddRecord(cls.c_str(), vls.c_str());
          x2.addAttribute("real_id", realid);
        }
        
      }
      
      if(buf2)
        delete buf2;
      
    }
    
    
    if(buf1)
      delete buf1;
  }
  x.writeToFile(trf.c_str());
  
  
  
  return 0;
}
void tr_twin_ht::changewithrealconnections(tr_twin_ht* other_tr, char* col1, char* col2)
{
  string trf;
  trf+=MAINFOLDER;
  trf+=this->trans_folder;
  trf+="/trans_changed_ids_";
  trf+=this->tblname;
  trf+=".xml";
  
  
  
  XMLNode x, x1, x2;
  XMLNode y, y1, y2;
  int i, j, ntr=0;
  x=XMLNode::parseFile(trf.c_str());
  x1=x.getChildNode("ids");
  ntr=x1.nChildNode();
  for(i=0; i<ntr; i++){
    x2=x1.getChildNode("id");
    char *real_idstr=0;
    if(real_idstr=x2.getAttribute("real_id")){
      char *col1v=this->real_table->FindRecord("id", real_idstr, col1);
      char *col2v=this->real_table->FindRecord("id", real_idstr, col2);
      listi lcol1(col1v, ',');
      listi lcol2(col2v, ',');
      listi lcol1_new(0, ',');
      listi lcol2_new(0, ',');
      int nlcol1=lcol1.getnum();
      int nlcol2=lcol2.getnum();
      int j;
      for(j=0; j<nlcol1; j++){
        if(strtoint(lcol1.getith(j))<0x80000000){
          lcol1_new.addelement(lcol1.getith(j));
        }else{
          lcol1_new.addelement(other_tr->getrealidforfake(lcol1.getith(j)));
        }
        
      }
      this->real_table->UpdateRecord("id", real_idstr, col1, lcol1_new.returnstring());
      //za 2rata kolona
      for(j=0; j<nlcol2; j++){
        if(strtoint(lcol2.getith(j))<0x80000000){
          lcol2_new.addelement(lcol2.getith(j));
        }else{
          lcol2_new.addelement(other_tr->getrealidforfake(lcol2.getith(j)));
        }
        
      }
      this->real_table->UpdateRecord("id", real_idstr, col2, lcol2_new.returnstring());
      
      
      
      delete real_idstr;
    }
    
  }
  
  /*
  //delete the folder of the transaction
  string cmd;
  cmd+="rm -r ";
  cmd+=MAINFOLDER;
  cmd+=this->trans_folder;
  system(cmd);
  */
}
char* tr_twin_ht::getrealidforfake(char* fakeid)
{
  string trf;
  trf+=MAINFOLDER;
  trf+=this->trans_folder;
  trf+="/trans_changed_ids_";
  trf+=this->tblname;
  trf+=".xml";
  
  char *retvalue=0;
  
  XMLNode x, x1, x2;
  XMLNode y, y1, y2;
  int i, j, ntr=0;
  x=XMLNode::parseFile(trf.c_str());
  x1=x.getChildNode("ids");
  ntr=x1.nChildNode();
  int foundindex;
  for(i=0; i<ntr; i++){
    x2=x1.getChildNode("id", &foundindex);
    char *attrbuf=x2.getAttribute("myid");
    if(attrbuf){
      if(!strcmp(fakeid, attrbuf)){
        x2=x1.getChildNode(foundindex);
        retvalue= x2.getAttribute("real_id");
      }
      delete attrbuf;
    }
    if(retvalue)
      break;
  }
  return retvalue;
}
void tr_twin_ht::deletetransfolder()
{
  //delete the folder of the transaction
  string cmd;
  cmd+="rm -r ";
  cmd+=MAINFOLDER;
  cmd+=this->trans_folder;
  system(cmd);
}


void tr_twin_ht::blockrecord(char* id_rec)
{
  
  srand ( time(NULL) );
  string fname1;
  fname1+=MAINFOLDER;
  fname1+=real_table->table_folder;
  fname1+="/data_";  
  fname1+=id_rec;  
  fname1+=".xml";
  XMLNode x1, x2;
  char *buf1=0;
trbl_two:
  x1=XMLNode::parseFile(fname1.c_str());
  x2=x1.getChildNode("records");
  

  buf1=x2.getAttribute("trid");
  if(!buf1){
    //blokiraj
    x2.addAttribute("trid", inttostr(this->trans_id));
    x1.writeToFile(fname1.c_str());
    
    
  }else{
    if(strcmp(buf1, id_rec)&&strcmp(buf1, "0")){
      //drug e blokiral , 4akaj
      usleep(200000+ rand()%800000);
      goto trbl_two;
      
    }
    //blokiraj
    x2.addAttribute("trid", id_rec);
    x1.writeToFile(fname1.c_str());
    
    
  }
  
  
  
  if(buf1)
    delete buf1;
  
  
  
  
}

void tr_twin_ht::unblockrecord(char* id_rec)
{
  string fname1;
  fname1+=MAINFOLDER;
  fname1+=real_table->table_folder;
  fname1+="/data_";  
  fname1+=id_rec;  
  fname1+=".xml";
  XMLNode x1, x2;
  char *buf1=0;
  
  x1=XMLNode::parseFile(fname1.c_str());
  x2=x1.getChildNode("records");
  x2.updateAttribute("0", "trid", "trid");
  x1.writeToFile(fname1.c_str());
}
int tr_twin_ht::getMAXID()
{
  int i, j;
  string fname;
  fname=MAINFOLDER;
  fname+=this->table_folder;
  
  
  fname+="/hash_main.xml";
  int rtv=1;
  char** freeids=0;
  int nids=0;
  XMLNode x1, x2, x3, x4;
  x1=XMLNode::parseFile(fname.c_str());
  x2=x1.getChildNode("info");
  x3=x2.getChildNode("nrecords");
  x4=x2.getChildNode("deletedids");
  char *buf0=0;
  char *buf1=0;
  
  buf0=x3.getText();
  buf1=x4.getText();
  if(buf1){
    if(strlen(buf1)>0){
      this->split(buf1, &nids, &freeids);
      rtv=strtoint(freeids[0]);
      
      
      
      goto getmid_endl1;   
    }else{
      
    }
    
  }else{

    
  }
  rtv=(0x80000000|strtoint(x3.getText()))+1;
  
 getmid_endl1:
 
  
  if(buf0)
    delete buf0;
  if(buf1)
    delete buf1;
  
  
  return rtv;
}