QueryGenerator::insert() - Code Metrics - KumbiaPHP/ActiveRecord - Measure and Improve Code Quality continuously with Scrutinizer

QueryGenerator::insert() A
last analyzed 2021-06-25 09:22 UTC

↳ Parent: QueryGenerator

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	2
nc	2
nop	2
dl	0
loc	18
rs	9.6666
c	0
b	0
f	0

<?php
/**
 * KumbiaPHP web & app Framework.
 *
 * LICENSE
 *
 * This source file is subject to the new BSD license that is bundled
 * with this package in the file LICENSE.txt.
 * It is also available through the world-wide-web at this URL:
 * http://wiki.kumbiaphp.com/Licencia
 * If you did not receive a copy of the license and are unable to
 * obtain it through the world-wide-web, please send an email
 * to [email protected] so we can send you a copy immediately.
 *
 * @category   Kumbia
 *
 * @copyright  2005 - 2020  Kumbia Team (http://www.kumbiaphp.com)
 * @license    http://wiki.kumbiaphp.com/Licencia     New BSD License
 */
namespace Kumbia\ActiveRecord;

/**
 * Generador de codigo SQL.
 */
class QueryGenerator
{
    /**
     * Construye una consulta select desde una lista de parametros.
     *
     *                       where: condiciones where
     *                       order: criterio de ordenamiento
     *                       fields: lista de campos
     *                       join: joins de tablas
     *                       group: agrupar campos
     *                       having: condiciones de grupo
     *                       limit: valor limit
     *                       offset: valor offset
     * @param  array     $params    parametros de consulta select
     * @param  string    $source
     * @param  string    $type
     * @return string
     */
    public static function select($source, $type, array $params)
    {
        $params = array_merge([
            'fields' => '*',
            'join'   => '',
            'limit'  => \null,
            'offset' => \null,
            'where'  => \null,
            'group'  => \null,
            'having' => \null,
            'order'  => \null
        ], $params);

        list($where, $group, $having, $order) = static::prepareParam($params);
        $sql                                  = "SELECT {$params['fields']} FROM $source {$params['join']} $where $group $having $order";

        if ( ! \is_null($params['limit']) || ! \is_null($params['offset'])) {
            $sql = self::query($type, 'limit', $sql, $params['limit'], $params['offset']);
        }

        return $sql;
    }

    /**
     * Permite construir el WHERE, GROUP BY, HAVING y ORDER BY de una consulta SQL
     * en base a los parámetros $params.
     *
     * @param  array   $params
     * @return string[]
     */
    protected static function prepareParam(array $params)
    {
        return [
            static::where($params['where']),
            static::group($params['group']),
            static::having($params['having']),
            static::order($params['order'])
        ];
    }

    /**
     * Genera una sentencia where.
     *
     * @param  string $where
     * @return string
     */
    protected static function where($where)
    {
        return empty($where) ? '' : "WHERE $where";
    }

    /**
     * Genera una sentencia GROUP.
     *
     * @param  string $group
     * @return string
     */
    protected static function group($group)
    {
        return empty($group) ? '' : "GROUP BY $group";
    }

    /**
     * Genera una sentencia HAVING.
     *
     * @param  string $having
     * @return string
     */
    protected static function having($having)
    {
        return empty($having) ? '' : "HAVING $having";
    }

    /**
     * Genera una sentencia ORDER BY.
     *
     * @param  string $order
     * @return string
     */
    protected static function order($order)
    {
        return empty($order) ? '' : "ORDER BY $order";
    }

    /**
     * Construye una consulta INSERT.
     *
     * @param  LiteRecord $model Modelo a actualizar
     * @param  array      $data  Datos pasados a la consulta preparada
     * @return string
     */
    public static function insert(LiteRecord $model, array &$data)
    {
        $meta    = $model::metadata();
        $data    = [];
        $columns = [];
        $values  = [];

        // Preparar consulta
        foreach ($meta->getFieldsList() as $field) {
            $columns[] = $field;
            static::insertField($field, $model, $data, $values);
        }
        $columns = \implode(',', $columns);
        $values  = \implode(',', $values);
        $source  = $model::getSource();

        return "INSERT INTO $source ($columns) VALUES ($values)";
    }

