package com.qianwen.mdc.collect.service;
|
|
import java.util.List;
|
|
import org.apache.iotdb.rpc.IoTDBConnectionException;
|
import org.apache.iotdb.rpc.StatementExecutionException;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import com.qianwen.mdc.collect.config.IotDBSessionConfig;
|
|
|
/**
|
* iotdb通用服务
|
*/
|
@Service
|
public class IotDBCommonService {
|
private static final Logger logger = LoggerFactory.getLogger(IotDBCommonService.class);
|
|
@Autowired
|
private IotDBSessionConfig iotdbCfg;
|
|
/**
|
* 模板是否挂载到指定路径了
|
* @param template 模板名称
|
* @param path 设备路径
|
* @return
|
*/
|
public boolean isTemplateSetOnPath(String template,String path) {
|
List<String> pathlist;
|
try {
|
pathlist = iotdbCfg.getSessionPool().showPathsTemplateSetOn(template);
|
//logger.info("pathlist"+pathlist);
|
return pathlist.contains(path);
|
} catch (StatementExecutionException|IoTDBConnectionException e) {
|
logger.error("获取模板使用错误",e);
|
}
|
|
return false;
|
}
|
|
/**
|
* 如果deviceId指定的路径没有挂载模板则执行挂载
|
* @param template 模板名称
|
* @param deviceId 设备路径
|
*/
|
public void setTemmplateIfNotSet(String template,String deviceId) {
|
if(!isTemplateSetOnPath(template, deviceId)) {
|
try {
|
iotdbCfg.getSessionPool().setSchemaTemplate(template, deviceId);
|
} catch (Exception e) {
|
logger.error("为deviceId设置模板错误,template="+template+",deviceId="+deviceId,e);
|
}
|
}
|
}
|
}
|
