Statement::setQuery() - Code Metrics - Inspection of "调整：查询语句控制" - dxkite/suda - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( cd2896...f9f6ad )

by 世昌

created 2019-05-13 10:11 UTC

Statement::setQuery() A

↳ Parent: Statement

Complexity

Conditions	1
Paths	1

Size

Total Lines	5
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	3
nc	1
nop	1
dl	0
loc	5
rs	10
c	0
b	0
f	0

<?php

namespace suda\orm\statement;

use function is_array;
use PDOStatement;
use suda\orm\Binder;
use suda\orm\middleware\Middleware;

abstract class Statement
{
    use PrepareTrait;

    const WRITE = 0;
    const READ = 1;

    const FETCH_ONE = 0;
    const FETCH_ALL = 1;

    /**
     * 语句类型
     *
     * @var int|null
     */
    protected $type = null;

    /**
     * 获取类型
     *
     * @var int
     */
    protected $fetch = null;

    /**
     * 滚动
     *
     * @var boolean|null
     */
    protected $scroll = null;

    /**
     * 绑定
     *
     * @var Binder[]
     */
    protected $binder = [];

    /**
     * SQL语句
     *
     * @var string
     */
    protected $string;

    /**
     * PDOStatement
     *
     * @var PDOStatement|null
     */
    protected $statement = null;

    /**
     * Query
     *
     * @var Query
     */
    protected $query;

    const RET_ROWS = 1;
    const RET_LAST_INSERT_ID = 2;
    const RET_BOOL = 3;

    /**
     * 返回类型
     *
     * @var int
     */
    protected $returnType = Statement::RET_BOOL;

    /**
     * 类
     *
     * @var string
     */
    protected $fetchClass;

    /**
     * 参数
     *
     * @var array
     */
    protected $fetchClassArgs = [];

    /**
     * 数据处理中间件
     *
     * @var Middleware
     */
    protected $middleware;

    /**
     * Statement constructor.
     * @param string $sql
     * @param mixed ...$args
     */
    public function __construct(string $sql, ...$args)
    {
        if (count($args) === 1 && is_array($args[0])) {
            $this->create($sql, $args[0]);
        } else {
            list($this->string, $this->binder) = $this->prepareQueryMark($sql, $args);
        }
    }

    protected function create(string $sql, array $parameter)
    {
        $this->string = $sql;
        $this->binder = $this->mergeBinder($this->binder, $parameter);
    }

    public function isRead(bool $set = null): bool
    {
        if ($set !== null) {
            $this->type = self::READ;
        }
        return $this->type === self::READ;
    }

    public function isWrite(bool $set = null): bool
    {
        if ($set !== null) {
            $this->type = self::WRITE;
        }
        return $this->type === self::WRITE;
    }

    /**
     * 判断是否为一条
     *
     * @param bool|null $set
     * @return boolean
     */
    public function isFetchOne(bool $set = null): bool
    {
        if ($set !== null) {
            $this->fetch = self::FETCH_ONE;
        }
        return $this->fetch === self::FETCH_ONE;
    }

    /**
     * 判断是否为一条
     *
     * @return boolean
     */
    public function isFetch(): bool
    {
        return $this->fetch !== null;
    }

    /**
     * @param bool|null $scroll
     */
    public function setScroll(?bool $scroll): void
    {
        $this->scroll = $scroll;
    }

    /**
     * 判断是否获取多条
     *
     * @param bool|null $set
     * @return boolean
     */
    public function isFetchAll(bool $set = null): bool
    {
        if ($set !== null) {
            $this->fetch = self::FETCH_ALL;
        }
        return $this->fetch === self::FETCH_ALL;
    }

    /**
     * 设置记录类
     *
     * @param string|null $class
     * @param array $args
     * @return $this
     */
    public function setFetchType(?string $class = null, array $args = [])
    {
        $this->fetchClass = $class;
        $this->fetchClassArgs = $args;
        return $this;
    }

    /**
     * 获取取值类
     *
     * @return string|null
     */
    public function getFetchClass(): ?string
    {
        return $this->fetchClass ?? null;
    }

