Apache Calcite - 使用内置函数

前言

在上一篇文章中学习了如何适配来源数据,并使用sql查询数据。当我们获取数据后,通常还会进行各种计算、变换工作,这时使用内置函数可以极大提高我们的效率。

函数介绍

Apache Calcite 提供了广泛的 SQL 函数支持,包括但不限于标准的 SQL 函数(如聚合函数、数学函数、字符串函数等)以及一些 Calcite 特有的扩展函数。这些函数可以在 SQL 查询中使用,以执行复杂的数据处理和分析任务。详细的介绍可以参考[1]。

下面是对参考手册中函数的分类介绍

  • 聚合函数:如 COUNT, SUM, AVG, MIN, MAX 等。
  • 数学函数:如 ABS, EXP, LOG, POWER, SQRT, SIN, COS 等。
  • 字符串函数:如 CONCAT, LENGTH, UPPER, LOWER, TRIM, SUBSTRING 等。
  • 日期和时间函数:如 CURRENT_DATE, CURRENT_TIME 等。
  • 转换函数:如 CAST, COALESCE, NULLIF, CASE 等。
  • 系统函数:如 USER, CURRENT_USER, SESSION_USER, SYSTEM_USER 等。
  • 窗口函数:如 ROW_NUMBER, RANK, DENSE_RANK, LEAD, LAG 等。

在代码中使用函数

我们可以直接在sql中使用这些函数,首先我们对上一篇文章中的代码进行一点小改动。

Linq4j

在进行改动前首先我们介绍一下Linq4j。Apache Calcite 的 Linq4j(Language-Integrated Query for Java)是一个提供类似于.NET LINQ(Language Integrated Query)的查询功能的库,专为Java语言设计。Linq4j 允许开发者使用Java来编写类似于SQL的查询语句,从而对Java集合、数组等进行查询操作。

Linq4j 是一个查询库,它提供了一组扩展的Java集合接口和迭代器接口,使得开发者可以在Java应用程序中使用声明式的方式来处理数据。它支持多种操作,包括筛选(filter)、映射(map)、聚合(aggregate)等,类似于SQL语言的操作。

我们使用Linq4j类提供的工具方法来将我们的来源数据列表转换为Enumerable对象,这样在查询Sql中可以使用相关的函数。

下面是一个使用案例,我们首先将用户列表转换为Enumerable类型,然后使用where方法来筛选年龄大于30的用户,接着使用orderBy方法按姓名排序,最后将结果转换为列表并打印。

这样的处理方式使得数据操作更加直观和易于理解,类似于我们在SQL中进行查询操作。

import org.apache.calcite.linq4j.Enumerable;
import org.apache.calcite.linq4j.Linq4j;List<User> users = Arrays.asList(new User("Alice", 28),new User("Bob", 35),new User("Charlie", 32)
);Enumerable<User> enumerable = Linq4j.asEnumerable(users);
List<User> filteredSortedUsers = enumerable.where(user -> user.getAge() > 30).orderBy(user -> user.getName()).toList();filteredSortedUsers.forEach(user -> System.out.println(user.getName() + " - " + user.getAge()));

改造代码

我们使用linq4j改造来源集合的创建,重新实现scan方法,这样可以在sql中使用相关的函数。

    public class TableForList extends AbstractTable implements ScannableTable{private PersonList personList;public TableForList(PersonList personList) {this.personList = personList;}@Overridepublic Enumerable<Object[]> scan(DataContext root) {return Linq4j.asEnumerable(personList.getPersonList()).select(emp -> new Object[]{emp.getId(), emp.getName(), emp.getAge()});}@Overridepublic RelDataType getRowType(RelDataTypeFactory typeFactory) {return typeFactory.builder().add("id", typeFactory.createSqlType(SqlTypeName.BIGINT)).add("name",typeFactory.createSqlType(SqlTypeName.VARCHAR)).add("age",typeFactory.createSqlType(SqlTypeName.INTEGER)).build();}}

sql中使用函数

