OracleSQLTranslator::isCLOBColumn() - Code Metrics - thecodingmachine/magic-query - Measure and Improve Code Quality continuously with Scrutinizer

OracleSQLTranslator::isCLOBColumn() C
last analyzed 2016-08-17 10:37 UTC

↳ Parent: OracleSQLTranslator

Complexity

Conditions	8
Paths	7

Size

Total Lines	27
Code Lines	13

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
c	2
b	0
f	0
dl	0
loc	27
rs	5.3846
cc	8
eloc	13
nc	7
nop	2

<?php

namespace SQLParser;

/**
 * OracleSQLTranslator.
 *
 * A translator from MySQL dialect into Oracle dialect for Limesurvey
 * (http://www.limesurvey.org/)
 *
 * Copyright (c) 2012, André Rothe <[email protected], [email protected]>
 *
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without modification,
 * are permitted provided that the following conditions are met:
 *
 *   * Redistributions of source code must retain the above copyright notice,
 *     this list of conditions and the following disclaimer.
 *   * Redistributions in binary form must reproduce the above copyright notice,
 *     this list of conditions and the following disclaimer in the documentation
 *     and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
 * SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
 * TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
 * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
 * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
 * DAMAGE.
 */

//include_once(ROOT_PATH . 'classes/adodb/adodb.inc.php');


//$_ENV['DEBUG'] = 1;


class OracleSQLTranslator extends PHPSQLCreator
{
    private $con; # this is the database connection from LimeSurvey
    private $preventColumnRefs = array();
    private $allTables = array();
    const ASTERISK_ALIAS = '[#RePl#]';

    public function __construct($con)
    {
        parent::__construct();
        $this->con = $con;
        $this->initGlobalVariables();
    }

    private function initGlobalVariables()
    {
        $this->preventColumnRefs = false;

        $this->allTables = array();
    }

    public static function dbgprint($txt)
// Bad
class Router
{
    public function generate($path)
    {
        return $_SERVER['HOST'].$path;
    }
}

// Better
class Router
{
    private $host;

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

    public function generate($path)
    {
        return $this->host.$path;
    }
}

class Controller
{
    public function myAction(Request $request)
    {
        // Instead of
        $page = isset($_GET['page']) ? intval($_GET['page']) : 1;

        // Better (assuming you use the Symfony2 request)
        $page = $request->query->get('page', 1);
    }
}
    {
        if (isset($_ENV['DEBUG'])) {
            print $txt;
        }
    }

    public static function preprint($s, $return = false)
    {
        $x = '<pre>';
        $x .= print_r($s, 1);
        $x .= '</pre>';
        if ($return) {
            return $x;
        }
        self::dbgprint($x."<br/>\n");
    }

    protected function processAlias($parsed)
    {
        if ($parsed === false) {
            return '';
        }
        # we don't need an AS between expression and alias
        $sql = ' '.$parsed['name'];

        return $sql;
    }

    protected function processDELETE($parsed)
    {
        if (count($parsed['TABLES']) > 1) {
            die('cannot translate delete statement into Oracle dialect, multiple tables are not allowed.');

        }

        return 'DELETE';
    }

    public static function getColumnNameFor($column)
    {
        if (strtolower($column) === 'uid') {
            $column = 'uid_';
        }
        // TODO: add more here, if necessary
        return $column;
    }

    public static function getShortTableNameFor($table)
    {
        if (strtolower($table) === 'surveys_languagesettings') {
            $table = 'surveys_lngsettings';
        }
        // TODO: add more here, if necessary
        return $table;
    }

    protected function processTable($parsed, $index)
    {
        if ($parsed['expr_type'] !== 'table') {
            return '';
        }

        $sql = $this->getShortTableNameFor($parsed['table']);
        $alias = $this->processAlias($parsed['alias']);
        $sql .= $alias;

        if ($index !== 0) {
            $sql = $this->processJoin($parsed['join_type']).' '.$sql;
            $sql .= $this->processRefType($parsed['ref_type']);
            $sql .= $this->processRefClause($parsed['ref_clause']);
        }

        # store the table and its alias for later use
        $last = array_pop($this->allTables);
        $last['tables'][] = array('table' => $this->getShortTableNameFor($parsed['table']), 'alias' => trim($alias));
        $this->allTables[] = $last;

        return $sql;
    }

