标签：JAVA String database void influxDB 插入 measurement public
package cn.test.jmeter.util;
import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import org.influxdb.dto.BatchPoints;
import org.influxdb.dto.Point;
import org.influxdb.dto.Point.Builder;
import org.influxdb.dto.Query;
import org.influxdb.dto.QueryResult;
import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;
/**
* @author weisy
* @date 2021/5/11
* @Description
*/
public class InfluxDbUtil {
private static String openurl = "http://IP:8086";//连接地址
private static String username = "admin";//用户名
private static String password = "admin";//密码
private static String database = "jmeter";//数据库
private String measurement;//表名
private InfluxDB influxDB;
public InfluxDbUtil(String username, String password, String openurl, String database) {
this.username = username;
this.password = password;
this.openurl = openurl;
this.database = database;
}
public static InfluxDbUtil setUp() {
//创建 连接
InfluxDbUtil influxDbUtil = new InfluxDbUtil(username, password, openurl, database);
influxDbUtil.influxDbBuild();
// influxDbUtil.createRetentionPolicy();
// influxDB.deleteDB(database);
// influxDB.createDB(database);
return influxDbUtil;
}
/**
* 连接时序数据库；获得InfluxDB
**/
public InfluxDB influxDbBuild() {
if (influxDB == null) {
influxDB = InfluxDBFactory.connect(openurl, username, password);
influxDB.createDatabase(database);
// influxDB.setRetentionPolicy("one_month");
}
return influxDB;
}
/**
* * 设置数据保存策略
* * defalut 策略名 /database 数据库名/ 30d 数据保存时限30天/ 1 副本个数为1/ 结尾DEFAULT 表示 设为默认的策略
*
*/
// public void createRetentionPolicy() {
// String command = String.format("CREATE RETENTION POLICY \"%s\" ON \"%s\" DURATION %s REPLICATION %s DEFAULT",
// "defalut", database, "30d", 1);
// this.query(command);
// }
/**
* * 查询
* * @param command 查询语句
* * @return
*
*/
public QueryResult query(String command) {
return influxDB.query(new Query(command, database));
}
/**
* * 插入
* * @param tags 标签
* * @param fields 字段
*
*/
/*
* 单条插入：多个tag多个field
* */
public void insert1(Map<String, String> tags, Map<String, Object> fields,String measurement) {
Builder builder = Point.measurement(measurement);
builder.tag(tags);
builder.fields(fields);
influxDB.write(database, "", builder.build());
}
/*
* 单条插入：多个tag多个field自定义时间戳
* */
public void insert2(Map<String, String> tags, Map<String, Object> fields,String measurement,Long timeStamp,TimeUnit timeUnit) {
Builder builder = Point.measurement(measurement);
builder.tag(tags);
builder.fields(fields);
if (0 != timeStamp) {
builder.time(timeStamp, timeUnit);
}
influxDB.write(database, "", builder.build());
}
/*
* 单条插入：单条tag单条field
* */
public void insert3(String tags, Integer fields,String measurement,Long timeStamp) {
Point point = Point.measurement(measurement)
.time(timeStamp, TimeUnit.MILLISECONDS)
.tag("label", tags)
.addField("value", fields).build();
influxDB.write("jmeter", "", point);
}
/*
* 批量插入
* */
public void insertBatch(ArrayList<Map<String, String>> sqlserverlist, String measurement) {
BatchPoints batchPoints = BatchPoints
.database("jmeter")
.build();
//遍历sqlserver获取数据
for(Map<String, String> map : sqlserverlist) {
//创建单条数据对象——表名
Point point = Point.measurement(measurement)
.time(Long.parseLong(map.get("timeStamp")), TimeUnit.MILLISECONDS)
//tag属性——只能存储String类型
.tag("label", map.get("label"))
//field存储数据
.addField("value", 1)
.addField("rt", map.get("rt"))
.build();
//将单条数据存储到集合中
batchPoints.point(point);
}
influxDB.write(batchPoints);
}
public void insertBatch2(ArrayList<Map<String, String>> sqlserverlist, String measurement) {
BatchPoints batchPoints = BatchPoints
.database("jmeter")
.build();
//遍历sqlserver获取数据
for(Map<String, String> map : sqlserverlist) {
//创建单条数据对象——表名
Point point = Point.measurement(measurement)
.time(Long.parseLong(map.get("timeStamp")), TimeUnit.MILLISECONDS)
//tag属性——只能存储String类型
.tag("label", map.get("label"))
//field存储数据
.addField("value", Integer.valueOf(map.get("value")))
.build();
//将单条数据存储到集合中
batchPoints.point(point);
}
influxDB.write(batchPoints);
}
/**
* * 删除
* * @param command 删除语句
* * @return 返回错误信息
*
*/
public String deleteMeasurementData(String command) {
QueryResult result = influxDB.query(new Query(command, database));
return result.getError();
}
/**
* * 创建数据库
* * @param dbName
*
*/
@SuppressWarnings("deprecation")
public void createDB(String dbName) {
influxDB.createDatabase(dbName);
}
/**
* * 删除数据库
* * @param dbName
*
*/
public void deleteDB(String dbName) {
influxDB.deleteDatabase(dbName);
}
public String getUsername() {
return username;
}
public void setUsername(String username) {
this.username = username;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getOpenurl() {
return openurl;
}
public void setOpenurl(String openurl) {
this.openurl = openurl;
}
public void setDatabase(String database) {
this.database = database;
}
public static void main(String[] args) {
InfluxDbUtil influxDB = InfluxDbUtil.setUp();
Map<String, String> tags = new HashMap<>();
Map<String, Object> fields = new HashMap<>();
tags.put("TAG_NAME","abc");
fields.put("TAG_VALUE","111");
// try {
// fields.put("TIMAMPEST", DateUtil.getCurrentDateStr());
// } catch (Exception e) {
// e.printStackTrace();
// }
influxDB.insert1(tags, fields,"table2");
//查询
QueryResult result= influxDB.query("select *from table2 order by time");
System.out.println(result);
}
}
标签：JAVA,String,database,void,influxDB,插入,measurement,public 来源： https://www.cnblogs.com/tianyun5115/p/14765960.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。