我们对上一篇文章中的Sql做出调整,使用各类函数。

        // 聚合函数ResultSet countResult = statement.executeQuery("select sum(age) from listSchema.MyTable");print(countResult);// 数学函数ResultSet sqrtResult = statement.executeQuery("select sqrt(sum(age)) from listSchema.MyTable");print(sqrtResult);// 字符串函数ResultSet lowerResult = statement.executeQuery("select lower('ABC'),sum(age) from listSchema.MyTable");print(lowerResult);// 日期函数ResultSet timeResult = statement.executeQuery("select current_time,sum(age) from listSchema.MyTable");print(timeResult);// 输出结果
242 
15.556349186104045 
abc 242 
20:14:51 242 

总结

Calcite提供了多种内置函数,使用这些函数可以简化我们的开发工作,提升效率

参考

[1]Calcite内置支持的函数清单,https://calcite.apache.org/docs/reference.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/20744.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

基础—SQL—DCL(数据控制语言)小结

一、总结 在SQL分类中的DCL语句部分&#xff0c;主要讲到了两个部分的知识。 1、用户管理 用户管理&#xff0c;主要是管理哪些用户可以访问当前 mysql 数据库。 包括&#xff1a;创建用户、修改用户密码以及删除用户 2、权限控制 权限管理&#xff0c;主要是控制我们当前用户…

vue前端Echars

<template><div :class"className" :style"{height:height,width:width}" /> </template><script> import * as echarts from echarts require(echarts/theme/macarons) // echarts theme 柱状图 import resize from ./mixins/re…

代码随想录算法训练营Day24|216.组合总和III、17.电话号码的字母组合

组合总和III 216. 组合总和 III - 力扣&#xff08;LeetCode&#xff09; 思路和昨日的组合题类似&#xff0c;但注意对回溯算法中&#xff0c;收获时的条件需要写对&#xff0c;path的长度要为k的同时&#xff0c;path中元素总和要为n。 class Solution { public:vector<…

禁用USB端口的办法,哪一种禁用USB端口的方法好

禁用USB端口的办法&#xff0c;哪一种禁用USB端口的方法好 禁用USB端口是保护公司数据安全的一种常见做法&#xff0c;旨在防止未经授权的数据传输和潜在的恶意软件传播。以下是几种常见的禁用USB端口方法及其效果评价。 1、硬件方法&#xff1a; BIOS设置&#xff1a;通过BIO…

混合动力电动汽车介绍(一)

电动汽车发展的技术背景主要包含环境问题和能源问题两大方面。环境问题的表现形式为空气污染&#xff0c;而能源问题的表现形式为现有能源供应体系对化石燃料的过分依赖。《新能源汽车产业发展规划&#xff08;2021-2035&#xff09;》中明确我国新能源汽车技术研发的“三纵”、…

探索Python机器学习:从基础到实践

探索Python机器学习&#xff1a;从基础到实践 本文将带您从机器学习的基础知识出发&#xff0c;逐步深入到实际应用&#xff0c;帮助您掌握Python机器学习的核心技能。 一、机器学习概述 1. 什么是机器学习&#xff1f; 机器学习是一种通过分析数据来自动发现模式并做出预测…

软件架构设计属性之5:可维护性属性分析与应用

文章目录 引言一、可维护性定义和重要性1.1 定义1.2 重要性 二、可维护性关键要素2.1 模块化2.2 单一职责2.3 低耦合2.4 高内聚2.5 抽象和封装2.6 实践建议 三、设计原则3.1 开闭原则3.2 依赖倒置原则3.3 评估方法3.4 挑战与解决方案 四、实战应用总结 引言 在当今数字化飞速发…

Java学习路径图

1.学习路径 JAVA架构师学习路径 2.路径拆解 2.1 Spring 2.1.1 SpringBoot原理 SpringBoot2学习视频 SpringBoot2笔记 SpringBoo2代码 2.2.2 SpringBoot项目 《谷粒商城》学习视频

Implicit-SDF-Planner代码详解(2)

Implicit-SDF-Planner代码详解&#xff08;2&#xff09; 第三部分:轨迹优化 在获得了一条初始路径后,下一步就是在此基础上生成一条光滑、安全、动力学可行的轨迹,这就是轨迹优化要解决的问题。 让我们回到plan_manager.cpp,看看PlannerManager的generateTraj函数: void P…

IPv6在军事中的价值

