diff --git a/persist.go b/persist.go
index e76b630..5ccf503 100644
--- a/persist.go
+++ b/persist.go
@@ -103,6 +103,7 @@ func Init(props *InitProps) {
 		BuildFindOffset(col, report)
 		BuildGetOne(col, report)
 		BuildDeleteOne(col, report)
+		BuildReplaceOne(col, report)
 
 		client.AddDefinition(col)
 	}
diff --git a/persist_replace.go b/persist_replace.go
new file mode 100644
index 0000000..45c562f
--- /dev/null
+++ b/persist_replace.go
@@ -0,0 +1,61 @@
+package persist
+
+import (
+	"fmt"
+	"context"
+	"reflect"
+
+	"go.mongodb.org/mongo-driver/v2/bson"
+
+	"git.gsuntres.com/general/commons"
+	"git.gsuntres.com/general/mongo"
+)
+
+func BuildReplaceOne(col map[string]any, report *InitReport) {
+	name := col["_name"].(string)
+	singular := col["singular"].(string)
+
+	// prepare input arguments and return results
+	in := []reflect.Type{
+		reflect.TypeOf((*context.Context)(nil)).Elem(),
+		reflect.TypeOf((*string)(nil)).Elem(),
+		reflect.TypeOf((*map[string]any)(nil)).Elem(),
+	}
+	out := []reflect.Type{
+		reflect.TypeOf(bson.M{}),
+		reflect.TypeOf((*error)(nil)).Elem(),
+	}
+
+	// create function signature
+	variadic := false
+	funcType := reflect.FuncOf(in, out, variadic)
+	fname := fmt.Sprintf("%s%s", "Replace", commons.StringTitle(singular))
+	fields = append(fields, reflect.StructField{
+		Name: fname,
+		Type: funcType,
+	})
+
+	isSystem := false
+	if v, ok := col["system"]; ok {
+		isSystem = v.(bool)
+	}
+
+	report.AddField(fname)
+
+	mc := mongo.GetMongoClient()
+
+	// we defer function's implementation until we create the actual struct
+	deferedFuncs[fname] = func(ctx context.Context, id string, data map[string]any) (bson.M, error) {
+		db := "__undefined__"
+		if isSystem {
+			db = sysDb
+		} else {
+			account := ctx.Value("account").(string)
+			if account != "" {
+				db = mc.GetName(account)
+			}
+		}
+
+		return mc.Replace(ctx, db, name, id, data)
+	}
+}