如何根据SQL查询结果控制Jenkins Pipeline的成功或失败？

完全可以实现这个需求，核心思路是先捕获SQL查询的返回结果，再新增一个判断阶段，根据结果用Jenkins Pipeline的内置函数控制构建状态。

具体步骤与代码示例 #

1. 捕获SQL查询结果 #

首先要确保能获取到查询返回的Pass/Fail值，而不是仅输出到控制台。可以通过sh步骤的returnStdout: true参数捕获命令执行的输出，再处理掉多余的空格、换行符保证判断准确。

2. 新增判断阶段 #

在获取结果后，新增一个阶段，用条件判断语句检查结果：如果是Fail，调用error()函数终止Pipeline并标记为失败；如果是Pass，则继续执行后续流程。

以下是完整的Pipeline示例（以MySQL为例，其他数据库可调整执行命令）：

pipeline {
    agent any

    stages {
        stage('执行SQL查询') {
            steps {
                script {
                    // 建议用Jenkins凭据管理存储数据库密码，避免明文暴露
                    def dbPassword = credentials('mysql-db-password')
                    
                    // 执行SQL查询并捕获结果，-s参数表示静默模式，只返回数据
                    def sqlResult = sh(
                        script: "mysql -u db-user -p\"${dbPassword}\" -D your-db-name -s -e \"SELECT result FROM check_table WHERE id = 1;\"",
                        returnStdout: true
                    ).trim()

                    // 将结果存入环境变量，供后续阶段使用
                    env.SQL_CHECK_RESULT = sqlResult
                    echo "SQL查询结果: ${sqlResult}"
                }
            }
        }

        stage('校验查询结果') {
            steps {
                script {
                    def result = env.SQL_CHECK_RESULT
                    if (result == 'Fail') {
                        error("SQL校验未通过，返回结果为${result}，Pipeline终止")
                    } else if (result == 'Pass') {
                        echo "SQL校验通过，返回结果为${result}，继续执行后续流程"
                    } else {
                        error("SQL查询结果异常，既不是Pass也不是Fail: ${result}")
                    }
                }
            }
        }

        // 后续需要执行的阶段（仅在校验通过时才会运行）
        stage('后续业务阶段') {
            steps {
                echo "进入正常业务流程..."
            }
        }
    }
}

关键说明 #

• 数据库命令适配：如果使用PostgreSQL，将sh中的命令替换为psql的对应格式：

  psql -U db-user -d your-db-name -t -c "SELECT result FROM check_table WHERE id = 1;"
  

  -t参数用于只返回纯数据，去掉表头和格式字符。
• 凭据安全：务必使用Jenkins的凭据管理功能存储数据库账号密码，避免在Pipeline代码中明文写敏感信息。
• 结果处理：trim()函数用于去除输出中的换行、空格等多余字符，确保和Pass/Fail的字符串匹配准确。

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