文章目录 前言1. MyBatis-plus 对 SQL 语句脚本的处理1.1 SQL 语句脚本的构建1.2 SqlSource 的转化 2. MyBatis 对 SqlSource 的使用 前言 在 MyBatis-plus 自定义通用方法及其实现原理 中笔者介绍了 MyBatis-plus 添加通用方法的实现方式，但是其中还有一些细节需要…

flink sql 在执行中是如何从sql语句或者是table api 转为最后的DataStream任务或者是DataSet任务的，本篇我们从源码角度看下中间的执行和转换过程。 DEMO 这是flink的一个单元测试方法，模拟实时数据查询 @Testpublic void testSelect() throws Exception {StreamExecutionE…

业务中需要对Trino查询语句中涉及的字段进行处理，所以对这一段源码进行追踪分析，记录如下。 源码追踪是从QueuedStatementResource类开始的。 QueuedStatementResource类与ExecutingStatementResource类，提供用户执行查询相关的Restful接口。…

上篇文章描述研究源码所用的demo，本篇文章开始正式追踪源码，在开看前，再次确认下我们要研究的问题： 1、mybatis如何找到存储sql的xml文件 2、mybatis如何解析xml中sql相关标签并拼装成完整的sql语句 3、m…

benchmarksql 在5.0版本中没有对人大金仓数据库(KingBase)的TPC-C测试支持，本文通过修改部分源码，让benchmarksql 5.0支持KingBase。 个人理解： BenchmarkSQL 是通过jdbc方式连接数据库，通过DML操作来对数据进行性能测试。 所以…

文章目录 SQL 解析MapReduce实现基本SQL操作的原理Join的实现原理Group By的实现原理Distinct的实现原理SQL 解析的背景AntlrANTLRWorksHive 的 Antlr 语法规则文件HiveLexer.gFromClauseParser.gIdentifiersParser.gSQL转化为MapReduce的过程SQL词法/语法解析 生成抽象语法树S…

序号作者版本时间备注1HamaWhite1.0.02022-08-15增加文档和源码2HamaWhite2.0.02022-11-241.支持Watermark 2.支持UDTF 3. 改变Calcite源码修改方式 4. 升级hudi和mysql cdc版本 源码地址: https://github.com/HamaWhiteGG/flink-sql-lineage 一、基础知识 1.1 Apache Ca…

第七章就来学习一下Flink SQL的解析提交流程。 问题整理： 1. Flink中的Calcite是什么？ 2. Flink SQL的提交流程是怎样的？ 1. Calcite Apache Calcite是一个动态数据管理框架 ，它具备很多典型数据库管理系统的功能&#xff0c…