草庐IT

data_stream

全部标签

java - 为什么 Spring Data 存储库方法参数名称在 Java 8 上也不可用?

我很难让spring-boot1.4版本的Pivotal示例项目通过测试fromtheirexamples它显示spring-data-jpa在其JPQL中使用unannotated命名参数例如fromexample.springdata.jpa.simple.SimpleUserRepository@Query("selectufromUseruwhereu.firstname=:firstname")ListfindByFirstname(Stringfirstname);注意它没有使用@Param注解这不能在我的机器上运行。我在这里详细了解了异常,从标题中可以不言自明。Namef

java.util.stream.Collectors : Why is the summingInt implemented with an array?

标准收集器summingInt在内部创建一个长度为1的数组:publicstaticCollectorsummingInt(ToIntFunctionmapper){returnnewCollectorImpl(()->newint[1],(a,t)->{a[0]+=mapper.applyAsInt(t);},(a,b)->{a[0]+=b[0];returna;},a->a[0],CH_NOID);}我想知道是否可以只定义:privateCollectorsummingInt(ToIntFunctionmapper){returnCollector.of(()->0,(a,t)->

java - FlyingSaucer renderer.setDocument 抛出 "Stream closed"异常

我在使用找到的简单示例创建PDF时遇到问题here.这是我第一次尝试使用它,我尝试了一些东西并进行了大量搜索,但没有找到产生错误的原因。错误源自renderer.setDocument(url);行。如果有人有任何想法、建议或替代方案,我们将不胜感激。packageflyingsaucerpdf;importjava.io.*;importcom.lowagie.text.DocumentException;importorg.xhtmlrenderer.pdf.ITextRenderer;publicclassFirstDoc{publicstaticvoidmain(String[

java - 如何使用java Stream检查集合是否为空

我是Java8的新手。我无法理解以下代码中的错误。思路是发Collection如果它不是空的。但是如果集合是空的而不是发送HttpStatus.NOT_FOUND实体响应。@RequestMapping(value="/find/pks",method=RequestMethod.GET,produces=MediaType.APPLICATION_JSON_VALUE)publicResponseEntity>getUsers(@RequestBodyfinalCollectionpks){returnStreamSupport.stream(userRepository.findA

java - 从 'stream()' 或 'parallelStream()' 中捕获异常会丢失正确的值

在下面的代码中,当从for迭代中捕获NumberFormatException时,适当形式的字符串出现在strList中第一个坏字符串之前(即"illegal_3")已成功解析(即"1"和"2"已解析为整数1和2)。publicvoidtestCaughtRuntimeExceptionOutOfIteration(){ListstrList=Stream.of("1","2","illegal_3","4","illegal_5","6").collect(Collectors.toList());ListintList=newArrayList();try{for(Stringst

java - Linq C# 中 Java 的 Stream#Peek 方法的等价物是什么?

我已经习惯使用Java的Stream#Peek方法,因为它是调试中间流操作的有用方法。对于那些不熟悉Stream#Peek的人方法,下面显示了它的定义:Streampeek(Consumeraction)Returnsastreamconsistingoftheelementsofthisstream,additionallyperformingtheprovidedactiononeachelementaselementsareconsumedfromtheresultingstream.Thisisanintermediateoperation.考虑下面这个简单的例子:Listin

java - Stream reduce() 要求到底包含什么?

在并行流上使用reduce()操作时,theOCPexambook说明reduce()参数必须遵守某些原则。这些原则如下:Theidentitymustbedefinedsuchthatforallelementsinthestreamu,combiner.apply(identity,u)isequaltou.Theaccumulatoroperatoropmustbeassociativeandstatelesssuchthat(aopb)opcisequaltoaop(bopc).Thecombineroperatormustalsobeassociativeandstatele

java - 如何使用 QueryDSL 在 Spring Data JPA 中使用 order by 和 Limit

我在我的项目中使用带有RDBMS的SpringDataJPA。我有一个要求,我必须从具有最新日期的表中的数据库中获取一条记录。为此,我需要使用限制和按功能排序或使用子查询。但是,我想知道我是否希望不使用NamedQuery,有没有一种方法可以使用SpringDataJPA和QueryDSL实现这一点。 最佳答案 难道QueryDslPredicateExecutor.findAll(Predicatepredicate,Pageablepageable)不应该为您解决问题吗?您可以提交一个newPageRequest(0,limit

java - Spring Data MongoDB 索引(唯一=真)

我在使用SpringData时遇到了很多问题和MongoDB当涉及到索引字段时。我已经查看了文档,但他们不太擅长解释@Indexed(unique=true)之间的区别。和@Indexed(unique=false).我有一个我想要索引的字段,以便我可以对其执行快速查询。在这种情况下,电子邮件地址通常应该是唯一的,但emailAddress有可能在一段时间内为空。但是,一旦一个记录为空emailAddress,我就不能再有任何其他记录具有空emailAddress。SpringData拒绝使用null插入任何附加记录电子邮件地址。它无法抛出任何它不起作用的东西。现在我将它设置为uniq

java - MongoDB : Sorting Data when using DBcollection find

我想借助基于lastUpdated字段的排序返回查找查询的结果。目前我看到了两种方式第一种方法BasicDBObjectquery=newBasicDBObject();query.put("updated_at","-1");query.put(MONGO_ATTR_SYMBOL,""+symbol);DBCursorcursor=DBcollection.find(query).sort(query);第二种方法DBCursorcursor=DBcollection.find(query,newBasicDBObject("sort",newBasicDBObject("lastU