成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

使用Golang連接MongoDB方法詳解

數據庫 MongoDB
本文主要講解使用MongoDB官方驅動Go.mongodb.org/mongo-driver/mongo 連接MongoDB的方法。

MongoDB Driver For Golang

Golang連接MongoDB的庫有很多,本文主要講解使用MongoDB官方驅動
go.mongodb.org/mongo-driver/mongo 連接MongoDB的方法。

支持使用URI類型的字符串連接MongoDB,字符串格式支持兩種類型:

  • 標準連接字符串格式
  • DNS種子列表連接格式

接下來以標準連接字符串格式來做講解。

使用Golang連接MongoDB

首先講下標準連接字符串格式URI,格式為:

mongodb://[username:password@]host1[:port1][,...hostN[:portN]][/[defaultauthdb][?options]]

通過上篇文章《一文了解MongoDB的各種部署模式》我們知道Golang有幾種不同的部署方式,不同的部署方式對應的URI也有些不同。

單節點(standalone)模式的格式為:

mongodb://username:password@mongodb0.example.com:27017

副本集模式的格式為:

mongodb://username:password@mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl

對于副本集模式,需要指定副本集配置中列出的mongod實例的主機名,還需要指定replicaSet選項。

分片集群模式的格式為:

mongodb://username:password@mongos0.example.com:27017,mongos1.example.com:27017,mongos2.example.com:27017

不管哪種模式,如果用戶名或密碼包含如下字符:

: / ? # [ ] @

必須將這些字符轉換為百分比編碼。

獲取 mongo-driver/mongo 包:

go get go.mongodb.org/mongo-driver/mongo

示例代碼如下:

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"os"

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

func main() {
  // 這里uri使用副本集模式,如果你的MongoDB是其他模式,改為上面其他模式的uri即可
	uri := os.Getenv("mongodb://username:password@mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl")
	opts :=  options.Client().ApplyURI(uri)
	client, err := mongo.Connect(context.TODO(), opts)
	if err != nil {
		panic(err)
	}
	coll := client.Database("sample_mflix").Collection("movies")
	title := "Back to the Future"

	var result bson.M
	err = coll.FindOne(context.TODO(), bson.D{{"title", title}}).Decode(&result)
	if err == mongo.ErrNoDocuments {
		fmt.Printf("No document was found with the title %s\n", title)
		return
	}
	if err != nil {
		panic(err)
	}

	jsonData, err := json.MarshalIndent(result, "", "    ")
	if err != nil {
		panic(err)
	}
	fmt.Printf("%s\n", jsonData)
}

也可以設置連接池的最大和最小連接數,示例代碼如下:

opts :=  options.Client().ApplyURI(uri)
opts.MaxPoolSize = 20
opts.MinPoolSize = 10
責任編輯:姜華 來源: 今日頭條
相關推薦

2023-05-11 08:00:44

Golangsync.Pool

2023-07-26 08:58:45

Golang單元測試

2023-11-29 07:47:29

Golang函數

2023-07-03 08:52:31

容器Golang

2010-01-28 10:31:32

Android使用SD

2023-05-15 08:50:58

ContextGolang

2011-07-20 09:16:02

MongoDB索引稀疏索引

2009-12-22 16:36:38

WCF重載

2009-12-28 13:28:03

WPF視頻

2023-07-31 09:13:13

ValidatorGolang

2011-07-05 09:44:31

QT Mysql 亂碼

2021-09-06 13:15:16

golang chan技巧語言

2024-03-06 09:11:34

2010-06-01 19:55:30

SVN使用

2009-01-16 15:37:34

Oracle數據庫API

2010-06-03 17:38:03

Hadoop命令

2010-10-09 10:30:03

JS event

2009-12-02 16:04:44

PHP fsockop

2010-01-28 17:07:03

Android Gal

2022-11-12 18:32:50

Golangomitemptyjson
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板: 欧美一区免费 | 国产高清免费视频 | 欧美一级欧美三级在线观看 | 亚洲一区二区三区免费在线 | 天堂资源 | 亚洲精品免费视频 | 日韩一区二区在线视频 | 欧美在线日韩 | av黄色在线观看 | 欧美男人天堂 | 欧美日韩精品一区二区 | 国产精品欧美一区二区 | 91精品国产一区二区三区 | 国产午夜久久久 | 日韩中文字幕在线视频观看 | 国产精品国产精品国产专区不卡 | 亚洲一区二区三区免费 | 日本a视频| 91精品国产91久久久 | 久久9久 | 操网站| 亚洲精品视频一区 | 欧美久久久网站 | 日韩精品一区二区三区在线播放 | 精品国产一区二区三区在线观看 | 久久国产一区二区 | 色偷偷噜噜噜亚洲男人 | 黄色一级免费看 | 欧美日韩精品久久久免费观看 | 精品久久1| 蜜臀久久99精品久久久久野外 | japanhdxxxx裸体| 一级毛片色一级 | 欧美a在线 | 欧美 日韩 国产 成人 在线 | 国产精品美女久久久久aⅴ国产馆 | 成人在线观看免费视频 | 91视频网| 欧美日韩一区在线观看 | 久久久久国产一区二区三区四区 | 亚洲三级在线 |