From 26a7a261154d727ca1e0756c04b8b941ebe62ed2 Mon Sep 17 00:00:00 2001 From: lyx0 Date: Tue, 26 Oct 2021 01:28:19 +0200 Subject: [PATCH] get name --- pkg/db/connect.go | 42 ++++++++++++++++++++++++++++-------------- 1 file changed, 28 insertions(+), 14 deletions(-) diff --git a/pkg/db/connect.go b/pkg/db/connect.go index 4922b45..ac15cf0 100644 --- a/pkg/db/connect.go +++ b/pkg/db/connect.go @@ -48,33 +48,47 @@ func Connect() { /* Insert channel */ - chnl := []interface{}{ - bson.D{{"channel", "nouryqt"}}, - bson.D{{"channel", "nourybot"}}, - } + // chnl := []interface{}{ + // bson.D{{"name", "nouryqt"}}, + // bson.D{{"name", "nourybot"}}, + // } - res, insertErr := collection.InsertMany(ctx, chnl) - if insertErr != nil { - log.Fatal(insertErr) - } - log.Info(res) + // res, insertErr := collection.InsertMany(ctx, chnl) + // if insertErr != nil { + // log.Fatal(insertErr) + // } + // log.Info(res) /* Iterate a cursor */ - cur, currErr := collection.Find(ctx, bson.D{}) + // var result bson.M + // err = collection.FindOne(ctx, bson.D{{}}).Decode(&result) + // if err != nil { + // if err == mongo.ErrNoDocuments { + // return + // } + + // panic(err) + // } + // log.Info(result["name"]) + + //------------------------------ + cur, currErr := collection.Find(ctx, bson.D{{}}) if currErr != nil { panic(currErr) } defer cur.Close(ctx) - var channels []Channel - if err = cur.All(ctx, &channels); err != nil { + var results []bson.M + if err = cur.All(ctx, &results); err != nil { panic(err) } - log.Info(channels) - + for _, result := range results { + fmt.Println(result["name"]) + } + //------------------------------ }