    /**
     * 是否滚动
     *
     * @param bool|null $set
     * @return boolean|null
     */
    public function isScroll(bool $set = null): ?bool
    {
        if ($set !== null) {
            $this->scroll = true;
        }
        return $this->scroll;
    }

    /**
     * 获取SQL字符串
     *
     * @return string
     */
    public function getString()
    {
        return $this->getQuery()->getQuery();
    }

    /**
     * 准备查询对象
     *
     * @return Query
     */
    protected function prepareQuery(): Query
    {
        return new Query($this->string, $this->binder);
    }

    /**
     * 准备查询对象
     *
     * @return Query
     */
    public function prepare(): Query
    {
        return $this->query = $this->prepareQuery();
    }

    /**
     * 获取查询对象
     *
     * @return Query
     */
    public function getQuery(): Query
    {
        if ($this->query === null) {
            $this->query = $this->prepare();
        }
        return $this->query;
    }

    /**
     * @param Query $query
     */
    public function setQuery(Query $query): void
    {
        $this->query = $query;
        $this->string = $query->getQuery();
        $this->binder = $query->getBinder();
    }

    /**
     * 获取绑定信息
     *
     * @return Binder[]
     */
    public function getBinder()
    {
        return $this->binder;
    }

    /**
     * @return string
     */
    public function __toString()
    {
        return $this->getString();
    }


    /**
     * Get PDOStatement
     *
     * @return  PDOStatement
     */
    public function getStatement(): ?PDOStatement
    {
        return $this->statement;
    }

    /**
     * Set PDOStatement
     *
     * @param PDOStatement $statement PDOStatement
     *
     * @return  $this
     */
    public function setStatement(PDOStatement $statement)
    {
        $this->statement = $statement;

        return $this;
    }


    /**
     * Get 返回类型
     *
     * @return  int
     */
    public function getReturnType()
    {
        return $this->returnType;
    }

    /**
     * Set 返回类型
     *
     * @param int $returnType 返回类型
     * @return  $this
     */
    public function setReturnType(int $returnType)
    {
        $this->returnType = $returnType;
        return $this;
    }

    /**
     * Get 参数
     *
     * @return  array
     */
    public function getFetchClassArgs()
    {
        return $this->fetchClassArgs;
    }

    /**
     * Get 数据处理中间件
     * @return  Middleware
     */
    public function getMiddleware()
    {
        return $this->middleware;
    }

    /**
     * Set 数据处理中间件
     *
     * @param Middleware $middleware 数据处理中间件
     * @return  $this
     */
    public function setMiddleware(Middleware $middleware)
    {
        $this->middleware = $middleware;
        return $this;
    }

    /**
     * @param Binder $binder
     * @return $this
     */
    public function addBinder(Binder $binder)
    {
        if (!in_array($binder, $this->binder)) {
            $this->binder[] = $binder;
        }
        return $this;
    }

    /**
     * 添加参数
     *
     * @param string $name
     * @param mixed $value
     * @param string|null $key
     * @return $this
     */
    public function addValue(string $name, $value, ?string $key = null)
    {
        return $this->addBinder(new Binder($name, $value, $key));
    }

    /**
     * @param int|null $type
     */
    public function setType(?int $type): void
    {
        $this->type = $type;
    }

    /**
     * @return int
     */
    public function getFetch(): int
    {
        return $this->fetch;
    }

    /**
     * @return int|null
     */
    public function getType(): ?int
    {
        return $this->type;
    }

    /**
     * @param int $fetch
     */
    public function setFetch(int $fetch): void
    {
        $this->fetch = $fetch;
    }
}


