springboot使用Cassandra组合查询数据

简介: springboot使用Cassandra组合查询数据


在application.yml中配置cassandra

data:
   cassandra:
     contact-points: 192.168.0.122
     port: 9042   
     username: XXX
     password: XX
     keyspace-name: XXX

pom中引入Cassandra

<!-- 引入cassandra-->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-cassandra</artifactId>
</dependency>

封装Cassandra的通用类

package com.wuzheng.vehicle.info.repository;
import org.springframework.data.cassandra.core.query.Query;
import java.io.Serializable;
import java.util.List;
/**
 * @description:基础 仓储层
 * @author:twislyn
 * @date:Created in 2020/05/21
 * @modified By:
 * @version: 1.0
 */
public interface BaseRepository<T> {
    /**
     * 按主键查询
     * @param id
     * @return
     */
    T getById(Serializable id);
    /**
     * 按条件查询对象
     * @param query
     * @return
     */
    T getObj(Query query);
    /**
     * 按条件查询列表
     * @param query
     * @return
     */
    List<T> listObjs(Query query);
//    /**
//     * 分页查询
//     * @param pagination
//     * @param query
//     * @return
//     */
//    Slice<T> pageObjs(Pagination pagination, Query query);
}

实现类:

package com.wuzheng.vehicle.info.repository.impl;
import com.datastax.driver.core.PagingState;
import com.wuzheng.vehicle.info.repository.BaseRepository;
import com.wuzheng.vehicle.info.utils.Pagination;
import org.springframework.data.cassandra.core.CassandraTemplate;
import org.springframework.data.cassandra.core.query.CassandraPageRequest;
import org.springframework.data.cassandra.core.query.Query;
import org.springframework.data.domain.Slice;
import javax.annotation.Resource;
import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.util.List;
/**
 * @description:基础 仓储实现层
 * @author:twislyn
 * @date:Created in 2020/05/21
 * @modified By:
 * @version: 1.0
 */
public class BaseRepositoryImpl<T> implements BaseRepository<T> {
    @Resource
    CassandraTemplate cassandraTemplate;
    protected Class<T> entityClass = currentModelClass();
    /**
     * 获取泛型类型
     *
     * @return
     */
    @SuppressWarnings("unchecked")
    protected Class<T> currentModelClass() {
        return (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0];
    }
    @Override
    public T getById(Serializable id) {
        return cassandraTemplate.selectOneById(id, entityClass);
    }
    @Override
    public T getObj(Query query) {
        return cassandraTemplate.selectOne(query, entityClass);
    }
    @Override
    public List<T> listObjs(Query query) {
        return cassandraTemplate.select(query, entityClass);
    }
//    @Override
//    public Slice<T> pageObjs(Pagination pagination, Query query) {
//        if (pagination.getPageSize() > 1) {
//            CassandraPageRequest pageRequest = pagination.getPageRequest();
//            Slice<T> slice = cassandraTemplate.slice(query.pageRequest(pageRequest), entityClass);
//            for (int i = 1, len = pagination.getPageSize(); i < len; i++) {
//                PagingState pagingState = ((CassandraPageRequest) slice.getPageable()).getPagingState();
//                if (pagingState == null) {
//                    return slice;
//                }
//                pageRequest = CassandraPageRequest.of(slice.getPageable(), pagingState);
//                slice = cassandraTemplate.slice(query.pageRequest(pageRequest), entityClass);
//            }
//            return slice;
//        }
//        return cassandraTemplate.slice(query.pageRequest(pagination.getPageRequest()), entityClass);
//
//    }
}

具体使用

自定义对应Cassandra的数据库的实体

package com.wuzheng.vehicle.supervise.entity;
import org.springframework.data.cassandra.core.mapping.Column;
import org.springframework.data.cassandra.core.mapping.PrimaryKey;
import org.springframework.data.cassandra.core.mapping.Table;
import java.util.List;
import java.util.Map;
/**
 * @description:燃油车辆实时数据
 * @author:twislyn
 * @date:Created in 2020/
 * 05/22
 * @modified By:
 * @version: 1.0
 */
