diff options
author | Mike Crute <mike@crute.us> | 2021-11-15 23:07:05 -0800 |
---|---|---|
committer | Mike Crute <mike@crute.us> | 2021-11-15 23:07:05 -0800 |
commit | 27b83d68d1419eed174e87de39a1351cd21d0375 (patch) | |
tree | 85d24c4621ba7fad478513758864686cc7fcc962 | |
parent | b47bd286aad7c113a87081c71f222ee8933a0256 (diff) | |
download | golib-27b83d68d1419eed174e87de39a1351cd21d0375.tar.bz2 golib-27b83d68d1419eed174e87de39a1351cd21d0375.tar.xz golib-27b83d68d1419eed174e87de39a1351cd21d0375.zip |
db: add FindAllByFilter
-rw-r--r-- | db/mongodb/client.go | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/db/mongodb/client.go b/db/mongodb/client.go index 8180991..963860e 100644 --- a/db/mongodb/client.go +++ b/db/mongodb/client.go | |||
@@ -58,8 +58,8 @@ func (m *Mongo) Collection(name string) *mongo.Collection { | |||
58 | return m.db.Collection(name) | 58 | return m.db.Collection(name) |
59 | } | 59 | } |
60 | 60 | ||
61 | func (m *Mongo) FindAll(ctx context.Context, cn string, out interface{}) error { | 61 | func (m *Mongo) FindAllByFilter(ctx context.Context, cn string, filter interface{}, out interface{}) error { |
62 | res, err := m.db.Collection(cn).Find(ctx, bson.D{}) | 62 | res, err := m.db.Collection(cn).Find(ctx, filter) |
63 | if err != nil { | 63 | if err != nil { |
64 | return err | 64 | return err |
65 | } | 65 | } |
@@ -71,6 +71,10 @@ func (m *Mongo) FindAll(ctx context.Context, cn string, out interface{}) error { | |||
71 | return nil | 71 | return nil |
72 | } | 72 | } |
73 | 73 | ||
74 | func (m *Mongo) FindAll(ctx context.Context, cn string, out interface{}) error { | ||
75 | return m.FindAllByFilter(ctx, cn, bson.D{}, out) | ||
76 | } | ||
77 | |||
74 | func (m *Mongo) FindOneById(ctx context.Context, cn string, id string, out interface{}) error { | 78 | func (m *Mongo) FindOneById(ctx context.Context, cn string, id string, out interface{}) error { |
75 | if err := m.db.Collection(cn).FindOne(ctx, bson.M{"_id": id}).Decode(out); err != nil { | 79 | if err := m.db.Collection(cn).FindOne(ctx, bson.M{"_id": id}).Decode(out); err != nil { |
76 | return err | 80 | return err |