diff --git a/service_a/internal/domains/meteo/service.go b/service_a/internal/domains/meteo/service.go
index ee25db1..a5db578 100644
--- a/service_a/internal/domains/meteo/service.go
+++ b/service_a/internal/domains/meteo/service.go
@@ -24,28 +24,9 @@ func (s *Service) IngestCSV(ctx context.Context, r io.Reader, fs *FileStats) err
 		return err
 	}
 
-	// TODO call insertToDB
-	s.insertAcceptedToDB(ctx, accepted, fs)
-	s.insertRejectedToDB(ctx, rejected, fs)
-
-	return nil
-}
-
-func (s *Service) insertAcceptedToDB(ctx context.Context, data []MeteoData, fs *FileStats) error {
-	var err error
-	fs.RowsInserted, err = s.repo.InsertAcceptedMeteoData(ctx, data)
-	if err != nil {
-		slog.Error("error", "err", err)
-		return err
-	}
-
-	return nil
-}
-
-func (s *Service) insertRejectedToDB(ctx context.Context, data []RejectedMeteoData, fs *FileStats) error {
-	var err error
-	fs.RowsRejected, err = s.repo.InsertRejectedMeteoData(ctx, data)
+	fs.RowsInserted, fs.RowsRejected, err = s.repo.InsertMeteoDataTX(ctx, accepted, rejected)
 	if err != nil {
+		slog.Error("error inserting meteo data", "err", err)
 		return err
 	}