springboot使用Cassandra组合查询数据

叁歲伎倆 2023-02-20 15:55 95阅读 0赞

### springboot使用Cassandra组合查询数据 ###

*   *  在application.yml中配置cassandra
     *  pom中引入Cassandra
     *  封装Cassandra的通用类
     *  具体使用
     *  实现通用接口
     *  具体查询逻辑(最重要)
     *  使用

## 在application.yml中配置cassandra ##

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

## pom中引入Cassandra ##

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

## 封装Cassandra的通用类 ##

![在这里插入图片描述][20200628091138709.png]

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);
        }
    
    
    }

## 使用 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1_size_16_color_FFFFFF_t_70]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1_size_16_color_FFFFFF_t_70 1]

--------------------

完

[20200628091138709.png]: https://img-blog.csdnimg.cn/20200628091138709.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20200628092445290.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20200628092504797.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JhaWR1XzIxMzQ5NjM1,size_16,color_FFFFFF,t_70