[Improvement][Api] Add referential integrity checks when deleting data sources.

[njnu-seafish]

Search before asking

• I had searched in the issues and found no similar feature requirement.

Description

Currently, referential integrity checks are missing when deleting data sources, which may cause scheduled tasks to fail.

Are you willing to submit a PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct

[SbloodyS]

Please describe how you want to achieve it. @njnu-seafish

[njnu-seafish]

Please describe how you want to achieve it. @njnu-seafish

@SbloodyS The following SQL query retrieves detailed information about tasks that reference a specific data source.

SELECT b.name project_name, d.name flow_name, a.name task_name, a.task_params
FROM t_ds_task_definition a
JOIN t_ds_project b ON a.project_code = b.code
JOIN t_ds_workflow_task_relation c ON a.code = c.post_task_code
JOIN t_ds_workflow_definition d ON c.workflow_definition_code = d.code
WHERE a.task_type IN ('SQL','PROCEDURE') AND JSON_UNQUOTE(JSON_EXTRACT(a.task_params, '$.datasource')) = 13 LIMIT 10;

This SQL query performs efficiently with task volumes in the thousands. However, for extremely large datasets, consider storing the datasource as a computed column and adding an index to optimize performance.

[matthewwalker1621-star]

Any progress on this issue

…

On Thu, Mar 19, 2026, 3:50 AM njnu-seafish ***@***.***> wrote: *njnu-seafish* left a comment (apache/dolphinscheduler#18077) <#18077 (comment)> Please describe how you want to achieve it. @njnu-seafish <https://github.com/njnu-seafish> The following SQL query retrieves detailed information about tasks that reference a specific data source. SELECT b.name project_name, d.name flow_name, a.name task_name, a.task_params FROM t_ds_task_definition a JOIN t_ds_project b ON a.project_code = b.code JOIN t_ds_workflow_task_relation c ON a.code = c.post_task_code JOIN t_ds_workflow_definition d ON c.workflow_definition_code = d.code WHERE a.task_type IN ('SQL','PROCEDURE') AND JSON_UNQUOTE(JSON_EXTRACT(a.task_params, '$.datasource')) = 13 LIMIT 10; This SQL query performs efficiently with task volumes in the thousands. However, for extremely large datasets, consider storing the datasource as a computed column and adding an index to optimize performance. — Reply to this email directly, view it on GitHub <#18077 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/B7GHLXCBNXDHBZECDXSYCM34ROYDPAVCNFSM6AAAAACWV57TH6VHI2DSMVQWIX3LMV43OSLTON2WKQ3PNVWWK3TUHM2DAOBYGY3DMMBRHE> . You are receiving this because you are subscribed to this thread.Message ID: ***@***.***>