- 总结
安装配置MongoDB驱动
安装驱动
goget -u github.com/mongodb/mongo-go-driver初始化模块
gomod init 模块名称执行go mod tidy
gomod tidy导入驱动
import( "context" "go.mongodb.org/mongo-driver/bson"//BOSN解析包 "go.mongodb.org/mongo-driver/mongo"//MongoDB的Go驱动包 "go.mongodb.org/mongo-driver/mongo/options")获得数据库连接
初始化连接
packagemainimport( "context" "fmt" "go.mongodb.org/mongo-driver/mongo" "go.mongodb.org/mongo-driver/mongo/options")varclient *mongo.ClientfuncinitDB() (err error) { // 设置客户端连接配置 clientOptions := options.Client().ApplyURI("mongodb://ip:port") // 连接到MongoDB client, err = mongo.Connect(context.TODO(), clientOptions) iferr != nil{ returnerr } // 检查连接 err = client.Ping(context.TODO(), nil) iferr != nil{ returnerr } returnnil}funcmain() { err := initDB() // 调用输出化数据库的函数 iferr != nil{ fmt.Printf("初始化失败！,err:%v\n", err) return }else{ fmt.Println("Connected to MongoDB!") }}连接MongoDB的Go驱动程序中有两大类型表示BSON数据：D和Raw。
类型D家族被用来简洁地构建使用本地Go类型的BSON对象。这对于构造传递给MongoDB的命令特别有用。D家族包括四类:
D：一个BSON文档。这种类型应该在顺序重要的情况下使用，比如MongoDB命令。
bson.D{{"foo", "bar"}, {"hello", "world"}, {"pi", 3.14159}}M：一张无序的map。它和D是一样的，只是它不保持顺序。
bson.M{"foo": "bar", "hello": "world", "pi": 3.14159}A：一个BSON数组。
bson.A{"hello", "world", 3.14159, bson.D{{"abcde", 12345}}}E：D里面的一个元素。
要使用BSON，需要先导入下面的包：
import"go.mongodb.org/mongo-driver/bson"Raw类型家族用于验证字节切片。你还可以使用Lookup()从原始类型检索单个元素。如果你不想要将BSON反序列化成另一种类型的开销，那么这是非常有用的。
数据库操作
添加文档
添加单个文档
使用collection.InsertOne()方法插入一条文档记录：
funcinsertOne(s interface{}) (err error) { collection := client.Database("datebase").Collection("collection") insertResult, err := collection.InsertOne(context.TODO(), s) iferr != nil{ returnerr } fmt.Println("Inserted a single document: ", insertResult.InsertedID) returnnil}测试：
s := struct{name string age int}{"tom", 20}err := insertOne(s)iferr != nil{ fmt.Printf("添加文档失败！,err:%v\n", err)}添加多个文档
使用collection.InsertMany()方法插入多条文档记录：
funcinsertMore(s []interface{}) (err error) { //students := []interface{}{s2, s3} collection := client.Database("datebase").Collection("collection") insertManyResult, err := collection.InsertMany(context.TODO(), s) iferr != nil{ returnerr } fmt.Println("Inserted multiple documents: ", insertManyResult.InsertedIDs) returnnil}测试：
typeStudent struct{ name string age int}s1 := Student{name: "tom", age: 20}s2 := Student{name: "kite", age: 21}s3 := Student{name: "rose", age: 22}ss := []interface{}{s1, s2, s3}insertMore(ss)iferr != nil{ fmt.Printf("添加多个文档失败！,err:%v\n", err)}查找文档
funcfind() (err error){ ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second) defercancel() collection := client.Database("datebase").Collection("collection") cur, err := collection.Find(ctx, bson.D{}) iferr != nil{ returnerr } defercur.Close(ctx) forcur.Next(ctx) { varresult bson.D err := cur.Decode(&result) iferr != nil{ returnerr } fmt.Printf("result: %v\n", result) } iferr := cur.Err(); err != nil{ returnerr } returnnil}更新文档
funcupdate() (err error) { ctx := context.TODO() deferclient.Disconnect(ctx) c := client.Database("datebase").Collection("collection") update := bson.D{{"$set", bson.D{{"attr1", "value1"}, {"attr2", "value2"}}}} ur, err := c.UpdateMany(ctx, bson.D{{"old_attr1", "old_value1"}}, update) iferr != nil{ returnerr } fmt.Printf("ur.ModifiedCount: %v\n", ur.ModifiedCount) returnnil}删除文档
funcdel() (err error) { c := client.Database("datebase").Collection("collection") ctx := context.TODO() dr, err := c.DeleteMany(ctx, bson.D{{"attr1", "value1"}}) iferr != nil{ returnerr } fmt.Printf("ur.ModifiedCount: %v\n", dr.DeletedCount) returnnil}总结
到此这篇关于golang连接MongoDB数据库及数据库操作指南的文章就介绍到这了