Method deleteSession

app/src/Sessions/DatabaseWorker.cpp:168–218

* @brief Cascades a delete across readings, raw bytes, snapshots, tags, columns, and the row. */

 * @brief Cascades a delete across readings, raw bytes, snapshots, tags, columns, and the row.
 */
void Sessions::DatabaseWorker::deleteSession(int sessionId, quint64 token)
{
  if (!m_db.isOpen()) {
    Q_EMIT mutationFinished(token, false, tr("Database not open"));
    return;
  }

  if (!m_db.transaction()) {
    Q_EMIT mutationFinished(token, false, m_db.lastError().text());
    return;
  }

  const auto runDelete = [&](const char* sql) -> bool {
    QSqlQuery q(m_db);
    q.prepare(QString::fromLatin1(sql));
    q.bindValue(0, sessionId);
    if (!q.exec()) [[unlikely]] {
      qWarning() << "[DatabaseWorker] deleteSession" << sql << "failed:" << q.lastError().text();
      return false;
    }

    return true;
  };

  const char* statements[] = {
    "DELETE FROM readings WHERE session_id = ?",
    "DELETE FROM raw_bytes WHERE session_id = ?",
    "DELETE FROM table_snapshots WHERE session_id = ?",
    "DELETE FROM session_tags WHERE session_id = ?",
    "DELETE FROM columns WHERE session_id = ?",
    "DELETE FROM sessions WHERE session_id = ?",
  };

  for (const char* sql : statements) {
    if (!runDelete(sql)) {
      m_db.rollback();
      Q_EMIT mutationFinished(token, false, m_db.lastError().text());
      return;
    }
  }

  if (!m_db.commit()) {
    m_db.rollback();
    Q_EMIT mutationFinished(token, false, m_db.lastError().text());
    return;
  }

  refreshSessionListInternal();
  Q_EMIT sessionListRefreshed(m_sessionList);
  Q_EMIT mutationFinished(token, true, QString());
}

/**
 * @brief Persists the notes string for a session.