1			<?php
2
3			namespace suda\orm\statement;
4
5			use function is_array;
6			use PDOStatement;
7			use suda\orm\Binder;
8			use suda\orm\middleware\Middleware;
9
10			abstract class Statement
11			{
12			use PrepareTrait;
13
14			const WRITE = 0;
15			const READ = 1;
16
17			const FETCH_ONE = 0;
18			const FETCH_ALL = 1;
19
20			/**
21			* 语句类型
22			*
23			* @var int\|null
24			*/
25			protected $type = null;
26
27			/**
28			* 获取类型
29			*
30			* @var int
31			*/
32			protected $fetch = null;
33
34			/**
35			* 滚动
36			*
37			* @var boolean\|null
38			*/
39			protected $scroll = null;
40
41			/**
42			* 绑定
43			*
44			* @var Binder[]
45			*/
46			protected $binder = [];
47
48			/**
49			* SQL语句
50			*
51			* @var string
52			*/
53			protected $string;
54
55			/**
56			* PDOStatement
57			*
58			* @var PDOStatement\|null
59			*/
60			protected $statement = null;
61
62			/**
63			* Query
64			*
65			* @var Query
66			*/
67			protected $query;
68
69			const RET_ROWS = 1;
70			const RET_LAST_INSERT_ID = 2;
71			const RET_BOOL = 3;
72
73			/**
74			* 返回类型
75			*
76			* @var int
77			*/
78			protected $returnType = Statement::RET_BOOL;
79
80			/**
81			* 类
82			*
83			* @var string
84			*/
85			protected $fetchClass;
86
87			/**
88			* 参数
89			*
90			* @var array
91			*/
92			protected $fetchClassArgs = [];
93
94			/**
95			* 数据处理中间件
96			*
97			* @var Middleware
98			*/
99			protected $middleware;
100
101			/**
102			* Statement constructor.
103			* @param string $sql
104			* @param mixed ...$args
105			*/
106			public function __construct(string $sql, ...$args)
107			{
108			if (count($args) === 1 && is_array($args[0])) {
109			$this->create($sql, $args[0]);
110			} else {
111			list($this->string, $this->binder) = $this->prepareQueryMark($sql, $args);
112			}
113			}
114
115			protected function create(string $sql, array $parameter)
116			{
117			$this->string = $sql;
118			$this->binder = $this->mergeBinder($this->binder, $parameter);
119			}
120
121			public function isRead(bool $set = null): bool
122			{
123			if ($set !== null) {
124			$this->type = self::READ;
125			}
126			return $this->type === self::READ;
127			}
128
129			public function isWrite(bool $set = null): bool
130			{
131			if ($set !== null) {
132			$this->type = self::WRITE;
133			}
134			return $this->type === self::WRITE;
135			}
136
137			/**
138			* 判断是否为一条
139			*
140			* @param bool\|null $set
141			* @return boolean
142			*/
143			public function isFetchOne(bool $set = null): bool
144			{
145			if ($set !== null) {
146			$this->fetch = self::FETCH_ONE;
147			}
148			return $this->fetch === self::FETCH_ONE;
149			}
150
151			/**
152			* 判断是否为一条
153			*
154			* @return boolean
155			*/
156			public function isFetch(): bool
157			{
158			return $this->fetch !== null;
159			}
160
161			/**
162			* @param bool\|null $scroll
163			*/
164			public function setScroll(?bool $scroll): void
165			{
166			$this->scroll = $scroll;
167			}
168
169			/**
170			* 判断是否获取多条
171			*
172			* @param bool\|null $set
173			* @return boolean
174			*/
175			public function isFetchAll(bool $set = null): bool
176			{
177			if ($set !== null) {
178			$this->fetch = self::FETCH_ALL;
179			}
180			return $this->fetch === self::FETCH_ALL;
181			}
182
183			/**
184			* 设置记录类
185			*
186			* @param string\|null $class
187			* @param array $args
188			* @return $this
189			*/
190			public function setFetchType(?string $class = null, array $args = [])
191			{
192			$this->fetchClass = $class;
193			$this->fetchClassArgs = $args;
194			return $this;
195			}
196
197			/**
198			* 获取取值类
199			*
200			* @return string\|null
201			*/
202			public function getFetchClass(): ?string
203			{
204			return $this->fetchClass ?? null;
205			}
206
207			/**
208			* 是否滚动
209			*
210			* @param bool\|null $set
211			* @return boolean\|null
212			*/
213			public function isScroll(bool $set = null): ?bool
214			{
215			if ($set !== null) {
216			$this->scroll = true;
217			}
218			return $this->scroll;
219			}
220
221			/**
222			* 获取SQL字符串
223			*
224			* @return string
225			*/
226			public function getString()
227			{
228			return $this->getQuery()->getQuery();
229			}
230
231			/**
232			* 准备查询对象
233			*
234			* @return Query
235			*/
236			protected function prepareQuery(): Query
237			{
238			return new Query($this->string, $this->binder);
239			}
240
241			/**
242			* 准备查询对象
243			*
244			* @return Query
245			*/
246			public function prepare(): Query
247			{
248			return $this->query = $this->prepareQuery();
249			}
250
251			/**
252			* 获取查询对象
253			*
254			* @return Query
255			*/
256			public function getQuery(): Query
257			{
258			if ($this->query === null) {
259			$this->query = $this->prepare();
260			}
261			return $this->query;
262			}
263
264			/**
265			* @param Query $query
266			*/
267			public function setQuery(Query $query): void
268			{
269			$this->query = $query;
270			$this->string = $query->getQuery();
271			$this->binder = $query->getBinder();
272			}
273
274			/**
275			* 获取绑定信息
276			*
277			* @return Binder[]
278			*/
279			public function getBinder()
280			{
281			return $this->binder;
282			}
283
284			/**
285			* @return string
286			*/
287			public function __toString()
288			{
289			return $this->getString();
290			}
291
292
293			/**
294			* Get PDOStatement
295			*
296			* @return PDOStatement
297			*/
298			public function getStatement(): ?PDOStatement
299			{
300			return $this->statement;
301			}
302
303			/**
304			* Set PDOStatement
305			*
306			* @param PDOStatement $statement PDOStatement
307			*
308			* @return $this
309			*/
310			public function setStatement(PDOStatement $statement)
311			{
312			$this->statement = $statement;
313
314			return $this;
315			}
316
317
318			/**
319			* Get 返回类型
320			*
321			* @return int
322			*/
323			public function getReturnType()
324			{
325			return $this->returnType;
326			}
327
328			/**
329			* Set 返回类型
330			*
331			* @param int $returnType 返回类型
332			* @return $this
333			*/
334			public function setReturnType(int $returnType)
335			{
336			$this->returnType = $returnType;
337			return $this;
338			}
339
340			/**
341			* Get 参数
342			*
343			* @return array
344			*/
345			public function getFetchClassArgs()
346			{
347			return $this->fetchClassArgs;
348			}
349
350			/**
351			* Get 数据处理中间件
352			* @return Middleware
353			*/
354			public function getMiddleware()
355			{
356			return $this->middleware;
357			}
358
359			/**
360			* Set 数据处理中间件
361			*
362			* @param Middleware $middleware 数据处理中间件
363			* @return $this
364			*/
365			public function setMiddleware(Middleware $middleware)
366			{
367			$this->middleware = $middleware;
368			return $this;
369			}
370
371			/**
372			* @param Binder $binder
373			* @return $this
374			*/
375			public function addBinder(Binder $binder)
376			{
377			if (!in_array($binder, $this->binder)) {
378			$this->binder[] = $binder;
379			}
380			return $this;
381			}
382
383			/**
384			* 添加参数
385			*
386			* @param string $name
387			* @param mixed $value
388			* @param string\|null $key
389			* @return $this
390			*/
391			public function addValue(string $name, $value, ?string $key = null)
392			{
393			return $this->addBinder(new Binder($name, $value, $key));
394			}
395
396			/**
397			* @param int\|null $type
398			*/
399			public function setType(?int $type): void
400			{
401			$this->type = $type;
402			}
403
404			/**
405			* @return int
406			*/
407			public function getFetch(): int
408			{
409			return $this->fetch;
410			}
411
412			/**
413			* @return int\|null
414			*/
415			public function getType(): ?int
416			{
417			return $this->type;
418			}
419
420			/**
421			* @param int $fetch
422			*/
423			public function setFetch(int $fetch): void
424			{
425			$this->fetch = $fetch;
426			}
427			}
428

dxkite / suda

Push — master ( cd2896...f9f6ad )

Statement::setQuery() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like