mongo 数据库操作

概述

通过 mongodb 的 uri 创建个可用的 mongodb 数据库连接。

准备条件

  1. 完成 golang 安装
  2. 自行搭建一个 mongo server，我们以 mongodb://admin:123456@localhost 为例

工具包说明

go-zero 包含两个 mongodb 工具包，其中 mongo 包已经废弃，后续不再支持维护，推荐使用 mon 工具包。

本章节的所有介绍都是基于 mon 工具包。

同时我们建议使用 byctl 来生成 mongo model，进行业务开发。

创建数据库连接

数据库的连接创建提供了两个方法，MustNewModel 和 NewModel。

方法说明

  1. MustNewModel
  1. 函数签名: 
  2.     MustNewModel func(uri, db, collection string, opts ...Option) *Model 
  3. 说明: 
  4.     1. 当 mongodb 连接创建存在问题时，会直接进退退出，输出错误日志。
  5.     2. 当 db 和 collection 不存在时，会创建 db 和 collection。
  6. 入参:
  7.     1. uri: mongodb uri (example: mongodb://<user>:<password>@<host>:<port>)
  8.     2. db: 数据库名
  9.     3. collection: 集合名
  10. 返回值:
  11.     1. *Model: 连接管理对象
  1. NewModel
  1. 函数签名: 
  2.     NewModel func(uri, db, collection string, opts ...Option) (*Model, error)
  3. 说明: 
  4.     1. 当 db 和 collection 不存在时，会创建 db 和 collection。
  5. 入参:
  6.     1. uri: mongodb uri (example: mongodb://<user>:<password>@<host>:<port>)
  7.     2. db: 数据库名
  8.     3. collection: 集合名
  9. 返回值:
  10.     1. *Model: 连接管理对象
  11.     2. error: 创建错误

代码示例

  1. conn := mon.MustNewModel("mongodb://<user>:<password>@<host>:<port>", "db", "collection")

参考文献