DbMySQLOld::create_table() - Code Metrics - Inspection of "Added scrutinizer config" - henrystivens/upload-image-and-data - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Branch — master (024767)

by Henry Stivens

created 2017-03-12 22:22 UTC

DbMySQLOld::create_table() F

↳ Parent: Project

Complexity

Conditions	21
Paths	> 20000

Size

Total Lines	66
Code Lines	45

Duplication

Lines	66
Ratio	100 %

Importance

Changes

Metric	Value
cc	21
eloc	45
nc	31121
nop	3
dl	66
loc	66
rs	2.79
c	0
b	0
f	0

How to fix Long Method Complexity

<?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
 * @package    Db
 * @subpackage Adapters
 * @copyright  Copyright (c) 2005 - 2017 Kumbia Team (http://www.kumbiaphp.com)
 * @license    http://wiki.kumbiaphp.com/Licencia     New BSD License
 */

/**
 * MySQL Database Support
 *
 * @category   Kumbia
 * @package    Db
 * @subpackage Adapters
 */
class DbMySQLOld extends DbBase implements DbBaseInterface
{

    /**
     * Resource de la Conexión a MySQL
     *
     * @var resource
     */
    public $id_connection;
    /**
     * Último Resultado de una Query
     *
     * @var resource
     */
    public $last_result_query;
    /**
     * Última sentencia SQL enviada a MySQL
     *
     * @var string
     */
    protected $last_query;
    /**
     * Último error generado por MySQL
     *
     * @var string
     */
    public $last_error;

    /**
     * Resultado de Array Asociativo
     *
     */
    const DB_ASSOC = MYSQL_ASSOC;

    /**
     * Resultado de Array Asociativo y Númerico
     *
     */
    const DB_BOTH = MYSQL_BOTH;

    /**
     * Resultado de Array Númerico
     *
     */
    const DB_NUM = MYSQL_NUM;

    /**
     * Tipo de Dato Integer
     *
     */
    const TYPE_INTEGER = 'INTEGER';

    /**
     * Tipo de Dato Date
     *
     */
    const TYPE_DATE = 'DATE';

    /**
     * Tipo de Dato Varchar
     *
     */
    const TYPE_VARCHAR = 'VARCHAR';

    /**
     * Tipo de Dato Decimal
     *
     */
    const TYPE_DECIMAL = 'DECIMAL';

    /**
     * Tipo de Dato Datetime
     *
     */
    const TYPE_DATETIME = 'DATETIME';

    /**
     * Tipo de Dato Char
     *
     */
    const TYPE_CHAR = 'CHAR';

    /**
     * Hace una conexión a la base de datos de MySQL
     *
     * @param array $config
     * @return bool
     */
    public function connect($config)
    {

        if (!extension_loaded('mysql')) {
            throw new KumbiaException('Debe cargar la extensión de PHP llamada php_mysql');
        }
        if (!isset($config['port']) || !$config['port']) $config['port'] = 3306;

        if ($this->id_connection = mysql_connect("{$config['host']}:{$config['port']}", $config['username'], $config['password'], true)) {
            if ($config['name'] !== '') {
                if (!mysql_select_db($config['name'], $this->id_connection)) {
                    throw new KumbiaException($this->error());
                }
            }
            //Selecciona charset
            if (isset($config['charset'])) mysql_query("SET NAMES {$config['charset']}");
            //mysql_set_charset($config['charset'],$this->id_connection); //Necesita mysql > 5.0.7
            return true;
        } else {
            throw new KumbiaException($this->error());
        }
    }

    /**
     * Efectua operaciones SQL sobre la base de datos
     *
     * @param string $sql_query
     * @return resource or false
     */
    public function query($sql_query)
    {
        $this->debug($sql_query);
        if ($this->logger) {
            Logger::debug($sql_query);
        }

        $this->last_query = $sql_query;
        if ($result_query = mysql_query($sql_query, $this->id_connection)) {
            $this->last_result_query = $result_query;
            return $result_query;
        } else {
            throw new KumbiaException($this->error(" al ejecutar <em>\"$sql_query\"</em>"));
        }
    }

    /**
     * Cierra la Conexión al Motor de Base de datos
     */
    public function close()
    {
        if ($this->id_connection) {
            return mysql_close();
        }
        return false;
    }

    /**
     * Devuelve fila por fila el contenido de un select
     *
     * @param resource $result_query
     * @param int $opt
     * @return array
     */
    public function fetch_array($result_query='', $opt=MYSQL_BOTH)
    {

        if (!$result_query) {
            $result_query = $this->last_result_query;
            if (!$result_query) {
                return false;
            }
        }
        return mysql_fetch_array($result_query, $opt);
    }

    /**
     * Constructor de la Clase
     *
     * @param array $config
     */
    public function __construct($config)
    {
        $this->connect($config);
    }

    /**
     * Devuelve el numero de filas de un select
     */
    public function num_rows($result_query='')
    {

        if (!$result_query) {
            $result_query = $this->last_result_query;
            if (!$result_query) {
                return false;
            }
        }
        if (($number_rows = mysql_num_rows($result_query)) !== false) {
            return $number_rows;
        } else {
            throw new KumbiaException($this->error());
        }
    }

    /**
     * Devuelve el nombre de un campo en el resultado de un select
     *
     * @param int $number
     * @param resource $result_query
     * @return string
     */
    public function field_name($number, $result_query='')
    {

        if (!$result_query) {
            $result_query = $this->last_result_query;
            if (!$result_query) {
                return false;
            }
        }
        if (($fieldName = mysql_field_name($result_query, $number)) !== false) {
            return $fieldName;
        } else {
            throw new KumbiaException($this->error());
        }
    }

    /**
     * Se Mueve al resultado indicado por $number en un select
     *
     * @param int $number
     * @param resource $result_query
     * @return boolean
     */
    public function data_seek($number, $result_query='')
    {
        if (!$result_query) {
            $result_query = $this->last_result_query;
            if (!$result_query) {
                return false;
            }
        }
        if (($success = mysql_data_seek($result_query, $number)) !== false) {
            return $success;
        } else {
            throw new KumbiaException($this->error());
        }
    }

    /**
     * Numero de Filas afectadas en un insert, update o delete
     *
     * @param resource $result_query
     * @return int
     */
    public function affected_rows($result_query='')
    {
        if (($numberRows = mysql_affected_rows()) !== false) {
            return $numberRows;
        } else {
            throw new KumbiaException($this->error());
        }
    }

    /**
     * Devuelve el error de MySQL
     *
     * @return string
     */
    public function error($err='')
    {
        if (!$this->id_connection) {
            $this->last_error = mysql_error() ? mysql_error() : "[Error Desconocido en MySQL: $err]";
            if ($this->logger) {
                Logger::error($this->last_error);
            }
            return $this->last_error;
        }
        $this->last_error = mysql_error() ? mysql_error() : "[Error Desconocido en MySQL: $err]";
        $this->last_error.= $err;
        if ($this->logger) {
            Logger::error($this->last_error);
        }
        return $this->last_error;
    }

    /**
     * Devuelve el no error de MySQL
     *
     * @return int
     */
    public function no_error()
    {
        return mysql_errno();
    }

    /**
     * Devuelve el ultimo id autonumerico generado en la BD
     *
     * @return int
     */
    public function last_insert_id($table='', $primary_key='')
    {
        return mysql_insert_id($this->id_connection);
    }

    /**
     * Verifica si una tabla existe o no
     *
     * @param string $table
     * @return boolean
     */
    public function table_exists($table, $schema='')
    {
        $table = addslashes("$table");
        if ($schema == '') {
            $num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '$table'");
        } else {
            $schema = addslashes("$schema");
            $num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '$table' AND TABLE_SCHEMA = '$schema'");
        }
        return $num[0];
    }

    /**
     * Devuelve un LIMIT valido para un SELECT del RBDM
     *
     * @param string $sql consulta sql
     * @return string
     */
    public function limit($sql)
    {
        $params = Util::getParams(func_get_args());
        $sql_new = $sql;

        if (isset($params['limit']) && is_numeric($params['limit'])) {
            $sql_new.=" LIMIT $params[limit]";
        }

        if (isset($params['offset']) && is_numeric($params['offset'])) {
            $sql_new.=" OFFSET $params[offset]";
        }

        return $sql_new;
    }

    /**
     * Borra una tabla de la base de datos
     *
     * @param string $table
     * @return boolean
     */
    public function drop_table($table, $if_exists=true)
    {
        if ($if_exists) {
            return $this->query("DROP TABLE IF EXISTS $table");
        } else {
            return $this->query("DROP TABLE $table");
        }
    }

    /**
     * Crea una tabla utilizando SQL nativo del RDBM
     *
     * TODO:
     * - Falta que el parametro index funcione. Este debe listar indices compuestos multipes y unicos
     * - Agregar el tipo de tabla que debe usarse (MySQL)
     * - Soporte para campos autonumericos
     * - Soporte para llaves foraneas
     *
     * @param string $table
     * @param array $definition
     * @return boolean
     */
    public function create_table($table, $definition, $index=array())
    {
        $create_sql = "CREATE TABLE $table (";
        if (!is_array($definition)) {
            throw new KumbiaException("Definición invalida para crear la tabla '$table'");
        }
        $create_lines = array();
        $index = array();
        $unique_index = array();
        $primary = array();
        //$not_null = "";
        //$size = "";
        foreach ($definition as $field => $field_def) {
            if (isset($field_def['not_null'])) {
                $not_null = $field_def['not_null'] ? 'NOT NULL' : '';
            } else {
                $not_null = "";
            }
            if (isset($field_def['size'])) {
                $size = $field_def['size'] ? '(' . $field_def['size'] . ')' : '';
            } else {
                $size = "";
            }
            if (isset($field_def['index'])) {
                if ($field_def['index']) {
                    $index[] = "INDEX(`$field`)";
                }
            }
            if (isset($field_def['unique_index'])) {
                if ($field_def['unique_index']) {
                    $index[] = "UNIQUE(`$field`)";
                }
            }
            if (isset($field_def['primary'])) {
                if ($field_def['primary']) {
                    $primary[] = "`$field`";
                }
            }
            if (isset($field_def['auto'])) {
                if ($field_def['auto']) {
                    $field_def['extra'] = isset($field_def['extra']) ? $field_def['extra'] . " AUTO_INCREMENT" : "AUTO_INCREMENT";
                }
            }
            if (isset($field_def['extra'])) {
                $extra = $field_def['extra'];
            } else {
                $extra = "";
            }
            $create_lines[] = "`$field` " . $field_def['type'] . $size . ' ' . $not_null . ' ' . $extra;
        }
        $create_sql.= join(',', $create_lines);
        $last_lines = array();
        if (count($primary)) {
            $last_lines[] = 'PRIMARY KEY(' . join(",", $primary) . ')';
        }
        if (count($index)) {
            $last_lines[] = join(',', $index);
        }
        if (count($unique_index)) {
            $last_lines[] = join(',', $unique_index);
        }
        if (count($last_lines)) {
            $create_sql.= ',' . join(',', $last_lines) . ')';
        }
        return $this->query($create_sql);
    }

    /**
     * Listar las tablas en la base de datos
     *
     * @return array
     */
    public function list_tables()
    {
        return $this->fetch_all("SHOW TABLES");
    }

    /**
     * Listar los campos de una tabla
     *
     * @param string $table
     * @return array
     */
    public function describe_table($table, $schema='')
    {
        if ($schema == '') {
            return $this->fetch_all("DESCRIBE `$table`");
        } else {
            return $this->fetch_all("DESCRIBE `$schema`.`$table`");
        }
    }

    /**
     * Devuelve fila por fila el contenido de un select
     *
     * @param resource $result_query
     * @param string $class clase de objeto
     * @return object
     */
    public function fetch_object($result_query=null, $class='stdClass')
    {
        if (!$result_query) {
            $result_query = $this->last_result_query;
        }
        return mysql_fetch_object($result_query, $class);
    }

    /**
     * Devuelve la ultima sentencia sql ejecutada por el Adaptador
     *
     * @return string
     */
    public function last_sql_query()
    {
        return $this->last_query;
    }

}


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			* @package Db
17			* @subpackage Adapters
18			* @copyright Copyright (c) 2005 - 2017 Kumbia Team (http://www.kumbiaphp.com)
19			* @license http://wiki.kumbiaphp.com/Licencia New BSD License
20			*/
21
22			/**
23			* MySQL Database Support
24			*
25			* @category Kumbia
26			* @package Db
27			* @subpackage Adapters
28			*/
29			class DbMySQLOld extends DbBase implements DbBaseInterface
30			{
31
32			/**
33			* Resource de la Conexión a MySQL
34			*
35			* @var resource
36			*/
37			public $id_connection;
38			/**
39			* Último Resultado de una Query
40			*
41			* @var resource
42			*/
43			public $last_result_query;
44			/**
45			* Última sentencia SQL enviada a MySQL
46			*
47			* @var string
48			*/
49			protected $last_query;
50			/**
51			* Último error generado por MySQL
52			*
53			* @var string
54			*/
55			public $last_error;
56
57			/**
58			* Resultado de Array Asociativo
59			*
60			*/
61			const DB_ASSOC = MYSQL_ASSOC;
62
63			/**
64			* Resultado de Array Asociativo y Númerico
65			*
66			*/
67			const DB_BOTH = MYSQL_BOTH;
68
69			/**
70			* Resultado de Array Númerico
71			*
72			*/
73			const DB_NUM = MYSQL_NUM;
74
75			/**
76			* Tipo de Dato Integer
77			*
78			*/
79			const TYPE_INTEGER = 'INTEGER';
80
81			/**
82			* Tipo de Dato Date
83			*
84			*/
85			const TYPE_DATE = 'DATE';
86
87			/**
88			* Tipo de Dato Varchar
89			*
90			*/
91			const TYPE_VARCHAR = 'VARCHAR';
92
93			/**
94			* Tipo de Dato Decimal
95			*
96			*/
97			const TYPE_DECIMAL = 'DECIMAL';
98
99			/**
100			* Tipo de Dato Datetime
101			*
102			*/
103			const TYPE_DATETIME = 'DATETIME';
104
105			/**
106			* Tipo de Dato Char
107			*
108			*/
109			const TYPE_CHAR = 'CHAR';
110
111			/**
112			* Hace una conexión a la base de datos de MySQL
113			*
114			* @param array $config
115			* @return bool
116			*/
117			public function connect($config)
118			{
119
120			if (!extension_loaded('mysql')) {
121			throw new KumbiaException('Debe cargar la extensión de PHP llamada php_mysql');
122			}
123			if (!isset($config['port']) \|\| !$config['port']) $config['port'] = 3306;
124
125			if ($this->id_connection = mysql_connect("{$config['host']}:{$config['port']}", $config['username'], $config['password'], true)) {
126			if ($config['name'] !== '') {
127			if (!mysql_select_db($config['name'], $this->id_connection)) {
128			throw new KumbiaException($this->error());
129			}
130			}
131			//Selecciona charset
132			if (isset($config['charset'])) mysql_query("SET NAMES {$config['charset']}");
133			//mysql_set_charset($config['charset'],$this->id_connection); //Necesita mysql > 5.0.7
134			return true;
135			} else {
136			throw new KumbiaException($this->error());
137			}
138			}
139
140			/**
141			* Efectua operaciones SQL sobre la base de datos
142			*
143			* @param string $sql_query
144			* @return resource or false
145			*/
146			public function query($sql_query)
147			{
148			$this->debug($sql_query);
149			if ($this->logger) {
150			Logger::debug($sql_query);
151			}
152
153			$this->last_query = $sql_query;
154			if ($result_query = mysql_query($sql_query, $this->id_connection)) {
155			$this->last_result_query = $result_query;
156			return $result_query;
157			} else {
158			throw new KumbiaException($this->error(" al ejecutar <em>\"$sql_query\"</em>"));
159			}
160			}
161
162			/**
163			* Cierra la Conexión al Motor de Base de datos
164			*/
165			public function close()
166			{
167			if ($this->id_connection) {
168			return mysql_close();
169			}
170			return false;
171			}
172
173			/**
174			* Devuelve fila por fila el contenido de un select
175			*
176			* @param resource $result_query
177			* @param int $opt
178			* @return array
179			*/
180			public function fetch_array($result_query='', $opt=MYSQL_BOTH)
181			{
182
183			if (!$result_query) {
184			$result_query = $this->last_result_query;
185			if (!$result_query) {
186			return false;
187			}
188			}
189			return mysql_fetch_array($result_query, $opt);
190			}
191
192			/**
193			* Constructor de la Clase
194			*
195			* @param array $config
196			*/
197			public function __construct($config)
198			{
199			$this->connect($config);
200			}
201
202			/**
203			* Devuelve el numero de filas de un select
204			*/
205			public function num_rows($result_query='')
206			{
207
208			if (!$result_query) {
209			$result_query = $this->last_result_query;
210			if (!$result_query) {
211			return false;
212			}
213			}
214			if (($number_rows = mysql_num_rows($result_query)) !== false) {
215			return $number_rows;
216			} else {
217			throw new KumbiaException($this->error());
218			}
219			}
220
221			/**
222			* Devuelve el nombre de un campo en el resultado de un select
223			*
224			* @param int $number
225			* @param resource $result_query
226			* @return string
227			*/
228			public function field_name($number, $result_query='')
229			{
230
231			if (!$result_query) {
232			$result_query = $this->last_result_query;
233			if (!$result_query) {
234			return false;
235			}
236			}
237			if (($fieldName = mysql_field_name($result_query, $number)) !== false) {
238			return $fieldName;
239			} else {
240			throw new KumbiaException($this->error());
241			}
242			}
243
244			/**
245			* Se Mueve al resultado indicado por $number en un select
246			*
247			* @param int $number
248			* @param resource $result_query
249			* @return boolean
250			*/
251			public function data_seek($number, $result_query='')
252			{
253			if (!$result_query) {
254			$result_query = $this->last_result_query;
255			if (!$result_query) {
256			return false;
257			}
258			}
259			if (($success = mysql_data_seek($result_query, $number)) !== false) {
260			return $success;
261			} else {
262			throw new KumbiaException($this->error());
263			}
264			}
265
266			/**
267			* Numero de Filas afectadas en un insert, update o delete
268			*
269			* @param resource $result_query
270			* @return int
271			*/
272			public function affected_rows($result_query='')
273			{
274			if (($numberRows = mysql_affected_rows()) !== false) {
275			return $numberRows;
276			} else {
277			throw new KumbiaException($this->error());
278			}
279			}
280
281			/**
282			* Devuelve el error de MySQL
283			*
284			* @return string
285			*/
286			public function error($err='')
287			{
288			if (!$this->id_connection) {
289			$this->last_error = mysql_error() ? mysql_error() : "[Error Desconocido en MySQL: $err]";
290			if ($this->logger) {
291			Logger::error($this->last_error);
292			}
293			return $this->last_error;
294			}
295			$this->last_error = mysql_error() ? mysql_error() : "[Error Desconocido en MySQL: $err]";
296			$this->last_error.= $err;
297			if ($this->logger) {
298			Logger::error($this->last_error);
299			}
300			return $this->last_error;
301			}
302
303			/**
304			* Devuelve el no error de MySQL
305			*
306			* @return int
307			*/
308			public function no_error()
309			{
310			return mysql_errno();
311			}
312
313			/**
314			* Devuelve el ultimo id autonumerico generado en la BD
315			*
316			* @return int
317			*/
318			public function last_insert_id($table='', $primary_key='')
319			{
320			return mysql_insert_id($this->id_connection);
321			}
322
323			/**
324			* Verifica si una tabla existe o no
325			*
326			* @param string $table
327			* @return boolean
328			*/
329			public function table_exists($table, $schema='')
330			{
331			$table = addslashes("$table");
332			if ($schema == '') {
333			$num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '$table'");
334			} else {
335			$schema = addslashes("$schema");
336			$num = $this->fetch_one("SELECT COUNT(*) FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_NAME = '$table' AND TABLE_SCHEMA = '$schema'");
337			}
338			return $num[0];
339			}
340
341			/**
342			* Devuelve un LIMIT valido para un SELECT del RBDM
343			*
344			* @param string $sql consulta sql
345			* @return string
346			*/
347			public function limit($sql)
348			{
349			$params = Util::getParams(func_get_args());
350			$sql_new = $sql;
351
352			if (isset($params['limit']) && is_numeric($params['limit'])) {
353			$sql_new.=" LIMIT $params[limit]";
354			}
355
356			if (isset($params['offset']) && is_numeric($params['offset'])) {
357			$sql_new.=" OFFSET $params[offset]";
358			}
359
360			return $sql_new;
361			}
362
363			/**
364			* Borra una tabla de la base de datos
365			*
366			* @param string $table
367			* @return boolean
368			*/
369			public function drop_table($table, $if_exists=true)
370			{
371			if ($if_exists) {
372			return $this->query("DROP TABLE IF EXISTS $table");
373			} else {
374			return $this->query("DROP TABLE $table");
375			}
376			}
377
378			/**
379			* Crea una tabla utilizando SQL nativo del RDBM
380			*
381			* TODO:
382			* - Falta que el parametro index funcione. Este debe listar indices compuestos multipes y unicos
383			* - Agregar el tipo de tabla que debe usarse (MySQL)
384			* - Soporte para campos autonumericos
385			* - Soporte para llaves foraneas
386			*
387			* @param string $table
388			* @param array $definition
389			* @return boolean
390			*/
391			public function create_table($table, $definition, $index=array())
392			{
393			$create_sql = "CREATE TABLE $table (";
394			if (!is_array($definition)) {
395			throw new KumbiaException("Definición invalida para crear la tabla '$table'");
396			}
397			$create_lines = array();
398			$index = array();
399			$unique_index = array();
400			$primary = array();
401			//$not_null = "";
402			//$size = "";
403			foreach ($definition as $field => $field_def) {
404			if (isset($field_def['not_null'])) {
405			$not_null = $field_def['not_null'] ? 'NOT NULL' : '';
406			} else {
407			$not_null = "";
408			}
409			if (isset($field_def['size'])) {
410			$size = $field_def['size'] ? '(' . $field_def['size'] . ')' : '';
411			} else {
412			$size = "";
413			}
414			if (isset($field_def['index'])) {
415			if ($field_def['index']) {
416			$index[] = "INDEX(`$field`)";
417			}
418			}
419			if (isset($field_def['unique_index'])) {
420			if ($field_def['unique_index']) {
421			$index[] = "UNIQUE(`$field`)";
422			}
423			}
424			if (isset($field_def['primary'])) {
425			if ($field_def['primary']) {
426			$primary[] = "`$field`";
427			}
428			}
429			if (isset($field_def['auto'])) {
430			if ($field_def['auto']) {
431			$field_def['extra'] = isset($field_def['extra']) ? $field_def['extra'] . " AUTO_INCREMENT" : "AUTO_INCREMENT";
432			}
433			}
434			if (isset($field_def['extra'])) {
435			$extra = $field_def['extra'];
436			} else {
437			$extra = "";
438			}
439			$create_lines[] = "`$field` " . $field_def['type'] . $size . ' ' . $not_null . ' ' . $extra;
440			}
441			$create_sql.= join(',', $create_lines);
442			$last_lines = array();
443			if (count($primary)) {
444			$last_lines[] = 'PRIMARY KEY(' . join(",", $primary) . ')';
445			}
446			if (count($index)) {
447			$last_lines[] = join(',', $index);
448			}
449			if (count($unique_index)) {
450			$last_lines[] = join(',', $unique_index);
451			}
452			if (count($last_lines)) {
453			$create_sql.= ',' . join(',', $last_lines) . ')';
454			}
455			return $this->query($create_sql);
456			}
457
458			/**
459			* Listar las tablas en la base de datos
460			*
461			* @return array
462			*/
463			public function list_tables()
464			{
465			return $this->fetch_all("SHOW TABLES");
466			}
467
468			/**
469			* Listar los campos de una tabla
470			*
471			* @param string $table
472			* @return array
473			*/
474			public function describe_table($table, $schema='')
475			{
476			if ($schema == '') {
477			return $this->fetch_all("DESCRIBE `$table`");
478			} else {
479			return $this->fetch_all("DESCRIBE `$schema`.`$table`");
480			}
481			}
482
483			/**
484			* Devuelve fila por fila el contenido de un select
485			*
486			* @param resource $result_query
487			* @param string $class clase de objeto
488			* @return object
489			*/
490			public function fetch_object($result_query=null, $class='stdClass')
491			{
492			if (!$result_query) {
493			$result_query = $this->last_result_query;
494			}
495			return mysql_fetch_object($result_query, $class);
496			}
497
498			/**
499			* Devuelve la ultima sentencia sql ejecutada por el Adaptador
500			*
501			* @return string
502			*/
503			public function last_sql_query()
504			{
505			return $this->last_query;
506			}
507
508			}
509

henrystivens / upload-image-and-data

Branch — master (024767)

DbMySQLOld::create_table() F

Complexity

Size

Duplication

Importance

How to fix Long Method Complexity

Long Method

Duplication Side-by-Side

Filter issues like