• Модуль: perfmon
  • Путь к файлу: ~/bitrix/modules/perfmon/classes/general/sql.php
  • Класс: CAllPerfomanceSQL
  • Вызов: CAllPerfomanceSQL::GetList
static function GetList($arSelect, $arFilter, $arOrder, $bGroup, $arNavStartParams = false)
{
	global $DB;

	if (!is_array($arSelect))
		$arSelect = array();
	if (count($arSelect) < 1)
		$arSelect = array(
			"ID",
		);

	if (!is_array($arOrder))
		$arOrder = array();
	if (count($arOrder) < 1)
		$arOrder = array(
			"HIT_ID" => "DESC",
			"NN" => "ASC",
		);

	$arQueryOrder = array();
	foreach ($arOrder as $strColumn => $strDirection)
	{
		$strColumn = mb_strtoupper($strColumn);
		$strDirection = mb_strtoupper($strDirection) == "ASC"? "ASC": "DESC";
		switch ($strColumn)
		{
		case "ID":
		case "HIT_ID":
		case "NN":
		case "MODULE_NAME":
		case "COMPONENT_NAME":
		case "NODE_ID":
			$arSelect[] = $strColumn;
			$arQueryOrder[$strColumn] = $strColumn." ".$strDirection;
			break;
		case "SQL_TEXT":
		case "QUERY_TIME":
			if (!$bGroup)
			{
				$arSelect[] = $strColumn;
				$arQueryOrder[$strColumn] = $strColumn." ".$strDirection;
			}
			break;
		case "MAX_QUERY_TIME":
		case "MIN_QUERY_TIME":
		case "AVG_QUERY_TIME":
		case "SUM_QUERY_TIME":
			if ($bGroup)
			{
				$arSelect[] = $strColumn;
				$arQueryOrder[$strColumn] = $strColumn." ".$strDirection;
			}
			break;
		case "COUNT":
			if ($bGroup)
			{
				$arSelect[] = $strColumn;
				$arQueryOrder[$strColumn] = $strColumn." ".$strDirection;
			}
			break;
		}
	}

	$arQueryGroup = array();
	$arQuerySelect = array();
	foreach ($arSelect as $strColumn)
	{
		$strColumn = mb_strtoupper($strColumn);
		switch ($strColumn)
		{
		case "ID":
		case "HIT_ID":
		case "NN":
		case "MODULE_NAME":
		case "COMPONENT_NAME":
		case "NODE_ID":
			if ($bGroup)
				$arQueryGroup[$strColumn] = "s.".$strColumn;
			$arQuerySelect[$strColumn] = "s.".$strColumn;
			break;
		case "SQL_TEXT":
		case "QUERY_TIME":
			if (!$bGroup)
				$arQuerySelect[$strColumn] = "s.".$strColumn;
			break;
		case "MAX_QUERY_TIME":
		case "MIN_QUERY_TIME":
		case "AVG_QUERY_TIME":
		case "SUM_QUERY_TIME":
			if ($bGroup)
			{
				$arQuerySelect[$strColumn] = mb_substr($strColumn, 0, 3)."(s.".mb_substr($strColumn, 4).") ".$strColumn;
			}
			break;
		case "COUNT":
			if ($bGroup)
			{
				$arQuerySelect[$strColumn] = "COUNT(s.ID) ".$strColumn;
			}
			break;
		}
	}

	$obQueryWhere = new CSQLWhere;
	$obQueryWhere->SetFields(array(
		"HIT_ID" => array(
			"TABLE_ALIAS" => "s",
			"FIELD_NAME" => "s.HIT_ID",
			"FIELD_TYPE" => "int",
			"JOIN" => false,
		),
		"COMPONENT_ID" => array(
			"TABLE_ALIAS" => "s",
			"FIELD_NAME" => "s.COMPONENT_ID",
			"FIELD_TYPE" => "int",
			"JOIN" => false,
		),
		"ID" => array(
			"TABLE_ALIAS" => "s",
			"FIELD_NAME" => "s.ID",
			"FIELD_TYPE" => "int",
			"JOIN" => false,
		),
		"QUERY_TIME" => array(
			"TABLE_ALIAS" => "s",
			"FIELD_NAME" => "s.QUERY_TIME",
			"FIELD_TYPE" => "double",
			"JOIN" => false,
		),
		"SUGGEST_ID" => array(
			"TABLE_ALIAS" => "iss",
			"FIELD_NAME" => "iss.SUGGEST_ID",
			"FIELD_TYPE" => "int",
			"JOIN" => "INNER JOIN b_perf_index_suggest_sql iss on iss.SQL_ID = s.ID",
			"LEFT_JOIN" => "LEFT JOIN b_perf_index_suggest_sql is on is.SQL_ID = s.ID",
		),
		"NODE_ID" => array(
			"TABLE_ALIAS" => "s",
			"FIELD_NAME" => "s.NODE_ID",
			"FIELD_TYPE" => "int",
			"JOIN" => false,
		),
	));

	if (count($arQuerySelect) < 1)
		$arQuerySelect = array("ID" => "s.ID");

	if (!is_array($arFilter))
		$arFilter = array();
	$strQueryWhere = $obQueryWhere->GetQuery($arFilter);

	if (is_array($arNavStartParams) && $arNavStartParams["nTopCount"] > 0)
	{
		$strSql = $DB->TopSQL("
			SELECT ".implode(", ", $arQuerySelect)."
			FROM b_perf_sql s
			".$obQueryWhere->GetJoins()."
			".($strQueryWhere? "WHERE ".$strQueryWhere: "")."
			".($bGroup? "GROUP BY ".implode(", ", $arQueryGroup): "")."
			".(count($arQueryOrder)? "ORDER BY ".implode(", ", $arQueryOrder): "")."
		", $arNavStartParams["nTopCount"]);
		$res = $DB->Query($strSql, false, "File: ".__FILE__."
Line: ".__LINE__); } elseif (is_array($arNavStartParams)) { $strSql = " SELECT count('x') CNT FROM b_perf_sql s ".$obQueryWhere->GetJoins()." ".($strQueryWhere? "WHERE ".$strQueryWhere: "")." ".($bGroup? "GROUP BY ".implode(", ", $arQueryGroup): "")." "; $res_cnt = $DB->Query($strSql); $ar_cnt = $res_cnt->Fetch(); $strSql = " SELECT ".implode(", ", $arQuerySelect)." FROM b_perf_sql s ".$obQueryWhere->GetJoins()." ".($strQueryWhere? "WHERE ".$strQueryWhere: "")." ".($bGroup? "GROUP BY ".implode(", ", $arQueryGroup): "")." ".(count($arQueryOrder)? "ORDER BY ".implode(", ", $arQueryOrder): "")." "; $res = new CDBResult(); $res->NavQuery($strSql, $ar_cnt["CNT"], $arNavStartParams); } else { $strSql = " SELECT ".implode(", ", $arQuerySelect)." FROM b_perf_sql s ".$obQueryWhere->GetJoins()." ".($strQueryWhere? "WHERE ".$strQueryWhere: "")." ".($bGroup? "GROUP BY ".implode(", ", $arQueryGroup): "")." ".(count($arQueryOrder)? "ORDER BY ".implode(", ", $arQueryOrder): "")." "; $res = $DB->Query($strSql, false, "File: ".__FILE__."
Line: ".__LINE__); } return $res; }