Database_Mssql_Driver - Code Metrics - vijinho/kohana2-legacy - Measure and Improve Code Quality continuously with Scrutinizer

Database_Mssql_Driver B
last analyzed 2016-08-25 15:53 UTC

↳ Parent: Project

Complexity

Total Complexity

Size/Duplication

Total Lines	278
Duplicated Lines	47.12 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	3
Bugs	2	Features	0

Metric	Value
c	3
b	2
f	0
dl	131
loc	278
rs	8.6206
wmc	50
lcom	1
cbo	4

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	__destruct()	0	4	2
D	connect()	0	37	9
A	query()	20	20	4
A	escape_table()	14	14	2
C	escape_column()	48	48	10
A	limit()	0	4	1
F	compile_select()	49	49	12
A	escape_str()	0	13	3
A	list_tables()	0	12	2
A	show_error()	0	4	1
A	list_fields()	0	11	2
A	field_data()	0	6	1

How to fix Duplicated Code Complexity

Duplicated Code

Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.

Common duplication problems, and corresponding solutions are:

If you have the same expression in different places: Extract expression to a method
If you have the same method in different sub-classes: Extract method, and pull up field to the parent class
If you have the same code in unrelated classes: Consider extracting the code to a new class, and injecting that class

Complex Class

Tip: Before tackling complexity, make sure that you eliminate any duplication first. This often can reduce the size of classes significantly.

Complex classes like Database_Mssql_Driver often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.

Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.

While breaking up the class, it is a good idea to analyze how other classes use Database_Mssql_Driver, and based on these observations, apply Extract Interface, too.

<?php defined('SYSPATH') or die('No direct access allowed.');
/**
 * MSSQL Database Driver
 *
 * @package    Core
 * @author     Kohana Team
 * @copyright  (c) 2007-2008 Kohana Team
 * @license    http://kohanaphp.com/license.html
 */
class Database_Mssql_Driver extends Database_Driver
{
    /**
     * Database connection link
     */
    protected $link;

    /**
     * Database configuration
     */
    protected $db_config;

    /**
     * Sets the config for the class.
     *
     * @param  array  database configuration
     */
    public function __construct($config)
    {
        $this->db_config = $config;

        Kohana::log('debug', 'MSSQL Database Driver Initialized');
    }

    /**
     * Closes the database connection.
     */
    public function __destruct()
    {
        is_resource($this->link) and mssql_close($this->link);
    }

    /**
     * Make the connection
     *
     * @return return connection
     */
    public function connect()
    {
        // Check if link already exists
        if (is_resource($this->link)) {
            return $this->link;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
        }

        // Import the connect variables
        extract($this->db_config['connection']);

        // Persistent connections enabled?
        $connect = ($this->db_config['persistent'] == true) ? 'mssql_pconnect' : 'mssql_connect';

        // Build the connection info
        $host = isset($host) ? $host : $socket;

        // Windows uses a comma instead of a colon
        $port = (isset($port) and is_string($port)) ? (KOHANA_IS_WIN ? ',' : ':').$port : '';

        // Make the connection and select the database
        if (($this->link = $connect($host.$port, $user, $pass, true)) and mssql_select_db($database, $this->link)) {
            /* This is being removed so I can use it, will need to come up with a more elegant workaround in the future...
             *
            if ($charset = $this->db_config['character_set'])
            {
                $this->set_charset($charset);
            }
            */

            // Clear password after successful connect
            $this->db_config['connection']['pass'] = null;

            return $this->link;
        }

        return false;
class Author {
    private $name;

    public function __construct($name) {
        $this->name = $name;
    }

    public function getName() {
        return $this->name;
    }
}

abstract class Post {
    public function getAuthor() {
        return 'Johannes';
    }
}

class BlogPost extends Post {
    public function getAuthor() {
        return new Author('Johannes');
    }
}

class ForumPost extends Post { /* ... */ }

function my_function(Post $post) {
    echo strtoupper($post->getAuthor());
}
    }

    /**
     * @param string $sql
     */
    public function query($sql)

