53 lines
1.2 KiB
C
53 lines
1.2 KiB
C
|
#ifndef INFLUXDB_H
|
||
|
|
#define INFLUXDB_H
|
||
|
|
|
||
|
|
#include <stdio.h>
|
||
|
|
#include <iostream>
|
||
|
|
#include <vector>
|
||
|
|
#include <string>
|
||
|
|
#include <curl/curl.h>
|
||
|
|
|
||
|
|
class InfluxDB{
|
||
|
|
private:
|
||
|
|
|
||
|
|
CURL * curl;
|
||
|
|
CURLcode respond;
|
||
|
|
long respondCode;
|
||
|
|
|
||
|
|
std::string databaseIP;
|
||
|
|
std::string dataPoints;
|
||
|
|
|
||
|
|
std::vector<std::string> databaseList;
|
||
|
|
|
||
|
|
static size_t WriteCallBack(char *contents, size_t size, size_t nmemb, void *userp);
|
||
|
|
|
||
|
|
void Execute();
|
||
|
|
|
||
|
|
public:
|
||
|
|
/// url = https://fsunuc.physics.fsu.edu/InfluxDB/
|
||
|
|
InfluxDB(std::string url, bool verbose = false);
|
||
|
|
~InfluxDB();
|
||
|
|
|
||
|
|
void SetURL(std::string url);
|
||
|
|
|
||
|
|
/// Query
|
||
|
|
std::string ShowDatabases(); /// this save the list of database into databaseList
|
||
|
|
std::string Query(std::string databaseName, std::string query);
|
||
|
|
|
||
|
|
/// the ShowDatabases() function must be called before
|
||
|
|
std::vector<std::string> GetDatabaseList() {return databaseList;}
|
||
|
|
|
||
|
|
void CreateDatabase(std::string databaseName);
|
||
|
|
|
||
|
|
/// for single or batch write,
|
||
|
|
/// 1, addDataPoint first, you can add as many as you like
|
||
|
|
/// 2, writeData.
|
||
|
|
void AddDataPoint(std::string fullString);
|
||
|
|
void ClearDataPointsBuffer();
|
||
|
|
void PrintDataPoints();
|
||
|
|
void WriteData(std::string databaseName);
|
||
|
|
|
||
|
|
};
|
||
|
|
|
||
|
|
#endif
|