Db3v4l\Core\SqlExecutor\Forked\NativeClient::getProcess()

Complexity

Conditions	28
Paths	385

Size

Total Lines	146
Code Lines	87

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	0

<?php
    protected function getProcess($sqlOrFilename, $action = self::EXECUTE_COMMAND)
    {
        $clientType = $this->getDbClientType($this->databaseConfiguration);

        // pass on _all_ env vars, including PATH. Not doing so is deprecated...
        $env = null;

        switch ($clientType) {
            case 'mysql':

Line indented incorrectly; expected 8 spaces, found 12

                $command = 'mysql';
                $options = [
                    '--host=' . $this->databaseConfiguration['host'],
                    '--port=' . $this->databaseConfiguration['port'] ?? '3306',
                    '--user=' . $this->databaseConfiguration['user'],
                    '-p' . $this->databaseConfiguration['password'],
                    '--binary-mode', // 'It also disables all mysql commands except charset and delimiter in non-interactive mode (for input piped to mysql or loaded using the source command)'
                    '-t',
                ];
                if (isset($this->databaseConfiguration['dbname'])) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = $this->databaseConfiguration['dbname'];
                }

Line indented incorrectly; expected 12 spaces, found 16

                if ($action == self::EXECUTE_COMMAND) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = '--execute=' . $sqlOrFilename;
                }

Line indented incorrectly; expected 12 spaces, found 16

               // $env = [
                    // problematic when wrapping the process in a call to `time`...
                    //'MYSQL_PWD' => $this->databaseConfiguration['password'],
                //];
                break;

            case 'psql':

Line indented incorrectly; expected 8 spaces, found 12

                $command = 'psql';
                $connectString = "postgresql://".$this->databaseConfiguration['user'].":".$this->databaseConfiguration['password'].
                    "@{$this->databaseConfiguration['host']}:".($this->databaseConfiguration['port'] ?? '5432').'/';
                if (isset($this->databaseConfiguration['dbname'])) {

Line indented incorrectly; expected 12 spaces, found 16

                    $connectString .= $this->databaseConfiguration['dbname'];
                }

Line indented incorrectly; expected 12 spaces, found 16

                $options = [
                    $connectString,
                    '-Pfooter=off'
                ];
                // NB: this triggers a different behaviour that piping multiple commands to stdin, namely
                // it wraps all of the commands in a transaction and allows either sql commands or a single meta-command
                if ($action == self::EXECUTE_COMMAND) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = '--command=' . $sqlOrFilename;
                }

Line indented incorrectly; expected 12 spaces, found 16

                //$env = [
                    // problematic when wrapping the process in a call to `time`...
                    //'PGPASSWORD' => $this->databaseConfiguration['password'],
                //];
                break;

            case 'sqlcmd':

Line indented incorrectly; expected 8 spaces, found 12

                $command = 'sqlcmd';
                $options = [
                    '-S' . $this->databaseConfiguration['host'] . ($this->databaseConfiguration['port'] != '' ?  ',' . $this->databaseConfiguration['port'] : ''),
                    '-U' . $this->databaseConfiguration['user'],
                    '-P' . $this->databaseConfiguration['password'],
                    '-r1',
                    '-b',
                ];
                if (isset($this->databaseConfiguration['dbname'])) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = '-d' . $this->databaseConfiguration['dbname'];
                }

Line indented incorrectly; expected 12 spaces, found 16

                if ($action == self::EXECUTE_FILE) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = '-i' . $sqlOrFilename;
                } elseif ($action == self::EXECUTE_COMMAND) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = '-Q' . $sqlOrFilename;
                }

Line indented incorrectly; expected 12 spaces, found 16

                break;

            case 'sqlite':

Line indented incorrectly; expected 8 spaces, found 12

                $command = 'sqlite3';
                // 'path' is the full path to the 'master' db (for Doctrine compatibility).
                //  non-master dbs are supposed to reside in the same directory
                if (isset($this->databaseConfiguration['dbname'])) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = dirname($this->databaseConfiguration['path']) . '/' . $this->databaseConfiguration['dbname'] . '.sqlite';

$options was never initialized. Although not strictly required by PHP, it is generally a good practice to add $options = array(); before regardless.

                } else {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = $this->databaseConfiguration['path'];
                }

