integry-activerecord/ARLogger.php at master · integry/integry-activerecord · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
<?php

/**
 * ActiveRecord query / action logger
 *
 * @package activerecord
 * @author Integry Systems
 */
class ARLogger
{
	private $isEnabled = true;
	private $startTime = null;
	private $outputType = 1;
	private $logFileName = "";

	private $lastQueryTime = null;

	const OUTPUT_FILE = 1;
	const OUTPUT_SCREEN = 2;

	const LOG_ACTION = 1;
	const LOG_OBJECT = 2;
	const LOG_QUERY = 3;

	public static $queryTimes = array();

	public function __construct()
	{
		$this->startTime = microtime(true);
	}

	public function logQuery($queryStr)
	{
		if (!$this->logFileName)
		{
			return null;
		}

		if ($queryStr instanceof PreparedStatementCommon)
		{
			$queryStr = $queryStr->getSQL() . "\n" . var_export($queryStr->getValues(), true);
		}

		$this->lastQueryTime = microtime(true);
		$this->addLogItem($queryStr, self::LOG_QUERY);
	}

	public function logObject(ActiveRecord $ARInstance, $restoredFromPool = false)
	{
		return false;
		$ID = $ARInstance->getID();

		if ($ARInstance->isLoaded())
		{
			$loadedStr = "data is loaded";
		}
		else
		{
			$loadedStr = "no data loaded";
		}

		if ($restoredFromPool)
		{
			$msg = "Restoring object from pool (".get_class($ARInstance).":$ID, $loadedStr)";
		}
		else
		{
			$msg = "Building new object (".get_class($ARInstance).":$ID, $loadedStr)";
		}
		$this->addLogItem($msg, self::LOG_OBJECT);
	}

	public function logQueryExecutionTime()
	{
		if (!$this->logFileName)
		{
			return null;
		}

		$time = microtime(true) - $this->lastQueryTime;
		self::$queryTimes[] = array($this->lastQuery, $time, $this->lastTrace);
		file_put_contents($this->logFileName, '( ' . $time . ' sec)' . "\n\n", FILE_APPEND);
	}

	private function addLogItem($msg, $logType)
	{
		if (!$this->logFileName)
		{
			return null;
		}

		$logItem = array("type" => $logType, "msg" => $msg);

		$logData = /*$this->startTime.*/ microtime(true) . " | " . $this->createLogItemStr($logItem);

		file_put_contents($this->logFileName, $logData, FILE_APPEND);

		$e = new Exception();
		$this->lastTrace = ApplicationException::getFileTrace($e->getTrace());
		$this->lastQuery = $msg;
	}

	private function createLogItemStr($itemArray)
	{
		$str = str_repeat('	', ActiveRecord::$transactionLevel);
		$str .= $itemArray['msg']."\n";
		return $str;
	}

	public function logAction($actionInfo)
	{
		$this->addLogItem($actionInfo, self::LOG_ACTION);
	}

	public function enable()
	{
		$this->isEnabled = true;
	}

	public function disable()
	{
		$this->isEnabled = false;
	}

	public function setLogFileName($path)
	{
		$this->logFileName = $path;
	}
}

?>