chdb-go库建库/建表时未返回已存在错误的问题求助

一、优先方案：使用ClickHouse原生语法避免错误 #

直接在SQL语句中添加IF NOT EXISTS，无论目标库/表是否存在，都不会触发错误或输出调试信息（存在则跳过创建，不存在则正常创建）：

Go示例 #

// 创建数据库（存在则跳过）
a := db.Query("CREATE DATABASE IF NOT EXISTS db")
// 创建表同理
db.Query("CREATE TABLE IF NOT EXISTS db.my_table (id Int64, name String) ENGINE = MergeTree() ORDER BY id")

Python示例 #

# 创建数据库（存在则跳过）
result = db.query("CREATE DATABASE IF NOT EXISTS db")
# 创建表同理
db.query("CREATE TABLE IF NOT EXISTS db.my_table (id Int64, name String) ENGINE = MergeTree() ORDER BY id")

这种方法从业务逻辑上规避了错误场景，代码简洁且无需额外捕获逻辑，是最推荐的处理方式。

二、捕获stderr输出获取错误信息 #

如果需要针对“目标已存在”的场景做特殊处理，可以通过重定向标准错误流（stderr）来捕获chdb输出的调试信息：

Go语言实现 #

package main

import (
    "bytes"
    "fmt"
    "os"
    "chdb.io/chdb"
)

func main() {
    db, err := chdb.NewSession("a")
    if err != nil {
        fmt.Println("初始化会话失败:", err)
        return
    }
    fmt.Print("\nburası\n")

    // 保存原stderr，创建管道用于捕获输出
    oldStderr := os.Stderr
    r, w, _ := os.Pipe()
    os.Stderr = w

    // 执行SQL
    _ = db.Query("CREATE DATABASE db")

    // 恢复原stderr并读取捕获的内容
    w.Close()
    os.Stderr = oldStderr
    var errBuf bytes.Buffer
    errBuf.ReadFrom(r)
    errMsg := errBuf.String()

    // 处理错误信息
    if errMsg != "" {
        fmt.Println("捕获到错误:", errMsg)
        // 根据错误标识判断是否为“已存在”错误
        if contains(errMsg, "DATABASE_ALREADY_EXISTS") {
            fmt.Println("数据库已存在，执行后续逻辑...")
        }
    } else {
        fmt.Println("数据库创建成功")
    }

    db.Query("USE db")
}

// 辅助函数：判断字符串是否包含子串
func contains(s, substr string) bool {
    return len(s) >= len(substr) && s[len(s)-len(substr):] == substr
}

Python语言实现 #

import chdb
from contextlib import redirect_stderr
import io

# 创建会话
db = chdb.Session("a")

# 准备捕获stderr
err_buffer = io.StringIO()
with redirect_stderr(err_buffer):
    # 执行SQL
    db.query("CREATE DATABASE db")

# 获取错误信息
error_msg = err_buffer.getvalue()
if error_msg:
    print(f"捕获到错误: {error_msg}")
    # 判断是否是数据库已存在的错误
    if "DATABASE_ALREADY_EXISTS" in error_msg:
        print("数据库已存在，执行后续操作...")
else:
    print("数据库创建成功")

内容的提问来源于stack exchange，提问作者İkram MERT