    {
        // Only cache if it's turned on, and only cache if it's not a write statement
        if ($this->db_config['cache'] and ! preg_match('#\b(?:INSERT|UPDATE|REPLACE|SET)\b#i', $sql)) {
            $hash = $this->query_hash($sql);

            if (! isset($this->query_cache[$hash])) {
                // Set the cached object
                $this->query_cache[$hash] = new Mssql_Result(mssql_query($sql, $this->link), $this->link, $this->db_config['object'], $sql);
            } else {
                // Rewind cached result
                $this->query_cache[$hash]->rewind();
            }

            // Return the cached query
            return $this->query_cache[$hash];
        }

        return new Mssql_Result(mssql_query($sql, $this->link), $this->link, $this->db_config['object'], $sql);
    }

    public function escape_table($table)

    {
        if (stripos($table, ' AS ') !== false) {
            // Force 'AS' to uppercase
            $table = str_ireplace(' AS ', ' AS ', $table);

            // Runs escape_table on both sides of an AS statement
            $table = array_map(array($this, __FUNCTION__), explode(' AS ', $table));

            // Re-create the AS statement
            return implode(' AS ', $table);
        }
        return '['.str_replace('.', '[.]', $table).']';
    }

    public function escape_column($column)

    {
        if (!$this->db_config['escape']) {
            return $column;
        }

        if ($column == '*') {
            return $column;
        }

        // This matches any functions we support to SELECT.
        if (preg_match('/(avg|count|sum|max|min)\(\s*(.*)\s*\)(\s*as\s*(.+)?)?/i', $column, $matches)) {
            if (count($matches) == 3) {
                return $matches[1].'('.$this->escape_column($matches[2]).')';
            } elseif (count($matches) == 5) {
                return $matches[1].'('.$this->escape_column($matches[2]).') AS '.$this->escape_column($matches[2]);
            }
        }

        // This matches any modifiers we support to SELECT.
        if (! preg_match('/\b(?:rand|all|distinct(?:row)?|high_priority|sql_(?:small_result|b(?:ig_result|uffer_result)|no_cache|ca(?:che|lc_found_rows)))\s/i', $column)) {
            if (stripos($column, ' AS ') !== false) {
                // Force 'AS' to uppercase
                $column = str_ireplace(' AS ', ' AS ', $column);

                // Runs escape_column on both sides of an AS statement
                $column = array_map(array($this, __FUNCTION__), explode(' AS ', $column));

                // Re-create the AS statement
                return implode(' AS ', $column);
            }

            return preg_replace('/[^.*]+/', '[$0]', $column);
        }

        $parts = explode(' ', $column);
        $column = '';

        for ($i = 0, $c = count($parts); $i < $c; $i++) {
            // The column is always last
            if ($i == ($c - 1)) {
                $column .= preg_replace('/[^.*]+/', '[$0]', $parts[$i]);
            } else { // otherwise, it's a modifier
                $column .= $parts[$i].' ';
            }
        }
        return $column;
    }

    /**
     * Limit in SQL Server 2000 only uses the keyword
     * 'TOP'; 2007 may have an offset keyword, but
     * I am unsure - for pagination style limit,offset
     * functionality, a fancy query needs to be built.
     *
     * @param unknown_type $limit
     * @return string
     */
    public function limit($limit, $offset=null)
    {
        return 'TOP '.$limit;
    }

    public function compile_select($database)

    {
        $sql = ($database['distinct'] == true) ? 'SELECT DISTINCT ' : 'SELECT ';
        $sql .= (count($database['select']) > 0) ? implode(', ', $database['select']) : '*';

        if (count($database['from']) > 0) {
            // Escape the tables
            $froms = array();
            foreach ($database['from'] as $from) {
                $froms[] = $this->escape_column($from);
            }
            $sql .= "\nFROM ";
            $sql .= implode(', ', $froms);
        }

        if (count($database['join']) > 0) {
            foreach ($database['join'] as $join) {
                $sql .= "\n".$join['type'].'JOIN '.implode(', ', $join['tables']).' ON '.$join['conditions'];
            }
        }

        if (count($database['where']) > 0) {
            $sql .= "\nWHERE ";
        }

        $sql .= implode("\n", $database['where']);

        if (count($database['groupby']) > 0) {
            $sql .= "\nGROUP BY ";
            $sql .= implode(', ', $database['groupby']);
        }

        if (count($database['having']) > 0) {
            $sql .= "\nHAVING ";
            $sql .= implode("\n", $database['having']);
        }

        if (count($database['orderby']) > 0) {
            $sql .= "\nORDER BY ";
            $sql .= implode(', ', $database['orderby']);
        }

        if (is_numeric($database['limit'])) {
            $sql .= "\n";
            $sql .= $this->limit($database['limit']);
        }

        return $sql;
    }

