Ubiquity\db\SqlUtils

Complexity

Total Complexity

35

Size/Duplication

Total Lines	135
Duplicated Lines	0 %

Test Coverage

Coverage

63.29%

Importance

Changes	1
Bugs	0	Features	0

14 Methods

Rating	Name	Duplication	Size	Complexity
A	getQuotedKeys()	0	6	2
A	getWhere()	0	6	2
A	getParameters()	0	6	2
A	getMultiWhere()	0	6	2
A	checkWhereParams()	0	12	4
A	getUpdateFieldsKeyAndValues()	0	6	2
A	checkWhere()	0	5	3
A	getCondition()	0	17	6
A	getUpdateFieldsKeyAndParams()	0	6	2
A	getInsertFields()	0	2	1
A	getWherePK()	0	6	2
A	getSearchWhere()	0	6	2
A	getFieldList()	0	13	4
A	getInsertFieldsValues()	0	2	1

<?php

namespace Ubiquity\db;

use Ubiquity\orm\OrmUtils;

/**
 * SQL utilities
 *
 * @author jc
 * @version 1.0.4
 */
class SqlUtils {
	public static $quote = '`';

	private static function getParameters($keyAndValues) {
		$ret = array();
		foreach ($keyAndValues as $key => $value) {
			$ret [] = ':' . $key;
		}
		return $ret;
	}

	private static function getQuotedKeys($keyAndValues) {
		$ret = array();
		foreach ($keyAndValues as $key => $value) {
			$ret [] = self::$quote . $key . self::$quote;
		}
		return $ret;
	}

	public static function getWhere($keyAndValues) {
		$ret = array();
		foreach ($keyAndValues as $key => $value) {
			$ret [] = self::$quote . $key . self::$quote . '= :' . $key;
		}
		return \implode(' AND ', $ret);
	}

	public static function getWherePK($pkKeyAndValues) {
		$ret = array();
		foreach ($pkKeyAndValues as $key => $value) {
			$ret [] = self::$quote . \trim($key, '___') . self::$quote . '= :' . $key;
		}
		return \implode(' AND ', $ret);
	}

	public static function getMultiWhere($values, $field) {
		$ret = array();
		foreach ($values as $value) {
			$ret [] = self::$quote . $field . self::$quote . "='" . $value . "'";
		}
		return \implode(' OR ', $ret);
	}

	public static function getSearchWhere($likeOp, $fields, $value, $jokerBefore = '%', $jokerAfter = '%') {
		$ret = array();
		foreach ($fields as $field) {
			$ret [] = self::$quote . $field . self::$quote . $likeOp . $jokerBefore . $value . $jokerAfter;
		}
		return \implode(' OR ', $ret);
	}

	public static function getInsertFields($keyAndValues) {
		return \implode(',', self::getQuotedKeys($keyAndValues));
	}

	public static function getInsertFieldsValues($keyAndValues) {
		return \implode(',', self::getParameters($keyAndValues));
	}

	public static function getUpdateFieldsKeyAndParams($keyAndValues) {
		$ret = array();
		foreach ($keyAndValues as $key => $value) {
			$ret [] = self::$quote . $key . self::$quote . '= :' . $key;
		}
		return \implode(',', $ret);
	}

	public static function getUpdateFieldsKeyAndValues($keyAndValues) {
		$ret = array();
		foreach ($keyAndValues as $key => $value) {
			$ret [] = self::$quote . $key . self::$quote . '= :' . $key;
		}
		return \implode(',', $ret);
	}

	public static function checkWhere($condition) {
		if ($condition != null && \stristr($condition, ' join ') === false) {
			$condition = ' WHERE ' . $condition;
		}
		return $condition;
	}

	public static function checkWhereParams($condition, &$params = []) {
		if (\strpos($condition, '?') !== -1) {
			foreach ($params as $k => $v) {
				if (\is_int($k)) {
					$params["_$k"] = $v;
					unset($params[$k]);
					$k = "_$k";
				}
				$condition = \str_replace('?', ":$k", $condition);
			}
		}
		return self::checkWhere($condition);
	}

	public static function getCondition($keyValues, $classname = null, $separator = ' AND ') {
		if (!\is_array($keyValues)) {
			return $keyValues;
		} else {
			if ((\array_keys($keyValues) === \range(0, \count($keyValues) - 1))) {//Not associative array
				if (isset ($classname)) {
					$keys = OrmUtils::getKeyFields($classname);
					if (\is_array($keys)) {
						$keyValues = \array_combine($keys, $keyValues);
					}
				}
			}
			$retArray = array();
			foreach ($keyValues as $key => $value) {
				$retArray [] = self::$quote . $key . self::$quote . " = '" . $value . "'";
			}
			return \implode($separator, $retArray);
		}
	}

	/**
	 *
	 * @param array|string $fields
	 * @param boolean|string $tableName
	 * @return string
	 */
	public static function getFieldList($fields, $tableName = false) {
		if (!\is_array($fields)) {
			return $fields;
		}
		$result = [];
		$prefix = '';
		if (\is_string($tableName)) {
			$prefix = self::$quote . $tableName . self::$quote . '.';
		}
		foreach ($fields as $field) {
			$result [] = $prefix . self::$quote . $field . self::$quote;
		}
		return \implode(',', $result);
	}
}