在调用 Execute 之前，插入操作必须有一个部署集

Question

我有一个运行 MongoDB 的 AWS 实例。我正在尝试做一个小的 db 操作，当下面包含的文件被写入单个 go 文件时，它似乎可以工作。当我尝试拆分它时，出现以下错误

在调用 Execute 之前，插入操作必须有一个部署集

拆分文件如下所示

connect.go

package db

import (
	"context"
	"fmt"
	"log"

	"go.mongodb.org/mongo-driver/mongo"
	"go.mongodb.org/mongo-driver/mongo/options"
)

var Client1 mongo.Client

func Connect() {
	// Set client options
	clientOptions := options.Client().ApplyURI("remote_url")

	// Connect to MongoDB
	Client1, err := mongo.Connect(context.TODO(), clientOptions)

	if err != nil {
		log.Fatal(err)
	}

	// Check the connection
	err = Client1.Ping(context.TODO(), nil)

	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("Connected to MongoDB!")
}

func main() {
	fmt.Println("Connection to MongoDB done.")
}

main.go

package main

import (
	"context"
	"fmt"
	"log"

	"db"

	"go.mongodb.org/mongo-driver/bson"
)

// You will be using this Trainer type later in the program
type Trainer struct {
	Name string
	Age  int
	City string
}

func main() {

	db.Connect()
	collection := db.Client1.Database("test2").Collection("trainers")
	_ = collection

	fmt.Println("Created collection", _)

	ash := Trainer{"Ash", 10, "Pallet Town"}
	// misty := Trainer{"Misty", 10, "Cerulean City"}
	// brock := Trainer{"Brock", 15, "Pewter City"}

	insertResult, err := collection.InsertOne(context.TODO(), ash)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println("Inserted a single document: ", insertResult)

	err = db.Client1.Disconnect(context.TODO())

	if err != nil {
		log.Fatal(err)
	}
	fmt.Println("Connection to MongoDB closed.")
}

它们被放置在以下结构中

/src -> main.go
/src -> /db/connect.go

Answer 1

我相信您的问题是由 variable shadowing (wiki) 引起的，并且您正在初始化一个局部变量而不是全局 mongo.Client 对象，因此您得到的是 throwing the error。

它发生在您的 connect.go 文件中，您在该文件中定义了两个具有相同名称的不同 Client1 变量：

1. 一个在全球范围内

2. Connect() 中的另一个在调用 mongo.Connect() 时被声明+初始化

   var Client1 mongo.Client // Client1 at global scope
   
   func Connect() {
       // Set client options
       clientOptions := options.Client().ApplyURI("remote_url")
   
       // Connect to MongoDB
       Client1, err := mongo.Connect(context.TODO(), clientOptions) // Client1 at local scope within Connect()
   

这导致全局范围的那个永远不会被初始化，所以 main.go 在尝试使用它时会崩溃，因为它是 nil。

有几种方法可以解决这个问题，例如在本地范围内为变量使用不同的名称并将客户端分配给全局范围：

    var Client1 mongo.Client

    func Connect() {
        // Set client options
        clientOptions := options.Client().ApplyURI("remote_url")

        // Connect to MongoDB
        Client1Local, err := mongo.Connect(context.TODO(), clientOptions)
        Client1 = *Client1Local

或者避免声明局部变量，直接在全局范围内初始化：

    var Client1 *mongo.Client // Note that now Client1 is of *mongo.Client type

    func Connect() {
        // Set client options
        clientOptions := options.Client().ApplyURI("remote_url")

        // Connect to MongoDB
        var err error
        Client1, err = mongo.Connect(context.TODO(), clientOptions) // Now it's an assignment, not a declaration+assignment anymore

更多关于 Golang 的变量阴影讨论在Issue#377 proposal

Answer 2

尝试包含类似，因为您省略了 db 目录，这可能是问题

import "db/db"

connect.go中还有main()，一个项目应该只有一个主包和main()函数。

---------------- Try what is discussed below exactly ------------

好的，这是我的测试设置，其代码目录树与您的类似：

[user@devsetup src]$ tree test
        test
        ├── dbtest
        │   └── db
        │       └── connect.go
        ├── main // This is executable file
        └── main.go

    2 directories, 3 files

在 connect.go 中我没有改变任何东西，只是删除了上面提到的 main()。 确保只使用导出的函数和变量，导出的函数/变量以大写字母开头。 在 main.go 中看起来像下面的代码。 * 进入 dbtest/db 目录并运行go install 命令。然后转到项目目录，即这里的test，然后运行go build main.go or go build .

package main

import (
        "context"
        "fmt"
        "log"

        "test/dbtest/db"

        // "go.mongodb.org/mongo-driver/bson"
)

// You will be using this Trainer type later in the program
type Trainer struct {
        Name string
        Age  int
        City string
}

func main() {

        db.Connect()
        collection := db.Client1.Database("test2").Collection("trainers")
        _ = collection

        // fmt.Println("Created collection", _)

        ash := Trainer{"Ash", 10, "Pallet Town"}
        // misty := Trainer{"Misty", 10, "Cerulean City"}
        // brock := Trainer{"Brock", 15, "Pewter City"}

        insertResult, err := collection.InsertOne(context.TODO(), ash)
        if err != nil {
                log.Fatal(err)
        }

        fmt.Println("Inserted a single document: ", insertResult)

        err = db.Client1.Disconnect(context.TODO())

        if err != nil {
                log.Fatal(err)
        }
        fmt.Println("Connection to MongoDB closed.")
}

这是我的二进制输出，因为我没有给出任何输入 url，它抛出了一个错误。似乎工作。我在 main.go 中注释掉了一个包和一行

[user@devsetup test]$ ./test
20xx/yy/zz aa:bb:cc error parsing uri: scheme must be "mongodb" or "mongodb+srv"