Cassandra映射器没有映射到类

Question

我正在构建一个REST API,我有访问器,

    @Accessor
public interface ActiveBidAccessor {
    @Query("SELECT * FROM keyspace.active_bid WHERE username = :username")
    public Result<ActiveBid> getAllByUsersname(@Param("username") String username);


    @Query("SELECT * FROM keyspace.active_bid")
    public Result<ActiveBid> getAll();
}

和ActiveBid类

@Table(keyspace = "keyspace", name = "active_bid", readConsistency = "QUORUM", writeConsistency = "QUORUM", caseSensitiveKeyspace = false, caseSensitiveTable = false)
public class ActiveBid {
    @PartitionKey
    UUID uid;
    @ClusteringColumn
    @Column(name = "username")
    String username;
    @Column(name = "project_name")
    String projectName;
    @Column(name = "project_link")
    String projectLink;
    @Column(name = "total_bid")
    int totalBid;
    @Column(name = "user_bid")
    long userBid;
    @Column(name = "avg_bid")
    long avgBid;
    @Column(name = "end_date")
    Date endDate;

    public ActiveBid(UUID uid, String username, String projectName, String projectLink, int totalBid, long userBid,
            long avgBid, Date endDate) {
        super();
        this.uid = uid;
        this.username = username;
        this.projectName = projectName;
        this.projectLink = projectLink;
        this.totalBid = totalBid;
        this.userBid = userBid;
        this.avgBid = avgBid;
        this.endDate = endDate;
    }

    public UUID getUid() {
        return uid;
    }

    public void setUid(UUID uid) {
        this.uid = uid;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getProjectName() {
        return projectName;
    }

    public void setProjectName(String projectName) {
        this.projectName = projectName;
    }

    public String getProjectLink() {
        return projectLink;
    }

    public void setProjectLink(String projectLink) {
        this.projectLink = projectLink;
    }

    public int getTotalBid() {
        return totalBid;
    }

    public void setTotalBid(int totalBid) {
        this.totalBid = totalBid;
    }

    public long getUserBid() {
        return userBid;
    }

    public void setUserBid(long userBid) {
        this.userBid = userBid;
    }

    public long getAvgBid() {
        return avgBid;
    }

    public void setAvgBid(long avgBid) {
        this.avgBid = avgBid;
    }

    public Date getEndDate() {
        return endDate;
    }

    public void setEndDate(Date endDate) {
        this.endDate = endDate;
    }

    @Override
    public int hashCode() {
        return Objects.hashCode(uid, username, projectName, projectLink, totalBid, userBid, avgBid, endDate);
    }

    @Override
    public boolean equals(Object obj) {
        if (obj instanceof ActiveBid) {
            ActiveBid that = (ActiveBid) obj;
            return Objects.equal(this.uid, that.uid) && Objects.equal(this.username, that.username)
                    && Objects.equal(this.projectName, that.projectName)
                    && Objects.equal(this.projectLink, that.projectLink) && Objects.equal(this.totalBid, that.totalBid)
                    && Objects.equal(this.userBid, that.userBid) && Objects.equal(this.avgBid, that.avgBid)
                    && Objects.equal(this.endDate, that.endDate);
        }
        return false;
    }

和我的球衣请求映射器以及获取数据的逻辑

@GET
@Path("/get")
@Produces(MediaType.APPLICATION_JSON)
public List<ActiveBid> getTrackInJSON() {
    logger.info("LoginApi: Returning the active bid");
    List<ActiveBid> activeBidList = new ArrayList<ActiveBid>();

    MappingManager manager = new MappingManager(cassDB.getSession());
    ActiveBidAccessor activeBidAccessor = manager.createAccessor(ActiveBidAccessor.class);
    Result<ActiveBid> activeBidResult = activeBidAccessor.getAllByUsersname("zakir");
    for(ActiveBid bid:activeBidResult){
        activeBidList.add(bid);
    }

    return activeBidList;
}

我收到以下错误

引发者:java.lang.RuntimeException:无法在com.datastax.driver.mapping的com.datastax.driver.mapping.ReflectionMapper.newEntity(ReflectionMapper.java:47)中创建com.xyz.v1.ActiveBid的实例. .result.map(Result.java:40)at com.datastax.driver.mapping.Result.one(Result.java:87)at com.datastax.driver.mapping.Mapper $ 1.apply(Mapper.java:82) at com.datastax.driver.mapping.Mapper $ 1.apply(Mapper.java:79)com.google.com上的com.google.common.util.concurrent.Futures $ 1.apply(Futures.java:713) .concurrent.Futures $ ChainingListenableFuture.run(Futures.java:861)在com.google.common.util.concurrent.MoreExecutors $ SameThreadExecutorService.execute(MoreExecutors.java:297)在com.google.common.util.concurrent.ExecutionList .executeListener(ExecutionList.java:156)com.google.common.util.concurrent.ExecutionList.exe(ExecutionList.java:145)com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:185) )在com.google.common.util.concurrent.Futures $ ChainingListenab com.google.common.util.util.concurrent.ExecutionList.executeListener(ExecutionList)中的com.google.common.util.concurrent.MoreExecutors $ SameThreadExecutorService.execute(MoreExecutors.java:297)上的leFuture $ 1.run(Futures.java:872) .java:156)com.com的com.google.common.util.concurrent.ExecutionList.execute(ExecutionList.java:145)com.google.common.util.concurrent.AbstractFuture.set(AbstractFuture.java:185). datastax.driver.core.DefaultResultSetFuture.onSet(DefaultResultSetFuture.java:174)在com.datastax.driver.core.RequestHandler.setFinalResult(RequestHandler.java:177)在com.datastax.driver.core.RequestHandler.access $ 2500(RequestHandler的.java:43)在com.datastax.driver.core.RequestHandler $ SpeculativeExecution.setFinalResult(RequestHandler.java:792)在com.datastax.driver.core.RequestHandler $ SpeculativeExecution.onSet(RequestHandler.java:467)在COM.在com.datastax.driver.core.Connection $ Dispatcher.channelRead0(Conn)上的datastax.driver.core.Connection $ Dispatcher.channelRead0(Connection.java:1013)ection.java:936)在io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)在io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)在io.netty.channel.AbstractChannelHandlerContext.fireChannelRead (AbstractChannelHandlerContext.java:304)在io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:266)在io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)在io.netty.channel. io.netty上的io.netty.channel.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:103)中的io.netty的io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)中的AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java :) .channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:304)at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:276)at io.netty.channel.odenel.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:263)at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:318)at io.netty.channel.AbstractChannelHandlerContext .fireChannelRead(AbstractChannelHandlerContext.java:304)在io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)在io.netty.channel.nio.AbstractNioByteChannel $ NioByteUnsafe.read(AbstractNioByteChannel.java:131)的IO. io.netty.channel.nio.NoEventLoop.processSelectedKeys(NioEventLoop. Java的:382)在io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)在io.netty.util.concurrent.SingleThreadEventExecutor $ 2.run(SingleThreadEventExecutor.java:112)... 1更多

有人可以帮我这个,我不知道Cassandra会难以合作.

Answer 1

司机不善于报告异常原因.该堆栈跟踪指向该

@Override
public T newEntity() {
    try {
        return entityClass.newInstance();
    } catch (Exception e) {
        throw new RuntimeException("Can't create an instance of " + entityClass.getName());
    }
}

不幸的是吞下了这个例外.

同样,读取该代码,似乎发生异常,因为您的实体类中没有可访问的无参数构造函数.

只需添加一个

public ActiveBid() {}

这里的文档没有明确说明,但是他们的所有示例都使用了这样的构造函数.