MongoDbPersistence

DependencyResolver

The dependency resolver.

DependencyResolver: DependencyResolver

Logger

The logger.

Logger: CompositeLogger

Connection

The MongoDB connection component.

Connection: *MongoDBConnection

CollectionName

The MongoDB colleciton name.

CollectionName: string;

Collection

The MongoDb collection object.

Collection: *mongodrv.Collection

Client

The MongoDB connection pool object.

Client: *mongodrv.Client

DatabaseName

The MongoDB database name.

DatabaseName: string

Db

The MongoDb database object.

Db *mongodrv.Database

maxPageSize

The maximum number of records to return from the database per request.

maxPageSize: int = 100

</span

Methods

Clear

Clears a component’s state.

(c *MongoDbPersistence[T]) Clear(ctx context.Context, correlationId string) error

• ctx: context.Context - operation context.
• correlationId: string - object to convert from the public partial format.
• returns: error - error or nil no errors occured.

Close

Closes the component and frees used resources.

(c *MongoDbPersistence[T]) Close(ctx context.Context, correlationId string) error

• ctx: context.Context - operation context.
• correlationId: string - object to convert from the public partial format.
• returns: error - error or nil no errors occured.

Configure

Configure method is configures component by passing configuration parameters.

(c *MongoDbPersistence[T]) Configure(ctx context.Context, config *cconf.ConfigParams)

• ctx: context.Context - operation context.
• config: *cconf.ConfigParams - configuration parameters to be set.

ConvertFromPublic

Converts an object value from public to internal format.

(c *MongoDbPersistence[T]) ConvertFromPublic(item T) (map[string]any, error)

• value: T - object in public format to convert.
• returns: (map[string]any, error) - converted object in internal format.

ConvertFromPublicPartial

ConvertFromPublicPartial method help convert object (map) from public view by replaced “Id” to “_id” field

ConvertFromPublicPartial(item T) (map[string]any, error)

• item: T - item for conversion.
• returns: (map[string]any, error) - result map

ConvertToPublic

Converts and object value from internal to public format.

(c *MongoDbPersistence[T]) ConvertToPublic(value any) (T, error)

• value: any - object in internal format to convert.
• returns: (T, error) - converted object in public format.

Create

Creates a data item.

(c *MongoDbPersistence[T]) Create(ctx context.Context, correlationId string, item T) (result T, err error)

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• item: T - item to be created.
• returns: (result T, err error) - created item

DefineSchema

Defines the database schema

(c *MongoDbPersistence[T]) DefineSchema()

DeleteByFilter

This method shall be called by a func DeleteByFilter method from the child class that receives FilterParams and converts them into a filter function.

(c *MongoDbPersistence[T]) DeleteByFilter(ctx context.Context, correlationId string, filter any) error

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• filter: any - (optional) filter function used to filter items.
• returns: error - error or nil no errors occured.

EnsureIndex

Adds index definition to create it on opening.

(c *MongoDbPersistence[T]) EnsureIndex(keys any, options *mongoopt.IndexOptions)

• keys: any - index keys (fields)
• options: *mongoopt.IndexOptions - index options

IsOpen

Method is checks if the component is opened.

(c *MongoDbPersistence[T]) IsOpen() bool

IsTerminated

Checks if the wee need to terminate process before close component.

(c *MongoDbPersistence[T]) IsTerminated() bool

• returns: bool - true if you need terminate your processes.

Open

Open method is opens the component.

(c *MongoDbPersistence[T]) Open(ctx context.Context, correlationId string) error

• ctx: context.Context - operation context.
• returns: error or nil when no errors occured.

GetCountByFilter

Gets a number of data items retrieved by a given filter.

This method shall be called by a func GetCountByFilter method from the child class that receives FilterParams and converts them into a filter function.

(c *MongoDbPersistence[T]) GetCountByFilter(ctx context.Context, correlationId string, filter any) (count int64, err error)

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id usedto trace execution through the call chain.
• filter: any - (optional) filter JSON object
• returns: (count int64, err error) - number of filtered items.

GetListByFilter