    /**
     * Agrega un campo a para generar una consulta preparada para un INSERT.
     *
     * @param  string     $field  Nombre del campo
     * @param  LiteRecord $model  valor del campo
     * @param  array      $data   array de datos
     * @param  array      $values array de valores
     * @return void
     */
    protected static function insertField($field, LiteRecord $model, array &$data, array &$values)
    {
        //$meta        = $model::metadata();
        if (self::haveValue($model, $field)) {
            $data[":$field"] = $model->$field;
            $values[]        = ":$field";
        } else {
            //if (!\in_array($field, $meta->getWithDefault()) && !\in_array($field, $meta->getAutoFields())) {
            $values[] = 'NULL';
        }
    }

    /**
     * Permite conocer si la columna debe definirse como nula.
     *
     * @param  LiteRecord $model
     * @param  string     $field
     * @return bool
     */
    protected static function haveValue(LiteRecord $model, $field)
    {
        return isset($model->$field) && $model->$field !== '';
    }

    /**
     * Construye una consulta UPDATE.
     *
     * @param  LiteRecord $model Modelo a actualizar
     * @param  array      $data  Datos pasados a la consulta preparada
     * @return string
     */
    public static function update(LiteRecord $model, array &$data)
    {
        $set = [];
        $pk  = $model::getPK();
        /*elimina la clave primaria*/
        $list = \array_diff($model::metadata()->getFieldsList(), [$pk]);
        foreach ($list as $field) {
            $value = isset($model->$field) ? $model->$field : \null;
            static::updateField($field, $value, $data, $set);
        }
        $set          = \implode(', ', $set);
        $source       = $model::getSource();
        $data[":$pk"] = $model->$pk;

        return "UPDATE $source SET $set WHERE $pk = :$pk";
    }

    /**
     * Generate SQL for DELETE sentence.
     *
     * @param  string $source source
     * @param  string $where  condition
     * @return string SQL
     */
    public static function deleteAll($source, $where)
    {
        return "DELETE FROM $source ".static::where($where);
    }

    /**
     * Generate SQL for COUNT sentence.
     *
     * @param  string $source source
     * @param  string $where  condition
     * @return string SQL
     */
    public static function count($source, $where)
    {
        return "SELECT COUNT(*) AS count FROM $source ".static::where($where);
    }

    /**
     * Agrega un campo a para generar una consulta preparada para un UPDATE.
     *
     * @param  string $field Nombre del campo
     * @param  mixed  $value valor
     * @param  array  $data  array de datos
     * @param  array  $set   array de valores
     * @return void
     */
    protected static function updateField($field, $value, array &$data, array &$set)
    {
        if ( ! empty($value)) {
            $data[":$field"] = $value;
            $set[]           = "$field = :$field";
        } else {
            $set[] = "$field = NULL";
        }
    }

    /**
     * Construye una consulta UPDATE.
     *
     * @todo ¿Hay que escapar los nombres de los campos?
     * @param  string      $model   nombre del modelo a actualizar
     * @param  array       $fields  campos a actualizar
     * @param  array       $data    Datos pasados a la consulta preparada
     * @param  string|null $where
     * @return string
     */
    public static function updateAll($model, array $fields, array &$data, $where)
    {
        $set = [];
        //$pk = $model::getPK();
        /*elimina la clave primaria*/
        foreach ($fields as $field => $value) {
            static::updateField($field, $value, $data, $set);
        }
        $set    = \implode(', ', $set);
        $source = $model::getSource();
        $where  = static::where($where);

        return "UPDATE $source SET $set $where";
    }

    /**
     * Ejecuta una consulta.
     *
     * @thow KumbiaException
     * @param  string  $type           tipo de driver
     * @param  string  $query_function nombre de funcion
     * @return mixed
     */
    public static function query($type, $query_function)
    {
        $query_function = "{$type}_{$query_function}";

        require_once __DIR__."/Query/{$query_function}.php";

        $args = \array_slice(\func_get_args(), 2);

        return \call_user_func_array(__NAMESPACE__."\\Query\\$query_function", $args);
    }
}


