DbRawController.php 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. <?php
  2. namespace App\Controller;
  3. use Doctrine\DBAL\Connection;
  4. use Doctrine\DBAL\FetchMode;
  5. use Symfony\Component\HttpFoundation\JsonResponse;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. class DbRawController
  9. {
  10. /** @var Connection */
  11. private $connection;
  12. public function __construct(Connection $connection)
  13. {
  14. $this->connection = $connection;
  15. }
  16. /**
  17. * @Route("/raw/db")
  18. */
  19. public function db(): JsonResponse
  20. {
  21. $statement = $this->connection->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
  22. $world = $statement->execute([mt_rand(1, 10000)]);
  23. return new JsonResponse($world->fetchAssociative());
  24. }
  25. /**
  26. * @Route("/raw/queries")
  27. */
  28. public function queries(Request $request): JsonResponse
  29. {
  30. $queries = (int) $request->query->get('queries', 1);
  31. $queries = min(max($queries, 1), 500);
  32. // possibility for enhancement is the use of SplFixedArray -> http://php.net/manual/de/class.splfixedarray.php
  33. $worlds = [];
  34. $statement = $this->connection->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
  35. for ($i = 0; $i < $queries; ++$i) {
  36. $world = $statement->execute([mt_rand(1, 10000)]);
  37. $worlds[] = $world->fetchAssociative();
  38. }
  39. return new JsonResponse($worlds);
  40. }
  41. /**
  42. * @Route("/raw/updates")
  43. */
  44. public function updates(Request $request): JsonResponse
  45. {
  46. $queries = (int) $request->query->get('queries', 1);
  47. $queries = min(500, max(1, $queries));
  48. $worlds = [];
  49. $writeStatement = $this->connection->prepare('UPDATE World SET randomNumber= ? WHERE id= ?');
  50. $readStatement = $this->connection->prepare('SELECT id,randomNumber FROM World WHERE id = ?');
  51. for ($i = 0; $i < $queries; ++$i) {
  52. $id = mt_rand(1, 10000);
  53. $world = $readStatement->execute([$id]);
  54. $world = $world->fetchAssociative();
  55. $writeStatement->execute(
  56. [$world['randomNumber'] = mt_rand(1, 10000), $id]
  57. );
  58. $worlds[] = $world;
  59. }
  60. return new JsonResponse($worlds);
  61. }
  62. }