    protected function processFROM($parsed)
    {
        $this->allTables[] = array('tables' => array(), 'alias' => '');

        return parent::processFROM($parsed);
    }

    protected function processTableExpression($parsed, $index)
    {
        if ($parsed['expr_type'] !== 'table_expression') {
            return '';
        }
        $sql = substr($this->processFROM($parsed['sub_tree']), 5); // remove FROM keyword
        $sql = '('.$sql.')';

        $alias .= $this->processAlias($parsed['alias']);

        $sql .= $alias;

        # store the tables-expression-alias for later use
        $last = array_pop($this->allTables);
        $last['alias'] = trim($alias);
        $this->allTables[] = $last;

        if ($index !== 0) {
            $sql = $this->processJoin($parsed['join_type']).' '.$sql;
            $sql .= $this->processRefType($parsed['ref_type']);
            $sql .= $this->processRefClause($parsed['ref_clause']);
        }

        return $sql;
    }

    private function getTableNameFromExpression($expr)

    {
        $pos = strpos($expr, '.');
        if ($pos === false) {
            $pos = -1;
        }

        return trim(substr($expr, 0, $pos + 1), '.');
    }

    private function getColumnNameFromExpression($expr)

    {
        $pos = strpos($expr, '.');
        if ($pos === false) {
            $pos = -1;
        }

        return substr($expr, $pos + 1);
    }

    private function isCLOBColumnInDB($table, $column)
    {
        $res = $this->con->GetOne(
                "SELECT count(*) FROM user_lobs WHERE table_name='".strtoupper($table)."' AND column_name='"
                        .strtoupper($column)."'");

        return ($res >= 1);
    }

    protected function isCLOBColumn($table, $column)
    {
        $tables = end($this->allTables);

        if ($table === '') {
            foreach ($tables['tables'] as $k => $v) {
                if ($this->isCLOBColumn($v['table'], $column)) {
                    return true;
                }
            }

            return false;
        }

        # check the aliases, $table cannot be empty
        foreach ($tables['tables'] as $k => $v) {
            if ((strtolower($v['alias']) === strtolower($table))
                    || (strtolower($tables['alias']) === strtolower($table))) {
                if ($this->isCLOBColumnInDB($v['table'], $column)) {
                    return true;
                }
            }
        }

        # it must be a valid table name
        return $this->isCLOBColumnInDB($table, $column);
    }

    protected function processOrderByExpression($parsed)
    {
        if ($parsed['type'] !== 'expression') {
            return '';
        }

        $table = $this->getTableNameFromExpression($parsed['base_expr']);
        $col = $this->getColumnNameFromExpression($parsed['base_expr']);

        $sql = ($table !== '' ? $table.'.' : '').$col;

        # check, if the column is a CLOB
        if ($this->isCLOBColumn($table, $col)) {
            $sql = 'cast(substr('.$sql.',1,200) as varchar2(200))';
        }

        return $sql.' '.$parsed['direction'];
    }

    protected function processColRef($parsed)
    {
        if ($parsed['expr_type'] !== 'colref') {
            return '';
        }

        $table = $this->getTableNameFromExpression($parsed['base_expr']);
        $col = $this->getColumnNameFromexpression($parsed['base_expr']);

        # we have to change the column name, if the column is uid
        # we have to change the tablereference, if the tablename is too long
        $col = $this->getColumnNameFor($col);
        $table = $this->getShortTableNameFor($table);

        # if we have * as colref, we cannot use other columns
        # we have to add alias.* if we know all table aliases
        if (($table === '') && ($col === '*')) {
            array_pop($this->preventColumnRefs);
            $this->preventColumnRefs[] = true;

            return ASTERISK_ALIAS; # this is the position, we have to replace later
        }

        $alias = '';
        if (isset($parsed['alias'])) {
            $alias = $this->processAlias($parsed['alias']);
        }

        return (($table !== '') ? ($table.'.'.$col) : $col).$alias;
    }

