Page findByTopicStatsId()

in src/main/java/org/apache/pulsar/manager/mapper/ConsumerStatsMapper.java [40:69]
27 lines of code
1 McCabe index (conditional complexity)

    Page<ConsumerStatsEntity> findByTopicStatsId(@Param("topicStatsId") long topicStatsId,
                                                 @Param("timestamp") long timestamp);

    @Select("SELECT consumer_stats_id as consumerStatsId,consumer as consumer,topic_stats_id as topicStatsId," +
            "replication_stats_id as replicationStatsId,subscription_stats_id as subscriptionStatsId,address as address," +
            "available_permits as availablePermits,connected_since as connectedSince,msg_rate_out as msgRateOut," +
            "msg_throughput_out as msgThroughputOut,msg_rate_redeliver as msgRateRedeliver," +
            "client_version as clientVersion,time_stamp ,metadata as metadata FROM consumers_stats " +
            "where subscription_stats_id=#{subscriptionStatsId} and time_stamp=#{timestamp}")
    Page<ConsumerStatsEntity> findBySubscriptionStatsId(@Param("subscriptionStatsId") long subscriptionStatsId,
                                                        @Param("timestamp") long timestamp);

    @Select("SELECT consumer_stats_id as consumerStatsId,consumer as consumer,topic_stats_id as topicStatsId," +
            "replication_stats_id as replicationStatsId,subscription_stats_id as subscriptionStatsId,address as address," +
            "available_permits as availablePermits,connected_since as connectedSince,msg_rate_out as msgRateOut," +
            "msg_throughput_out as msgThroughputOut,msg_rate_redeliver as msgRateRedeliver," +
            "client_version as clientVersion,time_stamp ,metadata as metadata FROM consumers_stats " +
            "where replication_stats_id=#{replicationStatsId} and time_stamp=#{timestamp}")
    Page<ConsumerStatsEntity> findByReplicationStatsId(@Param("replicationStatsId") long replicationStatsId,
                                                       @Param("timestamp") long timestamp);

    @Select({"<script>",
            "SELECT consumer_stats_id as consumerStatsId,consumer as consumer,topic_stats_id as topicStatsId," +
                    "replication_stats_id as replicationStatsId,subscription_stats_id as subscriptionStatsId,address as address," +
                    "available_permits as availablePermits,connected_since as connectedSince,msg_rate_out as msgRateOut," +
                    "msg_throughput_out as msgThroughputOut,msg_rate_redeliver as msgRateRedeliver," +
                    "client_version as clientVersion,time_stamp ,metadata as metadata FROM consumers_stats " +
            "where time_stamp=#{timestamp} and " +
                    "topic_stats_id IN <foreach collection='topicStatsIdList' item='topicStatsId' open='(' separator=',' close=')'> #{topicStatsId} </foreach>" +
                    "</script>"})