@Table("w_iot_fuelvehicle_realtime_base")
public class IotFuelVehicleRealtimeBase {
    @PrimaryKey("rowid")
    private String rowId;
    /**
     * 进气量
     */
    @Column("airin")
    private Double airIn;
    /**
     * 大气压力
     */
    @Column("atmp")
    private Double atmp;
    /**
     * 标定验证码
     */
    @Column("cvn")
    private String cvn;
    @Column("dpf")
    private Double dpf;
    /**
     * 发动机冷却液温度
     */
    @Column("ect")
    private Integer ect;
    /**
     * 发动机燃料流量
     */
    @Column("eflow")
    private Double eflow;
    /**
     * 发动机转速
     */
    @Column("espeed")
    private Double espeed;
    @Column("flist")
    private List flist;
    /**
     * 油箱液位
     */
    @Column("flvl")
    private Double flvl;
    /**
     * 故障码数量
     */
    @Column("fnum")
    private Integer fnum;
    /**
     * 摩擦扭矩(作为发动机最大基准扭矩的百分比)
     */
    @Column("ftorq")
    private Integer ftorq;
    /**
     * 数据采集时间_登入
     */
    @Column("gatime")
    private String gatime;
    /**
     * IUPR值
     */
    @Column("iupr")
    private String iupr;
    /**
     * 纬度
     */
    @Column("lat")
    private Double lat;
    /**
     * 经度
     */
    @Column("lng")
    private Double lng;
    @Column("locs")
    private Map<String, Double> locs;
    /**
     * 定位状态
     */
    @Column("locsts")
    private String locsts;
    /**
     * MIL状态
     */
    @Column("milsts")
    private Integer milsts;
    /**
     * OBD诊断协议
     */
    @Column("obddp")
    private Integer obddp;
    /**
     * 发动机净输出扭矩,或发动机实际扭矩/指示扭矩
     */
    @Column("otorq")
    private Integer otorq;
    @Column("rdysts")
    private String rdysts;
    @Column("reiss")
    private Boolean reiss;
    @Column("remrg")
    private Double remrg;
    @Column("rfld")
    private Map rfld;
    @Column("scrdnnox")
    private Double scrdnnox;
    @Column("scrint")
    private Double scrint;
    @Column("scroutt")
    private Double scroutt;
    @Column("scrupnox")
    private Double scrupnox;
    /**
     * 车速
     */
    @Column("speed")
    private Double speed;
    @Column("sstr")
    private String sstr;
    @Column("supsts")
    private String supsts;
    @Column("swareid")
    private String swareid;
    /**
     * 累计里程
     */
    @Column("tmiles")
    private Double tmiles;
    /**
     * vin码
     */
    @Column("vin")
    private String vin;
    public String getRowId() {
        return rowId;
    }
    public void setRowId(String rowId) {
        this.rowId = rowId;
    }
    public Double getAirIn() {
        return airIn;
    }
    public void setAirIn(Double airIn) {
        this.airIn = airIn;
    }
    public Double getAtmp() {
        return atmp;
    }
    public void setAtmp(Double atmp) {
        this.atmp = atmp;
    }
    public String getCvn() {
        return cvn;
    }
    public void setCvn(String cvn) {
        this.cvn = cvn;
    }
    public Double getDpf() {
        return dpf;
    }
    public void setDpf(Double dpf) {
        this.dpf = dpf;
    }
    public Integer getEct() {
        return ect;
    }
    public void setEct(Integer ect) {
        this.ect = ect;
    }
    public Double getEflow() {
        return eflow;
    }
    public void setEflow(Double eflow) {
        this.eflow = eflow;
    }
    public Double getEspeed() {
        return espeed;
    }
    public void setEspeed(Double espeed) {
        this.espeed = espeed;
    }
    public List getFlist() {
        return flist;
    }
    public void setFlist(List flist) {
        this.flist = flist;
    }
    public Double getFlvl() {
        return flvl;
    }
    public void setFlvl(Double flvl) {
        this.flvl = flvl;
    }
    public Integer getFnum() {
        return fnum;
    }
    public void setFnum(Integer fnum) {
        this.fnum = fnum;
    }
    public Integer getFtorq() {
        return ftorq;
    }
    public void setFtorq(Integer ftorq) {
        this.ftorq = ftorq;
    }
    public String getGatime() {
        return gatime;
    }
    public void setGatime(String gatime) {
        this.gatime = gatime;
    }
    public String getIupr() {
        return iupr;
    }
    public void setIupr(String iupr) {
        this.iupr = iupr;
    }
    public Double getLat() {
        return lat;
    }
    public void setLat(Double lat) {
        this.lat = lat;
    }
    public Double getLng() {
        return lng;
    }
    public void setLng(Double lng) {
        this.lng = lng;
    }
    public Map<String, Double> getLocs() {
        return locs;
    }
    public void setLocs(Map<String, Double> locs) {
        this.locs = locs;
    }
    public String getLocsts() {
        return locsts;
    }
    public void setLocsts(String locsts) {
        this.locsts = locsts;
    }
    public Integer getMilsts() {
        return milsts;
    }
    public void setMilsts(Integer milsts) {
        this.milsts = milsts;
    }
    public Integer getObddp() {
        return obddp;
    }
    public void setObddp(Integer obddp) {
        this.obddp = obddp;
    }
    public Integer getOtorq() {
        return otorq;
    }
    public void setOtorq(Integer otorq) {
        this.otorq = otorq;
    }
    public String getRdysts() {
        return rdysts;
    }
    public void setRdysts(String rdysts) {
        this.rdysts = rdysts;
    }
    public Boolean getReiss() {
        return reiss;
    }
    public void setReiss(Boolean reiss) {
        this.reiss = reiss;
    }
    public Double getRemrg() {
        return remrg;
    }
    public void setRemrg(Double remrg) {
        this.remrg = remrg;
    }
    public Map getRfld() {
        return rfld;
    }
    public void setRfld(Map rfld) {
        this.rfld = rfld;
    }
    public Double getScrdnnox() {
        return scrdnnox;
    }
    public void setScrdnnox(Double scrdnnox) {
        this.scrdnnox = scrdnnox;
    }
    public Double getScrint() {
        return scrint;
    }
    public void setScrint(Double scrint) {
        this.scrint = scrint;
    }
    public Double getScroutt() {
        return scroutt;
    }
    public void setScroutt(Double scroutt) {
        this.scroutt = scroutt;
    }
    public Double getScrupnox() {
        return scrupnox;
    }
    public void setScrupnox(Double scrupnox) {
        this.scrupnox = scrupnox;
    }
    public Double getSpeed() {
        return speed;
    }
    public void setSpeed(Double speed) {
        this.speed = speed;
    }
    public String getSstr() {
        return sstr;
    }
    public void setSstr(String sstr) {
        this.sstr = sstr;
    }
    public String getSupsts() {
        return supsts;
    }
    public void setSupsts(String supsts) {
        this.supsts = supsts;
    }
    public String getSwareid() {
        return swareid;
    }
    public void setSwareid(String swareid) {
        this.swareid = swareid;
    }
    public Double getTmiles() {
        return tmiles;
    }
    public void setTmiles(Double tmiles) {
        this.tmiles = tmiles;
    }
    public String getVin() {
        return vin;
    }
    public void setVin(String vin) {
        this.vin = vin;
    }
}

