代码拉取完成,页面将自动刷新
package impl
import (
"context"
"fmt"
"gitee.com/huyouba1/keyauth-g7/apps/token"
"github.com/infraboard/mcube/exception"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/mongo"
)
// Save Object
func (s *impl) save(ctx context.Context, ins *token.Token) error {
// s.col.InsertMany()
if _, err := s.col.InsertOne(ctx, ins); err != nil {
return exception.NewInternalServerError("inserted token(%s) document error, %s",
ins.AccessToken, err)
}
return nil
}
func (s *impl) get(ctx context.Context, id string) (*token.Token, error) {
filter := bson.M{"_id": id}
ins := token.NewDefaultToken()
if err := s.col.FindOne(ctx, filter).Decode(ins); err != nil {
if err == mongo.ErrNoDocuments {
return nil, exception.NewNotFound("access token %s not found", id)
}
return nil, exception.NewInternalServerError("find access token %s error, %s", id, err)
}
return ins, nil
}
func (s *impl) delete(ctx context.Context, ins *token.Token) error {
if ins == nil || ins.AccessToken == "" {
return fmt.Errorf("access token is nil")
}
// delete from book where id = ?
result, err := s.col.DeleteOne(ctx, bson.M{"_id": ins.AccessToken})
if err != nil {
return exception.NewInternalServerError("delete access token(%s) error, %s", ins.AccessToken, err)
}
if result.DeletedCount == 0 {
return exception.NewNotFound("access token %s not found", ins.AccessToken)
}
return nil
}
// UpdateByID, 通过主键来更新对象
func (s *impl) update(ctx context.Context, ins *token.Token) error {
// SQL update obj(SET f=v,f=v) where id=?
// s.col.UpdateOne(ctx, filter(), ins)
if _, err := s.col.UpdateByID(ctx, ins.AccessToken, ins); err != nil {
return exception.NewInternalServerError("update token(%s) document error, %s",
ins.AccessToken, err)
}
return nil
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。