Scala应用自动化执行CQL脚本失败，登录Cassandra时可正常运行

看起来你遇到了手动执行正常但自动化调用cqlsh失败的典型场景，我帮你梳理下核心问题和对应的解决方案：

核心诱因：命令拼接的转义陷阱 #

你的代码直接用字符串拼接生成shell命令，当用户名或密码包含特殊字符（比如单引号、空格、$、\等）时，shell会错误解析这些字符，导致cqlsh无法正确读取认证信息。手动执行时你直接输入的逻辑，和Scala通过command.!调用时的shell解析逻辑存在差异，这就是为啥手动能跑、自动化不行的关键原因。

最优解决方案：用ProcessBuilder安全传递参数 #

Scala的sys.process库支持用Seq传递命令参数，每个参数都是独立的，完全避免shell转义问题，这是最可靠的处理方式：

import scala.sys.process._

def executeScript(path: String, user: String, password: String, host: String): Unit = {
  // 将每个命令参数单独放入Seq，彻底避免shell解析特殊字符
  val cqlCommand = Seq(
    "cqlsh",
    "-f", path,          // 指定CQL脚本路径
    "-u", user,          // 认证用户名
    "-p", password,      // 认证密码，无需额外加引号
    host                 // Cassandra主机地址
  )

  // 执行命令并捕获退出码
  val exitCode = cqlCommand.!
  
  // 检查执行结果，非0则抛出异常提示
  if (exitCode != 0) {
    throw new RuntimeException(s"CQL脚本执行失败，退出码: $exitCode")
  }
}

这种方式下，不管密码里包含什么特殊字符，都会原封不动传递给cqlsh，完全不会被shell篡改解析逻辑。

备选方案：手动转义shell参数（不推荐） #

如果你一定要保留字符串拼接的方式，必须对所有参数进行shell转义，尤其是包含特殊字符的密码和用户名：

import scala.sys.process._

// 对shell参数进行转义，处理单引号等特殊字符
def escapeShellParam(param: String): String = {
  s"'${param.replace("'", "'\\''")}'"
}

def executeScript(path: String, user: String, password: String, host: String): Unit = {
  val escapedPath = escapeShellParam(path)
  val escapedUser = escapeShellParam(user)
  val escapedPassword = escapeShellParam(password)
  val escapedHost = escapeShellParam(host)

  val command = s"cqlsh -f $escapedPath -u $escapedUser -p $escapedPassword $escapedHost"
  val exitCode = command.!

  if (exitCode != 0) {
    throw new RuntimeException(s"脚本执行失败，退出码: $exitCode")
  }
}

不过这种方式容易遗漏边缘情况（比如反斜杠、换行符），所以优先推荐第一种方案。

额外排查技巧：捕获完整错误输出 #

你提供的异常信息被截断了，建议修改代码捕获完整的标准错误输出，这样能精准定位问题（比如是认证失败、主机连接不上、脚本语法错误还是权限问题）：

import scala.sys.process._

def executeScript(path: String, user: String, password: String, host: String): Unit = {
  val cqlCommand = Seq(
    "cqlsh",
    "-f", path,
    "-u", user,
    "-p", password,
    host
  )

  val stdout = new StringBuilder
  val stderr = new StringBuilder

  // 同时捕获标准输出和错误输出
  val exitCode = cqlCommand.!(ProcessLogger(stdout.append(_), stderr.append(_)))

  if (exitCode != 0) {
    throw new RuntimeException(
      s"CQL脚本执行失败，退出码: $exitCode\n" +
      s"标准输出: $stdout\n" +
      s"错误输出: $stderr"
    )
  }
}

环境排查要点 #

如果以上方案仍未解决问题，检查自动化任务的运行环境：

• 确认执行任务的用户有读取CQL脚本文件的权限，以及连接Cassandra集群的权限；
• 确认环境变量里能找到cqlsh，或者直接写绝对路径（比如/usr/bin/cqlsh）；
• 对比手动执行和自动化执行的PATH、CASSANDRA_CONF等环境变量，确保两者一致。

内容的提问来源于stack exchange，提问作者P. Jimenez