实现通用接口

package com.wuzheng.vehicle.info.repository;
import com.wuzheng.vehicle.info.entity.ForwardExportMsgTask;
import com.wuzheng.vehicle.info.dto.excel.WIotElecvehicleRealtimeBase;
import java.util.List;
/**
 * 转发报文数据
 */
public interface IotElecvehicleRealtimeBaseRepository extends BaseRepository<WIotElecvehicleRealtimeBase> {
    /**
     * 根据条件查询历史数据
     *
     * @param queryInfo 查询条件
     * @return
     */
    List<WIotElecvehicleRealtimeBase> list(ForwardExportMsgTask queryInfo);
}

具体查询逻辑(最重要)

package com.wuzheng.vehicle.info.repository.impl;
import com.wuzheng.vehicle.info.entity.ForwardExportMsgTask;
import com.wuzheng.vehicle.info.dto.excel.WIotElecvehicleRealtimeBase;
import com.wuzheng.vehicle.info.repository.IotElecvehicleRealtimeBaseRepository;
import com.wuzheng.vehicle.info.utils.StringUtils;
import org.springframework.data.cassandra.core.query.Columns;
import org.springframework.data.cassandra.core.query.Query;
import org.springframework.stereotype.Repository;
import java.util.List;
import static org.springframework.data.cassandra.core.query.Criteria.where;
@Repository
public class IotElecvehicleRealtimeBaseRepositoryImpl extends BaseRepositoryImpl<WIotElecvehicleRealtimeBase>
        implements IotElecvehicleRealtimeBaseRepository {
    @Override
    public List<WIotElecvehicleRealtimeBase> list(ForwardExportMsgTask queryInfo) {
        Query query = Query
                .query(where("idcode").like(queryInfo.getTaskPlatIdCode()))
                .and(where("vin").in(queryInfo.getTaskVin()))
                .and(where("msgtype").is(queryInfo.getTaskMsgType() + ""));
        if (StringUtils.isNotBlank(queryInfo.getTaskStartTimeStr())) {
            query = query.and(where("gatime").gt(queryInfo.getTaskStartTimeStr()));
        }
        if (StringUtils.isNotBlank(queryInfo.getTaskEndTimeStr())) {
            query = query.and(where("gatime").lt(queryInfo.getTaskEndTimeStr()));
        }
//        query = query.sort(Sort.by("vin").descending()).withAllowFiltering();
        query = query.withAllowFiltering();
        query = query.columns(Columns.from("vin", "gatime", "sstr", "rectime", "fwdtime", "ressts", "restime", "idcode", "msgtype"));
        System.out.println(query);
        return this.cassandraTemplate.select(query, WIotElecvehicleRealtimeBase.class);
    }
}

