jetlinks / reactor-ql Goto Github PK

View Code? Open in Web Editor NEW

172.0 10.0 97.0 491 KB

用SQL来描述Reactor API. 可用SQL来实现数据处理逻辑,支持实时数据处理,支持聚合,分组,自定义函数等功能,让数据处理更简单.

License: Apache License 2.0

Java 100.00%

reactor sql rule-engine sql-to-reactor sql-to-flux

reactor-ql's People

Contributors

Stargazers

Watchers

Forkers

ylwb zhitom yangxuan-321 chenglinjava68 jimoguilai geiliuup sanwanliu andy521 tsuijie lethetann lechance asdfgcjw jollyant hejun5448 zhongfuqiang-iot hanspro-it robbbit ai2hub szueric dulei2085 kmmao piwenjun nizgg cxcco ccwxl witosmart jracma kendankendan hezudao0324 jameszhang500 c2cn etongle-open crpeng2019 zhoutanxin zhuomingliang rsyuxiangyang lvluogang simon5110 zacobin rtl8710 floodboad budye wuchunfu leyoo bochaoding fox-momo duingold jackie1in easthj gtiger666 flyingdew dobean iablee bob-song aiming317 cloudgoon xiaohelong jianghushao kotlin2018 bei8202290 lasyka iot-source xiciliu zr-meta eddylapis ksj344688430 xiaomaoguai yq12yq liuyt cgb-iot jacco-su beilika muyiluop code-uri josonjiang xdnk7889 qminfoadmin hanysgit suyong1 violetsunny lybigdata pengyudeng entropy-cloud rwindwh geeeeeeker owenhappy phackss acproject xiiiblue beanluo cutecat-yu cccccui help-lixin d9night suevip1 hongye612430 zt713

reactor-ql's Issues

求文档

求API文档

能否实现类似mysql中的substr()功能

工作中遇到截取字符串的需求,看了文档和单元测试,好像并没有对应方法

如果where条件中有个list，怎么拼接条件

请问下，我想查询service中name=‘name1’的所有数据，下面的写法不对，应该怎么写呢

ArrayList<Map<String, Object>> services = new ArrayList<Map<String, Object>>() {
            {
                add(new HashMap<String, Object>() {
                    {
                        put("name", "name1");
                        put("key", "key1");
                    }
                });
                add(new HashMap<String, Object>() {
                    {
                        put("name", "name2");
                        put("key", "key2");
                    }
                });
            }
        };
ReactorQL.builder()
        .sql("select * from test where this.name='name1' ")
        .build()
        .start(Flux.just(services))
        .subscribe(System.out::println);

大佬，请教下为什么底层用jsqlparser而不是druid sql parser

group by 支持非列表达式

Hello，大佬，group by 后续考虑扩展支持非列表达式吗，例如别名或者函数

本地正常，服务器无法启动

spring boot版本2.6.2，服务器用的open-jdk8，请问下有办法处理吗

2021-12-30 23:24:14.766 ERROR [main] org.springframework.boot.SpringApplication - Application run failed
java.lang.RuntimeException: Failed to init Reactor's debug agent
	at org.springframework.boot.reactor.DebugAgentEnvironmentPostProcessor.postProcessEnvironment(DebugAgentEnvironmentPostProcessor.java:52)
	at org.springframework.boot.env.EnvironmentPostProcessorApplicationListener.onApplicationEnvironmentPreparedEvent(EnvironmentPostProcessorApplicationListener.java:102)
	at org.springframework.boot.env.EnvironmentPostProcessorApplicationListener.onApplicationEvent(EnvironmentPostProcessorApplicationListener.java:87)
	at org.springframework.context.event.SimpleApplicationEventMulticaster.doInvokeListener(SimpleApplicationEventMulticaster.java:176)
	at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:169)
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:143)
	at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:131)
	at org.springframework.boot.context.event.EventPublishingRunListener.environmentPrepared(EventPublishingRunListener.java:85)
	at org.springframework.boot.SpringApplicationRunListeners.lambda$environmentPrepared$2(SpringApplicationRunListeners.java:66)
	at java.util.ArrayList.forEach(ArrayList.java:1257)
	at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:120)
	at org.springframework.boot.SpringApplicationRunListeners.doWithListeners(SpringApplicationRunListeners.java:114)
	at org.springframework.boot.SpringApplicationRunListeners.environmentPrepared(SpringApplicationRunListeners.java:65)
	at org.springframework.boot.SpringApplication.prepareEnvironment(SpringApplication.java:338)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:296)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1301)
	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1290)
	at com.step.iot.manager.IotApplication.main(IotApplication.java:18)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.boot.loader.MainMethodRunner.run(MainMethodRunner.java:49)
	at org.springframework.boot.loader.Launcher.launch(Launcher.java:108)
	at org.springframework.boot.loader.Launcher.launch(Launcher.java:58)
	at org.springframework.boot.loader.JarLauncher.main(JarLauncher.java:88)
Caused by: java.lang.reflect.InvocationTargetException: null
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.springframework.boot.reactor.DebugAgentEnvironmentPostProcessor.postProcessEnvironment(DebugAgentEnvironmentPostProcessor.java:49)
	... 25 common frames omitted
Caused by: java.lang.IllegalStateException: No compatible attachment provider is available
	at reactor.tools.shaded.net.bytebuddy.agent.ByteBuddyAgent.install(ByteBuddyAgent.java:622)
	at reactor.tools.shaded.net.bytebuddy.agent.ByteBuddyAgent.install(ByteBuddyAgent.java:606)
	at reactor.tools.shaded.net.bytebuddy.agent.ByteBuddyAgent.install(ByteBuddyAgent.java:558)
	at reactor.tools.shaded.net.bytebuddy.agent.ByteBuddyAgent.install(ByteBuddyAgent.java:535)
	at reactor.tools.agent.ReactorDebugAgent.init(ReactorDebugAgent.java:56)
	... 30 common frames omitted

纯好奇。和 Flink 的 table SQL 相比，这个的优势在于？

请问有转义符概念吗

比如 fieldName 为 index-a, 如果直接填写这个会被识别为index减去 a
能不能写成
select index-a from t

可以支持直接传入JSON作为数据源吗？

Recommend Projects

React

A declarative, efficient, and flexible JavaScript library for building user interfaces.
Vue.js

🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
Typescript

TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
TensorFlow

An Open Source Machine Learning Framework for Everyone
Django

The Web framework for perfectionists with deadlines.
Laravel

A PHP framework for web artisans
D3

Bring data to life with SVG, Canvas and HTML. 📊📈🎉

Recommend Topics

javascript

JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
web

Some thing interesting about web. New door for the world.
server

A server is a program made to process requests and deliver data to clients.
Machine learning

Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Visualization

Some thing interesting about visualization, use data art
Game

Some thing interesting about game, make everyone happy.

Recommend Org

Facebook

We are working to build community through open source technology. NB: members must have two-factor auth.
Microsoft

Open source projects and samples from Microsoft.
Google

Google ❤️ Open Source for everyone.
Alibaba

Alibaba Open Source for everyone
D3

Data-Driven Documents codes.
Tencent

China tencent open source team.