计算机网络作为信息传输的主要通道&#xff0c;将在未来战场上发挥主导作用。当前的网络是基于IPv4协议构建的&#xff0c;然而&#xff0c;IPv4面临着一系列问题&#xff0c;如地址枯竭、路由瓶颈等&#xff0c;这些问题导致网络安全和服务质量难以适应军事网络的高速发展。在…

一文了解JVM面试篇(上)

Java内存区域 1、如何解释 Java 堆空间及 GC? 当通过 Java 命令启动 Java 进程的时候,会为它分配内存。内存的一部分用于创建 堆空间,当程序中创建对象的时候,就从对空间中分配内存。GC 是 JVM 内部的一 个进程,回收无效对象的内存用于将来的分配。 2、JVM 的主要组成…

前端工程化工具系列(四)—— Commitlint(v19.3.0):规范化 Git 提交

commitlint 是对 Git 提交的信息进行校验的工具。 1. 环境要求 v19 以上的 Stylelint&#xff0c;支持 Node.js 的版本为 v18 。 在命令行中输入以下内容来查看当前系统中 node 的版本。 node -vNode.js 推荐使用 v18.20.3 或者 v20.13.1。 这里使用的包管理器是 PNPM&#…

NextJs 数据篇 - 数据获取 | 缓存 | Server Actions

NextJs 数据篇 - 数据获取 | 缓存 | Server Actions 前言一. 数据获取 fetch1.1 缓存 caching① 服务端组件使用fetch② 路由处理器 GET 请求使用fetch 1.2 重新验证 revalidating① 基于时间的重新验证② 按需重新验证revalidatePathrevalidateTag 1.3 缓存的退出方式 二. Ser…

PostgreSQL的多态函数

项目中遇到一个需求,需要模拟Oracle的NVL2函数实现一个对应功能的函数 于是就写了一个自定义函数 CREATE OR REPLACE FUNCTION bkdb3.nvl2(expr anyelement, expr2 anyelement, expr3 anyelement)RETURNS anyelementLANGUAGE plpgsql AS $$ BEGINIF expr IS NOT NULL AND expr…

windows操作系统提权之服务提权实战rottenpotato

RottenPotato&#xff1a; 将服务帐户本地提权至SYSTEM load incognito list_tokens –u upload /home/kali/Desktop rottenpotato.exe . execute -Hc -f rottenpotato.exe impersonate_token "NT AUTHORITY\SYSTEM" load incognito 这条命令用于加载 Metasploi…

vue 关闭页面前释放资源

mounted() {window.addEventListener(beforeunload, e > this.handleBeforeUnload(e)) }beforeDestroy() {//监听-关闭页面的时候释放资源window.removeEventListener(beforeunload, e > this.handleBeforeUnload(e))},methods: {handleBeforeUnload(event){event.preven…

【Linux】在Windows环境下配置两台Linux机器的文件互传

相信有很多云服务器小伙伴都有想把一台linux资源传到另一台机器&#xff0c;那么该怎样实现&#xff1f; 本篇文章的演示案例都是基于centous进行传输&#xff0c;ubuntu进行接收&#xff01; 别的方法也都是一样的&#xff01; 方法一&#xff08;基于xshell进行的压缩包win…

Java项目:92 基于SSM的办公管理系统

作者主页&#xff1a;舒克日记 简介&#xff1a;Java领域优质创作者、Java项目、学习资料、技术互助 文中获取源码 基于SSM的办公管理系统 1、项目介绍 基于SSM的办公管理系统主要是对于办公用品的申领进行管理&#xff0c;系统分为三种角色&#xff0c;超级管理员、企业 职…

Python3 元组

前言 本文主要介绍Python中的元组(tuple)&#xff0c;主要内容包括 元组简介、元组特性、元组的基本操作。 文章目录 前言一、元组简介二、元组特性1、不可变性2、有序性3、异构性4、可以嵌套使用5、元组类型比列表类型更加节省内存空间 三、元组的基本操作1、创建2、索引3、…

利用WMI横向移动

一. WMI介绍和使用 1. WMI介绍 WMI是Windows在Powershell还未发布前&#xff0c;微软用来管理Windows系统的重要数据库工具&#xff0c;WMI本身的组织架构是一个数据库架构&#xff0c;WMI 服务使用 DCOM或 WinRM 协议, 在使用 wmiexec 进行横向移动时&#xff0c;windows 操…