#顯示用戶
show users

#創(chuàng)建用戶
create user "username" with password 'password'

#創(chuàng)建管理員權(quán)限用戶
create user "username" with password 'password' with all privileges

#刪除用戶
drop user "username"

#創(chuàng)建數(shù)據(jù)庫(kù)
create database "db_name"

#顯示所有的數(shù)據(jù)庫(kù)
show databases

#刪除數(shù)據(jù)庫(kù)
drop database "db_name"

#使用數(shù)據(jù)庫(kù)
use db_name

#顯示該數(shù)據(jù)庫(kù)中所有的表
show measurements

#創(chuàng)建表，直接在插入數(shù)據(jù)的時(shí)候指定表名，其中test為表名
insert test,host=127.0.0.1,monitor_name=test count=1

#刪除表
drop measurement "measurement_name"

#查詢數(shù)據(jù)
select * from test order by time desc

#查看當(dāng)前數(shù)據(jù)庫(kù)的數(shù)據(jù)保存策略（Retention Policies）
show retention policies on "db_name"

#創(chuàng)建新的數(shù)據(jù)保存策略
#rp_name：策略名
#db_name：具體的數(shù)據(jù)庫(kù)名；
#3w：保存3周，3周之前的數(shù)據(jù)將被刪除，influxdb具有各種事件參數(shù)，比如：h（小時(shí)），d（天），w（星期）
#replication 1：副本個(gè)數(shù)，一般為1就可以了
#default：設(shè)置為默認(rèn)策略
create retention policy "rp_name" on "db_name" duration 3w replication 1 default

#修改數(shù)據(jù)保存策略
alter retention policy "rp_name" on "db_name" duration 30d default

#刪除數(shù)據(jù)保存策略
drop retention policy "rp_name"

#查看數(shù)據(jù)庫(kù)的連續(xù)查詢（Continous Queries）
show continuous queries

#創(chuàng)建新的連續(xù)查詢（Continous Queries）
#cq_name：連續(xù)查詢名字
#db_name：數(shù)據(jù)庫(kù)名字
#sum(count)：計(jì)算總和
#table_name：當(dāng)前表名
#new_table_name：存新的數(shù)據(jù)的表名
#30m：時(shí)間間隔為30分鐘
create continous query cq_name on db_name begin select sum(count) into new_table_name from table_name group by time(30m) end

#刪除連續(xù)查詢
drop continous query cp_name on db_name

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using InfluxData.Net.Common.Enums;
using InfluxData.Net.InfluxDb;
using InfluxData.Net.InfluxDb.Models;
using Microsoft.AspNetCore.Mvc;

namespace WebApplication1.Controllers
{
 public class InfoController : Controller
 {
 //聲明InfluxDbClient
 private InfluxDbClient clientDb;

 public InfoController()
 {
  //連接InfluxDb的API地址、賬號(hào)、密碼
  var infuxUrl = "http://localhost:8086/";
  var infuxUser = "admin";
  var infuxPwd = "admin";

  //創(chuàng)建InfluxDbClient實(shí)例
  clientDb = new InfluxDbClient(infuxUrl, infuxUser, infuxPwd, InfluxDbVersion.Latest);
 }


 /// <summary>
 /// 從InfluxDB中讀取數(shù)據(jù)
 /// </summary>
 public async void GetData()
 {
  //傳入查詢命令，支持多條
  var queries = new[]
  {
  " SELECT * FROM Reading WHERE time> now() - 24h "
  };
  var dbName = "code-hub";

  //從指定庫(kù)中查詢數(shù)據(jù)
  var response = await clientDb.Client.QueryAsync(queries, dbName);
  //得到Serie集合對(duì)象（返回執(zhí)行多個(gè)查詢的結(jié)果）
  var series = response.ToList();
  //取出第一條命令的查詢結(jié)果，是一個(gè)集合
  var list = series[0].Values;
  //從集合中取出第一條數(shù)據(jù)
  var info_model = list.FirstOrDefault();
 }



 /// <summary>
 /// 往InfluxDB中寫入數(shù)據(jù)
 /// </summary>
 public async void AddData()
 {
  //基于InfluxData.Net.InfluxDb.Models.Point實(shí)體準(zhǔn)備數(shù)據(jù)
  var point_model = new Point()
  {
  Name = "Reading",//表名
  Tags = new Dictionary<string, object>()
  {
   { "Id", 158}
  },
  Fields = new Dictionary<string, object>()
  {
   { "Val", "webInfo" }
  },
  Timestamp = DateTime.UtcNow
  };
  var dbName = "code-hub";

  //從指定庫(kù)中寫入數(shù)據(jù)，支持傳入多個(gè)對(duì)象的集合
  var response = await clientDb.Client.WriteAsync(point_model, dbName);
 }
 }
}