Oci8Connection::getDefaultQueryGrammar() - Code Metrics - Inspection of "Bump v5.2.10" - yajra/laravel-oci8 - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 600ac0...da8e51 )

by Arjay

created 2016-06-24 02:03 UTC

Oci8Connection::getDefaultQueryGrammar() A

↳ Parent: Oci8Connection

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	0
dl	0
loc	4
rs	10
c	0
b	0
f	0

<?php

namespace Yajra\Oci8;

use Doctrine\DBAL\Connection as DoctrineConnection;
use Doctrine\DBAL\Driver\OCI8\Driver as DoctrineDriver;
use Illuminate\Database\Connection;
use Illuminate\Database\Grammar;
use PDO;
use Yajra\Oci8\Query\Grammars\OracleGrammar as QueryGrammar;
use Yajra\Oci8\Query\OracleBuilder as QueryBuilder;
use Yajra\Oci8\Query\Processors\OracleProcessor as Processor;
use Yajra\Oci8\Schema\Grammars\OracleGrammar as SchemaGrammar;
use Yajra\Oci8\Schema\OracleBuilder as SchemaBuilder;
use Yajra\Oci8\Schema\Sequence;
use Yajra\Oci8\Schema\Trigger;

class Oci8Connection extends Connection
{
    /**
     * @var string
     */
    protected $schema;

    /**
     * @var \Yajra\Oci8\Schema\Sequence
     */
    protected $sequence;

    /**
     * @var \Yajra\Oci8\Schema\Trigger
     */
    protected $trigger;

    /**
     * @param PDO|\Closure $pdo
     * @param string $database
     * @param string $tablePrefix
     * @param array $config
     */
    public function __construct($pdo, $database = '', $tablePrefix = '', array $config = [])
    {
        parent::__construct($pdo, $database, $tablePrefix, $config);
        $this->sequence = new Sequence($this);
        $this->trigger  = new Trigger($this);
    }

    /**
     * Get current schema.
     *
     * @return string
     */
    public function getSchema()
    {
        return $this->schema;
    }

    /**
     * Set current schema.
     *
     * @param string $schema
     * @return $this
     */
    public function setSchema($schema)
    {
        $this->schema = $schema;
        $sessionVars  = [
            'CURRENT_SCHEMA' => $schema,
        ];

        return $this->setSessionVars($sessionVars);
    }

    /**
     * Update oracle session variables.
     *
     * @param array $sessionVars
     * @return $this
     */
    public function setSessionVars(array $sessionVars)
    {
        $vars = [];
        foreach ($sessionVars as $option => $value) {
            if (strtoupper($option) == 'CURRENT_SCHEMA') {
                $vars[] = "$option  = $value";
            } else {
                $vars[] = "$option  = '$value'";
            }
        }
        $sql = "ALTER SESSION SET " . implode(" ", $vars);
        $this->statement($sql);

        return $this;
    }

    /**
     * Get sequence class.
     *
     * @return \Yajra\Oci8\Schema\Sequence
     */
    public function getSequence()
    {
        return $this->sequence;
    }

    /**
     * Set sequence class.
     *
     * @param \Yajra\Oci8\Schema\Sequence $sequence
     * @return \Yajra\Oci8\Schema\Sequence
     */
    public function setSequence(Sequence $sequence)
    {
        return $this->sequence = $sequence;
    }

    /**
     * Get oracle trigger class.
     *
     * @return \Yajra\Oci8\Schema\Trigger
     */
    public function getTrigger()
    {
        return $this->trigger;
    }

    /**
     * Set oracle trigger class.
     *
     * @param \Yajra\Oci8\Schema\Trigger $trigger
     * @return \Yajra\Oci8\Schema\Trigger
     */
    public function setTrigger(Trigger $trigger)
    {
        return $this->trigger = $trigger;
    }

    /**
     * Get a schema builder instance for the connection.
     *
     * @return \Yajra\Oci8\Schema\OracleBuilder
     */
    public function getSchemaBuilder()
    {
        if (is_null($this->schemaGrammar)) {
            $this->useDefaultSchemaGrammar();
        }

        return new SchemaBuilder($this);
    }

