import (
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
// initMongo β Initialize MongoDB Client
func initMongo(ctx context.Context) *mongo.Client {
// MongoDB https://www.digitalocean.com/community/tutorials/how-to-use-go-with-mongodb-using-the-mongodb-go-driver-ru
mongoClientOptions := options.Client().ApplyURI("mongodb://localhost:27017/")
client, err := mongo.Connect(ctx, mongoClientOptions)
if err != nil {
return nil
}
// Check Connect
err = client.Ping(ctx, nil)
if err != nil {
return nil
}
return client
}
// Π‘ΠΎΠ·Π΄Π°Π΅ΠΌ Π±ΠΈΠ±Π»ΠΈΠΎΡΠ΅ΠΊΡ storer ΠΈ Π² Π½Π΅ΠΉ ΠΊΠΎΠ»Π»Π΅ΠΊΡΠΈΡ sources
client := initMongo(context.TODO())
var collection := client.Database("storer").Collection("sources")