vrfMySqlDatabaseConnection.h

Go to the documentation of this file.

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

#include <vrfMsgTransport/vrfDatabaseConnection.h>
#include <vlutil/vlString.h>
#include <set>
#include <atomic>

struct MYSQL;

class DtVrfMySqlDatabaseConnection : public DtVrfDatabaseConnection
{
public:

   virtual ~DtVrfMySqlDatabaseConnection() override;

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

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

protected:

   DtVrfMySqlDatabaseConnection();

   virtual bool processConfiguration(const DtRwDatabaseLoggerConfig& config) override;

   virtual bool connect() override;

   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:

   DtVrfMySqlDatabaseConnection(const DtVrfMySqlDatabaseConnection& other);

   DtVrfMySqlDatabaseConnection& operator=(const DtVrfMySqlDatabaseConnection& other);

protected:

   DtString myHostIp;
   DtString myUserName;
   DtString myPassword;
   DtString myDatabaseName;
   unsigned myPort;

   MYSQL* myConn;
};