    /**
     * Begin a fluent query against a database table.
     *
     * @param  string $table
     * @return \Yajra\Oci8\Query\OracleBuilder
     */
    public function table($table)
    {
        $processor = $this->getPostProcessor();

        $query = new QueryBuilder($this, $this->getQueryGrammar(), $processor);


        return $query->from($table);
    }

    /**
     * Set oracle session date format.
     *
     * @param string $format
     * @return $this
     */
    public function setDateFormat($format = 'YYYY-MM-DD HH24:MI:SS')
    {
        $sessionVars = [
            'NLS_DATE_FORMAT'      => $format,
            'NLS_TIMESTAMP_FORMAT' => $format,
        ];

        return $this->setSessionVars($sessionVars);
    }

    /**
     * Get doctrine connection.
     *
     * @return \Doctrine\DBAL\Connection
     */
    public function getDoctrineConnection()
    {
        $driver = $this->getDoctrineDriver();

        $data = ['pdo' => $this->getPdo(), 'user' => $this->getConfig('username')];

        return new DoctrineConnection($data, $driver);
    }

    /**
     * Get doctrine driver.
     *
     * @return \Doctrine\DBAL\Driver\OCI8\Driver
     */
    protected function getDoctrineDriver()
    {
        return new DoctrineDriver;
    }

    /**
     * Get the default query grammar instance.
     *
     * @return \Yajra\Oci8\Query\Grammars\OracleGrammar
     */
    protected function getDefaultQueryGrammar()
    {
        return $this->withTablePrefix(new QueryGrammar);
    }

    /**
     * Set the table prefix and return the grammar.
     *
     * @param \Illuminate\Database\Grammar|\Yajra\Oci8\Query\Grammars\OracleGrammar|\Yajra\Oci8\Schema\Grammars\OracleGrammar $grammar
     * @return \Illuminate\Database\Grammar
     */
    public function withTablePrefix(Grammar $grammar)
    {
        return $this->withSchemaPrefix(parent::withTablePrefix($grammar));
    }

    /**
     * Set the schema prefix and return the grammar.
     *
     * @param \Illuminate\Database\Grammar|\Yajra\Oci8\Query\Grammars\OracleGrammar|\Yajra\Oci8\Schema\Grammars\OracleGrammar $grammar
     * @return \Illuminate\Database\Grammar
     */
    public function withSchemaPrefix(Grammar $grammar)
    {
        $grammar->setSchemaPrefix($this->getConfigSchemaPrefix());
abstract class User
{
    /** @return string */
    abstract public function getPassword();
}

class MyUser extends User
{
    public function getPassword()
    {
        // return something
    }

    public function getDisplayName()
    {
        // return some name.
    }
}

class AuthSystem
{
    public function authenticate(User $user)
    {
        $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName()));
        // do something.
    }
}

        return $grammar;
    }
    
    
    /**
     * Execute a PL/SQL Function and return its value.
     * Usage: DB::executeFunction('function_name(:binding_1,:binding_n)', [':binding_1' => 'hi', ':binding_n' => 'bye'], PDO::PARAM_LOB)
     * 
     * @author Tylerian - [email protected]
     * 
     * @param $sql (mixed)
     * @param $bindings (kvp array)
     * @param $returnType (PDO::PARAM_*)
     * @return $returnType

     */
     public function executeFunction($sql, array $bindings = [], $returnType = PDO::PARAM_STR)
    {
        $query = $this->getPdo()->prepare('begin :result := ' . $sql . '; end;');
        
        foreach ($bindings as $key => &$value)
        {
            if (!preg_match('/^:(.*)$/i', $key))
            {
                $key = ':' . $key;
            }
            
            $query->bindParam($key, $value);
        }
        
        $query->bindParam(':result', $result, $returnType);
        
        $query->execute();
        
        return $result;
    }

    /**
     * Get config schema prefix.
     *
     * @return string
     */
    protected function getConfigSchemaPrefix()
    {
        return isset($this->config['prefix_schema']) ? $this->config['prefix_schema'] : '';
    }

    /**
     * Get the default schema grammar instance.
     *
     * @return \Yajra\Oci8\Schema\Grammars\OracleGrammar
     */
    protected function getDefaultSchemaGrammar()
    {
        return $this->withTablePrefix(new SchemaGrammar);
    }

    /**
     * Get the default post processor instance.
     *
     * @return \Yajra\Oci8\Query\Processors\OracleProcessor
     */
    protected function getDefaultPostProcessor()
    {
        return new Processor;
    }
}


