Scala用sys.process._调用ClickHouse报错及替代方案咨询

错误原因分析 #

你遇到的Positional options are not supported错误，是因为Scala的sys.process.Process直接传入带单引号的字符串时，不会像shell那样解析引号。"clickhouse-client -q 'show databases'"会被拆分成三个参数：clickhouse-client、-q、'show databases'（包含单引号），而ClickHouse Client会把带引号的内容当成额外的位置参数，导致报错。

解决方案1：拆分命令为参数列表 #

直接使用Process的多参数重载，把命令和每个参数分开传递，跳过shell解析环节，参数会被正确传递给ClickHouse Client：

import sys.process._

val clickhouseClient = Process("clickhouse-client", "-q", "show databases").!!
println(s"************************************************** ${clickhouseClient}")

也可以用Seq形式更清晰地组织参数：

val result = Process(Seq("clickhouse-client", "-q", "show databases")).!!
println(result)

解决方案2：通过bash执行shell命令（等效Go的实现） #

如果需要执行复杂的shell逻辑（比如管道、变量替换、脚本块），可以像Go那样调用bash -c来执行完整的shell命令：

import sys.process._
import java.io.StringBuilder

// 等效Go的脚本模板
val submitCommand = """
#!/bin/bash
set -euf -o pipefail
cat %s | clickhouse-client --host=9000 \
                           --query="INSERT INTO some_table Format some_format" \
                           --stacktrace
""".stripMargin

// 替换模板中的%s为实际文件路径
val actualCommand = submitCommand.replace("%s", "/path/to/your/data.file")

// 执行命令并捕获输出和错误信息
val stdout = new StringBuilder
val stderr = new StringBuilder
val exitCode = Process(Seq("bash", "-c", actualCommand))
  .!(ProcessLogger(stdout.append(_), stderr.append(_)))

println(s"Exit code: $exitCode")
println(s"Stdout: ${stdout.toString()}")
println(s"Stderr: ${stderr.toString()}")

更优方案：使用ClickHouse官方客户端库 #

如果需要频繁和ClickHouse交互，直接调用命令行不是最优解，建议使用Scala的ClickHouse官方客户端库（如com.clickhouse:clickhouse-scala-client），可以更优雅地执行查询、插入操作，避免命令行解析的问题：

import com.clickhouse.client._
import com.clickhouse.client.config._

// 创建ClickHouse客户端实例
val client = ClickHouseClient.newInstance(ClickHouseProtocol.HTTP)
val config = ClickHouseConfig.newBuilder()
  .setHost("localhost")
  .setPort(8123) // HTTP默认端口8123，TCP默认9000
  .build()

// 执行查询并获取结果
val result = client.query(config, "show databases")
  .format(ClickHouseFormat.TabSeparated)
  .executeAndWait()
  .stream()
  .toList

println(result)

// 关闭客户端
client.close()

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