如何使用 dockercompose 连接到 CockroachDB?

如何使用 docker-compose 连接到 cockroachdb?

php小编草莓将为大家介绍如何使用docker-compose连接到CockroachDB。Docker-compose是一个用于定义和运行多个Docker容器的工具,而CockroachDB是一个分布式的关系型数据库管理系统。通过使用docker-compose,我们可以轻松地创建和管理CockroachDB容器,并将其与其他容器连接起来。在本文中,我们将详细介绍如何配置docker-compose文件以连接到CockroachDB,并提供一些实用的技巧和注意事项。无论您是初学者还是有经验的开发者,本文都将为您提供有用的指导,帮助您快速上手使用docker-compose连接到CockroachDB。

问题内容

我有一个 docker-compose 文件,我在其中本地部署数据库和 go 应用程序

services: node_1: container_name: node_1 image: cockroachdb/cockroach:latest command: start --insecure ports: - "26258:26258" - "8081:8081" networks: - network_cockroachdb node_2: container_name: node_2 image: cockroachdb/cockroach:latest hostname: node_2 ports: - "26257:26257" - "8080:8080" command: start --insecure --join=node_1 networks: - network_cockroachdb network_mode: 'host' app: build: . ports: - "12121:12121" environment: app_port: '12121' db_host: "node_2" db_port: 26257 db_user: root db_password: 123 db_database: mydb depends_on: - node_2 links: - node_2 networks: - network_cockroachdb networks: network_cockroachdb: driver: bridge登录后复制

  • 您对 depends_on 的使用实际上是无操作;您的应用程序很可能在数据库准备好处理连接之前尝试连接到数据库。

    事实上,在您运行 cockroach init 之前,您的数据库集群不会接受连接,因此您肯定会遇到此问题。

  • 您的撰写文件将无法启动 node_1,并出现以下错误:

    * ERROR: ERROR: no --join flags provided to 'cockroach start' * HINT: Consider using 'cockroach init' or 'cockroach start-single-node' instead * ERROR: no --join flags provided to 'cockroach start' HINT: Consider using 'cockroach init' or 'cockroach start-single-node' instead Failed running "start"登录后复制

  • 您的 node_1 端口转发不正确;容器中没有任何内容在侦听端口 8081。您可能需要类似以下内容:

    ports: - 8081:8080登录后复制

  • 最后,您没有指出示例代码中的 storage 模块来自何处,因此我无法使用它来进行测试。我编写了这个测试程序,其中包括一个等待数据库接受连接的循环:

    package main import ( "context" "fmt" "log" "os" "time" pgx "github.com/jackc/pgx/v4" ) func main() { connectionString := os.Getenv("db_uri") if connectionString == "" { connectionString = fmt.Sprintf("postgresql://%s@%s:%s/%s?sslmode=disable", os.Getenv("db_user"), os.Getenv("db_host"), os.Getenv("db_port"), os.Getenv("db_database"), ) } var conn *pgx.Conn var err error for { conn, err = pgx.Connect(context.Background(), connectionString) if err == nil { break } log.Printf("connection failed (%v); will retry...", err) time.Sleep(1 * time.Second) } log.Printf("connected to database") var value int if err := conn.QueryRow(context.Background(), "select 1").Scan(&value); err != nil { panic(err) } fmt.Printf("All done.n") }登录后复制