Method SqliteLogger

src/loggers/bt_sqlite_logger.cpp:58–139

}  // namespace

SqliteLogger::SqliteLogger(const Tree& tree, std::filesystem::path const& filepath,
                           bool append)
  : StatusChangeLogger()  // Deferred subscription
{
  const auto extension = filepath.filename().extension();
  if(extension != ".db3" && extension != ".btdb")
  {
    throw RuntimeError("SqliteLogger: the file extension must be [.db3] or [.btdb]");
  }

  enableTransitionToIdle(true);

  // Open database
  const int rc = sqlite3_open(filepath.string().c_str(), &db_);
  if(rc != SQLITE_OK)
  {
    throw RuntimeError(std::string("Cannot open database: ") + sqlite3_errmsg(db_));
  }

  // Create tables
  execSQL(db_, "CREATE TABLE IF NOT EXISTS Transitions ("
               "timestamp  INTEGER PRIMARY KEY NOT NULL, "
               "session_id INTEGER NOT NULL, "
               "node_uid   INTEGER NOT NULL, "
               "duration   INTEGER, "
               "state      INTEGER NOT NULL,"
               "extra_data VARCHAR );");

  execSQL(db_, "CREATE TABLE IF NOT EXISTS Nodes ("
               "session_id INTEGER NOT NULL, "
               "fullpath   VARCHAR, "
               "node_uid   INTEGER NOT NULL );");

  execSQL(db_, "CREATE TABLE IF NOT EXISTS Definitions ("
               "session_id INTEGER PRIMARY KEY AUTOINCREMENT, "
               "date       TEXT NOT NULL,"
               "xml_tree   TEXT NOT NULL);");

  if(!append)
  {
    execSQL(db_, "DELETE from Transitions;");
    execSQL(db_, "DELETE from Definitions;");
    execSQL(db_, "DELETE from Nodes;");
  }

  // Insert tree definition
  auto tree_xml = WriteTreeToXML(tree, true, true);
  sqlite3_stmt* stmt = prepareStatement(db_, "INSERT into Definitions (date, xml_tree) "
                                             "VALUES (datetime('now','localtime'),?);");
  sqlite3_bind_text(stmt, 1, tree_xml.c_str(), -1, SQLITE_TRANSIENT);
  execStatement(stmt);

  // Get session_id
  stmt = prepareStatement(db_, "SELECT MAX(session_id) FROM Definitions LIMIT 1;");
  if(sqlite3_step(stmt) == SQLITE_ROW)
  {
    session_id_ = sqlite3_column_int(stmt, 0);
  }