ACloudSQLManager.cc

Go to the documentation of this file.

#include <sstream>

#include <atm/ACloudSQLManager.h>
#include <det/Detector.h>
#include <utl/ErrorLogger.h>
#include <utl/TimeStamp.h>
#include <utl/StringCompare.h>
#include <utl/MoonCycle.h>

using namespace std;
using namespace atm;
using namespace det;


REGISTER_A_MANAGER("ACloudSQLManager", ACloudSQLManager);


ACloudSQLManager::ACloudSQLManager() :
  VSQLManager()
{
  const char* const tables[] = {
    "authors", "building_camera", "cloud_pixel",
    "db_header", "software"
  };
  const int n = sizeof(tables) / sizeof(tables[0]);
  fAvailableComponents.insert(tables, tables + n);
}

VManager::Status
ACloudSQLManager::GetData(vector<vector<int> >& returnData,
                          const string& tableName,
                          const string& componentName,
                          const IndexMap& componentIndex)
  const
{
  if (tableName != "cloud_pixel") {
    ERROR(string("Cannot handle call for ") +
          QueryInfoMessage(tableName, componentName));
    return eNotFound;
  }

  ostringstream query;
  query << "SELECT pixel_id, cloud_coverage, start_time, end_time ";

  // Check for a software version specification...
  if (!utl::StringEquivalent(fDatabaseSoftwareVersion, "default"))
    query << "FROM cloud_pixel, building_camera, software "
          << "WHERE cloud_pixel.building_camera_id = building_camera.building_camera_id "
          << "AND cloud_pixel.software_id = software.software_id "
          << "AND software.software_version = \"" << fDatabaseSoftwareVersion
          << "\" ";
  // ...or don't
  else
    query << "FROM cloud_pixel, building_camera "
          << "WHERE cloud_pixel.building_camera_id = building_camera.building_camera_id ";

  const utl::TimeStamp detTime = Detector::GetInstance().GetTime();

  query << "AND building_camera.building_number = "
        << componentIndex.find("eyeId")->second << " "
        << "AND building_camera.camera_number = "
        << componentIndex.find("telescopeId")->second << " "
        << "AND moon_cycle = "
        << utl::MoonCycle(detTime).GetFullMoonCycle() << " "
        << "AND start_time <= " << detTime.GetGPSSecond() << " "
        << "AND (end_time > " << detTime.GetGPSSecond() << " "
        << "OR end_time IS NULL) "
        << "ORDER BY pixel_id";

  if (Query(query) == eNotFound)
    return eNotFound;

  boost::tuple<int, int, int, int> pixelId_coverage_gpsStart_gpsEnd;
  vector<int> rowData;
  rowData.reserve(4);
  returnData.clear();

  while (FetchRowMany(pixelId_coverage_gpsStart_gpsEnd, false) == eFound) {
    rowData.clear();
    rowData.push_back(pixelId_coverage_gpsStart_gpsEnd.get<0>());
    rowData.push_back(pixelId_coverage_gpsStart_gpsEnd.get<1>());
    rowData.push_back(pixelId_coverage_gpsStart_gpsEnd.get<2>());
    rowData.push_back(pixelId_coverage_gpsStart_gpsEnd.get<3>());
    returnData.push_back(rowData);
  }

  FreeResult();

  return eFound;
}

VManager::Status
ACloudSQLManager::GetDBResFundamental(const std::string& tableName,
                                      const std::string& columnName,
                                      const IndexMap& componentIndex)
  const
{
  const utl::TimeStamp detTime = Detector::GetInstance().GetTime();

  ostringstream query;

  // cloud_pixel table is special, as it requires checking software version
  if (tableName == "cloud_pixel") {

    query << "SELECT " << columnName << " "
          << "FROM cloud_pixel, building_camera "
          << "WHERE cloud_pixel.building_camera_id = building_camera.building_camera_id ";

    // If software version is not "default," check for a particular version.
    if (!utl::StringEquivalent(fDatabaseSoftwareVersion, "default"))
      query << "AND software.software_version = \""
            << fDatabaseSoftwareVersion << "\" ";

    query << "AND start_time <= \"" << detTime.GetGPSSecond() << "\" "
          << "AND (end_time > \"" << detTime.GetGPSSecond() << "\" "
          << "OR end_time IS NULL) "
          << "AND moon_cycle = \"" << utl::MoonCycle(detTime).GetFullMoonCycle() << "\" "
          << "AND building_camera.building_number = "
          << componentIndex.find("eyeId")->second << " "
          << "AND building_camera.camera_number = "
          << componentIndex.find("telescopeId")->second << " "
          << "AND cloud_pixel.pixel_id = "
          << componentIndex.find("pixelId")->second << " "
          << "ORDER BY cloud_pixel.start_time, cloud_pixel.last_modified "
          << "DESC LIMIT 1";

  } else {

    if (fAvailableComponents.find(tableName) == fAvailableComponents.end())
      return eNotFound;

    // issue queries in form :
    //   SELECT columnName FROM tableName WHERE
    //     componentIndex[0].first = componentIndex[0].second AND
    //     componentIndex[1].first = componentIndex[1].second
    //     (etc)
    //
    query << "SELECT " << columnName << " "
             "FROM " << tableName << " "
             "WHERE " << MergeIndexMap(componentIndex);
  }

  return Query(query);
}


// Configure (x)emacs for this file ...
// Local Variables:
// mode: c++
// End: