11#include "ns3/nstime.h"
23 int rc = sqlite3_open(name.c_str(), &
m_db);
31 rc = sqlite3_close_v2(
m_db);
39 SpinExec(
"PRAGMA journal_mode = MEMORY");
92 return sqlite3_column_int(stmt, pos);
100 return static_cast<uint32_t>(sqlite3_column_int(stmt, pos));
108 return sqlite3_column_double(stmt, pos);
124 return sqlite3_bind_double(stmt, pos, value.GetSeconds()) == SQLITE_OK;
132 return sqlite3_bind_double(stmt, pos, value) == SQLITE_OK;
140 return sqlite3_bind_int(stmt, pos,
static_cast<int>(value)) == SQLITE_OK;
148 return sqlite3_bind_int64(stmt, pos, value) == SQLITE_OK;
156 return sqlite3_bind_int64(stmt, pos, value) == SQLITE_OK;
164 return sqlite3_bind_int(stmt, pos,
static_cast<int>(value)) == SQLITE_OK;
172 return sqlite3_bind_int(stmt, pos,
static_cast<int>(value)) == SQLITE_OK;
180 return sqlite3_bind_int(stmt, pos, value) == SQLITE_OK;
188 return sqlite3_bind_text(stmt, pos, value.c_str(), -1, SQLITE_STATIC) == SQLITE_OK;
197 std::unique_lock lock{
m_mutex};
199 rc = sqlite3_prepare_v2(db, cmd.c_str(),
static_cast<int>(cmd.size()), stmt,
nullptr);
217 rc = sqlite3_prepare_v2(db, cmd.c_str(),
static_cast<int>(cmd.size()), stmt,
nullptr);
218 }
while (rc == SQLITE_BUSY || rc == SQLITE_LOCKED);
228 rc = sqlite3_step(stmt);
229 }
while (rc == SQLITE_BUSY || rc == SQLITE_LOCKED);
240 rc = sqlite3_finalize(stmt);
241 }
while (rc == SQLITE_BUSY || rc == SQLITE_LOCKED);
253 rc = sqlite3_reset(stmt);
254 }
while (rc == SQLITE_BUSY || rc == SQLITE_LOCKED);
268 if (rc != SQLITE_OK && rc != SQLITE_DONE)
276 std::cerr << sqlite3_errmsg(db) << std::endl;
328 int rc = SQLITE_ERROR;
330 std::unique_lock lock{
m_mutex};
350 int rc = SQLITE_ERROR;
352 std::unique_lock lock{
m_mutex};
sqlite3 * m_db
Database pointer.
bool SpinExec(const std::string &cmd) const
Execute a command until the return value is OK or an ERROR.
static bool CheckError(sqlite3 *db, int rc, const std::string &cmd, bool hardExit)
Check any error in the db.
~SQLiteOutput()
Destructor.
static int SpinStep(sqlite3_stmt *stmt)
Execute a step operation on a statement until the result is ok or an error.
void SetJournalInMemory()
Instruct SQLite to store the journal in memory.
T RetrieveColumn(sqlite3_stmt *stmt, int pos) const
Retrieve a value from an executed statement.
bool Bind(sqlite3_stmt *stmt, int pos, const T &value) const
Bind a value to a sqlite statement.
static int SpinReset(sqlite3_stmt *stmt)
Reset a statement until the result is ok or an error.
static int SpinFinalize(sqlite3_stmt *stmt)
Finalize a statement until the result is ok or an error.
bool WaitExec(const std::string &cmd) const
Execute a command, waiting on a mutex.
static void Error(sqlite3 *db, const std::string &cmd)
Fail, printing an error message from sqlite.
bool SpinPrepare(sqlite3_stmt **stmt, const std::string &cmd) const
Prepare a statement.
SQLiteOutput(const std::string &name)
SQLiteOutput constructor.
bool WaitPrepare(sqlite3_stmt **stmt, const std::string &cmd) const
Prepare a statement, waiting on a mutex.
Simulation virtual time values and global simulation resolution.
#define NS_ABORT_MSG_UNLESS(cond, msg)
Abnormal program termination if a condition is false, with a message.
#define NS_FATAL_ERROR(msg)
Report a fatal error with a message and terminate.
#define NS_ABORT_MSG(msg)
Unconditional abnormal program termination with a message.
#define NS_LOG_COMPONENT_DEFINE(name)
Define a Log component with a specific name.
#define NS_LOG_FUNCTION(parameters)
If log level LOG_FUNCTION is enabled, this macro will output all input parameters separated by ",...
Every class exported by the ns3 library is enclosed in the ns3 namespace.