mongodb

README

Go MongoDB

---

Description

This is a simple package to connect to a MongoDB database.

Connection and Get Collection Usage

package main

import (
    "github.com/root27/go-mongodb"
)

func main(){
     

	db ,err:= mongodb.Connect("mongourl") // mongourl is the env variable name

    if err != nil {
        panic(err)
    }

    // db is a pointer to a mongo.Database
    // use it to perform operations on the database

    //Get Collection
    collection := db.GetCollection(db, "databaseName","collectionName")
}

Insert Usage

package main

import (
    "github.com/root27/go-mongodb"
)

func main(){
     

    db ,err:= mongodb.Connect("mongourl") // mongourl is the env variable name

    if err != nil {
        panic(err)
    }

    // db is a pointer to a mongo.Database
    // use it to perform operations on the database

    //Get Collection
    collection := db.GetCollection(db, "databaseName","collectionName")

    //Insert
    err = collection.InsertOne(db, bson.M{"name": "pi", "value": 3.14159})
    if err != nil {
        panic(err)
    }
}

Find Usage

package main

import (
    "github.com/root27/go-mongodb"
)

func main(){
     

    db ,err:= mongodb.Connect("mongourl") // mongourl is the env variable name

    if err != nil {
        panic(err)
    }

    // db is a pointer to a mongo.Database
    // use it to perform operations on the database

    //Get Collection
    collection := db.GetCollection(db, "databaseName","collectionName")

    //Find
    var result bson.M
    err = collection.FindOne(db, bson.M{"name": "pi"}).Decode(&result)
    if err != nil {
        panic(err)
    }

    fmt.Println("pi:", result["value"])
}

Documentation

Index

• func Connect(envName string) (*mongo.Client, error)
• func DeleteOne(collection *mongo.Collection, filter interface{}) (*mongo.DeleteResult, error)
• func Disconnect(client *mongo.Client)
• func FindMany(collection *mongo.Collection, filter interface{}) (*mongo.Cursor, error)
• func FindOne(collection *mongo.Collection, filter interface{}) *mongo.SingleResult
• func GetCollection(client *mongo.Client, dbName string, collectionName string) *mongo.Collection
• func InsertMany(collection *mongo.Collection, data []interface{}) (*mongo.InsertManyResult, error)
• func InsertOne(collection *mongo.Collection, data interface{}) (*mongo.InsertOneResult, error)
• func LoadEnv(envName string) string
• func UpdateMany(collection mongo.Collection, filter interface{}, update interface{}) (*mongo.UpdateResult, error)
• func UpdateOne(collection mongo.Collection, filter interface{}, update interface{}) (*mongo.UpdateResult, error)

Functions

func Connect

func Connect(envName string) (*mongo.Client, error)

func DeleteOne

func DeleteOne(collection *mongo.Collection, filter interface{}) (*mongo.DeleteResult, error)

func Disconnect

func Disconnect(client *mongo.Client)

func FindMany

func FindMany(collection *mongo.Collection, filter interface{}) (*mongo.Cursor, error)

func FindOne

func FindOne(collection *mongo.Collection, filter interface{}) *mongo.SingleResult

func GetCollection

func GetCollection(client *mongo.Client, dbName string, collectionName string) *mongo.Collection

func InsertMany

func InsertMany(collection *mongo.Collection, data []interface{}) (*mongo.InsertManyResult, error)

func InsertOne

func InsertOne(collection *mongo.Collection, data interface{}) (*mongo.InsertOneResult, error)

func LoadEnv

func LoadEnv(envName string) string

func UpdateMany

func UpdateMany(collection mongo.Collection, filter interface{}, update interface{}) (*mongo.UpdateResult, error)

func UpdateOne

func UpdateOne(collection mongo.Collection, filter interface{}, update interface{}) (*mongo.UpdateResult, error)