Golang中数据库查询无结果的原因排查方案合理性咨询

原代码通过user_uuid和role查询用户所属组织下状态正常的服务器域名，当查询无结果时，希望区分是user_uuid（组织不存在）、role（无对应服务器）还是服务器全部宕机导致的问题，同时确认修改后的查询方案是否可行。

你的修改方案存在的问题 #

1. 逻辑偏离原需求：
   • 第一个EXISTS查询错误关联了servers表，若用户存在所属组织但该组织无服务器，会被误判为ORGANIZATION_NOTFOUND；
   • 后续的servers查询未关联用户所属组织，变成了查询全局所有对应role的服务器，完全偏离原代码“用户所属组织下的服务器”的逻辑。
2. 变量绑定与扫描错误：
   查询结果字段是res，但代码中用Scan(&accessPoint)，导致res变量未被赋值，后续的switch判断完全失效，同时accessPoint也无法拿到正确的服务器域名。
3. 冗余查询与一致性风险：
   多次重复查询相同条件的servers数据，不仅降低性能，还可能因查询期间数据变化导致结果不一致。

是否需要区分错误原因？ #

如果业务需要给用户返回明确的错误提示（比如“您的组织不存在”、“该角色无可用服务器”等），那么区分错误原因是有必要的；如果只需要返回“无可用服务器”这类统一提示，就无需额外区分。

可行的解决方案 #

方案一：分步查询（逻辑清晰，易维护） #

通过三次独立查询逐步排查问题，适合对性能要求不高但需要明确错误分支的场景：

var accessPoint string
var orgSeq int

// 1. 检查用户是否存在并关联有效组织
err := db.Raw(`
    SELECT o.seq
    FROM sso_user u
    INNER JOIN organization o ON u.organization = o.organization
    WHERE u.user_uuid = ?
`, d.UserUuid).Scan(&orgSeq).Error
if err != nil {
    db.Rollback()
    return "", configs.ErrNotFoundOrg
}

// 2. 检查该组织下是否有对应role的服务器
var hasRoleServer bool
err = db.Raw(`
    SELECT EXISTS(
        SELECT 1 FROM servers s
        WHERE s.org_seq = ? AND s.role = ?
    )
`, orgSeq, role).Scan(&hasRoleServer).Error
if err != nil {
    db.Rollback()
    return "", fmt.Errorf("check role server: %w", err)
}
if !hasRoleServer {
    db.Rollback()
    return "", configs.ErrNotFoundRole
}

// 3. 查询该组织下对应role且状态正常的服务器
err = db.Raw(`
    SELECT s.domain
    FROM servers s
    WHERE s.org_seq = ? AND s.role = ? AND s.status = 1
    ORDER BY rand() LIMIT 1
`, orgSeq, role).Scan(&accessPoint).Error
if err != nil {
    db.Rollback()
    return "", configs.ErrServerNotRunning
}

db.Commit()
return accessPoint, nil

方案二：单查询返回多状态（减少DB调用） #

通过一次查询返回组织存在性、角色服务器存在性、活跃服务器存在性三个标识，同时获取服务器域名：

var (
    accessPoint string
    orgExists   bool
    roleExists  bool
    hasActive   bool
)

err := db.Raw(`
    SELECT
        COALESCE(s.domain, '') AS domain,
        EXISTS(
            SELECT 1 FROM sso_user u
            INNER JOIN organization o ON u.organization = o.organization
            WHERE u.user_uuid = ?
        ) AS org_exists,
        EXISTS(
            SELECT 1 FROM servers s
            INNER JOIN organization o ON s.org_seq = o.seq
            INNER JOIN sso_user u ON u.organization = o.organization
            WHERE u.user_uuid = ? AND s.role = ?
        ) AS role_exists,
        EXISTS(
            SELECT 1 FROM servers s
            INNER JOIN organization o ON s.org_seq = o.seq
            INNER JOIN sso_user u ON u.organization = o.organization
            WHERE u.user_uuid = ? AND s.role = ? AND s.status = 1
        ) AS has_active
    FROM servers s
    INNER JOIN organization o ON s.org_seq = o.seq
    INNER JOIN sso_user u ON u.organization = o.organization
    WHERE u.user_uuid = ? AND s.role = ? AND s.status = 1
    ORDER BY rand() LIMIT 1
`, d.UserUuid, d.UserUuid, role, d.UserUuid, role, d.UserUuid, role).Scan(&accessPoint, &orgExists, &roleExists, &hasActive).Error

if err != nil {
    db.Rollback()
    return "", fmt.Errorf("get access point: %w", err)
}

if !orgExists {
    db.Rollback()
    return "", configs.ErrNotFoundOrg
}
if !roleExists {
    db.Rollback()
    return "", configs.ErrNotFoundRole
}
if !hasActive {
    db.Rollback()
    return "", configs.ErrServerNotRunning
}

db.Commit()
return accessPoint, nil

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