如何用Ansible mysql_query模块处理依赖查询、条件逻辑及事务安全？

我正在使用community.mysql.mysql_query模块通过Ansible对数据库执行查询操作，需要在单事务中执行多个带独立条件的SELECT语句，但遇到了查询依赖或需处理条件逻辑的场景：

场景一：查询依赖（先查用户名再查姓氏） #

当前实现代码：

- name: "Read User Name"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT username AS user_name
          FROM table1 WHERE user_id = 1
  register: user_name_reg

- name: "Set User Name"
  set_fact:
      user_name: "{{ user_name_reg['query_result'][0][0]['user_name'] }}"

- name: "Read User Last Name"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT userLastName AS user_last_name
          FROM table2 WHERE user_name = "{{ user_name }}"
  register: user_last_name_reg

场景二：条件逻辑查询（无结果则执行备选查询） #

伪代码逻辑：

# user_name = query_result("
# SELECT username AS user_name
# FROM table1 WHERE user_id = 1")

# if not user_name:
#    user_name = query_result("
#    SELECT username AS user_name
#    FROM table2 WHERE user_special_id = 1")

当前Ansible实现：

- name: "Read User Name 1st"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT username AS user_name
          FROM table1 WHERE user_id = 1
  register: user_name_reg

- name: "Set User Name"
  set_fact:
      user_name: "{{ user_name_reg['query_result'][0][0]['user_name'] }}"

- name: "Read User Name 2nd"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT username AS user_name
          FROM table2 WHERE user_special_id = 1
  register: user_name2_reg
  when: "user_name = NULL"

我认为当前实现不具备事务安全性，因为任务间无锁定机制，现提出两个问题：

1. 是否可以使用mysql_query模块在单事务中处理上述场景？
2. 若不可行，采用SQL脚本或Ansible动作模块实现是否更合理？

问题1解答：mysql_query模块单事务处理的可行性 #

community.mysql.mysql_query模块原生不支持在单个模块调用中执行依赖式或条件式的多查询逻辑，核心原因：

• 模块每次调用都会建立独立数据库连接，执行完查询后立即关闭，无法跨任务保持事务上下文。
• 虽然支持在query参数传入多条SQL，但这些语句是批量独立执行的，无法实现“用前一条查询结果作为后一条查询条件”——模块会一次性发送所有SQL到数据库，中间无法插入Ansible变量赋值或条件判断。

如果要通过mysql_query实现事务内查询，需将依赖逻辑转移到SQL层面：

• 场景一可通过JOIN或子查询合并两个查询：

- name: "Get User Name and Last Name in Single Query"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT t1.username AS user_name, t2.userLastName AS user_last_name
          FROM table1 t1
          JOIN table2 t2 ON t1.username = t2.user_name
          WHERE t1.user_id = 1
  register: user_details_reg

• 场景二可通过UNION ALL结合LIMIT实现 fallback 逻辑：

- name: "Get User Name with Fallback"
  community.mysql.mysql_query:
      login_host: "{{login_host}}"
      login_db: "{{login_db}}"
      query:
          - >-
          SELECT username AS user_name
          FROM table1 WHERE user_id = 1
          UNION ALL
          SELECT username AS user_name
          FROM table2 WHERE user_special_id = 1
          LIMIT 1
  register: user_name_reg

这种方式能在单条SQL、单模块调用内完成逻辑，且处于单事务中（MySQL默认自动提交单条SQL，若需显式事务可添加START TRANSACTION;和COMMIT;到查询列表）。

问题2解答：SQL脚本或Ansible动作模块的合理性 #

若业务逻辑复杂（如多步依赖、复杂条件分支），采用SQL脚本或自定义动作模块更合理：

1. SQL脚本方式：
   • 将所有逻辑写入.sql文件，用community.mysql.mysql_script模块执行，脚本内可使用存储过程、变量、IF-ELSE分支实现复杂逻辑，全程处于单事务中。
   • 示例脚本（get_user_details.sql）：

     START TRANSACTION;
     SET @user_name = (SELECT username FROM table1 WHERE user_id = 1);
     IF @user_name IS NULL THEN
         SET @user_name = (SELECT username FROM table2 WHERE user_special_id = 1);
     END IF;
     SELECT @user_name AS user_name, userLastName AS user_last_name FROM table2 WHERE user_name = @user_name;
     COMMIT;
     

   • Ansible调用：

     - name: "Execute SQL Script for User Details"
       community.mysql.mysql_script:
           login_host: "{{login_host}}"
           login_db: "{{login_db}}"
           script: get_user_details.sql
       register: user_details_reg
     

2. 自定义Ansible动作模块：
   • 适合需要高度自定义且需复用的场景，用Python编写模块可直接控制MySQL连接与事务生命周期，在单连接内完成多步查询和条件判断，返回结构化结果给Ansible，兼顾灵活性与Ansible的易用性。

综上，简单逻辑可通过SQL合并查询用mysql_query实现；复杂逻辑优先选择SQL脚本，需更高灵活性则考虑自定义动作模块。

内容的提问来源于stack exchange，提问作者A95