modify
This commit is contained in:
as2252258@163.com
+191
-187
@@ -19,219 +19,223 @@ trait Builder
|
|||||||
{
|
{
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $alias
|
* @param $alias
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
private function builderAlias($alias): string
|
private function builderAlias($alias): string
|
||||||
{
|
{
|
||||||
return " AS " . $alias;
|
return " AS " . $alias;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $table
|
* @param $table
|
||||||
* @return string
|
* @return string
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
private function builderFrom($table): string
|
private function builderFrom($table): string
|
||||||
{
|
{
|
||||||
if ($table instanceof ActiveQuery) {
|
if ($table instanceof ActiveQuery) {
|
||||||
$table = '(' . SqlBuilder::builder($table)->get($table) . ')';
|
$table = '(' . SqlBuilder::builder($table)->get($table) . ')';
|
||||||
}
|
}
|
||||||
return " FROM " . $table;
|
return " FROM " . $table;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $join
|
* @param $join
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
#[Pure] private function builderJoin($join): string
|
#[Pure] private function builderJoin($join): string
|
||||||
{
|
{
|
||||||
if (!empty($join)) {
|
if (!empty($join)) {
|
||||||
return ' ' . implode(' ', $join);
|
return ' ' . implode(' ', $join);
|
||||||
}
|
}
|
||||||
return '';
|
return '';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param null $select
|
* @param null $select
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
#[Pure] private function builderSelect($select = NULL): string
|
#[Pure] private function builderSelect($select = NULL): string
|
||||||
{
|
{
|
||||||
if (empty($select)) {
|
if (empty($select)) {
|
||||||
return "SELECT *";
|
return "SELECT *";
|
||||||
}
|
}
|
||||||
if (is_array($select)) {
|
if (is_array($select)) {
|
||||||
return "SELECT " . implode(',', $select);
|
return "SELECT " . implode(',', $select);
|
||||||
} else {
|
} else {
|
||||||
return "SELECT " . $select;
|
return "SELECT " . $select;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $group
|
* @param $group
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
private function builderGroup($group): string
|
private function builderGroup($group): string
|
||||||
{
|
{
|
||||||
if (empty($group)) {
|
if (empty($group)) {
|
||||||
return '';
|
return '';
|
||||||
}
|
}
|
||||||
return ' GROUP BY ' . $group;
|
return ' GROUP BY ' . $group;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $order
|
* @param $order
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
#[Pure] private function builderOrder($order): string
|
#[Pure] private function builderOrder($order): string
|
||||||
{
|
{
|
||||||
if (!empty($order)) {
|
if (!empty($order)) {
|
||||||
return ' ORDER BY ' . implode(',', $order);
|
return ' ORDER BY ' . implode(',', $order);
|
||||||
} else {
|
} else {
|
||||||
return '';
|
return '';
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param ActiveQuery $query
|
* @param ActiveQuery $query
|
||||||
* @return string
|
* @return string
|
||||||
*/
|
*/
|
||||||
#[Pure] private function builderLimit(ActiveQuery $query): string
|
#[Pure] private function builderLimit(ActiveQuery $query): string
|
||||||
{
|
{
|
||||||
if (!is_numeric($query->limit) || $query->limit < 1) {
|
if (!is_numeric($query->limit) || $query->limit < 1) {
|
||||||
return "";
|
return "";
|
||||||
}
|
}
|
||||||
if ($query->offset !== null) {
|
if ($query->offset !== null) {
|
||||||
return ' LIMIT ' . $query->offset . ',' . $query->limit;
|
return ' LIMIT ' . $query->offset . ',' . $query->limit;
|
||||||
}
|
}
|
||||||
return ' LIMIT ' . $query->limit;
|
return ' LIMIT ' . $query->limit;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $where
|
* @param $where
|
||||||
* @return string
|
* @return string
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
private function where($where): string
|
private function where($where): string
|
||||||
{
|
{
|
||||||
$_tmp = [];
|
$_tmp = [];
|
||||||
if (empty($where)) return '';
|
if (empty($where)) return '';
|
||||||
if (is_string($where)) return $where;
|
if (is_string($where)) return $where;
|
||||||
foreach ($where as $key => $value) {
|
foreach ($where as $key => $value) {
|
||||||
$_value = is_string($value) ? $value : $this->conditionMap($value);
|
if (is_string($value) || is_string($key)) {
|
||||||
|
$_value = is_string($key) ? sprintf('%s=\'%s\'', $key, $value) : $value;
|
||||||
|
} else {
|
||||||
|
$_value = $this->conditionMap($value);
|
||||||
|
}
|
||||||
|
|
||||||
if (empty($_value)) continue;
|
if (empty($_value)) continue;
|
||||||
|
|
||||||
$_tmp[] = $_value;
|
$_tmp[] = $_value;
|
||||||
}
|
}
|
||||||
if (!empty($_tmp)) {
|
if (!empty($_tmp)) {
|
||||||
return sprintf(' WHERE %s', implode(' AND ', $_tmp));
|
return sprintf(' WHERE %s', implode(' AND ', $_tmp));
|
||||||
}
|
}
|
||||||
return '';
|
return '';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $condition
|
* @param $condition
|
||||||
* @return string
|
* @return string
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
private function conditionMap($condition): string
|
private function conditionMap($condition): string
|
||||||
{
|
{
|
||||||
$array = [];
|
$array = [];
|
||||||
if (is_string($condition) || empty($condition)) {
|
if (is_string($condition) || empty($condition)) {
|
||||||
return $condition;
|
return $condition;
|
||||||
}
|
}
|
||||||
|
|
||||||
foreach ($condition as $key => $value) {
|
foreach ($condition as $key => $value) {
|
||||||
$array = $this->resolve($array, $key, $value);
|
$array = $this->resolve($array, $key, $value);
|
||||||
}
|
}
|
||||||
if (is_array($array)) {
|
if (is_array($array)) {
|
||||||
return implode(' AND ', $array);
|
return implode(' AND ', $array);
|
||||||
}
|
}
|
||||||
return $array;
|
return $array;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $array
|
* @param $array
|
||||||
* @param $key
|
* @param $key
|
||||||
* @param $value
|
* @param $value
|
||||||
* @return mixed
|
* @return mixed
|
||||||
* @throws NotFindClassException
|
* @throws NotFindClassException
|
||||||
* @throws ReflectionException
|
* @throws ReflectionException
|
||||||
*/
|
*/
|
||||||
private function resolve($array, $key, $value): mixed
|
private function resolve($array, $key, $value): mixed
|
||||||
{
|
{
|
||||||
if (empty($value)) return $array;
|
if (empty($value)) return $array;
|
||||||
if (!is_numeric($key)) {
|
if (!is_numeric($key)) {
|
||||||
$value = is_numeric($value) ? $value : '\'' . $value . '\'';
|
$value = is_numeric($value) ? $value : '\'' . $value . '\'';
|
||||||
|
|
||||||
$array[] = sprintf("%s=%s", $key, $value);
|
$array[] = sprintf("%s=%s", $key, $value);
|
||||||
} else if (is_array($value)) {
|
} else if (is_array($value)) {
|
||||||
$array = $this->_arrayMap($value, $array);
|
$array = $this->_arrayMap($value, $array);
|
||||||
} else {
|
} else {
|
||||||
$array[] = sprintf('%s', $value);
|
$array[] = sprintf('%s', $value);
|
||||||
}
|
}
|
||||||
return $array;
|
return $array;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $condition
|
* @param $condition
|
||||||
* @param $array
|
* @param $array
|
||||||
* @return string
|
* @return string
|
||||||
* @throws NotFindClassException
|
* @throws NotFindClassException
|
||||||
* @throws ReflectionException
|
* @throws ReflectionException
|
||||||
* @throws ReflectionException
|
* @throws ReflectionException
|
||||||
*/
|
*/
|
||||||
private function _arrayMap($condition, $array): string
|
private function _arrayMap($condition, $array): string
|
||||||
{
|
{
|
||||||
if (!isset($condition[0])) {
|
if (!isset($condition[0])) {
|
||||||
return implode(' AND ', $this->_hashMap($condition));
|
return implode(' AND ', $this->_hashMap($condition));
|
||||||
}
|
}
|
||||||
$stroppier = strtoupper($condition[0]);
|
$stroppier = strtoupper($condition[0]);
|
||||||
if (str_contains($stroppier, 'OR')) {
|
if (str_contains($stroppier, 'OR')) {
|
||||||
if (!is_string($condition[2])) {
|
if (!is_string($condition[2])) {
|
||||||
$condition[2] = $this->_hashMap($condition[2]);
|
$condition[2] = $this->_hashMap($condition[2]);
|
||||||
}
|
}
|
||||||
$builder = Snowflake::createObject(['class' => OrCondition::class, 'value' => $condition[2], 'column' => $condition[1], 'oldParams' => $array]);
|
$builder = Snowflake::createObject(['class' => OrCondition::class, 'value' => $condition[2], 'column' => $condition[1], 'oldParams' => $array]);
|
||||||
}else if (isset(ConditionClassMap::$conditionMap[$stroppier])) {
|
} else if (isset(ConditionClassMap::$conditionMap[$stroppier])) {
|
||||||
$defaultConfig = ConditionClassMap::$conditionMap[$stroppier];
|
$defaultConfig = ConditionClassMap::$conditionMap[$stroppier];
|
||||||
$create = array_merge($defaultConfig, ['column' => $condition[1], 'value' => $condition[2]]);
|
$create = array_merge($defaultConfig, ['column' => $condition[1], 'value' => $condition[2]]);
|
||||||
$builder = Snowflake::createObject($create);
|
$builder = Snowflake::createObject($create);
|
||||||
} else {
|
} else {
|
||||||
$builder = Snowflake::createObject(['class' => HashCondition::class, 'value' => $condition]);
|
$builder = Snowflake::createObject(['class' => HashCondition::class, 'value' => $condition]);
|
||||||
}
|
}
|
||||||
|
|
||||||
$array[] = $builder->builder();
|
$array[] = $builder->builder();
|
||||||
|
|
||||||
return implode(' AND ', $array);
|
return implode(' AND ', $array);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @param $condition
|
* @param $condition
|
||||||
* @return array
|
* @return array
|
||||||
*/
|
*/
|
||||||
private function _hashMap($condition): array
|
private function _hashMap($condition): array
|
||||||
{
|
{
|
||||||
$_array = [];
|
$_array = [];
|
||||||
foreach ($condition as $key => $value) {
|
foreach ($condition as $key => $value) {
|
||||||
$value = is_numeric($value) ? $value : '\'' . $value . '\'';
|
$value = is_numeric($value) ? $value : '\'' . $value . '\'';
|
||||||
if (!is_numeric($key)) {
|
if (!is_numeric($key)) {
|
||||||
$_array[] = sprintf('%s=%s', $key, $value);
|
$_array[] = sprintf('%s=%s', $key, $value);
|
||||||
} else {
|
} else {
|
||||||
$_array[] = $value;
|
$_array[] = $value;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return $_array;
|
return $_array;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user