    protected function processFunctionOnSelect($parsed)
    {
        $old = end($this->preventColumnRefs);
        $sql = $this->processFunction($parsed);

        if ($old !== end($this->preventColumnRefs)) {
            # prevents wrong handling of count(*)
            array_pop($this->preventColumnRefs);
            $this->preventColumnRefs[] = $old;
            $sql = str_replace(ASTERISK_ALIAS, '*', $sql);
        }

        return $sql;
    }

    protected function processSELECT($parsed)
    {
        $this->preventColumnRefs[] = false;

        $sql = '';
        foreach ($parsed as $k => $v) {
            $len = strlen($sql);
            $sql .= $this->processColRef($v);
            $sql .= $this->processSelectExpression($v);
            $sql .= $this->processFunctionOnSelect($v);
            $sql .= $this->processConstant($v);

            if ($len == strlen($sql)) {
                $this->stop('SELECT', $k, $v, 'expr_type');

            }

            $sql .= ',';
        }
        $sql = substr($sql, 0, -1);

        return 'SELECT '.$sql;
    }

    private function correctColRefStatement($sql)
    {
        $alias = '';
        $tables = end($this->allTables);

        # should we correct the selection list?
        if (array_pop($this->preventColumnRefs)) {

            # do we have a table-expression alias?
            if ($tables['alias'] !== '') {
                $alias = $tables['alias'].'.*';
            } else {
                foreach ($tables['tables'] as $k => $v) {
                    $alias .= ($v['alias'] === '' ? $v['table'] : $v['alias']).'.*,';
                }
                $alias = substr($alias, 0, -1);
            }
            $sql = str_replace(ASTERISK_ALIAS, $alias, $sql);
        }

        return $sql;
    }

    protected function processSelectStatement($parsed)
    {
        $sql = $this->processSELECT($parsed['SELECT']);
        $from = $this->processFROM($parsed['FROM']);

        # correct * references with tablealias.*
        # this must be called after processFROM(), because we need the table information
        $sql = $this->correctColRefStatement($sql).' '.$from;

        if (isset($parsed['WHERE'])) {
            $sql .= ' '.$this->processWHERE($parsed['WHERE']);
        }
        if (isset($parsed['GROUP'])) {
            $sql .= ' '.$this->processGROUP($parsed['GROUP']);
        }
        if (isset($parsed['ORDER'])) {
            $sql .= ' '.$this->processORDER($parsed['ORDER']);
        }

        # select finished, we remove its tables
        #  FIXME: we should add it to the previous tablelist with the
        #  global alias, if such one exists
        array_pop($this->allTables);

        return $sql;
    }

    public function create($parsed)
    {
        $k = key($parsed);
        switch ($k) {
        case 'USE':
        # this statement is not an Oracle statement
            $this->created = '';
class MyClass { }

$x = new MyClass();
$x->foo = true;
            break;

        default:
            $this->created = parent::create($parsed);
            break;
        }

        return $this->created;
    }

    public function process($sql)
    {
        self::dbgprint($sql.'<br/>');

        $this->initGlobalVariables();
        $parser = new SQLParser($sql);
        self::preprint($parser->parsed);


        $sql = $this->create($parser->parsed);
        self::dbgprint($sql.'<br/>');

        return $sql;
    }
}

//$translator = new OracleSQLTranslator(false);

//$translator->process("SELECT q.qid, question, gid FROM questions as q WHERE (select count(*) from answers as a where a.qid=q.qid and scale_id=0)=0 and sid=11929 AND type IN ('F', 'H', 'W', 'Z', '1') and q.parent_qid=0");
//$translator->process("SELECT *, (SELECT a from xyz WHERE b>1) haha, (SELECT *, b from zks,abc WHERE d=1) hoho FROM blubb d, blibb c WHERE d.col = c.col");



