vrfSqliteDatabaseConnection.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2024 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
#pragma once

#include <vrfMsgTransport/vrfMsgTransportDefines.h>
#include <vrfMsgTransport/vrfDatabaseConnection.h>
#include <vlutil/vlFilename.h>
#include <atomic>

struct sqlite3;

class DT_DLL_vrfMsgTransport DtVrfSqliteDatabaseConnection : public DtVrfDatabaseConnection
{
public:

   virtual ~DtVrfSqliteDatabaseConnection() override;

   static DtVrfDatabaseConnection* create()
   {
      return new DtVrfSqliteDatabaseConnection();
   };

   static DtString type()
   {
      return "sqlite-database-connection";
   };

protected:

   DtVrfSqliteDatabaseConnection();

   virtual bool processConfiguration(const DtRwDatabaseLoggerConfig& config) override;

   virtual bool connect() override { return true; }

   virtual bool createDatabase() override;

   virtual bool createTableForEvent(const DtVrfDatabaseEvent& event) override;

   virtual bool insertOrIgnoreEntriesForEvents(const DtVrfDatabaseEventVector& events) override;

   virtual bool insertOrUpdateEntriesForEvents(const DtVrfDatabaseEventVector& events) override;

   virtual bool updateEntryForEvent(const DtVrfDatabaseEvent& event) override;

   virtual std::string escapeString(std::string str) override;

private:

   DtVrfSqliteDatabaseConnection(const DtVrfSqliteDatabaseConnection& other);

   DtVrfSqliteDatabaseConnection& operator=(const DtVrfSqliteDatabaseConnection& other);

protected:

   DtFilename myFilename;

   sqlite3* myDb;
};