RuleGo RuleGo
🏠Home
  • Quick Start
  • Rule Chain
  • Standard Components
  • Extension Components
  • Custom Components
  • Visualization
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • Trigger
  • Advanced Topics
  • Performance
  • Standard Components
  • Extension Components
  • Custom Components
  • Components Marketplace
  • Overview
  • Quick Start
  • Routing
  • DSL
  • API
  • Options
  • Components
🔥Editor (opens new window)
  • RuleGo Editor (opens new window)
  • RuleGo Server (opens new window)
  • StreamSQL
  • Github (opens new window)
  • Gitee (opens new window)
  • Changelog (opens new window)
  • English
  • 简体中文
🏠Home
  • Quick Start
  • Rule Chain
  • Standard Components
  • Extension Components
  • Custom Components
  • Visualization
  • RuleGo-Server
  • RuleGo-MCP-Server
  • AOP
  • Trigger
  • Advanced Topics
  • Performance
  • Standard Components
  • Extension Components
  • Custom Components
  • Components Marketplace
  • Overview
  • Quick Start
  • Routing
  • DSL
  • API
  • Options
  • Components
🔥Editor (opens new window)
  • RuleGo Editor (opens new window)
  • RuleGo Server (opens new window)
  • StreamSQL
  • Github (opens new window)
  • Gitee (opens new window)
  • Changelog (opens new window)
  • English
  • 简体中文

广告采用随机轮播方式显示 ❤️成为赞助商
  • Quick Start

  • Rule Chain

  • Standard Components

  • Extension Components

  • Custom Components

  • Components marketplace

  • Visualization

  • AOP

  • Trigger

  • Advanced Topic

  • RuleGo-Server

  • FAQ

  • Endpoint Module

  • Support

  • StreamSQL

    • Overview
    • Quick Start
    • Core Concepts
    • SQL Reference
    • API Reference
    • RuleGo Integration
    • functions

    • case-studies

      • Case Studies Overview
        • Case Categories
          • 📊 Data Merging
          • 📈 Real-time Analysis
          • 🔄 Change Data Capture
          • 🏢 Business Scenarios
        • 🚀 Quick Start
        • 📖 Usage Instructions
          • Environment Preparation
          • Running Cases
          • Case Features
        • 🔗 Related Resources
        • 💡 Contributing Cases
      • Single Stream Data Merging
      • Multi-Stream Data Merging
      • Change Data Capture
      • Real-time Data Analysis
      • Business Scenario Applications
目录

Case Studies Overview

# StreamSQL Case Studies

This chapter provides practical application cases of StreamSQL in various real-world business scenarios, covering common stream processing requirements such as data merging, change data capture, real-time analysis, etc. All cases are based on the actual source code of the StreamSQL project to ensure executability and practicality.

# Case Categories

# 📊 Data Merging

  • Single Stream Data Merging - Data merging within the same data stream
  • Multi-Stream Data Merging - Merging processing between multiple data streams

# 📈 Real-time Analysis

  • Real-time Data Analysis - Real-time indicator calculation, anomaly detection, and trend analysis

# 🔄 Change Data Capture

  • Change Data Capture - Database change monitoring and real-time synchronization processing

# 🏢 Business Scenarios

  • Business Scenario Applications - Practical business scenarios in e-commerce, finance, IoT, etc.

# 🚀 Quick Start

Each case includes the following content:

  1. Business Scenario Description - Detailed business background and requirement analysis
  2. Data Model Design - Input and output data structure definition
  3. SQL Query Implementation - Complete StreamSQL query statements
  4. Go Code Examples - Complete runnable code examples
  5. Running Results Display - Actual running effects and output results
  6. Extension Suggestions - Further optimization and extension recommendations

# 📖 Usage Instructions

# Environment Preparation

Ensure you have installed StreamSQL:

go get github.com/rulego/streamsql
1

# Running Cases

Each case provides complete runnable code, you can:

  1. Copy the code to a local Go file
  2. Adjust configuration parameters as needed
  3. Run the code to see the effects
  4. Modify according to actual business needs

# Case Features

  • ✅ Based on Actual Source Code - All cases are based on actual features of the StreamSQL project
  • ✅ Complete and Runnable - Provide complete code examples that can run directly
  • ✅ Business-Oriented - Oriented to actual business scenarios with practical value
  • ✅ Progressive Learning - From simple to complex, easy to learn and understand
  • ✅ Best Practices - Reflect the best usage methods of StreamSQL

# 🔗 Related Resources

  • StreamSQL Quick Start - Basic getting started tutorial
  • SQL Reference Manual - Complete SQL syntax reference
  • API Reference Documentation - Detailed API description

# 💡 Contributing Cases

If you have good StreamSQL application cases, welcome to contribute to the project:

  1. Fork StreamSQL Project (opens new window)
  2. Add your case under the examples/ directory
  3. Submit Pull Request
  4. We will add excellent cases to the documentation

Let's start exploring the powerful features of StreamSQL, and learn how to effectively use StreamSQL in production environments through these practical cases!

Edit this page on GitHub (opens new window)
Last Updated: 2025/08/05, 02:24:31
Custom Functions
Single Stream Data Merging

← Custom Functions Single Stream Data Merging→

Theme by Vdoing | Copyright © 2023-2025 RuleGo Team | Apache 2.0 License

  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式