扬州住房和建设局网站,wordpress自适应杂志幻灯,承装承修承试材料在哪个网站做,wordpress安装phpJava Stream使用这段时间在学数据库和Java#xff0c;发现Java的Stream实际上和数据库的查询操作非常类似。这里简单介绍Stream的用法#xff0c;并和Sql Server中的操作联系起来。此文为初学Stream所写#xff0c;以后对Stream有更深的理解后会重写当我们使用一个流的时候发现Java的Stream实际上和数据库的查询操作非常类似。这里简单介绍Stream的用法并和Sql Server中的操作联系起来。此文为初学Stream所写以后对Stream有更深的理解后会重写当我们使用一个流的时候通常包括三个基本步骤获取一个数据源(source)数据转换执行操作获取想要的结果每次转换原有 Stream 对象不改变返回一个新的 Stream 对象(可以有多次转换)这就允许对其操作可以像链条一样排列变成一个管道如下图所示。一、创建 stream有多种方式生成 Stream Source从 Collection 和数组Collection.stream()Collection.parallelStream()Arrays.stream(T array) or Stream.of()从 BufferedReaderjava.io.BufferedReader.lines()静态工厂java.util.stream.IntStream.range()java.nio.file.Files.walk()自己构建java.util.Spliterator其它Random.ints()BitSet.stream()Pattern.splitAsStream(java.lang.CharSequence)JarFile.stream()创建Stream示例// 1. Individual valuesStream stream Stream.of(a, b, c);// 2. ArraysString [] strArray new String[] {a, b, c};stream Stream.of(strArray);stream Arrays.stream(strArray);// 3. CollectionsList list Arrays.asList(strArray);stream list.stream();二、stream 操作stream的操作分为两大类一类为中间操作一类为终端操作。中间操作:返回值仍然为一个流不会消耗流终端操作:返回最终结果终端操作会消耗掉流使之不再可用1.stream.filter()stream.filter() 是一个中间操作stream.filter()用于对stream进行某种筛选stream.filter() 相当于Sql server 中from ... where ...在filter()中应当给出筛选条件准确的说应该实现Predicate接口这个接口将被应用于stream中的每一个元素判断其是否应该被包含在结果stream中。这个接口只有一个抽象方法待用户实现抽象方法应该返回一个布尔值当布尔值为真时stream.filter()将这个元素包含在结果stream中stream.filter()使用示例:创建Integer流然后筛选出偶数ArrayList arrlist new ArrayList();Stream st arrlist.stream();Stream st2 st.filter(new Predicate() {Overridepublic boolean test(Integer arg0) {return arg0 % 2 0;}});还可以用lambda表达式来实现ArrayList arrlist new ArrayList();Stream st arrlist.stream();Stream st2 st.filter((o1)-(o1 % 2 0));关于Predicate接口它还有.and(),.or(),.negate(),.isEqual()四个默认方法这里不多介绍。但这些方法也十分常用对于稍微复杂一点的逻辑就需要使用。使用Precicate接口需要导入import java.util.function.Predicate;2.stream.map()stream.map()是一个中间操作stream.map()用于对stream进行某种映射stream.map() 相当于Sql server 中select虽然这么说不太恰当因为Sql sever 的select实际上时 SQL语言中 \(\sigma , \prod\)的加和而stream.map() 应该是\(\prod\).在stream.map()中应该指定转换条件准确的说应该实现一个Function()接口,这个接口将被用于stream的每一个元素将元素按照一定的映射关系映射成新的元素。Function接口的参数意义使用Function接口需要导入import java.util.function.Function;这个接口只有一个抽象方法待用户实现抽象方法apply() 接受一个T类型的参数返回一个R类型的结果stream.map()使用示例:创建Integer流然后映射到其原值的两倍ArrayList arrlist new ArrayList();for(int i 1; i 5; i) {arrlist.add(i);}Stream st arrlist.stream();Stream st2 st.map(new Function() {Overridepublic Integer apply(Integer arg0) {return arg0 * 2;}});ArrayList ans new ArrayList();ans (ArrayList) st2.collect(Collectors.toList());for(Integer i : ans) {System.out.print(i );}还可以用lambda表达式来实现// 初学可以先不这么写ArrayList ans (ArrayList)arrlist.stream().map((o1)-(2*o1)).collect(Collectors.toList());stream.map() 的几种其他形式IntStream mapToInt(ToIntFunction super T mapper);LongStream mapToLong(ToLongFunction super T mapper);DoubleStream mapToDouble(ToDoubleFunction super T mapper);这三者实际上是对\(Function\) 中 R的固定封装3.stream.flatMap()stream.flatMap()是一个中间操作stream.flatMap()和stream.map()都是进行映射的方法区别在于flatMap()处理的元素类型仍是流flagMap用于将若干个流先拆分成若干个单个元素再整合成一个流即流的合并。简单来说flatMap()将集合的集合降维成单个元素的集合实例: 将数组\([[1,2,3],[4,5,6],[7,8],[9]]\)转化为[1,2,3,4,5,6,7,8,9]ArrayList list_2 new ArrayList();list_2.add(new ArrayList(Arrays.asList(1,2,3)));list_2.add(new ArrayList(Arrays.asList(4,5,6)));list_2.add(new ArrayList(Arrays.asList(7,8)));list_2.add(new ArrayList(Arrays.asList(9)));ArrayList list_1 (ArrayList) list_2.stream()// list_2.stream() 为 [1,2,3] [4,5,6] [7,8] [9] 每个表示流的不同元素.flatMap((o1)-(o1).stream())// 以 o1 [1,2,3]为例,(o1)-(o1).stream() 转化为1,2,3.collect(Collectors.toList());for(Integer i : list_1) {System.out.print(i );}stream.flagMap()的几种其他形式IntStream flatMapToInt(Function super T, ? extends IntStream mapper);LongStream flatMapToLong(Function super T, ? extends LongStream mapper);DoubleStream flatMapToDouble(Function super T, ? extends DoubleStream mapper);这三者实际上是对\(Function\) 中 R的固定封装4.stream.allMatch() ,stream.anyMatch() 和 stream.noneMatch()stream.allMatch() 和 stream.anyMatch()均为终端操作传入一个Predicate函数式接口用于指定条件5.stream.collect()stream.collect()为终端操作Stream的核心在于collect即对数据的收集。用法一将流转化为Collection或MapCollectors.toCollection() 将数据转换成Collection,只要是Collection的实现都可以例如ArrayListHashSet该方法能够接受一个Collection对象示例//ListStream.of(1,2,3,4,5,6,7,8,9).collect(Collectors.toCollection(ArrayList::new));//SetStream.of(1,2,3,4,5,6,7,8,9).collect(Collectors.toCollection(HashSet::new));// Stream.of(1,2,3,4,5,6,7,8,9).collect(Collectors.toList());// Stream.of(1,2,3,4,5,6,7,8,9).collect(Collectors.toSet());// Stream.of(1,2,3,4,5,6,7,8,9).collect(Collectors.toMap(key,value));用法二字符串聚合规约Collectors.joining()拼接有三个重载方法底层实现是StringBuilder通过append方法拼接到一起并且可以自定义分隔符(这个感觉还是很有用的很多时候需要把一个list转成一个String指定分隔符就可以实现了非常方便)、前缀、后缀。Student studentA new Student(20190001, 小明);Student studentB new Student(20190002, 小红);Student studentC new Student(20190003, 小丁);//使用分隔符201900012019000220190003Stream.of(studentA, studentB, studentC).map(Student::getId).collect(Collectors.joining());//使用^_^ 作为分隔符//20190001^_^20190002^_^20190003Stream.of(studentA, studentB, studentC).map(Student::getId).collect(Collectors.joining(^_^));//使用^_^ 作为分隔符//[]作为前后缀//[20190001^_^20190002^_^20190003]Stream.of(studentA, studentB, studentC).map(Student::getId).collect(Collectors.joining(^_^, [, ]));用法三统计个数Collectors.counting() 统计元素个数这个和Stream.count() 作用都是一样的返回的类型一个是包装Long另一个是基本long但是他们的使用场景还是有区别的这个后面再提。// Long 8Stream.of(1,0,-10,9,8,100,200,-80).collect(Collectors.counting());//如果仅仅只是为了统计那就没必要使用Collectors了那样更消耗资源// long 8Stream.of(1,0,-10,9,8,100,200,-80).count();用法四集合分组Collectos.groupingBy()实现集合分组返回值为一个Map假如现在有一个实体Studentpublic class Student {private String name;private int score;private int age;public Student(String name,int score,int age){this.name name;this.score score;this.age age;}public String getName() {return name;}public void setName(String name) {this.name name;}public int getScore() {return score;}public void setScore(int score) {this.score score;}public int getAge() {return age;}public void setAge(int age) {this.age age;}}现在对其按照Name分组Map StrListStrMap students.stream().collect(Collectors.groupingBy(Student::getName));6.stream.forEach() 和stream.forEach() 终端操作stream.forEach()遍历流中的每一个元素不一定依靠流的顺序,而stream.forEachOrdered()按照流的顺序遍历。Stream.of(1,2,3,4,5,6).forEach(System.out::println);7.stream.max() , stream.min() , stream.count()三个终端操作stream.max()返回流中的最大值stream.min()返回流中的最小值未传入Comparator则填null默认用Comparable的compareTo函数比较。stream.count()返回流中元素个数8.stream.findAny()返回流中任意一个元素如果流为空返回一个空的Optional.List list Arrays.asList(1, 2, 3, 4, 5, 6);Optional any list.stream().findAny();