使用


相关文章
|
7天前
|
前端开发 Java API
SpringBoot整合Flowable【06】- 查询历史数据
本文介绍了Flowable工作流引擎中历史数据的查询与管理。首先回顾了流程变量的应用场景及其局限性,引出表单在灵活定制流程中的重要性。接着详细讲解了如何通过Flowable的历史服务API查询用户的历史绩效数据,包括启动流程、执行任务和查询历史记录的具体步骤,并展示了如何将查询结果封装为更易理解的对象返回。最后总结了Flowable提供的丰富API及其灵活性,为后续学习驳回功能做了铺垫。
18 0
SpringBoot整合Flowable【06】- 查询历史数据
|
7天前
|
存储 前端开发 Java
SpringBoot整合Flowable【05】- 使用流程变量传递业务数据
本文介绍了如何使用Flowable的流程变量来管理绩效流程中的自定义数据。首先回顾了之前的简单绩效流程,指出现有流程缺乏分数输入和保存步骤。接着详细解释了流程变量的定义、分类(运行时变量和历史变量)及类型。通过具体代码示例展示了如何在绩效流程中插入全局和局部流程变量,实现各节点打分并维护分数的功能。最后总结了流程变量的使用场景及其在实际业务中的灵活性,并承诺将持续更新Flowable系列文章,帮助读者更好地理解和应用Flowable。 简要来说,本文通过实例讲解了如何利用Flowable的流程变量功能优化绩效评估流程,确保每个环节都能记录和更新分数,同时提供了全局和局部变量的对比和使用方法。
33 0
|
2月前
|
SQL 前端开发 关系型数据库
SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据
SpringBoot使用mysql查询昨天、今天、过去一周、过去半年、过去一年数据
83 9
|
3月前
|
SQL JSON Java
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
这篇文章介绍了如何在Spring Boot项目中整合MyBatis和PageHelper进行分页操作,并且集成Swagger2来生成API文档,同时定义了统一的数据返回格式和请求模块。
117 1
mybatis使用三:springboot整合mybatis,使用PageHelper 进行分页操作,并整合swagger2。使用正规的开发模式:定义统一的数据返回格式和请求模块
|
2月前
|
存储 easyexcel Java
SpringBoot+EasyExcel轻松实现300万数据快速导出!
本文介绍了在项目开发中使用Apache POI进行数据导入导出的常见问题及解决方案。首先比较了HSSFWorkbook、XSSFWorkbook和SXSSFWorkbook三种传统POI版本的优缺点,然后根据数据量大小推荐了合适的使用场景。接着重点介绍了如何使用EasyExcel处理超百万数据的导入导出,包括分批查询、分批写入Excel、分批插入数据库等技术细节。通过测试,300万数据的导出用时约2分15秒,导入用时约91秒,展示了高效的数据处理能力。最后总结了公司现有做法的不足,并提出了改进方向。
|
3月前
|
Web App开发 JavaScript Java
elasticsearch学习五:springboot整合 rest 操作elasticsearch的 实际案例操作,编写搜索的前后端,爬取京东数据到elasticsearch中。
这篇文章是关于如何使用Spring Boot整合Elasticsearch,并通过REST客户端操作Elasticsearch,实现一个简单的搜索前后端,以及如何爬取京东数据到Elasticsearch的案例教程。
287 0
elasticsearch学习五:springboot整合 rest 操作elasticsearch的 实际案例操作,编写搜索的前后端,爬取京东数据到elasticsearch中。
|
JSON 缓存 前端开发
【SpringBoot 2】(八)数据响应 页面响应(一)
【SpringBoot 2】(八)数据响应 页面响应(一)
237 0
【SpringBoot 2】(八)数据响应 页面响应(一)
|
JSON 缓存 前端开发
【SpringBoot 2】(八)数据响应 页面响应(一)
【SpringBoot 2】(八)数据响应 页面响应(一)
499 0
【SpringBoot 2】(八)数据响应 页面响应(一)
|
前端开发 Java 数据安全/隐私保护
【SpringBoot 2】(八)数据响应 页面响应(二)
【SpringBoot 2】(八)数据响应 页面响应(二)
182 0
|
前端开发 Java 数据安全/隐私保护
【SpringBoot 2】(八)数据响应 页面响应(二)
【SpringBoot 2】(八)数据响应 页面响应(二)
145 0

热门文章

最新文章