@Test void selectRowCountShouldReturnEmptyByDefault() { Optional<Integer> maybeRowCount = testee.selectRowCount(BLOB_ID).blockOptional(); assertThat(maybeRowCount).isEmpty(); }
Mono<Integer> selectRowCount(BlobId blobId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setString(ID, blobId.asString())) .map(row -> row.getInt(NUMBER_OF_CHUNK)); }
CassandraDefaultBucketDAO { Mono<Integer> selectRowCount(BlobId blobId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setString(ID, blobId.asString())) .map(row -> row.getInt(NUMBER_OF_CHUNK)); } }
CassandraDefaultBucketDAO { Mono<Integer> selectRowCount(BlobId blobId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setString(ID, blobId.asString())) .map(row -> row.getInt(NUMBER_OF_CHUNK)); } @Inject @VisibleForTesting  CassandraDefaultBucketDAO(Session session); }
CassandraDefaultBucketDAO { Mono<Integer> selectRowCount(BlobId blobId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setString(ID, blobId.asString())) .map(row -> row.getInt(NUMBER_OF_CHUNK)); } @Inject @VisibleForTesting  CassandraDefaultBucketDAO(Session session);  }
CassandraDefaultBucketDAO { Mono<Integer> selectRowCount(BlobId blobId) { return cassandraAsyncExecutor.executeSingleRow( select.bind() .setString(ID, blobId.asString())) .map(row -> row.getInt(NUMBER_OF_CHUNK)); } @Inject @VisibleForTesting  CassandraDefaultBucketDAO(Session session);   }