1			<?php
2
3			namespace Yajra\Oci8;
4
5			use Doctrine\DBAL\Connection as DoctrineConnection;
6			use Doctrine\DBAL\Driver\OCI8\Driver as DoctrineDriver;
7			use Illuminate\Database\Connection;
8			use Illuminate\Database\Grammar;
9			use PDO;
10			use Yajra\Oci8\Query\Grammars\OracleGrammar as QueryGrammar;
11			use Yajra\Oci8\Query\OracleBuilder as QueryBuilder;
12			use Yajra\Oci8\Query\Processors\OracleProcessor as Processor;
13			use Yajra\Oci8\Schema\Grammars\OracleGrammar as SchemaGrammar;
14			use Yajra\Oci8\Schema\OracleBuilder as SchemaBuilder;
15			use Yajra\Oci8\Schema\Sequence;
16			use Yajra\Oci8\Schema\Trigger;
17
18			class Oci8Connection extends Connection
19			{
20			/**
21			* @var string
22			*/
23			protected $schema;
24
25			/**
26			* @var \Yajra\Oci8\Schema\Sequence
27			*/
28			protected $sequence;
29
30			/**
31			* @var \Yajra\Oci8\Schema\Trigger
32			*/
33			protected $trigger;
34
35			/**
36			* @param PDO\|\Closure $pdo
37			* @param string $database
38			* @param string $tablePrefix
39			* @param array $config
40			*/
41			public function __construct($pdo, $database = '', $tablePrefix = '', array $config = [])
42			{
43			parent::__construct($pdo, $database, $tablePrefix, $config);
44			$this->sequence = new Sequence($this);
45			$this->trigger = new Trigger($this);
46			}
47
48			/**
49			* Get current schema.
50			*
51			* @return string
52			*/
53			public function getSchema()
54			{
55			return $this->schema;
56			}
57
58			/**
59			* Set current schema.
60			*
61			* @param string $schema
62			* @return $this
63			*/
64			public function setSchema($schema)
65			{
66			$this->schema = $schema;
67			$sessionVars = [
68			'CURRENT_SCHEMA' => $schema,
69			];
70
71			return $this->setSessionVars($sessionVars);
72			}
73
74			/**
75			* Update oracle session variables.
76			*
77			* @param array $sessionVars
78			* @return $this
79			*/
80			public function setSessionVars(array $sessionVars)
81			{
82			$vars = [];
83			foreach ($sessionVars as $option => $value) {
84			if (strtoupper($option) == 'CURRENT_SCHEMA') {
85			$vars[] = "$option = $value";
86			} else {
87			$vars[] = "$option = '$value'";
88			}
89			}
90			$sql = "ALTER SESSION SET " . implode(" ", $vars);
91			$this->statement($sql);
92
93			return $this;
94			}
95
96			/**
97			* Get sequence class.
98			*
99			* @return \Yajra\Oci8\Schema\Sequence
100			*/
101			public function getSequence()
102			{
103			return $this->sequence;
104			}
105
106			/**
107			* Set sequence class.
108			*
109			* @param \Yajra\Oci8\Schema\Sequence $sequence
110			* @return \Yajra\Oci8\Schema\Sequence
111			*/
112			public function setSequence(Sequence $sequence)
113			{
114			return $this->sequence = $sequence;
115			}
116
117			/**
118			* Get oracle trigger class.
119			*
120			* @return \Yajra\Oci8\Schema\Trigger
121			*/
122			public function getTrigger()
123			{
124			return $this->trigger;
125			}
126
127			/**
128			* Set oracle trigger class.
129			*
130			* @param \Yajra\Oci8\Schema\Trigger $trigger
131			* @return \Yajra\Oci8\Schema\Trigger
132			*/
133			public function setTrigger(Trigger $trigger)
134			{
135			return $this->trigger = $trigger;
136			}
137
138			/**
139			* Get a schema builder instance for the connection.
140			*
141			* @return \Yajra\Oci8\Schema\OracleBuilder
142			*/
143			public function getSchemaBuilder()
144			{
145			if (is_null($this->schemaGrammar)) {
146			$this->useDefaultSchemaGrammar();
147			}
148
149			return new SchemaBuilder($this);
150			}
151
152			/**
153			* Begin a fluent query against a database table.
154			*
155			* @param string $table
156			* @return \Yajra\Oci8\Query\OracleBuilder
157			*/
158			public function table($table)
159			{
160			$processor = $this->getPostProcessor();
161
162			$query = new QueryBuilder($this, $this->getQueryGrammar(), $processor);
			0 ignored issues – show Compatibility introduced 2015-12-03 05:05 UTC by Report Bug Copy Issue Report `$this->getQueryGrammar()` of type `object<Illuminate\Databa...Query\Grammars\Grammar>` is not a sub-type of `object<Yajra\Oci8\Query\Grammars\OracleGrammar>`. It seems like you assume a child class of the class `Illuminate\Database\Query\Grammars\Grammar` to be always present. This check looks for parameters that are defined as one type in their type hint or doc comment but seem to be used as a narrower type, i.e an implementation of an interface or a subclass. Consider changing the type of the parameter or doing an instanceof check before assuming your parameter is of the expected type. Loading history... Compatibility introduced 2015-12-03 05:05 UTC by Report Bug Copy Issue Report `$processor` of type `object<Illuminate\Databa...y\Processors\Processor>` is not a sub-type of `object<Yajra\Oci8\Query\...essors\OracleProcessor>`. It seems like you assume a child class of the class `Illuminate\Database\Query\Processors\Processor` to be always present. This check looks for parameters that are defined as one type in their type hint or doc comment but seem to be used as a narrower type, i.e an implementation of an interface or a subclass. Consider changing the type of the parameter or doing an instanceof check before assuming your parameter is of the expected type. Loading history...
163
164			return $query->from($table);
165			}
166
167			/**
168			* Set oracle session date format.
169			*
170			* @param string $format
171			* @return $this
172			*/
173			public function setDateFormat($format = 'YYYY-MM-DD HH24:MI:SS')
174			{
175			$sessionVars = [
176			'NLS_DATE_FORMAT' => $format,
177			'NLS_TIMESTAMP_FORMAT' => $format,
178			];
179
180			return $this->setSessionVars($sessionVars);
181			}
182
183			/**
184			* Get doctrine connection.
185			*
186			* @return \Doctrine\DBAL\Connection
187			*/
188			public function getDoctrineConnection()
189			{
190			$driver = $this->getDoctrineDriver();
191
192			$data = ['pdo' => $this->getPdo(), 'user' => $this->getConfig('username')];
193
194			return new DoctrineConnection($data, $driver);
195			}
196
197			/**
198			* Get doctrine driver.
199			*
200			* @return \Doctrine\DBAL\Driver\OCI8\Driver
201			*/
202			protected function getDoctrineDriver()
203			{
204			return new DoctrineDriver;
205			}
206
207			/**
208			* Get the default query grammar instance.
209			*
210			* @return \Yajra\Oci8\Query\Grammars\OracleGrammar
211			*/
212			protected function getDefaultQueryGrammar()
213			{
214			return $this->withTablePrefix(new QueryGrammar);
215			}
216
217			/**
218			* Set the table prefix and return the grammar.
219			*
220			* @param \Illuminate\Database\Grammar\|\Yajra\Oci8\Query\Grammars\OracleGrammar\|\Yajra\Oci8\Schema\Grammars\OracleGrammar $grammar
221			* @return \Illuminate\Database\Grammar
222			*/
223			public function withTablePrefix(Grammar $grammar)
224			{
225			return $this->withSchemaPrefix(parent::withTablePrefix($grammar));
226			}
227
228			/**
229			* Set the schema prefix and return the grammar.
230			*
231			* @param \Illuminate\Database\Grammar\|\Yajra\Oci8\Query\Grammars\OracleGrammar\|\Yajra\Oci8\Schema\Grammars\OracleGrammar $grammar
232			* @return \Illuminate\Database\Grammar
233			*/
234			public function withSchemaPrefix(Grammar $grammar)
235			{
236			$grammar->setSchemaPrefix($this->getConfigSchemaPrefix());
			0 ignored issues – show Bug introduced 2016-03-09 04:43 UTC by Report Bug Copy Issue Report It seems like you code against a specific sub-type and not the parent class `Illuminate\Database\Grammar` as the method `setSchemaPrefix()` does only exist in the following sub-classes of `Illuminate\Database\Grammar`: `Yajra\Oci8\Query\Grammars\OracleGrammar`, `Yajra\Oci8\Schema\Grammars\OracleGrammar`. Maybe you want to `instanceof` check for one of these explicitly? Let’s take a look at an example: abstract class User { /** @return string / abstract public function getPassword(); } class MyUser extends User { public function getPassword() { // return something } public function getDisplayName() { // return some name. } } class AuthSystem { public function authenticate(User $user) { $this->logger->info(sprintf('Authenticating %s.', $user->getDisplayName())); // do something. } } In the above example, the authenticate() method works fine as long as you just pass instances of MyUser. However, if you now also want to pass a different sub-classes of User which does not have a getDisplayName() method, the code will break. Available Fixes Change the type-hint for the parameter: class AuthSystem { public function authenticate(MyUser $user) { / ... / } } Add an additional type-check: class AuthSystem { public function authenticate(User $user) { if ($user instanceof MyUser) { $this->logger->info(/* ... /); } // or alternatively if ( ! $user instanceof MyUser) { throw new \LogicException( '$user must be an instance of MyUser, ' .'other instances are not supported.' ); } } } Note:* PHP Analyzer uses reverse abstract interpretation to narrow down the types inside the if block in such a case. Add the method to the parent class: abstract class User { /** @return string / abstract public function getPassword(); /* @return string */ abstract public function getDisplayName(); } Loading history...
237
238			return $grammar;
239			}
240
241
242			/**
243			* Execute a PL/SQL Function and return its value.
244			* Usage: DB::executeFunction('function_name(:binding_1,:binding_n)', [':binding_1' => 'hi', ':binding_n' => 'bye'], PDO::PARAM_LOB)
245			*
246			* @author Tylerian - [email protected]
247			*
248			* @param $sql (mixed)
249			* @param $bindings (kvp array)
250			* @param $returnType (PDO::PARAM_*)
251			* @return $returnType
			0 ignored issues – show Documentation introduced 2016-06-24 02:07 UTC by Report Bug Copy Issue Report The doc-type `$returnType` could not be parsed: Unknown type name "$returnType" at position 0. (view supported doc-types) This check marks PHPDoc comments that could not be parsed by our parser. To see which comment annotations we can parse, please refer to our documentation on supported doc-types. Loading history...
252			*/
253			public function executeFunction($sql, array $bindings = [], $returnType = PDO::PARAM_STR)
254			{
255			$query = $this->getPdo()->prepare('begin :result := ' . $sql . '; end;');
256
257			foreach ($bindings as $key => &$value)
258			{
259			if (!preg_match('/^:(.*)$/i', $key))
260			{
261			$key = ':' . $key;
262			}
263
264			$query->bindParam($key, $value);
265			}
266
267			$query->bindParam(':result', $result, $returnType);
268
269			$query->execute();
270
271			return $result;
272			}
273
274			/**
275			* Get config schema prefix.
276			*
277			* @return string
278			*/
279			protected function getConfigSchemaPrefix()
280			{
281			return isset($this->config['prefix_schema']) ? $this->config['prefix_schema'] : '';
282			}
283
284			/**
285			* Get the default schema grammar instance.
286			*
287			* @return \Yajra\Oci8\Schema\Grammars\OracleGrammar
288			*/
289			protected function getDefaultSchemaGrammar()
290			{
291			return $this->withTablePrefix(new SchemaGrammar);
292			}
293
294			/**
295			* Get the default post processor instance.
296			*
297			* @return \Yajra\Oci8\Query\Processors\OracleProcessor
298			*/
299			protected function getDefaultPostProcessor()
300			{
301			return new Processor;
302			}
303			}
304

yajra / laravel-oci8

Push — master ( 600ac0...da8e51 )

Oci8Connection::getDefaultQueryGrammar() A

Complexity

Size

Duplication

Importance

Available Fixes

Duplication Side-by-Side

Filter issues like