diff --git a/internal/storage/postgresql/postgresql.go b/internal/storage/postgresql/postgresql.go
index a0fff0e..87e1d8c 100644
--- a/internal/storage/postgresql/postgresql.go
+++ b/internal/storage/postgresql/postgresql.go
@@ -42,7 +42,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 
 	var id uint
 	// insert recipe
-	err = s.db.QueryRow(
+	err = tx.QueryRow(
 		ctx,
 		"insert into recipe (title, description, image, cooking_time, servings, cal) values ($1, $2, $3, $4, $5, $6) returning id",
 		recipe.Title, recipe.Description, recipe.Image, recipe.CookingTime, recipe.ServingsNum, recipe.Calories,
@@ -54,7 +54,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 	// insert ingredients
 	for _, r := range recipe.Ingredients {
 		var ing_id uint
-		err = s.db.QueryRow(
+		err = tx.QueryRow(
 			ctx,
 			"insert into recipe_ingredients_group (recipe_id, title) values ($1, $2) returning id",
 			id, r.Title,
@@ -64,7 +64,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 		}
 
 		for _, i := range r.Ingredients {
-			_, err = s.db.Exec(
+			_, err = tx.Exec(
 				ctx,
 				"insert into recipe_ingredients (recipe_ingredients_group_id, ingredient) values ($1, $2)",
 				ing_id, i,
@@ -77,7 +77,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 
 	// insert steps
 	for i, step := range recipe.Recipe_steps {
-		_, err = s.db.Exec(
+		_, err = tx.Exec(
 			ctx,
 			"insert into recipe_steps (recipe_id, step_num, step_text) values ($1, $2, $3)",
 			id, i, step,
@@ -89,7 +89,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 
 	// insert advices
 	for _, a := range recipe.Advices {
-		_, err = s.db.Exec(
+		_, err = tx.Exec(
 			ctx,
 			"insert into recipe_advices (recipe_id, advice) values ($1, $2)",
 			id, a,
@@ -101,7 +101,7 @@ func (s *Storage) AddRecipe(ctx context.Context, recipe models.Recipe) error {
 
 	// insert categories
 	for _, c := range recipe.Categories {
-		_, err = s.db.Exec(
+		_, err = tx.Exec(
 			ctx,
 			"insert into recipe_categories (recipe_id, category) values ($1, $2)",
 			id, c,