from influxdb import InfluxDBClient
from influxdb import DataFrameClient
import pandas as pd

class influx_db(object):
    """
    A class to CRUD in influx database.

    """

    def __init__ (self,host,port,user,password):

        #Self Variable Declaration.
        self.host=host
        self.port = port
        self.user = user
        self.password = password
        self.database = ''
        self.client = ''

    def create_db(self, dbname):
        self.client = DataFrameClient(self.host, self.port, self.user, self.password, dbname)
        self.client.create_database(dbname)

    def insert_dataframe(self, df, dbname, timestamp, false):
        self.client = DataFrameClient(self.host, self.port, self.user, self.password, dbname)
        self.client.create_database(dbname)
        self.client.write_points(df, 'random_name')


    def insert_dataframe(self, df, dbname, timestamp, false):
        self.client = DataFrameClient(host, port, user, password, dbname)
        self.client.create_database(dbname)
        self.client.write_points(df, 'random_name')


    def insert_value(self, dbname, tablename):



    def delete_value(self, dbname, tablename):




    def update(self, dbname, tablename):



    def query(self, sql,dbname):
        self.client = DataFrameClient(host, port, user, password, dbname)
        return self.client.query(sql)
        #return pd.DataFrame(re.items(), columns=['Date', 'DateValue'])

    def tables(self, dbname):
        self.client = DataFrameClient(host, port, user, password, dbname)
        return self.client.query("show series")

    def database(self):
        return client.query("show databases")

    def show(self, dbname,tablename):
        self.client = DataFrameClient(host, port, user, password, dbname)
        return self.client.query("select * from %s"%tablename)

# print("Write DataFrame")
# client.write_points(df, 'random_name')

# print("Read DataFrame")
# re=client.query("select * from random_name")