1		<?php
2
3		namespace SQLParser;
4
5		/**
6		* OracleSQLTranslator.
7		*
8		* A translator from MySQL dialect into Oracle dialect for Limesurvey
9		* (http://www.limesurvey.org/)
10		*
11		* Copyright (c) 2012, André Rothe <[email protected], [email protected]>
12		*
13		* All rights reserved.
14		*
15		* Redistribution and use in source and binary forms, with or without modification,
16		* are permitted provided that the following conditions are met:
17		*
18		* * Redistributions of source code must retain the above copyright notice,
19		* this list of conditions and the following disclaimer.
20		* * Redistributions in binary form must reproduce the above copyright notice,
21		* this list of conditions and the following disclaimer in the documentation
22		* and/or other materials provided with the distribution.
23		*
24		* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
25		* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
26		* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT
27		* SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
28		* INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED
29		* TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
30		* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
31		* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
32		* ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH
33		* DAMAGE.
34		*/
35
36		//include_once(ROOT_PATH . 'classes/adodb/adodb.inc.php');
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-02-29 11:47 UTC by Report Bug Copy Issue Report `56%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
37
38		//$_ENV['DEBUG'] = 1;
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-02-29 11:47 UTC by Report Bug Copy Issue Report `67%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
39
40		class OracleSQLTranslator extends PHPSQLCreator
41		{
42		private $con; # this is the database connection from LimeSurvey
43		private $preventColumnRefs = array();
44		private $allTables = array();
45		const ASTERISK_ALIAS = '[#RePl#]';
46
47		public function __construct($con)
48		{
49		parent::__construct();
50		$this->con = $con;
51		$this->initGlobalVariables();
52		}
53
54		private function initGlobalVariables()
55		{
56		$this->preventColumnRefs = false;
		0 ignored issues – show Documentation Bug introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report It seems like `false` of type `false` is incompatible with the declared type `array` of property `$preventColumnRefs`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
57		$this->allTables = array();
58		}
59
60		public static function dbgprint($txt)
		0 ignored issues – show Coding Style introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report `dbgprint` uses the super-global variable `$_ENV` which is generally not recommended. Instead of super-globals, we recommend to explicitly inject the dependencies of your class. This makes your code less dependent on global state and it becomes generally more testable: // Bad class Router { public function generate($path) { return $_SERVER['HOST'].$path; } } // Better class Router { private $host; public function __construct($host) { $this->host = $host; } public function generate($path) { return $this->host.$path; } } class Controller { public function myAction(Request $request) { // Instead of $page = isset($_GET['page']) ? intval($_GET['page']) : 1; // Better (assuming you use the Symfony2 request) $page = $request->query->get('page', 1); } } Loading history...
61		{
62		if (isset($_ENV['DEBUG'])) {
63		print $txt;
64		}
65		}
66
67		public static function preprint($s, $return = false)
68		{
69		$x = '<pre>';
70		$x .= print_r($s, 1);
71		$x .= '</pre>';
72		if ($return) {
73		return $x;
74		}
75		self::dbgprint($x."<br/>\n");
76		}
77
78		protected function processAlias($parsed)
79		{
80		if ($parsed === false) {
81		return '';
82		}
83		# we don't need an AS between expression and alias
84		$sql = ' '.$parsed['name'];
85
86		return $sql;
87		}
88
89		protected function processDELETE($parsed)
90		{
91		if (count($parsed['TABLES']) > 1) {
92		die('cannot translate delete statement into Oracle dialect, multiple tables are not allowed.');
		0 ignored issues – show Coding Style Compatibility introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report The method `processDELETE()` contains an exit expression. An exit expression should only be used in rare cases. For example, if you write a short command line script. In most cases however, using an `exit` expression makes the code untestable and often causes incompatibilities with other libraries. Thus, unless you are absolutely sure it is required here, we recommend to refactor your code to avoid its usage. Loading history...
93		}
94
95		return 'DELETE';
96		}
97
98		public static function getColumnNameFor($column)
99		{
100		if (strtolower($column) === 'uid') {
101		$column = 'uid_';
102		}
103		// TODO: add more here, if necessary
104		return $column;
105		}
106
107		public static function getShortTableNameFor($table)
108		{
109		if (strtolower($table) === 'surveys_languagesettings') {
110		$table = 'surveys_lngsettings';
111		}
112		// TODO: add more here, if necessary
113		return $table;
114		}
115
116		protected function processTable($parsed, $index)
117		{
118		if ($parsed['expr_type'] !== 'table') {
119		return '';
120		}
121
122		$sql = $this->getShortTableNameFor($parsed['table']);
123		$alias = $this->processAlias($parsed['alias']);
124		$sql .= $alias;
125
126		if ($index !== 0) {
127		$sql = $this->processJoin($parsed['join_type']).' '.$sql;
128		$sql .= $this->processRefType($parsed['ref_type']);
129		$sql .= $this->processRefClause($parsed['ref_clause']);
130		}
131
132		# store the table and its alias for later use
133		$last = array_pop($this->allTables);
134		$last['tables'][] = array('table' => $this->getShortTableNameFor($parsed['table']), 'alias' => trim($alias));
135		$this->allTables[] = $last;
136
137		return $sql;
138		}
139
140		protected function processFROM($parsed)
141		{
142		$this->allTables[] = array('tables' => array(), 'alias' => '');
143
144		return parent::processFROM($parsed);
145		}
146
147		protected function processTableExpression($parsed, $index)
148		{
149		if ($parsed['expr_type'] !== 'table_expression') {
150		return '';
151		}
152		$sql = substr($this->processFROM($parsed['sub_tree']), 5); // remove FROM keyword
153		$sql = '('.$sql.')';
154
155		$alias .= $this->processAlias($parsed['alias']);
		0 ignored issues – show Bug introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report The variable `$alias` does not exist. Did you forget to declare it? This check marks access to variables or properties that have not been declared yet. While PHP has no explicit notion of declaring a variable, accessing it before a value is assigned to it is most likely a bug. Loading history...
156		$sql .= $alias;
157
158		# store the tables-expression-alias for later use
159		$last = array_pop($this->allTables);
160		$last['alias'] = trim($alias);
161		$this->allTables[] = $last;
162
163		if ($index !== 0) {
164		$sql = $this->processJoin($parsed['join_type']).' '.$sql;
165		$sql .= $this->processRefType($parsed['ref_type']);
166		$sql .= $this->processRefClause($parsed['ref_clause']);
167		}
168
169		return $sql;
170		}
171
172	View Code Duplication	private function getTableNameFromExpression($expr)
		0 ignored issues – show Duplication introduced 2015-12-08 18:20 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...
173		{
174		$pos = strpos($expr, '.');
175		if ($pos === false) {
176		$pos = -1;
177		}
178
179		return trim(substr($expr, 0, $pos + 1), '.');
180		}
181
182	View Code Duplication	private function getColumnNameFromExpression($expr)
		0 ignored issues – show Duplication introduced 2015-12-08 18:20 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...
183		{
184		$pos = strpos($expr, '.');
185		if ($pos === false) {
186		$pos = -1;
187		}
188
189		return substr($expr, $pos + 1);
190		}
191
192		private function isCLOBColumnInDB($table, $column)
193		{
194		$res = $this->con->GetOne(
195		"SELECT count(*) FROM user_lobs WHERE table_name='".strtoupper($table)."' AND column_name='"
196		.strtoupper($column)."'");
197
198		return ($res >= 1);
199		}
200
201		protected function isCLOBColumn($table, $column)
202		{
203		$tables = end($this->allTables);
204
205		if ($table === '') {
206		foreach ($tables['tables'] as $k => $v) {
207		if ($this->isCLOBColumn($v['table'], $column)) {
208		return true;
209		}
210		}
211
212		return false;
213		}
214
215		# check the aliases, $table cannot be empty
216		foreach ($tables['tables'] as $k => $v) {
217		if ((strtolower($v['alias']) === strtolower($table))
218		\|\| (strtolower($tables['alias']) === strtolower($table))) {
219		if ($this->isCLOBColumnInDB($v['table'], $column)) {
220		return true;
221		}
222		}
223		}
224
225		# it must be a valid table name
226		return $this->isCLOBColumnInDB($table, $column);
227		}
228
229		protected function processOrderByExpression($parsed)
230		{
231		if ($parsed['type'] !== 'expression') {
232		return '';
233		}
234
235		$table = $this->getTableNameFromExpression($parsed['base_expr']);
236		$col = $this->getColumnNameFromExpression($parsed['base_expr']);
237
238		$sql = ($table !== '' ? $table.'.' : '').$col;
239
240		# check, if the column is a CLOB
241		if ($this->isCLOBColumn($table, $col)) {
242		$sql = 'cast(substr('.$sql.',1,200) as varchar2(200))';
243		}
244
245		return $sql.' '.$parsed['direction'];
246		}
247
248		protected function processColRef($parsed)
249		{
250		if ($parsed['expr_type'] !== 'colref') {
251		return '';
252		}
253
254		$table = $this->getTableNameFromExpression($parsed['base_expr']);
255		$col = $this->getColumnNameFromexpression($parsed['base_expr']);
256
257		# we have to change the column name, if the column is uid
258		# we have to change the tablereference, if the tablename is too long
259		$col = $this->getColumnNameFor($col);
260		$table = $this->getShortTableNameFor($table);
261
262		# if we have * as colref, we cannot use other columns
263		# we have to add alias.* if we know all table aliases
264		if (($table === '') && ($col === '*')) {
265		array_pop($this->preventColumnRefs);
266		$this->preventColumnRefs[] = true;
267
268		return ASTERISK_ALIAS; # this is the position, we have to replace later
269		}
270
271		$alias = '';
272		if (isset($parsed['alias'])) {
273		$alias = $this->processAlias($parsed['alias']);
274		}
275
276		return (($table !== '') ? ($table.'.'.$col) : $col).$alias;
277		}
278
279		protected function processFunctionOnSelect($parsed)
280		{
281		$old = end($this->preventColumnRefs);
282		$sql = $this->processFunction($parsed);
283
284		if ($old !== end($this->preventColumnRefs)) {
285		# prevents wrong handling of count(*)
286		array_pop($this->preventColumnRefs);
287		$this->preventColumnRefs[] = $old;
288		$sql = str_replace(ASTERISK_ALIAS, '*', $sql);
289		}
290
291		return $sql;
292		}
293
294		protected function processSELECT($parsed)
295		{
296		$this->preventColumnRefs[] = false;
297
298		$sql = '';
299		foreach ($parsed as $k => $v) {
300		$len = strlen($sql);
301		$sql .= $this->processColRef($v);
302		$sql .= $this->processSelectExpression($v);
303		$sql .= $this->processFunctionOnSelect($v);
304		$sql .= $this->processConstant($v);
305
306		if ($len == strlen($sql)) {
307		$this->stop('SELECT', $k, $v, 'expr_type');
		0 ignored issues – show Bug introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report The method `stop()` does not seem to exist on `object<SQLParser\OracleSQLTranslator>`. This check looks for calls to methods that do not seem to exist on a given type. It looks for the method on the type itself as well as in inherited classes or implemented interfaces. This is most likely a typographical error or the method has been renamed. Loading history...
308		}
309
310		$sql .= ',';
311		}
312		$sql = substr($sql, 0, -1);
313
314		return 'SELECT '.$sql;
315		}
316
317		private function correctColRefStatement($sql)
318		{
319		$alias = '';
320		$tables = end($this->allTables);
321
322		# should we correct the selection list?
323		if (array_pop($this->preventColumnRefs)) {
324
325		# do we have a table-expression alias?
326		if ($tables['alias'] !== '') {
327		$alias = $tables['alias'].'.*';
328		} else {
329		foreach ($tables['tables'] as $k => $v) {
330		$alias .= ($v['alias'] === '' ? $v['table'] : $v['alias']).'.*,';
331		}
332		$alias = substr($alias, 0, -1);
333		}
334		$sql = str_replace(ASTERISK_ALIAS, $alias, $sql);
335		}
336
337		return $sql;
338		}
339
340		protected function processSelectStatement($parsed)
341		{
342		$sql = $this->processSELECT($parsed['SELECT']);
343		$from = $this->processFROM($parsed['FROM']);
344
345		# correct * references with tablealias.*
346		# this must be called after processFROM(), because we need the table information
347		$sql = $this->correctColRefStatement($sql).' '.$from;
348
349		if (isset($parsed['WHERE'])) {
350		$sql .= ' '.$this->processWHERE($parsed['WHERE']);
351		}
352		if (isset($parsed['GROUP'])) {
353		$sql .= ' '.$this->processGROUP($parsed['GROUP']);
354		}
355		if (isset($parsed['ORDER'])) {
356		$sql .= ' '.$this->processORDER($parsed['ORDER']);
357		}
358
359		# select finished, we remove its tables
360		# FIXME: we should add it to the previous tablelist with the
361		# global alias, if such one exists
362		array_pop($this->allTables);
363
364		return $sql;
365		}
366
367		public function create($parsed)
368		{
369		$k = key($parsed);
370		switch ($k) {
371		case 'USE':
372		# this statement is not an Oracle statement
373		$this->created = '';
		0 ignored issues – show Bug introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report The property `created` does not exist. Did you maybe forget to declare it? In PHP it is possible to write to properties without declaring them. For example, the following is perfectly valid PHP code: class MyClass { } $x = new MyClass(); $x->foo = true; Generally, it is a good practice to explictly declare properties to avoid accidental typos and provide IDE auto-completion: class MyClass { public $foo; } $x = new MyClass(); $x->foo = true; Loading history...
374		break;
375
376		default:
377		$this->created = parent::create($parsed);
378		break;
379		}
380
381		return $this->created;
382		}
383
384		public function process($sql)
385		{
386		self::dbgprint($sql.'<br/>');
387
388		$this->initGlobalVariables();
389		$parser = new SQLParser($sql);
390		self::preprint($parser->parsed);
		0 ignored issues – show Bug introduced 2015-12-08 18:20 UTC by Report Bug Copy Issue Report The property `parsed` does not seem to exist in `SQLParser\SQLParser`. An attempt at access to an undefined property has been detected. This may either be a typographical error or the property has been renamed but there are still references to its old name. If you really want to allow access to undefined properties, you can define magic methods to allow access. See the php core documentation on Overloading. Loading history...
391
392		$sql = $this->create($parser->parsed);
393		self::dbgprint($sql.'<br/>');
394
395		return $sql;
396		}
397		}
398
399		//$translator = new OracleSQLTranslator(false);
		0 ignored issues – show Unused Code Comprehensibility introduced 2016-02-29 11:47 UTC by Report Bug Copy Issue Report `67%` of this comment could be valid code. Did you maybe forget this after debugging? Sometimes obsolete code just ends up commented out instead of removed. In this case it is better to remove the code once you have checked you do not need it. The code might also have been commented out for debugging purposes. In this case it is vital that someone uncomments it again or your project may behave in very unexpected ways in production. This check looks for comments that seem to be mostly valid code and reports them. Loading history...
400		//$translator->process("SELECT q.qid, question, gid FROM questions as q WHERE (select count(*) from answers as a where a.qid=q.qid and scale_id=0)=0 and sid=11929 AND type IN ('F', 'H', 'W', 'Z', '1') and q.parent_qid=0");
401		//$translator->process("SELECT , (SELECT a from xyz WHERE b>1) haha, (SELECT , b from zks,abc WHERE d=1) hoho FROM blubb d, blibb c WHERE d.col = c.col");
402
403

thecodingmachine / magic-query

OracleSQLTranslator::isCLOBColumn() C last analyzed 2016-08-17 10:37 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

OracleSQLTranslator::isCLOBColumn() C
last analyzed 2016-08-17 10:37 UTC