    public function escape_str($str)
    {
        if (!$this->db_config['escape']) {
            return $str;
        }

        is_resource($this->link) or $this->connect();
        //mssql_real_escape_string($str, $this->link); <-- this function doesn't exist

        $characters = array('/\x00/', '/\x1a/', '/\n/', '/\r/', '/\\\/', '/\'/');
        $replace    = array('\\\x00', '\\x1a', '\\n', '\\r', '\\\\', "''");
        return preg_replace($characters, $replace, $str);
    }

    public function list_tables()
    {
        $sql    = 'SHOW TABLES FROM ['.$this->db_config['connection']['database'].']';
        $result = $this->query($sql)->result(false, MSSQL_ASSOC);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);

        $retval = array();
        foreach ($result as $row) {
            $retval[] = current($row);
        }

        return $retval;
    }

    public function show_error()
    {
        return mssql_get_last_message($this->link);
    }

    public function list_fields($table)
    {
        $result = array();

        foreach ($this->field_data($table) as $row) {
            // Make an associative array
            $result[$row->Field] = $this->sql_type($row->Type);
        }

        return $result;
    }

    public function field_data($table)
    {
        $query = $this->query("SELECT COLUMN_NAME AS Field, DATA_TYPE as Type  FROM INFORMATION_SCHEMA.Columns WHERE TABLE_NAME = '".$this->escape_table($table)."'", $this->link);


        return $query->result_array(true);
    }
}

/**
 * MSSQL Result
 */
class Mssql_Result extends Database_Result
{

    // Fetch function and return type
    protected $fetch_type  = 'mssql_fetch_object';
    protected $return_type = MSSQL_ASSOC;

    /**
     * Sets up the result variables.
     *
     * @param  resource  query result
     * @param  resource  database link
     * @param  boolean   return objects or arrays
     * @param  string    SQL query that was run
     */
    public function __construct($result, $link, $object = true, $sql)
    {
        $this->result = $result;

        // If the query is a resource, it was a SELECT, SHOW, DESCRIBE, EXPLAIN query
        if (is_resource($result)) {
            $this->current_row = 0;
            $this->total_rows  = mssql_num_rows($this->result);
            $this->fetch_type = ($object === true) ? 'mssql_fetch_object' : 'mssql_fetch_array';
        } elseif (is_bool($result)) {
            if ($result == false) {

                // SQL error
                throw new Kohana_Database_Exception('database.error', mssql_get_last_message($link).' - '.$sql);
            } else {
                // Its an DELETE, INSERT, REPLACE, or UPDATE querys
                $last_id          = mssql_query('SELECT @@IDENTITY AS last_id', $link);
                $result           = mssql_fetch_assoc($last_id);
                $this->insert_id  = $result['last_id'];
                $this->total_rows = mssql_rows_affected($link);
            }
        }

        // Set result type
        $this->result($object);

        // Store the SQL
        $this->sql = $sql;
    }

    /**
     * Destruct, the cleanup crew!
     */
    public function __destruct()
    {
        if (is_resource($this->result)) {
            mssql_free_result($this->result);
        }
    }

    public function result($object = true, $type = MSSQL_ASSOC)

    {
        $this->fetch_type = ((bool) $object) ? 'mssql_fetch_object' : 'mssql_fetch_array';

        // This check has to be outside the previous statement, because we do not
        // know the state of fetch_type when $object = NULL
        // NOTE - The class set by $type must be defined before fetching the result,
        // autoloading is disabled to save a lot of stupid overhead.
        if ($this->fetch_type == 'mssql_fetch_object') {
            $this->return_type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
        } else {
            $this->return_type = $type;
        }

        return $this;
    }

    public function as_array($object = null, $type = MSSQL_ASSOC)
    {
        return $this->result_array($object, $type);
    }

    public function result_array($object = null, $type = MSSQL_ASSOC)

    {
        $rows = array();

        if (is_string($object)) {
            $fetch = $object;
        } elseif (is_bool($object)) {
            if ($object === true) {
                $fetch = 'mssql_fetch_object';

                // NOTE - The class set by $type must be defined before fetching the result,
                // autoloading is disabled to save a lot of stupid overhead.
                $type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
            } else {
                $fetch = 'mssql_fetch_array';
            }
        } else {
            // Use the default config values
            $fetch = $this->fetch_type;

            if ($fetch == 'mssql_fetch_object') {
                $type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
            }
        }

        if (mssql_num_rows($this->result)) {
            // Reset the pointer location to make sure things work properly
            mssql_data_seek($this->result, 0);

            while ($row = $fetch($this->result, $type)) {
                $rows[] = $row;
            }
        }

        return isset($rows) ? $rows : array();
    }

