JQuick-SQL 多源 JOIN：统一业务键后的跨系统关联查询
Meta 描述：掌握 jquick-sql 多源 JOIN 的正确路径：在应用层或 jquick-connector 标准化数据并 registerTable，再使用 SQL 关联已注册表。
标签：jquick-sql、多源 JOIN、异构数据源联邦查询、Java 跨库查询、业务键治理、JQuickDataSet、轻量级 SQL 引擎
官网示例：
- FORMULAS 示例页：https://www.jquick.org/jquick-sql
- github 地址：https://github.com/paohaijiao/jquick-sql
前言
订单、客户、库存和履约状态往往分散在不同系统。jquick-sql 可以在已注册的多张内存表之间执行 JOIN，帮助 Java 应用以低成本实现统一分析。但它不直接连接数据库、文件、NoSQL 或 REST 系统；每个来源都必须先由应用层或 jquick-connector 读取并转换。
多源 JOIN 的四步方法
第一步，确定业务粒度，例如“一行订单”或“一行订单明细”。第二步，统一关联键的类型和格式。第三步，按来源注册独立表。第四步，使用显式别名和 JOIN 条件编写 SQL。
这样可以避免把原始来源差异带入查询层。对中国中小企业而言，先解决最关键的 2–3 张表关联，通常比一次建设完整数据平台更容易落地。
关联键、空值与重复行
JOIN 结果异常最常见的原因是键不一致或数据重复。接入阶段应统一字符串去空格、编码大小写、数字与文本 ID 的转换，并明确空键的处理策略。若一侧存在多行匹配，结果会按业务粒度扩大，应先决定是否需要预聚合或去重。
建议为每个注册表保留来源标识，并在 SQL 中使用表别名，避免同名字段造成混淆。
支持范围与查询设计
可使用 INNER JOIN、LEFT JOIN 等已有 SQL 能力表达核心关联；不要将 FULL OUTER JOIN 作为稳定支持项。对于复杂链路，先分别执行小范围查询验证键覆盖率，再逐步增加聚合、过滤和子查询。
SQL 的执行对象仍是已注册数据集，且不代表引擎将 JOIN 下推到外部数据库或服务。
代码案例
import com.github.paohaijiao.engine.JQuickSQL;
import com.github.paohaijiao.statement.JQuickColumnMeta;
import com.github.paohaijiao.statement.JQuickDataSet;
import com.github.paohaijiao.statement.JQuickRow;
import java.util.Arrays;
public class MultiSourceJoinDemo {
public static void main(String[] args) {
// 两张表分别可来自应用层/JQuick Connector 已完成的外部读取与转换。
JQuickSQL sql = JQuickSQL.embedded();
try {
sql.registerTable("db_orders", Arrays.asList(
new JQuickColumnMeta("order_no", String.class, "db_orders"),
new JQuickColumnMeta("customer_id", String.class, "db_orders"),
new JQuickColumnMeta("amount", Double.class, "db_orders")
), Arrays.asList(
row("order_no", "O001", "customer_id", "C001", "amount", 300.0),
row("order_no", "O002", "customer_id", "C002", "amount", 160.0)
));
sql.registerTable("api_customers", Arrays.asList(
new JQuickColumnMeta("customer_id", String.class, "api_customers"),
new JQuickColumnMeta("tier", String.class, "api_customers")
), Arrays.asList(
row("customer_id", "C001", "tier", "VIP"),
row("customer_id", "C002", "tier", "STANDARD")
));
JQuickDataSet result = sql.execute(
"SELECT c.tier, COUNT(*) AS order_count, SUM(o.amount) AS total_amount " +
"FROM db_orders o JOIN api_customers c ON o.customer_id = c.customer_id " +
"GROUP BY c.tier"
);
result.printTable();
} finally {
sql.shutdown();
}
}
private static JQuickRow row(Object... values) {
JQuickRow row = new JQuickRow();
for (int i = 0; i < values.length; i += 2) row.put((String) values[i], values[i + 1]);
return row;
}
}
常见问题
**多源 JOIN 是否需要同一个数据库？**不需要，但各来源数据要先在应用层或 jquick-connector 转换并注册。
**JOIN 后数据翻倍怎么办？**检查一对多或多对多关系，必要时在关联前聚合或按业务键去重。
**是否支持 FULL OUTER JOIN？**不应依赖该能力；项目说明明确不将其列为支持范围。
总结与拓展
多源 JOIN 的难点通常不在 SQL 语法，而在业务键和数据口径。以 JQuickRow / JQuickDataSet 为统一边界，jquick-sql 能帮助团队把跨系统关联逻辑沉淀为可读、可测试的 Java SQL 查询。
Core Advantage
Joins normalized datasets from multiple origins through one explicit and auditable SQL layer.
Applicable Scenarios
Order-to-shipment matching, customer 360 views, stock reconciliation, campaign attribution, and operational KPI analysis.
