zensol
/
sling_aptsell
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

base: zensol:a584ca37e383bd35cec6c39ee4e6094588b0dbba
Branches Tags
zensol:main
..
compare: zensol:0e68676369ce6f7a5a09c9d6688bbb347efbf404
Branches Tags
zensol:main

No commits in common. "a584ca37e383bd35cec6c39ee4e6094588b0dbba" and "0e68676369ce6f7a5a09c9d6688bbb347efbf404" have entirely different histories.
a584ca37e3 ... 0e68676369

6 changed files with 4170 additions and 12 deletions
Show Stats Expand all files Collapse all files

4161
ddl_autoflowdemo.sql Normal file
View File

File diff suppressed because it is too large Load Diff

7
fix_errors.sql Normal file
View File

@ -0,0 +1,7 @@
-- 1. Drop foreign key constraints that prevent data insertion since the parent 'users' table is not part of the replication
ALTER TABLE `demo`.`crm_sales_visit_records` DROP FOREIGN KEY `fk_recorder_id`;
ALTER TABLE `demo`.`user_profiles` DROP FOREIGN KEY `fk_1`;
-- 2. Drop the generated column 'biz_key' in 'crm_acv_targets' and recreate it as a standard VARCHAR column so Sling can import data into it
ALTER TABLE `demo`.`crm_acv_targets` DROP COLUMN `biz_key`;
ALTER TABLE `demo`.`crm_acv_targets` ADD COLUMN `biz_key` VARCHAR(16) NULL COMMENT '业务主键（如FY26Q1，全年为FY26）';

8
sync.sh
View File

@ -1,10 +1,6 @@
sling run -r sync_aptselldemo.yaml sling run -r sync_aptselldemo_homelab.yaml
sling run -r sync_demo_local.yaml sling run -r sync_demo_local.yaml
sling run -r sync_demo.yaml sling run -r sync_demo_homelab.yaml
# Sync particular tables to local/homelab
sling run -r sync_aptselldemo_homelab.yaml --streams qingflow.crm_opportunities_snapshot
sling run -r sync_demo_homelab.yaml --streams autoflow-demo.crm_opportunities_snapshot

2
sync_aptselldemo_homelab.yaml
View File

@ -58,8 +58,6 @@ streams:
object: "aptselldemo.crm_message_work_items" object: "aptselldemo.crm_message_work_items"
"qingflow.crm_opportunities": "qingflow.crm_opportunities":
object: "aptselldemo.crm_opportunities" object: "aptselldemo.crm_opportunities"
"qingflow.crm_opportunities_snapshot":
object: "aptselldemo.crm_opportunities_snapshot"
"qingflow.crm_opportunity_review_execution_index": "qingflow.crm_opportunity_review_execution_index":
object: "aptselldemo.crm_opportunity_review_execution_index" object: "aptselldemo.crm_opportunity_review_execution_index"
"qingflow.crm_opportunity_stage_stay_bucket": "qingflow.crm_opportunity_stage_stay_bucket":

2
sync_demo_homelab.yaml
View File

@ -58,8 +58,6 @@ streams:
object: "demo.crm_message_work_items" object: "demo.crm_message_work_items"
"autoflow-demo.crm_opportunities": "autoflow-demo.crm_opportunities":
object: "demo.crm_opportunities" object: "demo.crm_opportunities"
"autoflow-demo.crm_opportunities_snapshot":
object: "demo.crm_opportunities_snapshot"
"autoflow-demo.crm_opportunity_review_execution_index": "autoflow-demo.crm_opportunity_review_execution_index":
object: "demo.crm_opportunity_review_execution_index" object: "demo.crm_opportunity_review_execution_index"
"autoflow-demo.crm_opportunity_stage_stay_bucket": "autoflow-demo.crm_opportunity_stage_stay_bucket":

2
sync_demo_local.yaml
View File

@ -58,8 +58,6 @@ streams:
object: "demo.crm_message_work_items" object: "demo.crm_message_work_items"
"autoflow-demo.crm_opportunities": "autoflow-demo.crm_opportunities":
object: "demo.crm_opportunities" object: "demo.crm_opportunities"
"autoflow-demo.crm_opportunities_snapshot":
object: "demo.crm_opportunities_snapshot"
"autoflow-demo.crm_opportunity_review_execution_index": "autoflow-demo.crm_opportunity_review_execution_index":
object: "demo.crm_opportunity_review_execution_index" object: "demo.crm_opportunity_review_execution_index"
"autoflow-demo.crm_opportunity_stage_stay_bucket": "autoflow-demo.crm_opportunity_stage_stay_bucket":