PokemonInsertRequest.cpp

Go to the documentation of this file.

#include "YAPOG/System/StringHelper.hpp"
#include "YAPOG/Database/DatabaseStream.hpp"

#include "Database/Requests/Inserts/PokemonInsertRequest.hpp"
#include "Database/Tables/PokemonTable.hpp"

namespace yse
{
  PokemonInsertRequest::PokemonInsertRequest 
    (const PokemonTable& pokemonTable)
    : pokemonTable_ (pokemonTable)
    , id_ ()
  {
  }

  PokemonInsertRequest::~PokemonInsertRequest ()
  {
  }

  bool PokemonInsertRequest::Insert 
    (yap::DatabaseManager& databaseManager)
  {
    yap::String query_string = 
      "INSERT INTO pokemon ("
      "account_id, "
      "pokemon_static_id, "
      "pokemon_experience, "
      "pokemon_hp, "
      "pokemon_gender, "
      "pokemon_nickname, "
      "pokemon_shiny, "
      "pokemon_loyalty, "
      "pokemon_nature, "
      "pokemon_trading_number, "
      "pokemon_trader_account_id, "
      "pokemon_box_number, "
      "pokemon_box_index, "
      "pokemon_catch_date, "
      "pokemon_status) "
      "VALUES ("
      ":accountID, "
      ":staticID, " 
      ":experience, "
      ":hp, "
      ":gender, "
      ":nickname, "
      ":shiny, "
      ":loyalty, "
      ":nature, "
      ":tradingNumber, "
      ":traderAccountID, "
      ":boxNumber, "
      ":boxIndex, "
      "NOW (), "
      ":status "
      ")"
      "RETURNING pokemon_id";

    yap::DatabaseStream query 
      (query_string, databaseManager.GetConnection ());

    try
    {
      query.Write (pokemonTable_.accountID_.GetValue ());
      query.Write (pokemonTable_.staticID_);
      query.Write (pokemonTable_.experience_);
      query.Write (pokemonTable_.hp_);
      query.Write (static_cast<yap::UInt8>(pokemonTable_.gender_));
      query.Write (pokemonTable_.nickname_);
      query.Write (pokemonTable_.shiny_);
      query.Write (pokemonTable_.loyalty_);
      query.Write (pokemonTable_.nature_);
      query.Write (pokemonTable_.tradingNumber_);
      query.Write (pokemonTable_.traderAccountID_);
      query.Write (pokemonTable_.boxNumber_);
      query.Write (pokemonTable_.boxIndex_);
      query.Write (static_cast<yap::UInt8>(pokemonTable_.status_));

      id_ = yap::ID (query.ReadInt ());

      return true;
    }
    catch (const pgs::pg_excpt& e)
    {
      std::cerr << e.errmsg () << std::endl;
    }
  }

  const yap::ID& PokemonInsertRequest::GetID ()
  {
    return id_;
  }

} // namespace yse