package com.springcloudme.serviceinfluxdbapp.controller;

import com.springcloudme.serviceinfluxdbapp.utils.InfluxDBUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.ModelAndView;

@RestController
@RequestMapping("/influxdb")
public class InfluxdbController {

	private static Logger log = LoggerFactory.getLogger(InfluxdbController.class);

	@RequestMapping("/queryUI")
	public ModelAndView queryUI(){
		ModelAndView mav = new ModelAndView();
		mav.setViewName("query");
		return mav;
	}

	@RequestMapping("/query")
	public Object query(@RequestParam String sql){
		log.info("in /influxdb/query");
		InfluxDBUtils utils= InfluxDBUtils.getInfluxDBUtil();
		return utils.query(utils.getInstance(),sql);
	}

	@RequestMapping("/insert")
	public Object insert(){
		log.info("in /influxdb/query");
		InfluxDBUtils utils= InfluxDBUtils.getInfluxDBUtil();
		return utils.insert(utils.getInstance());
	}
}