Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
0.00% covered (danger)
0.00%
0 / 3
CRAP
0.00% covered (danger)
0.00%
0 / 189
oracle_extractor
0.00% covered (danger)
0.00%
0 / 1
0.00% covered (danger)
0.00%
0 / 3
870
0.00% covered (danger)
0.00%
0 / 189
 write_table
0.00% covered (danger)
0.00%
0 / 1
306
0.00% covered (danger)
0.00%
0 / 122
 write_data
0.00% covered (danger)
0.00%
0 / 1
110
0.00% covered (danger)
0.00%
0 / 55
 write_start
0.00% covered (danger)
0.00%
0 / 1
6
0.00% covered (danger)
0.00%
0 / 12
<?php
/**
*
* This file is part of the phpBB Forum Software package.
*
* @copyright (c) phpBB Limited <https://www.phpbb.com>
* @license GNU General Public License, version 2 (GPL-2.0)
*
* For full copyright and license information, please see
* the docs/CREDITS.txt file.
*
*/
namespace phpbb\db\extractor;
use phpbb\db\extractor\exception\extractor_not_initialized_exception;
class oracle_extractor extends base_extractor
{
    /**
    * {@inheritdoc}
    */
    public function write_table($table_name)
    {
        if (!$this->is_initialized)
        {
            throw new extractor_not_initialized_exception();
        }
        $sql_data = '-- Table: ' . $table_name . "\n";
        $sql_data .= "DROP TABLE $table_name\n/\n";
        $sql_data .= "\nCREATE TABLE $table_name (\n";
        $sql = "SELECT COLUMN_NAME, DATA_TYPE, DATA_PRECISION, DATA_LENGTH, NULLABLE, DATA_DEFAULT
            FROM ALL_TAB_COLS
            WHERE table_name = '{$table_name}'";
        $result = $this->db->sql_query($sql);
        $rows = array();
        while ($row = $this->db->sql_fetchrow($result))
        {
            $line = '  "' . $row['column_name'] . '" ' . $row['data_type'];
            if ($row['data_type'] !== 'CLOB')
            {
                if ($row['data_type'] !== 'VARCHAR2' && $row['data_type'] !== 'CHAR')
                {
                    $line .= '(' . $row['data_precision'] . ')';
                }
                else
                {
                    $line .= '(' . $row['data_length'] . ')';
                }
            }
            if (!empty($row['data_default']))
            {
                $line .= ' DEFAULT ' . $row['data_default'];
            }
            if ($row['nullable'] == 'N')
            {
                $line .= ' NOT NULL';
            }
            $rows[] = $line;
        }
        $this->db->sql_freeresult($result);
        $sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME
            FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B
            WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME
                AND B.CONSTRAINT_TYPE = 'P'
                AND A.TABLE_NAME = '{$table_name}'";
        $result = $this->db->sql_query($sql);
        $primary_key = array();
        $constraint_name = '';
        while ($row = $this->db->sql_fetchrow($result))
        {
            $constraint_name = '"' . $row['constraint_name'] . '"';
            $primary_key[] = '"' . $row['column_name'] . '"';
        }
        $this->db->sql_freeresult($result);
        if (count($primary_key))
        {
            $rows[] = "  CONSTRAINT {$constraint_name} PRIMARY KEY (" . implode(', ', $primary_key) . ')';
        }
        $sql = "SELECT A.CONSTRAINT_NAME, A.COLUMN_NAME
            FROM USER_CONS_COLUMNS A, USER_CONSTRAINTS B
            WHERE A.CONSTRAINT_NAME = B.CONSTRAINT_NAME
                AND B.CONSTRAINT_TYPE = 'U'
                AND A.TABLE_NAME = '{$table_name}'";
        $result = $this->db->sql_query($sql);
        $unique = array();
        $constraint_name = '';
        while ($row = $this->db->sql_fetchrow($result))
        {
            $constraint_name = '"' . $row['constraint_name'] . '"';
            $unique[] = '"' . $row['column_name'] . '"';
        }
        $this->db->sql_freeresult($result);
        if (count($unique))
        {
            $rows[] = "  CONSTRAINT {$constraint_name} UNIQUE (" . implode(', ', $unique) . ')';
        }
        $sql_data .= implode(",\n", $rows);
        $sql_data .= "\n)\n/\n";
        $sql = "SELECT A.REFERENCED_NAME, C.*
            FROM USER_DEPENDENCIES A, USER_TRIGGERS B, USER_SEQUENCES C
            WHERE A.REFERENCED_TYPE = 'SEQUENCE'
                AND A.NAME = B.TRIGGER_NAME
                AND B.TABLE_NAME = '{$table_name}'
                AND C.SEQUENCE_NAME = A.REFERENCED_NAME";
        $result = $this->db->sql_query($sql);
        $type = $this->request->variable('type', '');
        while ($row = $this->db->sql_fetchrow($result))
        {
            $sql_data .= "\nDROP SEQUENCE \"{$row['referenced_name']}\"\n/\n";
            $sql_data .= "\nCREATE SEQUENCE \"{$row['referenced_name']}\"";
            if ($type == 'full')
            {
                $sql_data .= ' START WITH ' . $row['last_number'];
            }
            $sql_data .= "\n/\n";
        }
        $this->db->sql_freeresult($result);
        $sql = "SELECT DESCRIPTION, WHEN_CLAUSE, TRIGGER_BODY
            FROM USER_TRIGGERS
            WHERE TABLE_NAME = '{$table_name}'";
        $result = $this->db->sql_query($sql);
        while ($row = $this->db->sql_fetchrow($result))
        {
            $sql_data .= "\nCREATE OR REPLACE TRIGGER {$row['description']}WHEN ({$row['when_clause']})\n{$row['trigger_body']}\n/\n";
        }
        $this->db->sql_freeresult($result);
        $sql = "SELECT A.INDEX_NAME, B.COLUMN_NAME
            FROM USER_INDEXES A, USER_IND_COLUMNS B
            WHERE A.UNIQUENESS = 'NONUNIQUE'
                AND A.INDEX_NAME = B.INDEX_NAME
                AND B.TABLE_NAME = '{$table_name}'";
        $result = $this->db->sql_query($sql);
        $index = array();
        while ($row = $this->db->sql_fetchrow($result))
        {
            $index[$row['index_name']][] = $row['column_name'];
        }
        foreach ($index as $index_name => $column_names)
        {
            $sql_data .= "\nCREATE INDEX $index_name ON $table_name(" . implode(', ', $column_names) . ")\n/\n";
        }
        $this->db->sql_freeresult($result);
        $this->flush($sql_data);
    }
    /**
    * {@inheritdoc}
    */
    public function write_data($table_name)
    {
        if (!$this->is_initialized)
        {
            throw new extractor_not_initialized_exception();
        }
        $ary_type = $ary_name = array();
        // Grab all of the data from current table.
        $sql = "SELECT *
            FROM $table_name";
        $result = $this->db->sql_query($sql);
        $i_num_fields = ocinumcols($result);
        for ($i = 0; $i < $i_num_fields; $i++)
        {
            $ary_type[$i] = ocicolumntype($result, $i + 1);
            $ary_name[$i] = ocicolumnname($result, $i + 1);
        }
        while ($row = $this->db->sql_fetchrow($result))
        {
            $schema_vals = $schema_fields = array();
            // Build the SQL statement to recreate the data.
            for ($i = 0; $i < $i_num_fields; $i++)
            {
                // Oracle uses uppercase - we use lowercase
                $str_val = $row[strtolower($ary_name[$i])];
                if (preg_match('#char|text|bool|raw|clob#i', $ary_type[$i]))
                {
                    $str_quote = '';
                    $str_empty = "''";
                    $str_val = sanitize_data_oracle($str_val);
                }
                else if (preg_match('#date|timestamp#i', $ary_type[$i]))
                {
                    if (empty($str_val))
                    {
                        $str_quote = '';
                    }
                    else
                    {
                        $str_quote = "'";
                    }
                }
                else
                {
                    $str_quote = '';
                    $str_empty = 'NULL';
                }
                if (empty($str_val) && $str_val !== '0')
                {
                    $str_val = $str_empty;
                }
                $schema_vals[$i] = $str_quote . $str_val . $str_quote;
                $schema_fields[$i] = '"' . $ary_name[$i] . '"';
            }
            // Take the ordered fields and their associated data and build it
            // into a valid sql statement to recreate that field in the data.
            $sql_data = "INSERT INTO $table_name (" . implode(', ', $schema_fields) . ') VALUES (' . implode(', ', $schema_vals) . ")\n/\n";
            $this->flush($sql_data);
        }
        $this->db->sql_freeresult($result);
    }
    /**
    * {@inheritdoc}
    */
    public function write_start($table_prefix)
    {
        if (!$this->is_initialized)
        {
            throw new extractor_not_initialized_exception();
        }
        $sql_data = "--\n";
        $sql_data .= "-- phpBB Backup Script\n";
        $sql_data .= "-- Dump of tables for $table_prefix\n";
        $sql_data .= "-- DATE : " . gmdate("d-m-Y H:i:s", $this->time) . " GMT\n";
        $sql_data .= "--\n";
        $this->flush($sql_data);
    }
}