drz5553
drz5553
2019-02-20 03:47

Mongo-Go-Driver无法连接

已采纳

So I am trying to use https://github.com/mongodb/mongo-go-driver to connect to a mongo database in golang.

Here is my connection handler:

var DB *mongo.Database

func CreateConnectionHandler()(*mongo.Database, error){
    fmt.Println("inside createConnection in database package")
    godotenv.Load()
    fmt.Println("in CreateConnectionHandler and SERVER_CONFIG: ")
    fmt.Println(os.Getenv("SERVER_CONFIG"))
    uri:=""
    if os.Getenv("SERVER_CONFIG")=="kubernetes"{
        fmt.Println("inside kubernetes db config")
        uri = "mongodb://patientplatypus:SUPERSECRETPASSDOOT@
               mongo-release-mongodb.default.svc.cluster.local:27017/
               platypusNEST?authMechanism=SCRAM-SHA-1"
    }else if os.Getenv("SERVER_CONFIG")=="compose"{
        fmt.Println("inside compose db config")
        uri = "mongodb://datastore:27017"
    }
    ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
    client, err := mongo.Connect(ctx, uri)
    if err != nil {
        return nil, fmt.Errorf("mongo client couldn't connect: %v", err)
    }
    DB := client.Database("platypusNEST")
    return DB, nil
}

And the error I am getting:

api         | database/connection.go:29:30: cannot use uri (type 
string) as type *options.ClientOptions in argument to mongo.Connect

So I tried replacing uri with the connection string like this:

client, err := mongo.Connect(ctx, "mongodb://datastore:27017")

But I still got the error.

Compare this with what is in the documentation:

ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
client, err := mongo.Connect(ctx, "mongodb://localhost:27017")

And it is exactly the same! I'm really not sure why there is this error. Any ideas?

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

2条回答

  • douye1940 douye1940 2年前

    To those who come searching - the docs are out of date as of this posting, but their latest push here: https://github.com/mongodb/mongo-go-driver/commit/32946b1f8b9412a6a94e68ff789575327bb257cf has them doing this with the connect:

    client, err := mongo.NewClient(options.Client().ApplyURI(uri))
    

    You will also now need to import the options package. Happy hacking.

    EDIT: thanks vcanales for finding this - you're a gentleman and a scholar.

    点赞 评论 复制链接分享
  • duan198727 duan198727 2年前

    In addition to the accepted answer - this snippet below may be improved by using an environment variable to pass in the Mongodb URL.

    package main
    
    import (
       "context
       "fmt"
       "time"
       "go.mongodb.org/mongo-driver/mongo"
       "go.mongodb.org/mongo-driver/mongo/options"
       "go.mongodb.org/mongo-driver/mongo/readpref"
    )
    
    func ConnectMongo() {
    
       var (
           client     *mongo.Client
           mongoURL = "mongodb://localhost:27017"
       )
    
       // Initialize a new mongo client with options
       client, err := mongo.NewClient(options.Client().ApplyURI(mongoURL))
    
       // Connect the mongo client to the MongoDB server
       ctx, _ := context.WithTimeout(context.Background(), 10*time.Second)
       err = client.Connect(ctx)
    
       // Ping MongoDB
       ctx, _ = context.WithTimeout(context.Background(), 10*time.Second)
       if err = client.Ping(ctx, readpref.Primary()); err != nil {
           fmt.Println("could not ping to mongo db service: %v
    ", err)
           return
       }
    
       fmt.Println("connected to nosql database:", mongoURL)
    
    }
    
    
    func main() {
    
       ConnectMongo()
    }
    

    More information on options and readpref respectively: https://docs.mongodb.com/manual/reference/method/cursor.readPref/index.html https://docs.mongodb.com/manual/core/read-preference/

    点赞 评论 复制链接分享