Java嵌入SPL轻松实现数据分组

要在Java代码中实现类似SQL中的GroupBy分组聚合运算,是比较繁琐的,通常先要声明数据结构(Java实体类),然后用Java集合进行循环遍历,最后根据分组条件添加到某个子集合中8 . Java有了λ(流)代码简洁了许多,分组后往往还要跟着聚合操作,仍然需要单写聚合函数总和(),count (*), topN()等。这些还都是最常规的分组和聚合运算,遇到对位分组,枚举分组,多重分组等非常规分组加上其他聚集函数(姓,…),代码就变得非常冗长且不通用。如果能有一个中间件专门负责这类计算,采用类似SQL脚本做算法描述,在Java中直接调用脚本并返回结果集就好了. Java版集算器和SPL脚本,就是这样的机制,下面举例说明如何使用。

SPL实现

<李>

常规分组

职责。xlsx文件中保存着每个人的加班记录:

<强>工作日

<>强名称

2016-02-05

阿什利

2016-02-08

阿什利

2016-02-09

阿什利

2016-02-10

约翰逊约翰逊2016-02-11

约翰逊2016-02-12

2016-02-15

阿什利

2016-02-16

阿什利

2016-02-17

阿什利


汇总每个人的值班天数:

=1文件(“/用户/测试/duty.xlsx") .importxls@tx ()

=2 A1.groups(名称;计数(名称):计数)

癑ava嵌入SPL轻松实现数据分组"

保存脚本文件<强> CountName。dfx (嵌入Java会用到)

<李>

每组TopN

取每个月,每个人,头三天的加班记录

=1文件(“/用户/测试/duty.xlsx") .importxls@tx ()

=2 A1.group(月(工作日):妈,名称;直~上(3):超越)

癑ava嵌入SPL轻松实现数据分组"

保存脚本文件<强> RecMonTop3。dfx (嵌入Java会用到)

Java调用

SPL嵌入到Java应用程序十分方便,通过JDBC调用存储过程方法加载,用常规分组保存的文件<强> CountName.dfx 强,示例调用如下:

<>之前…,,Connection  con =,零;,,forname (“com.esproc.jdbc.InternalDriver");,,=,监狱DriverManager.getConnection (“JDBC: esproc:当地://?,,//调用存储过程,其中CountName是dfx的文件名,,st =(com只esproc.jdbc.InternalCStatement) con.prepareCall (“call  CountName()“);,,//执行存储过程,,st.execute();,,//获取结果集,,ResultSet  rs =, st.getResultSet ();,……,, Connection  con =,零;,,forname (“com.esproc.jdbc.InternalDriver");,,=,监狱DriverManager.getConnection (“JDBC: esproc:当地://?,,//调用存储过程,其中CountName是dfx的文件名,,st =(com只esproc.jdbc.InternalCStatement) con.prepareCall (“call  CountName()“);,,//执行存储过程,,st.execute();,,//获取结果集,,ResultSet  rs =, st.getResultSet ();,…

,

替换成RecMonTop3。dfx是同样的道理,只需调用RecMonTop3()即可,也可同时返回两个结果集。这里只用Java片段粗略解释了如何嵌入SPL,详细步骤请参阅Java如何调用SPL脚本,也非常简单,不再赘述。同时,SPL也支持ODBC驱动,集成到支持ODBC的语言,嵌入过程类似。

拓展节选

之前没有相关的总结,其实关于数据分组,细分起来其实还有很多种,对位分组,枚举分组,多重分组…,在乾学院SPL官方论坛都有总结和示例,这里节选其中两种。

<李>

SPL对位分组

<强>示例1 :按顺序分别列出使用汉语、英语、法语作为官方语言的国家数量

 MySQL8:, with  t(名称、奥德),as  (select  & # 39;中国# 39;,1,union  all  select  & # 39;英语# 39;,2,union  all  select  & # 39;法国# 39;(3),select  t.name,,计数(countrycode), cnt 得到t  left  join  world.countrylanguage  s 提醒t.name=s.language  where  s.isofficial=& # 39; t # 39;, group  by 名字,ord  order  by 奥德;MySQL8:, with  t(名称、奥德),as  (select  & # 39;中国# 39;,1,union  all  select  & # 39;英语# 39;,2,union  all  select  & # 39;法国# 39;(3),select  t.name,,计数(countrycode), cnt 得到t  left  join  world.countrylanguage  s 提醒t.name=s.language  where  s.isofficial=& # 39; t # 39;, group  by 名字,ord  order  by 奥德;
Java嵌入SPL轻松实现数据分组