php小编西瓜在本文中将带您了解如何使用Postgres和MongoDB进行CRUD操作。Postgres是一种关系型数据库，而MongoDB则是一种文档型数据库。CRUD操作指的是创建（Create）、读取（Read）、更新（Update）和删除（Delete）数据的过程。通过结合使用这两种不同类型的数据库，您可以根据不同的需求选择最适合的数据库进行数据操作，以提高效率和灵活性。接下来，让我们一起来探索这两种数据库在CRUD操作中的应用吧！
问题内容
我对 Go 和后端还很陌生，并且正在参加 Go 实习计划。我们构建了一个连接到 psql 数据库的 CRUD，现在我被告知连接 mongoDB，我们将其用于开发，而 PSQL 将用于生产。我是否必须从头开始创建用于 mongo 的新处理程序，或者我可以使用相同的处理程序并以某种方式确定正在使用的数据库类型并相应地使用相应的逻辑吗？例如，我有一个用于用户注册端点的处理程序：
func (ctrl *UserController) Register(c *gin.Context) { var user models.User if err := c.BindJSON(&user); err != nil { c.AbortWithStatusJSON(http.StatusUnprocessableEntity, gin.H{ "error": true, "message": err.Error(), }) return } err := ctrl.userService.Register(&user) if err != nil { c.AbortWithStatusJSON(http.StatusUnprocessableEntity, gin.H{ "error": true, "message": err.Error(), }) return } c.JSON(http.StatusCreated, gin.H{ "message": "successfully created an user", })}func (svc *UserService) Register(user *models.User) error { if svc.userRepo.CheckIfEmailExists(user.Email) { return errors.New("user already registered") } hash, err := svc.generatePasswordHash(user.Password) if err != nil { return errors.New("err can't register user") } user.Password = hash return svc.userRepo.Insert(user)}func (repo *UserRepository) CheckIfEmailExists(mail string) bool { var user models.User err := repo.dbClient.Debug().Model(models.User{}).Where("email = ?", mail).Find(&user).Error return errors.Is(err, gorm.ErrRecordNotFound)}func (repo *UserRepository) Insert(user *models.User) error { err := repo.dbClient.Debug().Model(models.User{}).Create(user).Error if err != nil { log.Printf("failed to insert user: %v", err) return err } return nil}
登录后复制
我为 mongo 构建了插入、注册和 CheckIfEmailExists 函数：
func (repo *UserRepository) InsertInMongo(user *models.UserB) error { coll := repo.mongoClient.DB.Collection("users") _, err := coll.InsertOne(context.TODO(), user) if err != nil { log.Printf("failed to insert user: %v", err) return err } return nil}func (svc *UserService) RegisterToMongo(user *models.UserB) error { check := svc.userRepo.CheckIfEmailExistsInMongo(user.Email) if check { return errors.New("user already registered") } hash, err := svc.generatePasswordHash(user.Password) if err != nil { return errors.New("err can't register user") } user.Password = hash return svc.userRepo.InsertInMongo(user)}func (repo *UserRepository) CheckIfEmailExistsInMongo(email string) bool { coll := repo.mongoClient.Collection filter := bson.D{{Key: "email", Value: email}} count, err := coll.CountDocuments(context.TODO(), filter) if err != nil { panic(err) } if count != 0 { return true } return false}
登录后复制
解决方法
您没有提供如何创建 UserService 的代码。
理想情况下，您应该有一个如下所示的界面：
type UserRepository interface { CheckIfEmailExists(mail string) bool Insert(user *models.User) error …}
登录后复制
然后，UserService 应该像这样创建：
// We use the interface as paramfunc NewUserService(userRepo UserRepository) UserService { return UserService{ UserRepo: userRepo }}
登录后复制
并且您将有两个单独的存储库，都实现 UserRepository 接口 – 这意味着它们应该具有与接口相同的名称和相同签名（参数、返回类型）的方法：
mongo_user_repository.go
Type MongoUserRepo struct { …}func (repo MongoUserRepo) CheckIfEmailExists(mail string) bool { … some mongo logic here}func (repo MongoUserRepo) Insert(user *models.User) error { … some mongo logic here}
登录后复制
postgres_user_repository.go
type PostgresUserRepo struct { …}func (repo PostgresUserRepo) CheckIfEmailExists(mail string) bool { … some postgres logic here}func (repo PostgresUserRepo) Insert(user *models.User) error { … some postgres logic here}
登录后复制
您可以根据用例传递其中任何一个，如下面的（非常糟糕的）示例：
main.go
…var userService UserServiceif os.Getenv(“environment”) == “prod” { userService = NewUserService(postgreUserRepo)} else if os.Getenv(“environment”) == “dev” { userService = NewUserService(mongoUserRepo)}
登录后复制
以上就是使用 Postgres 和 MongoDB 进行 CRUD？的详细内容，更多请关注【创想鸟】其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2357182.html
