Documentation ¶
Index ¶
- func WithTransaction(callback func() (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)
- type DatabaseBase
- type FindOption
- type InsertOneResult
- type MongoDBConfig
- type MongoDb
- func (db *MongoDb) Aggregate(collection string, pipeline interface{}, docs interface{}) error
- func (db *MongoDb) AggregateOne(collection string, pipeline interface{}, doc interface{}) error
- func (db *MongoDb) Close()
- func (db *MongoDb) Connect()
- func (db *MongoDb) Count(collection string, filter interface{}) (int64, error)
- func (db *MongoDb) DeleteMany(collection string, filter interface{}) (interface{}, error)
- func (db *MongoDb) DeleteOne(collection string, filter interface{}) (interface{}, error)
- func (db *MongoDb) Distinct(collection, fieldName string, filter interface{}) ([]string, error)
- func (db *MongoDb) EnsureIndex(collection string, name string, keys bson.M, unique bool) string
- func (db *MongoDb) Find(collection string, filter interface{}, option FindOption, ...) error
- func (db *MongoDb) FindOne(collection string, filter interface{}, projection interface{}, doc interface{}) error
- func (db *MongoDb) FindOneAndUpdate(collection string, filter interface{}, update, doc interface{}) error
- func (db *MongoDb) GetClient() interface{}
- func (db *MongoDb) GetCursor(collection string, filter, sort interface{}, skip, limit int64, ...) (interface{}, error)
- func (db *MongoDb) Init(i interface{}) error
- func (db *MongoDb) Insert(collection string, doc interface{}) (InsertOneResult, error)
- func (db *MongoDb) InsertMany(collection string, docs []interface{}) ([]interface{}, error)
- func (db *MongoDb) UpdateMany(collection string, filter interface{}, update interface{}) (interface{}, error)
- func (db *MongoDb) UpdateOne(collection string, filter interface{}, update interface{}) (UpdateOneResult, error)
- type Order
- type UpdateOneResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithTransaction ¶
func WithTransaction(callback func() (interface{}, error), opts ...*options.TransactionOptions) (interface{}, error)
Types ¶
type DatabaseBase ¶
type DatabaseBase interface { Init(config interface{}) error Connect() Close() GetClient() interface{} GetCursor(collection string, filter, sort interface{}, skip, limit int64, projection interface{}) (interface{}, error) Find(collection string, filter interface{}, option FindOption, projection, docs interface{}) error Distinct(collection, fieldName string, filter interface{}) ([]string, error) Aggregate(collection string, pipeline interface{}, docs interface{}) error FindOne(collection string, filter interface{}, projection interface{}, doc interface{}) error AggregateOne(collection string, pipeline interface{}, doc interface{}) error // Insert executes an insert command to insert a single document into the collection. // The _id can be retrieved from the result. Insert(collection string, doc interface{}) (InsertOneResult, error) InsertMany(collection string, docs []interface{}) ([]interface{}, error) UpdateOne(collection string, filter, doc interface{}) (UpdateOneResult, error) FindOneAndUpdate(collection string, filter, update, doc interface{}) error UpdateMany(collection string, filter interface{}, doc interface{}) (interface{}, error) DeleteOne(collection string, filter interface{}) (interface{}, error) DeleteMany(collection string, filter interface{}) (interface{}, error) Count(collection string, filter interface{}) (int64, error) EnsureIndex(collection string, name string, keys bson.M, unique bool) string }
type InsertOneResult ¶
type InsertOneResult struct {
Id interface{} `json:"id"`
}
type MongoDBConfig ¶
type MongoDBConfig struct { Host string `yaml:"host"` Username string `yaml:"user"` Password string `yaml:"password"` AuthSource string `yaml:"authSource"` Name string `yaml:"name"` }
YAML config for MongoDB
func (*MongoDBConfig) IsValid ¶
func (c *MongoDBConfig) IsValid() bool
type MongoDb ¶
type MongoDb struct { DatabaseBase // contains filtered or unexported fields }
func GetMongoDb ¶
func GetMongoDb() *MongoDb
func (*MongoDb) AggregateOne ¶
func (*MongoDb) DeleteMany ¶
func (*MongoDb) EnsureIndex ¶
func (*MongoDb) Find ¶
func (db *MongoDb) Find(collection string, filter interface{}, option FindOption, projection, docs interface{}) error
func (*MongoDb) FindOneAndUpdate ¶
func (*MongoDb) GetClient ¶
func (db *MongoDb) GetClient() interface{}
Returns the current session, *mongo.Client
func (*MongoDb) Insert ¶
func (db *MongoDb) Insert(collection string, doc interface{}) (InsertOneResult, error)
func (*MongoDb) InsertMany ¶
func (*MongoDb) UpdateMany ¶
type UpdateOneResult ¶
type UpdateOneResult struct {
Id interface{} `json:"id"`
}
Click to show internal directories.
Click to hide internal directories.