Line indented incorrectly; expected 12 spaces, found 16

                if ($action == self::EXECUTE_COMMAND) {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = $sqlOrFilename;
                }

Line indented incorrectly; expected 12 spaces, found 16

                break;

            case 'sqlplus':

Line indented incorrectly; expected 8 spaces, found 12

                /// @todo disable execution of dangerous (or all) SQLPLUS commands.
                ///       See the list at https://docs.oracle.com/en/database/oracle/oracle-database/18/sqpug/SQL-Plus-command-reference.html#GUID-177F24B7-D154-4F8B-A05B-7568079800C6
                $command = 'sqlplus';
                $connectionIdentifier = '//' . $this->databaseConfiguration['host'] .
                    ($this->databaseConfiguration['port'] != '' ?  ':' . $this->databaseConfiguration['port'] : '');
                // nb: for oracle, if we use pdbs to map 'databases', they get a new service name
                /// @todo allow support for _not_ doing that, and using schemas as 'databases'
                if (isset($this->databaseConfiguration['servicename'])) {

Line indented incorrectly; expected 12 spaces, found 16

                    $connectionIdentifier .= '/' . $this->databaseConfiguration['servicename'];
                } else {

Line indented incorrectly; expected 12 spaces, found 16

                    if ($this->databaseConfiguration['dbname'] != '') {

Line indented incorrectly; expected 16 spaces, found 20

                        $connectionIdentifier .= '/' . $this->databaseConfiguration['dbname'];
                    }

Line indented incorrectly; expected 16 spaces, found 20

                }

Line indented incorrectly; expected 12 spaces, found 16

                $options = [
                    '-L', // 'attempts to log in just once, instead of reprompting on error'
                    '-NOLOGINTIME',
                    '-S',
                    $this->databaseConfiguration['user'] . '/' . $this->databaseConfiguration['password'] . '@' . $connectionIdentifier,
                ];
                /// @todo make this optional somehow / allow SYSOPER as alternative
                if (strtolower($this->databaseConfiguration['user']) === 'sys') {

Line indented incorrectly; expected 12 spaces, found 16

                    $options[] = 'AS';
                    $options[] = 'SYSDBA';
                }

Line indented incorrectly; expected 12 spaces, found 16

                if ($action == self::EXECUTE_FILE) {

Line indented incorrectly; expected 12 spaces, found 16

                    /// @todo wouldn't it be better to create another temp file with prefixed the sqlplus commands?
                    //$options[] = '@' . $sqlOrFilename;
                    $sqlOrFilename = "WHENEVER OSERROR EXIT FAILURE;\nWHENEVER SQLERROR EXIT SQL.SQLCODE;\nSET PAGESIZE 50000;\nSET FEEDBACK OFF;\n" . file_get_contents($sqlOrFilename);
                    $action = self::EXECUTE_COMMAND;
                } else {

Line indented incorrectly; expected 12 spaces, found 16

                    $sqlOrFilename = "WHENEVER OSERROR EXIT FAILURE;\nWHENEVER SQLERROR EXIT SQL.SQLCODE;\nSET PAGESIZE 50000;\nSET FEEDBACK OFF;\n" . $sqlOrFilename;
                }

Line indented incorrectly; expected 12 spaces, found 16

                break;

                default:

Line indented incorrectly; expected 8 spaces, found 16

                throw new \OutOfBoundsException("Unsupported db client '$clientType'");

Case breaking statement indented incorrectly; expected 20 spaces, found 16

        }

        $commandLine = $this->buildCommandLine($command, $options);

        /// @todo investigate: for psql is this better done via --file ?
        if ($action == self::EXECUTE_FILE && $clientType != 'sqlsrv' && $clientType != 'sqlplus') {
            $commandLine .= ' < ' . escapeshellarg($sqlOrFilename);
        }

        if ($action == self::EXECUTE_COMMAND && $clientType == 'sqlplus') {
            $commandLine .= " << 'SQLEOF'\n" . $sqlOrFilename . "\nSQLEOF";
        }

        $process = Process::fromShellCommandline($commandLine, null, $env);

        if ($action == self::EXECUTE_COMMAND && $clientType == 'sqlplus') {
            // The way Symfony Process deals with sighchildEnabled breaks EOF handling. We disable it
            $process->forceSigchildEnabledIndividually(false);
        }

        return $process;
    }