|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
namespace Ps2alerts\Api\Repository; |
|
4
|
|
|
|
|
5
|
|
|
use Aura\SqlQuery\AbstractQuery; |
|
6
|
|
|
use Aura\SqlQuery\QueryFactory; |
|
7
|
|
|
use Ps2alerts\Api\Contract\DatabaseAwareInterface; |
|
8
|
|
|
use Ps2alerts\Api\Contract\DatabaseAwareTrait; |
|
9
|
|
|
use Ps2alerts\Api\Contract\RedisAwareInterface; |
|
10
|
|
|
use Ps2alerts\Api\Contract\RedisAwareTrait; |
|
11
|
|
|
use Ps2alerts\Api\Contract\UuidAwareInterface; |
|
12
|
|
|
use Ps2alerts\Api\Contract\UuidAwareTrait; |
|
13
|
|
|
use Ps2alerts\Api\QueryObjects\QueryObject; |
|
14
|
|
|
|
|
15
|
|
|
abstract class AbstractEndpointRepository implements |
|
16
|
|
|
DatabaseAwareInterface, |
|
17
|
|
|
RedisAwareInterface, |
|
18
|
|
|
UuidAwareInterface |
|
19
|
|
|
{ |
|
20
|
|
|
use DatabaseAwareTrait; |
|
21
|
|
|
use RedisAwareTrait; |
|
22
|
|
|
use UuidAwareTrait; |
|
23
|
|
|
|
|
24
|
|
|
/** |
|
25
|
|
|
* Determines the table that the DB is interfacing with |
|
26
|
|
|
* |
|
27
|
|
|
* @return string |
|
28
|
|
|
*/ |
|
29
|
|
|
abstract public function getTable(); |
|
30
|
|
|
|
|
31
|
|
|
/** |
|
32
|
|
|
* Determines the primary key of the table |
|
33
|
|
|
* |
|
34
|
|
|
* @return string |
|
35
|
|
|
*/ |
|
36
|
|
|
abstract public function getPrimaryKey(); |
|
37
|
|
|
|
|
38
|
|
|
/** |
|
39
|
|
|
* Determines the Result key of the table |
|
40
|
|
|
* |
|
41
|
|
|
* @return string |
|
42
|
|
|
*/ |
|
43
|
|
|
abstract public function getResultKey(); |
|
44
|
|
|
|
|
45
|
|
|
/** |
|
46
|
|
|
* Builds a new query factory ready for use with the QueryObjects |
|
47
|
|
|
* |
|
48
|
|
|
* @return \Aura\SqlQuery\AbstractQuery |
|
49
|
|
|
*/ |
|
50
|
|
|
public function newQuery() |
|
51
|
|
|
{ |
|
52
|
|
|
$factory = new QueryFactory('mysql'); |
|
53
|
|
|
|
|
54
|
|
|
$query = $factory->newSelect(); // Suspect I'll only ever need this one |
|
55
|
|
|
$query->from($this->getTable()); |
|
56
|
|
|
|
|
57
|
|
|
return $query; |
|
58
|
|
|
} |
|
59
|
|
|
|
|
60
|
|
|
/** |
|
61
|
|
|
* Executes the statement to the DB and returns the results |
|
62
|
|
|
* |
|
63
|
|
|
* @param \Aura\SqlQuery\AbstractQuery $query |
|
64
|
|
|
* @param boolean $single |
|
65
|
|
|
* |
|
66
|
|
|
* @return array |
|
67
|
|
|
*/ |
|
68
|
|
|
public function fireStatementAndReturn($query, $single = false) |
|
69
|
|
|
{ |
|
70
|
|
|
$pdo = $this->getDatabaseDriver(); |
|
71
|
|
|
|
|
72
|
|
|
if ($single === false) { |
|
73
|
|
|
return $pdo->fetchAll($query->getStatement(), $query->getBindValues()); |
|
74
|
|
|
} |
|
75
|
|
|
|
|
76
|
|
|
return $pdo->fetchOne($query->getStatement(), $query->getBindValues()); |
|
77
|
|
|
} |
|
78
|
|
|
|
|
79
|
|
|
/** |
|
80
|
|
|
* Reads a single record from the database |
|
81
|
|
|
* |
|
82
|
|
|
* @param string $id |
|
83
|
|
|
* |
|
84
|
|
|
* @return array |
|
85
|
|
|
*/ |
|
86
|
|
|
public function readSinglebyId($id, $keyType = 'primary') |
|
|
|
|
|
|
87
|
|
|
{ |
|
88
|
|
|
$query = $this->newQuery(); |
|
89
|
|
|
$key = $this->returnKeyType($keyType); |
|
90
|
|
|
|
|
91
|
|
|
$query->cols(['*']) |
|
92
|
|
|
->where("`{$key}` = '{$id}'"); |
|
93
|
|
|
|
|
94
|
|
|
return $this->fireStatementAndReturn($query, true); |
|
95
|
|
|
} |
|
96
|
|
|
|
|
97
|
|
|
/** |
|
98
|
|
|
* Reads all related records from the database |
|
99
|
|
|
* |
|
100
|
|
|
* @param string $id |
|
101
|
|
|
* |
|
102
|
|
|
* @return array |
|
103
|
|
|
*/ |
|
104
|
|
|
public function readAllById($id, $keyType = 'primary') |
|
|
|
|
|
|
105
|
|
|
{ |
|
106
|
|
|
$query = $this->newQuery(); |
|
107
|
|
|
$key = $this->returnKeyType($keyType); |
|
108
|
|
|
|
|
109
|
|
|
$query->cols(['*']) |
|
110
|
|
|
->where("`{$key}` = '{$id}'"); |
|
111
|
|
|
|
|
112
|
|
|
return $this->fireStatementAndReturn($query); |
|
113
|
|
|
} |
|
114
|
|
|
|
|
115
|
|
|
/** |
|
116
|
|
|
* Reads all records based off a simple where statement |
|
117
|
|
|
* |
|
118
|
|
|
* @param string $field |
|
119
|
|
|
* @param string $value |
|
120
|
|
|
* |
|
121
|
|
|
* @return array |
|
122
|
|
|
*/ |
|
123
|
|
|
public function readAllByField($field, $value) |
|
124
|
|
|
{ |
|
125
|
|
|
$query = $this->newQuery(); |
|
126
|
|
|
|
|
127
|
|
|
$query->cols(['*']) |
|
128
|
|
|
->where("`{$field}` = '{$value}'"); |
|
129
|
|
|
|
|
130
|
|
|
return $this->fireStatementAndReturn($query); |
|
131
|
|
|
} |
|
132
|
|
|
|
|
133
|
|
|
/** |
|
134
|
|
|
* Sets the proper key to search on based off a string |
|
135
|
|
|
* |
|
136
|
|
|
* @param string $key |
|
137
|
|
|
* |
|
138
|
|
|
* @return string |
|
139
|
|
|
*/ |
|
140
|
|
|
public function returnKeyType($key) |
|
141
|
|
|
{ |
|
142
|
|
|
switch ($key) { |
|
143
|
|
|
case 'result': |
|
144
|
|
|
return $this->getResultKey(); |
|
145
|
|
|
case 'primary': |
|
146
|
|
|
default: |
|
147
|
|
|
return $this->getPrimaryKey(); |
|
148
|
|
|
} |
|
149
|
|
|
} |
|
150
|
|
|
} |
|
151
|
|
|
|
Maelstromeous /
ps2alerts-api
Loading history...
Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation.
You can also find more detailed suggestions in the “Code” section of your repository.