1
0

QueryLogger.php 1.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. <?php
  2. /**
  3. * @copyright Copyright (c) 2016, ownCloud, Inc.
  4. *
  5. * @author Morris Jobke <hey@morrisjobke.de>
  6. * @author Robin Appelman <robin@icewind.nl>
  7. *
  8. * @license AGPL-3.0
  9. *
  10. * This code is free software: you can redistribute it and/or modify
  11. * it under the terms of the GNU Affero General Public License, version 3,
  12. * as published by the Free Software Foundation.
  13. *
  14. * This program is distributed in the hope that it will be useful,
  15. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  17. * GNU Affero General Public License for more details.
  18. *
  19. * You should have received a copy of the GNU Affero General Public License, version 3,
  20. * along with this program. If not, see <http://www.gnu.org/licenses/>
  21. *
  22. */
  23. namespace OC\Diagnostics;
  24. use OC\Cache\CappedMemoryCache;
  25. use OCP\Diagnostics\IQueryLogger;
  26. class QueryLogger implements IQueryLogger {
  27. /**
  28. * @var \OC\Diagnostics\Query
  29. */
  30. protected $activeQuery;
  31. /**
  32. * @var \OC\Diagnostics\Query[]
  33. */
  34. protected $queries;
  35. /**
  36. * QueryLogger constructor.
  37. */
  38. public function __construct() {
  39. $this->queries = new CappedMemoryCache(1024);
  40. }
  41. /**
  42. * @param string $sql
  43. * @param array $params
  44. * @param array $types
  45. */
  46. public function startQuery($sql, array $params = null, array $types = null) {
  47. $this->activeQuery = new Query($sql, $params, microtime(true), $this->getStack());
  48. }
  49. private function getStack() {
  50. $stack = debug_backtrace();
  51. array_shift($stack);
  52. array_shift($stack);
  53. array_shift($stack);
  54. return $stack;
  55. }
  56. public function stopQuery() {
  57. if ($this->activeQuery) {
  58. $this->activeQuery->end(microtime(true));
  59. $this->queries[] = $this->activeQuery;
  60. $this->activeQuery = null;
  61. }
  62. }
  63. /**
  64. * @return Query[]
  65. */
  66. public function getQueries() {
  67. return $this->queries->getData();
  68. }
  69. }