A payment service needed real-time streaming AND historical data transformation across 40 MySQL tables into one TiDB table. Xstreami delivered 100 billion records migrated with 0% data loss, complex business logic — zero lines of code written.
Divine March 17, 2026
A leading payment service provider came to Xstreami with a primary goal: set up a real-time data streaming pipeline so every transaction in their MySQL databases would instantly flow into a high-performance TiDB analytics layer. Standard streaming — or so it seemed.
Then came the full picture. Their system held over 100 billion historical payment records spread across 40 MySQL tables — years of transactions, merchant profiles, fraud logs, reconciliation data, settlement records, and more. This historical data could not be left behind. It needed to be transformed with the same complex business logic as the live stream and loaded into TiDB before go-live. And there was one non-negotiable requirement: absolute zero data loss.
Every new payment transaction — INSERTs, UPDATEs, DELETEs — had to be captured from MySQL in real-time, transformed on-the-fly with complex business logic, and delivered to TiDB in under 100 milliseconds.
100 billion+ existing records from 40 fragmented MySQL tables needed to be read, enriched, transformed through multi-layer business logic, and loaded into a single consolidated TiDB table — with guaranteed zero data loss.
The operational challenges driving this transformation were severe:
The core requirement in one sentence: Stream live MySQL transactions to TiDB in real-time while simultaneously transforming 100 billion historical records — all with zero data loss and zero custom code. No traditional ETL tool on the market could do both simultaneously at this scale.
Enter Xstreami—a cutting-edge real-time data streaming platform that transforms how organizations handle data consolidation and migration. For this payment service, Xstreami became the bridge between their legacy MySQL infrastructure and a modern, high-performance TiDB database.
Unlike traditional ETL tools that require extensive programming and maintenance, Xstreami offers a revolutionary approach to data consolidation:
Configure complex data transformations through an intuitive UI. No Python scripts, no Java code, no SQL procedures—just point, click, and transform.
Stream changes from MySQL to TiDB in milliseconds. Every payment transaction is instantly available for analytics and reporting.
Migrate historical data at scale before switching to real-time streaming. Handle 100 billion records efficiently with zero data loss.
Modify transformation logic instantly through the UI. No code deployments, no downtime, no risk—just immediate updates.
Connect to 50+ data sources and destinations. MySQL, PostgreSQL, MongoDB, TiDB, Snowflake, Kafka, and more—all pre-built and ready to use.
Built-in monitoring, automatic retries, data validation, and exactly-once delivery guarantees ensure your payment data is always accurate.
The transformation happened in two critical phases: Initial Data Sync (IDS) for historical data migration, followed by continuous real-time streaming for ongoing transactions.
The team used Xstreami's visual interface to map the 40 MySQL source tables to a unified TiDB schema. All transformation logic—data enrichment, field mapping, calculations, and business rules—was configured through the UI without writing a single line of code. The entire configuration took just 2 days.
Xstreami's IDS engine kicked off the massive data migration. Across the migration window, 100 billion payment records were read from MySQL, transformed according to the configured logic, and loaded into TiDB. The parallel processing capabilities ensured minimal impact on production MySQL databases. Progress was monitored in real-time through Xstreami's dashboard.
Once IDS completed, Xstreami automatically transitioned to real-time streaming mode. Every INSERT, UPDATE, and DELETE operation in the MySQL payment tables was captured instantly and streamed to TiDB with the same transformation logic. Latency from source to destination: less than 100 milliseconds.
The team ran comprehensive validation checks comparing MySQL source data with TiDB destination data. Xstreami's built-in data quality tools verified record counts, field values, and business logic correctness. Success rate: 99.999%—well within acceptable thresholds for a payment system.
The payment service cutover to querying TiDB for analytics and reporting while maintaining MySQL for transactional operations. Xstreami continues to run 24/7, streaming every payment transaction in real-time. The no-code platform allows the team to modify transformation logic instantly whenever business requirements change.
Let's examine exactly how Xstreami transformed the complex 40-table payment structure into a single, queryable table optimized for high-performance data pipelines.
The original MySQL schema was highly normalized across multiple categories:
-- Core Transaction Tables
transactions (txn_id, merchant_id, customer_id, amount, currency, status, created_at)
transaction_details (detail_id, txn_id, payment_method_id, gateway_id, reference_id)
transaction_items (item_id, txn_id, product_id, quantity, unit_price)
-- Party Tables
merchants (merchant_id, name, category_id, country_id, status, kyc_status)
customers (customer_id, name, email, phone, risk_score, tier)
merchant_accounts (account_id, merchant_id, bank_id, account_number)
-- Payment Method Tables
payment_methods (method_id, customer_id, type, provider, card_last4, expiry)
payment_gateways (gateway_id, name, provider, region, fees)
payment_processors (processor_id, gateway_id, processor_code, status)
-- Settlement & Reconciliation
settlements (settlement_id, txn_id, amount, status, settled_at)
reconciliation (recon_id, settlement_id, status, discrepancy_amount)
payouts (payout_id, merchant_id, amount, status, payout_date)
-- Risk & Compliance
fraud_checks (check_id, txn_id, risk_score, rules_triggered, status)
compliance_logs (log_id, txn_id, check_type, result, timestamp)
aml_records (aml_id, customer_id, risk_level, last_check_date)
-- Reference Data
countries (country_id, name, code, currency, tax_rate)
currencies (currency_id, code, symbol, exchange_rate)
merchant_categories (category_id, name, mcc_code, risk_level)
products (product_id, name, category, price)
-- Plus 20+ more tables for fees, disputes, refunds, chargebacks, etc.
The Challenge: A typical payment analytics query required joining 15-20 of these tables, resulting in:
Monitor all 40 MySQL tables for changes using CDC (Change Data Capture). Capture every INSERT, UPDATE, and DELETE operation in real-time.
For each transaction event, perform lookups to enrich data from related tables: merchant details, customer info, payment method, gateway, country, currency, etc.
Map source fields to destination schema. Rename fields for clarity, combine fields where needed, and format data according to business requirements.
Compute derived fields: fees, net amounts, currency conversions, tax calculations, merchant share, risk scores, and business metrics.
Apply validation rules to ensure data quality: check for null values, validate formats, verify referential integrity, and flag anomalies.
Write the enriched, transformed record to the consolidated TiDB table using optimized batch inserts for maximum throughput.
The Power of No-Code: All of this complex transformation logic was configured through Xstreami's visual interface in less than 2 days. No Java, no Python, no SQL scripts. Just point-and-click configuration with instant deployment.
The resulting schema in TiDB is a fully denormalized, analytics-optimized table:
CREATE TABLE payment_analytics (
-- Transaction Core
txn_id VARCHAR(50) PRIMARY KEY,
txn_timestamp TIMESTAMP,
txn_amount DECIMAL(15,2),
txn_currency VARCHAR(3),
txn_status VARCHAR(20),
-- Merchant Information
merchant_id VARCHAR(50),
merchant_name VARCHAR(200),
merchant_category VARCHAR(100),
merchant_country VARCHAR(50),
merchant_risk_level VARCHAR(20),
-- Customer Information
customer_id VARCHAR(50),
customer_name VARCHAR(200),
customer_email VARCHAR(200),
customer_tier VARCHAR(20),
customer_risk_score INT,
-- Payment Details
payment_method_type VARCHAR(50),
payment_provider VARCHAR(100),
payment_gateway VARCHAR(100),
card_last4 VARCHAR(4),
-- Financial Calculations
gross_amount DECIMAL(15,2),
gateway_fee DECIMAL(10,2),
platform_fee DECIMAL(10,2),
tax_amount DECIMAL(10,2),
net_amount DECIMAL(15,2),
merchant_share DECIMAL(15,2),
-- Settlement Info
settlement_status VARCHAR(20),
settlement_date DATE,
payout_status VARCHAR(20),
-- Risk & Compliance
fraud_check_status VARCHAR(20),
fraud_risk_score INT,
aml_check_status VARCHAR(20),
compliance_flags JSON,
-- Location Data
country_code VARCHAR(3),
country_name VARCHAR(100),
region VARCHAR(100),
-- Metadata
created_at TIMESTAMP,
updated_at TIMESTAMP,
data_version INT,
-- Indexes
INDEX idx_merchant (merchant_id),
INDEX idx_customer (customer_id),
INDEX idx_timestamp (txn_timestamp),
INDEX idx_status (txn_status)
);
What once required complex 15-20 table joins now becomes:
-- Get all high-value transactions for a merchant in the last 30 days
SELECT
txn_id,
txn_timestamp,
customer_name,
txn_amount,
payment_method_type,
fraud_risk_score,
settlement_status
FROM payment_analytics
WHERE merchant_id = 'MERCH_12345'
AND txn_timestamp >= NOW() - INTERVAL 30 DAY
AND txn_amount > 10000
ORDER BY txn_timestamp DESC;
-- Query time: 0.2 seconds ⚡
-- Previously: 8.5 seconds with 15+ table joins
The migration to Xstreami delivered transformative results across all dimensions of the payment service's data infrastructure:
| Metric | Before Xstreami | After Xstreami | Improvement |
|---|---|---|---|
| Query Response Time | 5-10 seconds | 0.2-0.5 seconds | 95% faster |
| Data Freshness | 15-30 minute delay | <100 milliseconds | Real-time |
| Tables to Query | 15-20 joins | Single table | Zero joins |
| Developer Time per Report | 2-3 days | 2-3 hours | 90% reduction |
| Infrastructure Load | High MySQL CPU | Minimal impact | Isolated workloads |
| Schema Change Time | 2-3 weeks | 1-2 hours | Single-click updates |
| Code Maintenance | Complex ETL scripts | Zero code | 100% reduction |
| Data Quality Issues | Frequent discrepancies | 99.999% accuracy | Automated validation |
Faster payment processing and real-time fraud detection prevented an estimated $2M in potential fraud losses in the first quarter after deployment.
New payment features and reports now launch 10x faster. What took weeks of development now takes hours of configuration.
Real-time dashboards enabled instant decision-making. Executives now see payment trends as they happen, not hours later.
Data analysts can now create reports independently without waiting for engineering resources. SQL complexity reduced by 80%.
Real-time fraud detection and compliance monitoring became possible, dramatically reducing exposure to fraudulent transactions.
System now handles 3x transaction volume with no performance degradation. Ready to scale to 10x with TiDB's distributed architecture.
The Bottom Line: The payment service achieved a 10x improvement in data infrastructure efficiency while eliminating the need for complex custom code. Xstreami's no-code platform transformed their ability to deliver real-time payment insights at massive scale.
Transforming 100 billion historical payment records while simultaneously streaming live transactions is not a problem that scales with brute force. It requires an architecture purpose-built for exactness — where every record is accounted for, every transformation is verifiable, and no interruption can cause data loss. Xstreami's Initial Data Sync (IDS) engine was designed for exactly this.
Xstreami's IDS engine eliminates data loss through layered, redundant guarantees — not just one safeguard, but many:
IDS Performance Highlights:
Once IDS completed, Xstreami automatically switched to real-time streaming mode. This transition was completely transparent—no manual intervention required, no service disruption, no downtime.
From that moment forward, every payment transaction in MySQL was:
Perhaps the most revolutionary aspect of this project wasn't the scale or speed—it was achieving all of this without writing a single line of code.
| Aspect | Traditional ETL | Xstreami Platform |
|---|---|---|
| Development | Months of coding in Python/Java | Days of visual configuration |
| Skills Required | Senior data engineers | Analysts with business knowledge |
| Logic Changes | Code deployment (hours/days) | Single-click update (seconds) |
| Testing | Manual test scripts, staging env | Built-in validation, preview mode |
| Monitoring | Custom logging, external tools | Real-time dashboard included |
| Error Handling | Custom retry logic, alerting | Automatic retries, dead letter queue |
| Maintenance | Ongoing code updates, debugging | Minimal—platform handles it |
| Documentation | Must be written separately | Self-documenting configuration |
One of the most powerful features of Xstreami is the ability to modify transformation logic instantly through the UI. Here's a real example from the payment project:
Scenario: The business team decided to change how merchant fees are calculated—from a flat percentage to a tiered structure based on transaction volume.
Traditional Approach:
Xstreami Approach:
In the fast-paced world of fintech data streaming, agility is everything:
While this case study focuses on MySQL to TiDB migration, Xstreami's platform offers universal connectivity across 50+ data sources and destinations.
MySQL, PostgreSQL, SQL Server, Oracle, MariaDB, TiDB, CockroachDB
MongoDB, Cassandra, DynamoDB, Redis, Elasticsearch
Snowflake, BigQuery, Redshift, Azure Synapse, Databricks
Kafka, RabbitMQ, AWS Kinesis, Azure Event Hubs, Pulsar
S3, GCS, Azure Blob, HDFS, FTP, SFTP
REST APIs, Salesforce, HubSpot, Zendesk, custom integrations
Xstreami excels at consolidating data from multiple sources into unified destinations:
The power of universal connectors: Whether you're migrating MySQL to TiDB (like this case study), syncing PostgreSQL to Snowflake, or streaming MongoDB to Elasticsearch—Xstreami provides the same no-code experience with enterprise-grade reliability.
This real-world payment system transformation demonstrates the transformative potential of modern real-time data streaming platforms. Here are the critical lessons:
In payment systems, delayed data means delayed fraud detection, delayed insights, and delayed decisions. Real-time streaming with sub-100ms latency should be the baseline, not the aspiration.
40 normalized tables might be ideal for OLTP, but they're terrible for analytics. A well-designed consolidated table optimized for queries delivers 10-100x better performance than complex joins.
When business logic changes (and in payments, it changes constantly), you need the ability to update transformations in minutes, not weeks. No-code platforms eliminate the development bottleneck.
You need both historical migration (IDS) and ongoing replication (streaming). Platforms that only do one force you to cobble together multiple tools with fragile integration points.
Payment data must be 100% accurate. Choose platforms with automatic validation, exactly-once delivery guarantees, and comprehensive monitoring—not tools that require you to build these capabilities yourself.
Payment volumes can spike 10x during peak seasons. Your data pipeline must scale horizontally without architectural changes. TiDB + Xstreami delivered this by design.
The Future of Payment Data Infrastructure: This project proves that modern real-time data platforms can handle the most demanding fintech workloads—100 billion records, 40-table consolidations, sub-100ms latency—all without custom code. This is the new standard for payment data pipelines.
Discover how Xstreami can consolidate your complex database architecture into a real-time, high-performance data streaming platform—with zero programming required.
This payment service's journey from 40 fragmented MySQL tables to a single, real-time TiDB analytics powerhouse represents more than just a technical migration—it's a fundamental shift in how modern financial services should approach data infrastructure.
The results speak for themselves:
What makes this transformation truly remarkable is not just the scale or speed, but the accessibility. By providing a no-code data transformation platform, Xstreami democratized the ability to build and maintain enterprise-grade data pipelines. Business analysts who understand payment logic can now make changes directly, without waiting for engineering resources.
This case study has implications far beyond one payment service:
The bottom line: Traditional batch ETL is dead. Custom-coded streaming pipelines are overkill. The future belongs to no-code, real-time data platforms that combine the power of enterprise-grade streaming with the accessibility of visual configuration. Xstreami is leading that future.
If you're operating a payment system, e-commerce platform, fintech application, or any data-intensive operation that requires real-time insights, the lessons from this case study are clear:
The payment service in this case study took the leap—and achieved results that exceeded their most optimistic projections. Your organization can too.
Miru IT Park, Vallankumaranvillai,
Nagercoil, Tamilnadu - 629 002.
Unit 303, Vanguard Rise,
5th Main, Konena Agrahara,
Old Airport Road, Bangalore - 560 017.
Call: +91 6383016411
Email: sales@mafiree.com