    public function list_fields()
    {
        $field_names = array();
        while ($field = mssql_fetch_field($this->result)) {
            $field_names[] = $field->name;
        }

        return $field_names;
    }

    public function seek($offset)
    {
        if (! $this->offsetExists($offset)) {
            return false;
        }

        return mssql_data_seek($this->result, $offset);
    }
} // End mssql_Result Class


1		<?php defined('SYSPATH') or die('No direct access allowed.');
2		/**
3		* MSSQL Database Driver
4		*
5		* @package Core
6		* @author Kohana Team
7		* @copyright (c) 2007-2008 Kohana Team
8		* @license http://kohanaphp.com/license.html
9		*/
10		class Database_Mssql_Driver extends Database_Driver
11		{
12		/**
13		* Database connection link
14		*/
15		protected $link;
16
17		/**
18		* Database configuration
19		*/
20		protected $db_config;
21
22		/**
23		* Sets the config for the class.
24		*
25		* @param array database configuration
26		*/
27		public function __construct($config)
28		{
29		$this->db_config = $config;
30
31		Kohana::log('debug', 'MSSQL Database Driver Initialized');
32		}
33
34		/**
35		* Closes the database connection.
36		*/
37		public function __destruct()
38		{
39		is_resource($this->link) and mssql_close($this->link);
40		}
41
42		/**
43		* Make the connection
44		*
45		* @return return connection
46		*/
47		public function connect()
48		{
49		// Check if link already exists
50		if (is_resource($this->link)) {
51		return $this->link;
		0 ignored issues – show Bug Best Practice introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report The return type of `return $this->link;` (`resource`) is incompatible with the return type documented by `Database_Mssql_Driver::connect` of type `return`. If you return a value from a function or method, it should be a sub-type of the type that is given by the parent type f.e. an interface, or abstract method. This is more formally defined by the Lizkov substitution principle, and guarantees that classes that depend on the parent type can use any instance of a child type interchangably. This principle also belongs to the SOLID principles for object oriented design. Let’s take a look at an example: class Author { private $name; public function __construct($name) { $this->name = $name; } public function getName() { return $this->name; } } abstract class Post { public function getAuthor() { return 'Johannes'; } } class BlogPost extends Post { public function getAuthor() { return new Author('Johannes'); } } class ForumPost extends Post { /* ... */ } function my_function(Post $post) { echo strtoupper($post->getAuthor()); } Our function `my_function` expects a `Post` object, and outputs the author of the post. The base class `Post` returns a simple string and outputting a simple string will work just fine. However, the child class `BlogPost` which is a sub-type of `Post` instead decided to return an `object`, and is therefore violating the SOLID principles. If a `BlogPost` were passed to `my_function`, PHP would not complain, but ultimately fail when executing the `strtoupper` call in its body. Loading history...
52		}
53
54		// Import the connect variables
55		extract($this->db_config['connection']);
56
57		// Persistent connections enabled?
58		$connect = ($this->db_config['persistent'] == true) ? 'mssql_pconnect' : 'mssql_connect';
59
60		// Build the connection info
61		$host = isset($host) ? $host : $socket;
62
63		// Windows uses a comma instead of a colon
64		$port = (isset($port) and is_string($port)) ? (KOHANA_IS_WIN ? ',' : ':').$port : '';
65
66		// Make the connection and select the database
67		if (($this->link = $connect($host.$port, $user, $pass, true)) and mssql_select_db($database, $this->link)) {
68		/* This is being removed so I can use it, will need to come up with a more elegant workaround in the future...
69		*
70		if ($charset = $this->db_config['character_set'])
71		{
72		$this->set_charset($charset);
73		}
74		*/
75
76		// Clear password after successful connect
77		$this->db_config['connection']['pass'] = null;
78
79		return $this->link;
80		}
81
82		return false;
		0 ignored issues – show Bug Best Practice introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report The return type of `return false;` (`false`) is incompatible with the return type documented by `Database_Mssql_Driver::connect` of type `return`. If you return a value from a function or method, it should be a sub-type of the type that is given by the parent type f.e. an interface, or abstract method. This is more formally defined by the Lizkov substitution principle, and guarantees that classes that depend on the parent type can use any instance of a child type interchangably. This principle also belongs to the SOLID principles for object oriented design. Let’s take a look at an example: class Author { private $name; public function __construct($name) { $this->name = $name; } public function getName() { return $this->name; } } abstract class Post { public function getAuthor() { return 'Johannes'; } } class BlogPost extends Post { public function getAuthor() { return new Author('Johannes'); } } class ForumPost extends Post { /* ... */ } function my_function(Post $post) { echo strtoupper($post->getAuthor()); } Our function `my_function` expects a `Post` object, and outputs the author of the post. The base class `Post` returns a simple string and outputting a simple string will work just fine. However, the child class `BlogPost` which is a sub-type of `Post` instead decided to return an `object`, and is therefore violating the SOLID principles. If a `BlogPost` were passed to `my_function`, PHP would not complain, but ultimately fail when executing the `strtoupper` call in its body. Loading history...
83		}
84
85		/**
86		* @param string $sql
87		*/
88	View Code Duplication	public function query($sql)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
89		{
90		// Only cache if it's turned on, and only cache if it's not a write statement
91		if ($this->db_config['cache'] and ! preg_match('#\b(?:INSERT\|UPDATE\|REPLACE\|SET)\b#i', $sql)) {
92		$hash = $this->query_hash($sql);
93
94		if (! isset($this->query_cache[$hash])) {
95		// Set the cached object
96		$this->query_cache[$hash] = new Mssql_Result(mssql_query($sql, $this->link), $this->link, $this->db_config['object'], $sql);
97		} else {
98		// Rewind cached result
99		$this->query_cache[$hash]->rewind();
100		}
101
102		// Return the cached query
103		return $this->query_cache[$hash];
104		}
105
106		return new Mssql_Result(mssql_query($sql, $this->link), $this->link, $this->db_config['object'], $sql);
107		}
108
109	View Code Duplication	public function escape_table($table)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
110		{
111		if (stripos($table, ' AS ') !== false) {
112		// Force 'AS' to uppercase
113		$table = str_ireplace(' AS ', ' AS ', $table);
114
115		// Runs escape_table on both sides of an AS statement
116		$table = array_map(array($this, __FUNCTION__), explode(' AS ', $table));
117
118		// Re-create the AS statement
119		return implode(' AS ', $table);
120		}
121		return '['.str_replace('.', '[.]', $table).']';
122		}
123
124	View Code Duplication	public function escape_column($column)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
125		{
126		if (!$this->db_config['escape']) {
127		return $column;
128		}
129
130		if ($column == '*') {
131		return $column;
132		}
133
134		// This matches any functions we support to SELECT.
135		if (preg_match('/(avg\|count\|sum\|max\|min)\(\s(.)\s\)(\sas\s*(.+)?)?/i', $column, $matches)) {
136		if (count($matches) == 3) {
137		return $matches[1].'('.$this->escape_column($matches[2]).')';
138		} elseif (count($matches) == 5) {
139		return $matches[1].'('.$this->escape_column($matches[2]).') AS '.$this->escape_column($matches[2]);
140		}
141		}
142
143		// This matches any modifiers we support to SELECT.
144		if (! preg_match('/\b(?:rand\|all\|distinct(?:row)?\|high_priority\|sql_(?:small_result\|b(?:ig_result\|uffer_result)\|no_cache\|ca(?:che\|lc_found_rows)))\s/i', $column)) {
145		if (stripos($column, ' AS ') !== false) {
146		// Force 'AS' to uppercase
147		$column = str_ireplace(' AS ', ' AS ', $column);
148
149		// Runs escape_column on both sides of an AS statement
150		$column = array_map(array($this, __FUNCTION__), explode(' AS ', $column));
151
152		// Re-create the AS statement
153		return implode(' AS ', $column);
154		}
155
156		return preg_replace('/[^.*]+/', '[$0]', $column);
157		}
158
159		$parts = explode(' ', $column);
160		$column = '';
161
162		for ($i = 0, $c = count($parts); $i < $c; $i++) {
163		// The column is always last
164		if ($i == ($c - 1)) {
165		$column .= preg_replace('/[^.*]+/', '[$0]', $parts[$i]);
166		} else { // otherwise, it's a modifier
167		$column .= $parts[$i].' ';
168		}
169		}
170		return $column;
171		}
172
173		/**
174		* Limit in SQL Server 2000 only uses the keyword
175		* 'TOP'; 2007 may have an offset keyword, but
176		* I am unsure - for pagination style limit,offset
177		* functionality, a fancy query needs to be built.
178		*
179		* @param unknown_type $limit
180		* @return string
181		*/
182		public function limit($limit, $offset=null)
183		{
184		return 'TOP '.$limit;
185		}
186
187	View Code Duplication	public function compile_select($database)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
188		{
189		$sql = ($database['distinct'] == true) ? 'SELECT DISTINCT ' : 'SELECT ';
190		$sql .= (count($database['select']) > 0) ? implode(', ', $database['select']) : '*';
191
192		if (count($database['from']) > 0) {
193		// Escape the tables
194		$froms = array();
195		foreach ($database['from'] as $from) {
196		$froms[] = $this->escape_column($from);
197		}
198		$sql .= "\nFROM ";
199		$sql .= implode(', ', $froms);
200		}
201
202		if (count($database['join']) > 0) {
203		foreach ($database['join'] as $join) {
204		$sql .= "\n".$join['type'].'JOIN '.implode(', ', $join['tables']).' ON '.$join['conditions'];
205		}
206		}
207
208		if (count($database['where']) > 0) {
209		$sql .= "\nWHERE ";
210		}
211
212		$sql .= implode("\n", $database['where']);
213
214		if (count($database['groupby']) > 0) {
215		$sql .= "\nGROUP BY ";
216		$sql .= implode(', ', $database['groupby']);
217		}
218
219		if (count($database['having']) > 0) {
220		$sql .= "\nHAVING ";
221		$sql .= implode("\n", $database['having']);
222		}
223
224		if (count($database['orderby']) > 0) {
225		$sql .= "\nORDER BY ";
226		$sql .= implode(', ', $database['orderby']);
227		}
228
229		if (is_numeric($database['limit'])) {
230		$sql .= "\n";
231		$sql .= $this->limit($database['limit']);
232		}
233
234		return $sql;
235		}
236
237		public function escape_str($str)
238		{
239		if (!$this->db_config['escape']) {
240		return $str;
241		}
242
243		is_resource($this->link) or $this->connect();
244		//mssql_real_escape_string($str, $this->link); <-- this function doesn't exist
245
246		$characters = array('/\x00/', '/\x1a/', '/\n/', '/\r/', '/\\\/', '/\'/');
247		$replace = array('\\\x00', '\\x1a', '\\n', '\\r', '\\\\', "''");
248		return preg_replace($characters, $replace, $str);
249		}
250
251		public function list_tables()
252		{
253		$sql = 'SHOW TABLES FROM ['.$this->db_config['connection']['database'].']';
254		$result = $this->query($sql)->result(false, MSSQL_ASSOC);
		0 ignored issues – show Documentation introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report `MSSQL_ASSOC` is of type `integer`, but the function expects a `boolean`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
255
256		$retval = array();
257		foreach ($result as $row) {
258		$retval[] = current($row);
259		}
260
261		return $retval;
262		}
263
264		public function show_error()
265		{
266		return mssql_get_last_message($this->link);
267		}
268
269		public function list_fields($table)
270		{
271		$result = array();
272
273		foreach ($this->field_data($table) as $row) {
274		// Make an associative array
275		$result[$row->Field] = $this->sql_type($row->Type);
276		}
277
278		return $result;
279		}
280
281		public function field_data($table)
282		{
283		$query = $this->query("SELECT COLUMN_NAME AS Field, DATA_TYPE as Type FROM INFORMATION_SCHEMA.Columns WHERE TABLE_NAME = '".$this->escape_table($table)."'", $this->link);
		0 ignored issues – show Unused Code introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report The call to `Database_Mssql_Driver::query()` has too many arguments starting with `$this->link`. This check compares calls to functions or methods with their respective definitions. If the call has more arguments than are defined, it raises an issue. If a function is defined several times with a different number of parameters, the check may pick up the wrong definition and report false positives. One codebase where this has been known to happen is Wordpress. In this case you can add the `@ignore` PhpDoc annotation to the duplicate definition and it will be ignored. Loading history...
284
285		return $query->result_array(true);
286		}
287		}
288
289		/**
290		* MSSQL Result
291		*/
292		class Mssql_Result extends Database_Result
293		{
294
295		// Fetch function and return type
296		protected $fetch_type = 'mssql_fetch_object';
297		protected $return_type = MSSQL_ASSOC;
298
299		/**
300		* Sets up the result variables.
301		*
302		* @param resource query result
303		* @param resource database link
304		* @param boolean return objects or arrays
305		* @param string SQL query that was run
306		*/
307		public function __construct($result, $link, $object = true, $sql)
308		{
309		$this->result = $result;
310
311		// If the query is a resource, it was a SELECT, SHOW, DESCRIBE, EXPLAIN query
312		if (is_resource($result)) {
313		$this->current_row = 0;
314		$this->total_rows = mssql_num_rows($this->result);
315		$this->fetch_type = ($object === true) ? 'mssql_fetch_object' : 'mssql_fetch_array';
316		} elseif (is_bool($result)) {
317		if ($result == false) {
		0 ignored issues – show Coding Style Best Practice introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report It seems like you are loosely comparing two booleans. Considering using the strict comparison `===` instead. When comparing two booleans, it is generally considered safer to use the strict comparison operator. Loading history...
318		// SQL error
319		throw new Kohana_Database_Exception('database.error', mssql_get_last_message($link).' - '.$sql);
320		} else {
321		// Its an DELETE, INSERT, REPLACE, or UPDATE querys
322		$last_id = mssql_query('SELECT @@IDENTITY AS last_id', $link);
323		$result = mssql_fetch_assoc($last_id);
324		$this->insert_id = $result['last_id'];
325		$this->total_rows = mssql_rows_affected($link);
326		}
327		}
328
329		// Set result type
330		$this->result($object);
331
332		// Store the SQL
333		$this->sql = $sql;
334		}
335
336		/**
337		* Destruct, the cleanup crew!
338		*/
339		public function __destruct()
340		{
341		if (is_resource($this->result)) {
342		mssql_free_result($this->result);
343		}
344		}
345
346	View Code Duplication	public function result($object = true, $type = MSSQL_ASSOC)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
347		{
348		$this->fetch_type = ((bool) $object) ? 'mssql_fetch_object' : 'mssql_fetch_array';
349
350		// This check has to be outside the previous statement, because we do not
351		// know the state of fetch_type when $object = NULL
352		// NOTE - The class set by $type must be defined before fetching the result,
353		// autoloading is disabled to save a lot of stupid overhead.
354		if ($this->fetch_type == 'mssql_fetch_object') {
355		$this->return_type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
356		} else {
357		$this->return_type = $type;
358		}
359
360		return $this;
361		}
362
363		public function as_array($object = null, $type = MSSQL_ASSOC)
364		{
365		return $this->result_array($object, $type);
366		}
367
368	View Code Duplication	public function result_array($object = null, $type = MSSQL_ASSOC)
		0 ignored issues – show Duplication introduced 2016-08-25 15:43 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. 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. Loading history...
369		{
370		$rows = array();
371
372		if (is_string($object)) {
373		$fetch = $object;
374		} elseif (is_bool($object)) {
375		if ($object === true) {
376		$fetch = 'mssql_fetch_object';
377
378		// NOTE - The class set by $type must be defined before fetching the result,
379		// autoloading is disabled to save a lot of stupid overhead.
380		$type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
381		} else {
382		$fetch = 'mssql_fetch_array';
383		}
384		} else {
385		// Use the default config values
386		$fetch = $this->fetch_type;
387
388		if ($fetch == 'mssql_fetch_object') {
389		$type = (is_string($type) and Kohana::auto_load($type)) ? $type : 'stdClass';
390		}
391		}
392
393		if (mssql_num_rows($this->result)) {
394		// Reset the pointer location to make sure things work properly
395		mssql_data_seek($this->result, 0);
396
397		while ($row = $fetch($this->result, $type)) {
398		$rows[] = $row;
399		}
400		}
401
402		return isset($rows) ? $rows : array();
403		}
404
405		public function list_fields()
406		{
407		$field_names = array();
408		while ($field = mssql_fetch_field($this->result)) {
409		$field_names[] = $field->name;
410		}
411
412		return $field_names;
413		}
414
415		public function seek($offset)
416		{
417		if (! $this->offsetExists($offset)) {
418		return false;
419		}
420
421		return mssql_data_seek($this->result, $offset);
422		}
423		} // End mssql_Result Class
424

vijinho / kohana2-legacy

Database_Mssql_Driver B last analyzed 2016-08-25 15:53 UTC