mongo 数据库操作

概述

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

准备条件

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

工具包说明

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

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

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

创建数据库连接

数据库的连接创建提供了两个方法,MustNewModelNewModel

方法说明

  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")

参考文献