Gets a list of data items retrieved by a given filter and sorted according to sort parameters.

This method shall be called by a func GetListByFilter method from the child class that receives FilterParams and converts them into a filter function.

(c *MongoDbPersistence[T]) GetListByFilter(ctx context.Context, correlationId string, filter any, sort any, sel any) (items []T, err error)

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• filter: any - (optional) filter function used to filter items
• sort: any - (optional) sorting parameters
• select: any - (optional) projection parameters (not used yet)
• returns: (items []T, err error) - data list of results by filter.

GetOneRandom

Gets a random item from items that match to a given filter.

This method shall be called by a func GetOneRandom method from the child class that receives FilterParams and converts them into a filter function.

(c *MongoDbPersistence[T]) GetOneRandom(ctx context.Context, correlationId string, filter any) (item T, err error)

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• filter: any - fileter JSON object.
• returns: (item T, err error) - random item.

GetPageByFilter

Gets a page of data items retrieved by a given filter and sorted according to sort parameters.

This method shall be called by a func GetPageByFilter method from the child class that receives FilterParams and converts them into a filter function.

(c *MongoDbPersistence[T]) GetPageByFilter(ctx context.Context, correlationId string, filter any, paging *cdata.PagingParams, sort any, sel any) (page *cdata.DataPage[T], err error)

• ctx: context.Context - operation context.
• correlationId: string - (optional) transaction id used to trace execution through the call chain.
• filter: any - (optional) filter JSON object
• paging: *cdata.PagingParams - (optional) paging parameters
• sort: any - (optional) sorting JSON object
• sel: any - (optional) projection JSON object
• returns: (page *cdata.DataPage[T], err error) - data page obtained by filtering

SetReferences

Sets references to dependent components.

(c *MessageQueue) SetReferences(ctx context.Context, references cref.IReferences)

• ctx: context.Context - operation context.
• references: cref.IReferences - references to locate the component dependencies.

Examples

type MyMongoDbPersistence struct {
	*persistence.MongoDbPersistence[MyData]
}

func NewMyMongoDbPersistence() *MyMongoDbPersistence {
	c := &MyMongoDbPersistence{}
	c.MongoDbPersistence = persistence.InheritMongoDbPersistence[MyData](c, "my_data")
	return c
}

func (c *MyMongoDbPersistence) GetByName(ctx context.Context, correlationId string, name string) (count int64, err error) {
	return c.MongoDbPersistence.GetCountByFilter(ctx, correlationId, bson.M{"name": name})
}

func (c *MyMongoDbPersistence) Set(ctx context.Context, correlationId string,
	item MyData) (result MyData, err error) {
	var defaultValue MyData

	newItem, err := c.Overrides.ConvertFromPublic(item)
	if err != nil {
		return defaultValue, err
	}

	id := newItem["_id"]
	filter := bson.M{"_id": id}
	var options mngoptions.FindOneAndReplaceOptions
	retDoc := mngoptions.After
	options.ReturnDocument = &retDoc
	upsert := true
	options.Upsert = &upsert

	res := c.Collection.FindOneAndReplace(ctx, filter, newItem, &options)
	if err := res.Err(); err != nil {
		if errors.Is(err, mongo.ErrNoDocuments) {
			return result, nil
		}
		return result, err
	}

	c.Logger.Trace(ctx, correlationId, "Set in %s with id = %s", c.CollectionName, id)
	var docPointer MyData
	if err := res.Decode(&docPointer); err != nil {
		if errors.Is(err, mongo.ErrNoDocuments) {
			return result, nil
		}
		return result, err
	}

	return c.Overrides.ConvertToPublic(docPointer)
}

func main() {
	persistence := NewMyMongoDbPersistence()
	persistence.Configure(context.Background(), config.NewConfigParamsFromTuples(
		"host", "localhost",
		"port", 27017,
	))

	_ = persistence.Open(context.Background(), "123")
	persistence.Set(context.Background(), "123", MyData{Id: "123", Name: "ABC"})
	item, err := persistence.GetByName(context.Background(), "123", "ABC")
	fmt.Println(item) // Result: { name: "ABC" }
}