UpdateResource.php 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. <?php
  2. namespace Benchmark\Resources;
  3. use Benchmark\Entities\RandomNumber;
  4. use Hamlet\Database\{Procedure, Session};
  5. use Hamlet\Http\Entities\JsonEntity;
  6. use Hamlet\Http\Requests\Request;
  7. use Hamlet\Http\Resources\HttpResource;
  8. use Hamlet\Http\Responses\{Response, SimpleOKResponse};
  9. class UpdateResource implements HttpResource
  10. {
  11. use QueriesCountTrait;
  12. /** @var Procedure */
  13. private $selectProcedure;
  14. /** @var Procedure */
  15. private $updateProcedure;
  16. public function __construct(Session $session)
  17. {
  18. $this->selectProcedure = $session->prepare('
  19. SELECT id,
  20. randomNumber
  21. FROM World
  22. WHERE id = ?
  23. ');
  24. $this->updateProcedure = $session->prepare('
  25. UPDATE World
  26. SET randomNumber = ?
  27. WHERE id = ?
  28. ');
  29. }
  30. public function getResponse(Request $request): Response
  31. {
  32. $count = $this->getQueriesCount($request);
  33. $payload = [];
  34. while ($count--) {
  35. $id = mt_rand(1, 10000);
  36. $randomNumber = mt_rand(1, 10000);
  37. $this->selectProcedure->bindInteger($id);
  38. /** @var RandomNumber $entry */
  39. $entry = $this->selectProcedure->processOne()
  40. ->selectAll()->cast(RandomNumber::class)
  41. ->collectHead();
  42. $modifiedEntry = $entry->withNumber($randomNumber);
  43. $this->updateProcedure->bindInteger($modifiedEntry->number());
  44. $this->updateProcedure->bindInteger($modifiedEntry->id());
  45. $this->updateProcedure->execute();
  46. $payload[] = $modifiedEntry;
  47. }
  48. return new SimpleOKResponse(new JsonEntity($payload));
  49. }
  50. }