1			<?php
2			/**
3			* KumbiaPHP web & app Framework.
4			*
5			* LICENSE
6			*
7			* This source file is subject to the new BSD license that is bundled
8			* with this package in the file LICENSE.txt.
9			* It is also available through the world-wide-web at this URL:
10			* http://wiki.kumbiaphp.com/Licencia
11			* If you did not receive a copy of the license and are unable to
12			* obtain it through the world-wide-web, please send an email
13			* to [email protected] so we can send you a copy immediately.
14			*
15			* @category Kumbia
16			*
17			* @copyright 2005 - 2020 Kumbia Team (http://www.kumbiaphp.com)
18			* @license http://wiki.kumbiaphp.com/Licencia New BSD License
19			*/
20			namespace Kumbia\ActiveRecord;
21
22			/**
23			* Generador de codigo SQL.
24			*/
25			class QueryGenerator
26			{
27			/**
28			* Construye una consulta select desde una lista de parametros.
29			*
30			* where: condiciones where
31			* order: criterio de ordenamiento
32			* fields: lista de campos
33			* join: joins de tablas
34			* group: agrupar campos
35			* having: condiciones de grupo
36			* limit: valor limit
37			* offset: valor offset
38			* @param array $params parametros de consulta select
39			* @param string $source
40			* @param string $type
41			* @return string
42			*/
43			public static function select($source, $type, array $params)
44			{
45			$params = array_merge([
46			'fields' => '*',
47			'join' => '',
48			'limit' => \null,
49			'offset' => \null,
50			'where' => \null,
51			'group' => \null,
52			'having' => \null,
53			'order' => \null
54			], $params);
55
56			list($where, $group, $having, $order) = static::prepareParam($params);
57			$sql = "SELECT {$params['fields']} FROM $source {$params['join']} $where $group $having $order";
58
59			if ( ! \is_null($params['limit']) \|\| ! \is_null($params['offset'])) {
60			$sql = self::query($type, 'limit', $sql, $params['limit'], $params['offset']);
61			}
62
63			return $sql;
64			}
65
66			/**
67			* Permite construir el WHERE, GROUP BY, HAVING y ORDER BY de una consulta SQL
68			* en base a los parámetros $params.
69			*
70			* @param array $params
71			* @return string[]
72			*/
73			protected static function prepareParam(array $params)
74			{
75			return [
76			static::where($params['where']),
77			static::group($params['group']),
78			static::having($params['having']),
79			static::order($params['order'])
80			];
81			}
82
83			/**
84			* Genera una sentencia where.
85			*
86			* @param string $where
87			* @return string
88			*/
89			protected static function where($where)
90			{
91			return empty($where) ? '' : "WHERE $where";
92			}
93
94			/**
95			* Genera una sentencia GROUP.
96			*
97			* @param string $group
98			* @return string
99			*/
100			protected static function group($group)
101			{
102			return empty($group) ? '' : "GROUP BY $group";
103			}
104
105			/**
106			* Genera una sentencia HAVING.
107			*
108			* @param string $having
109			* @return string
110			*/
111			protected static function having($having)
112			{
113			return empty($having) ? '' : "HAVING $having";
114			}
115
116			/**
117			* Genera una sentencia ORDER BY.
118			*
119			* @param string $order
120			* @return string
121			*/
122			protected static function order($order)
123			{
124			return empty($order) ? '' : "ORDER BY $order";
125			}
126
127			/**
128			* Construye una consulta INSERT.
129			*
130			* @param LiteRecord $model Modelo a actualizar
131			* @param array $data Datos pasados a la consulta preparada
132			* @return string
133			*/
134			public static function insert(LiteRecord $model, array &$data)
135			{
136			$meta = $model::metadata();
137			$data = [];
138			$columns = [];
139			$values = [];
140
141			// Preparar consulta
142			foreach ($meta->getFieldsList() as $field) {
143			$columns[] = $field;
144			static::insertField($field, $model, $data, $values);
145			}
146			$columns = \implode(',', $columns);
147			$values = \implode(',', $values);
148			$source = $model::getSource();
149
150			return "INSERT INTO $source ($columns) VALUES ($values)";
151			}
152
153			/**
154			* Agrega un campo a para generar una consulta preparada para un INSERT.
155			*
156			* @param string $field Nombre del campo
157			* @param LiteRecord $model valor del campo
158			* @param array $data array de datos
159			* @param array $values array de valores
160			* @return void
161			*/
162			protected static function insertField($field, LiteRecord $model, array &$data, array &$values)
163			{
164			//$meta = $model::metadata();
165			if (self::haveValue($model, $field)) {
166			$data[":$field"] = $model->$field;
167			$values[] = ":$field";
168			} else {
169			//if (!\in_array($field, $meta->getWithDefault()) && !\in_array($field, $meta->getAutoFields())) {
170			$values[] = 'NULL';
171			}
172			}
173
174			/**
175			* Permite conocer si la columna debe definirse como nula.
176			*
177			* @param LiteRecord $model
178			* @param string $field
179			* @return bool
180			*/
181			protected static function haveValue(LiteRecord $model, $field)
182			{
183			return isset($model->$field) && $model->$field !== '';
184			}
185
186			/**
187			* Construye una consulta UPDATE.
188			*
189			* @param LiteRecord $model Modelo a actualizar
190			* @param array $data Datos pasados a la consulta preparada
191			* @return string
192			*/
193			public static function update(LiteRecord $model, array &$data)
194			{
195			$set = [];
196			$pk = $model::getPK();
197			/elimina la clave primaria/
198			$list = \array_diff($model::metadata()->getFieldsList(), [$pk]);
199			foreach ($list as $field) {
200			$value = isset($model->$field) ? $model->$field : \null;
201			static::updateField($field, $value, $data, $set);
202			}
203			$set = \implode(', ', $set);
204			$source = $model::getSource();
205			$data[":$pk"] = $model->$pk;
206
207			return "UPDATE $source SET $set WHERE $pk = :$pk";
208			}
209
210			/**
211			* Generate SQL for DELETE sentence.
212			*
213			* @param string $source source
214			* @param string $where condition
215			* @return string SQL
216			*/
217			public static function deleteAll($source, $where)
218			{
219			return "DELETE FROM $source ".static::where($where);
220			}
221
222			/**
223			* Generate SQL for COUNT sentence.
224			*
225			* @param string $source source
226			* @param string $where condition
227			* @return string SQL
228			*/
229			public static function count($source, $where)
230			{
231			return "SELECT COUNT(*) AS count FROM $source ".static::where($where);
232			}
233
234			/**
235			* Agrega un campo a para generar una consulta preparada para un UPDATE.
236			*
237			* @param string $field Nombre del campo
238			* @param mixed $value valor
239			* @param array $data array de datos
240			* @param array $set array de valores
241			* @return void
242			*/
243			protected static function updateField($field, $value, array &$data, array &$set)
244			{
245			if ( ! empty($value)) {
246			$data[":$field"] = $value;
247			$set[] = "$field = :$field";
248			} else {
249			$set[] = "$field = NULL";
250			}
251			}
252
253			/**
254			* Construye una consulta UPDATE.
255			*
256			* @todo ¿Hay que escapar los nombres de los campos?
257			* @param string $model nombre del modelo a actualizar
258			* @param array $fields campos a actualizar
259			* @param array $data Datos pasados a la consulta preparada
260			* @param string\|null $where
261			* @return string
262			*/
263			public static function updateAll($model, array $fields, array &$data, $where)
264			{
265			$set = [];
266			//$pk = $model::getPK();
267			/elimina la clave primaria/
268			foreach ($fields as $field => $value) {
269			static::updateField($field, $value, $data, $set);
270			}
271			$set = \implode(', ', $set);
272			$source = $model::getSource();
273			$where = static::where($where);
274
275			return "UPDATE $source SET $set $where";
276			}
277
278			/**
279			* Ejecuta una consulta.
280			*
281			* @thow KumbiaException
282			* @param string $type tipo de driver
283			* @param string $query_function nombre de funcion
284			* @return mixed
285			*/
286			public static function query($type, $query_function)
287			{
288			$query_function = "{$type}_{$query_function}";
289
290			require_once __DIR__."/Query/{$query_function}.php";
291
292			$args = \array_slice(\func_get_args(), 2);
293
294			return \call_user_func_array(__NAMESPACE__."\\Query\\$query_function", $args);
295			}
296			}
297

KumbiaPHP / ActiveRecord

QueryGenerator::insert() A last analyzed 2021-06-25 09:22 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

QueryGenerator::insert() A
last analyzed 2021-06-25 09:22 UTC