update 分离语句拼装

Author: kvnZero

app/ApiJson/ApiJson.php

@@ -9,16 +9,8 @@
 
 class ApiJson
 {
-    /** @var array $request */
-    protected $request;
-
-    /** @var string $method */
-    protected $method;
-
-    public function __construct(RequestInterface $request, string $method)
+    public function __construct(protected RequestInterface $request, protected string $method)
     {
-        $this->request = $request;
-        $this->method = $method;
     }
 
     public function Query(): array

app/ApiJson/Entity/ConditionEntity.php

@@ -0,0 +1,26 @@
+<?php
+
+namespace App\ApiJson\Entity;
+
+class ConditionEntity
+{
+    protected array $methodRules = [
+
+    ];
+
+    /**
+     * @param array $condition 条件
+     */
+    public function __construct(protected array $condition)
+    {
+        $this->formatSql();
+    }
+
+    /**
+     * 整理语句
+     */
+    protected function formatSql()
+    {
+
+    }
+}

app/ApiJson/Entity/TableEntity.php

@@ -0,0 +1,39 @@
+<?php
+
+namespace App\ApiJson\Entity;
+
+class TableEntity
+{
+    /** @var ConditionEntity $ConditionEntity */
+    protected ConditionEntity $conditionEntity;
+
+    /** @var string $realTableName 真实表名 */
+    protected string $realTableName;
+
+    /**
+     * @param string $tableName 表名
+     * @param array $jsonContent json数据
+     */
+    public function __construct(protected string $tableName, protected array $jsonContent)
+    {
+        $this->realTableName = $tableName;
+    }
+
+    protected function parseConditionEntity()
+    {
+        $entity = new ConditionEntity(
+            $this->getConditionByContent()
+        );
+        $this->conditionEntity = $entity;
+    }
+
+    protected function getConditionByContent(): array
+    {
+        $sanitizeTableName = str_replace(['[]'], '', $this->tableName);
+        if (isset($this->jsonContent[$sanitizeTableName])) {
+            $this->realTableName = $sanitizeTableName;
+            return $this->jsonContent[$sanitizeTableName];
+        }
+        return $this->jsonContent[$this->tableName];
+    }
+}

app/ApiJson/Method/FunctionColumnHandle.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+class FunctionColumnHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return $this->key === '@column';
+    }
+
+    protected function buildModel()
+    {
+        $this->value = str_replace([';',':'], [',', ' AS '], $this->value);
+        $this->builder->select(explode(',', $this->value));
+    }
+}

app/ApiJson/Method/FunctionGroupHandle.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+class FunctionGroupHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return $this->key === '@group';
+    }
+
+    protected function buildModel()
+    {
+        $groupArr = explode(',', $this->value);
+        $this->builder->groupBy($groupArr);
+    }
+}

app/ApiJson/Method/FunctionHavingHandle.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+class FunctionHavingHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return $this->key === '@having';
+    }
+
+    protected function buildModel()
+    {
+        $havingArr = explode(';', $this->value);
+        foreach ($havingArr as $having) {
+            $this->builder->havingRaw($having);
+        }
+    }
+}

app/ApiJson/Method/FunctionOrderHandle.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+class FunctionOrderHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return $this->key === '@order';
+    }
+
+    protected function buildModel()
+    {
+        $orderArr = explode(',', $this->value);
+        foreach ($orderArr as $order) {
+            $this->builder->orderBy(str_replace(['-', '+'], '', $order), str_ends_with($order, '-') ? 'desc' : 'asc');
+        }
+    }
+}

app/ApiJson/Method/MethodHandleInterface.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+use Hyperf\Database\Query\Builder;
+
+abstract class MethodHandleInterface
+{
+    /** @var string 清洗后的查询key */
+    protected string $sanitizeKey;
+
+    public function __construct(protected Builder $builder, protected string $key, protected $value)
+    {
+        preg_match('#(?<key>[a-zA-z0-9_]+)#', $this->key, $match);
+        $this->sanitizeKey = $match['key'] ?? $this->key;
+    }
+
+    public function handle(): string
+    {
+        if (!$this->validateCondition()) return "";
+        return $this->buildModel();
+    }
+
+    abstract protected function validateCondition(): bool;
+
+    abstract protected function buildModel();
+}

app/ApiJson/Method/WhereBetweenHandle.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+class WhereBetweenHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return str_ends_with($this->key, '$');
+    }
+
+    protected function buildModel()
+    {
+        $value = !is_array($this->value) ? [$this->value] : $this->value;
+        $sql = [];
+        foreach ($value as $item) {
+            $itemArr = explode(',', $item);
+            $sql[] = sprintf("%s BETWEEN %s AND %s", $this->sanitizeKey, trim($itemArr[0]), trim($itemArr[1]));
+        }
+        $this->builder->whereRaw(join(' OR ', $sql)); //3.2.3
+    }
+}

app/ApiJson/Method/WhereExistsHandle.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\ApiJson\Method;
+
+use Hyperf\Database\Query\Builder;
+
+class WhereExistsHandle extends MethodHandleInterface
+{
+    protected function validateCondition(): bool
+    {
+        return str_ends_with($this->key, '}{@');
+    }
+
+    protected function buildModel()
+    {
+        $this->builder->whereExists(function(Builder $query) {
+            $query = $query->from($this->value['from']);
+
+            //这里应该再接入处理列表
+            foreach ($this->value[$this->value['from']] as $k => $v) {
+                $query->where($k, $v);
+            }
+        });
+    }
+}