Mib::create_schema() - Code Metrics - Inspection of "class extraction on trap_class" - patrickpr/trapdirector - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 27233f...bd4945 )

by Patrick

created 2019-11-11 15:19 UTC

Mib::create_schema() B

↳ Parent: Mib

Complexity

Conditions	8
Paths	14

Size

Total Lines	47
Code Lines	27

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	8
eloc	27
c	1
b	0
f	0
nc	14
nop	2
dl	0
loc	47
rs	8.4444

<?php

namespace Trapdirector;

use Trapdirector\Logging;
use PDO;

class Mib
{
    
    protected $logging; //< logging class
    protected $trapsDB; //< Database class
    
    
    /**
     * Setup Mib Class
     * @param Logging $logClass : where to log
     * @param Database $dbClass : Database
     */
    function __construct($logClass,$dbClass)
    {
        $this->logging=$logClass;
        $this->trapsDB=$dbClass;       
    }

    /** Create database schema
     *	@param $schema_file	string File to read schema from
     *	@param $table_prefix string to replace #PREFIX# in schema file by this
     */
    public function create_schema($schema_file,$table_prefix)
    {
        //Read data from snmptrapd from stdin
        $input_stream=fopen($schema_file, 'r');
        
        if ($input_stream=== false)
        {
            $this->logging->log("Error reading schema !",ERROR,'');
            return;
        }
        $newline='';
        $cur_table='';
        $cur_table_array=array();
        $db_conn=$this->trapsDB->db_connect_trap();
        
        while (($line=fgets($input_stream)) !== false)
        {
            $newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
            if (preg_match('/; *$/', $newline))
            {
                $sql= $newline;
                if ($db_conn->query($sql) === false) {
                    $this->logging->log('Error create schema : '.$sql,ERROR,'');
                    return;
                }
                if (preg_match('/^ *CREATE TABLE ([^ ]+)/',$newline,$cur_table_array))
                {
                    $cur_table='table '.$cur_table_array[1];
                }
                else
                {
                    $cur_table='secret SQL stuff :-)';
                }
                $this->logging->log('Creating : ' . $cur_table,INFO );
                $newline='';
            }
        }
        
        $sql= $newline;
        if ($sql != '' )
        {
            if ($db_conn->query($sql) === false) {
                $this->logging->log('Error create schema : '.$sql,ERROR,'');
                return;
            }
        }
        $this->logging->log('Schema created',INFO);
    }
    
    /**
     * Update database schema from current (as set in db) to $target_version
     *     @param $prefix string file prefix of sql update File
     *     @param $target_version int target db version number
     *     @param $table_prefix string to replace #PREFIX# in schema file by this
     *     @param bool $getmsg : only get messages from version upgrades
     *     @return string : if $getmsg=true, return messages.
     */
    public function update_schema($prefix,$target_version,$table_prefix,$getmsg=false)
    {
        // Get current db number
        $db_conn=$this->trapsDB->db_connect_trap();
        $sql='SELECT id,value from '.$this->db_prefix.'db_config WHERE name=\'db_version\' ';

        $this->logging->log('SQL query : '.$sql,DEBUG );
        if (($ret_code=$db_conn->query($sql)) === false) {
            $this->logging->log('Cannot get db version. Query : ' . $sql,2,'');
            return;
        }
        $version=$ret_code->fetchAll();
        $cur_version=$version[0]['value'];
        $db_version_id=$version[0]['id'];
        
        if ($this->trapsDB->trapDBType == 'pgsql')
        {
            $prefix .= 'update_pgsql/schema_';
        }
        else
        {
            $prefix .= 'update_sql/schema_';
        }
        //echo "version all :\n";print_r($version);echo " \n $cur_ver \n";
        if ($getmsg === true)
        {
            $message='';
            $this->logging->log('getting message for upgrade',DEBUG );
            while($cur_version<$target_version)
            {
                $cur_version++;
                $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
                $input_stream=fopen($updateFile, 'r');
                if ($input_stream=== false)
                {
                    $this->logging->log("Error reading update file ". $updateFile,2,'');
                    return;
                }
                do { $line=fgets($input_stream); }
                while ($line !== false && !preg_match('/#MESSAGE/',$line));
                if ($line === false)
                {
                    $this->logging->log("No message in file ". $updateFile,2,'');
                    return;
                }
                $message .= ($cur_version-1) . '->' . $cur_version. ' : ' . preg_replace('/#MESSAGE : /','',$line)."\n";
            }
            return $message;
        }
        while($cur_version<$target_version)
        { // tODO : execute pre & post scripts
            $cur_version++;
            $this->logging->log('Updating to version : ' .$cur_version ,INFO );
            $updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
            $input_stream=fopen($updateFile, 'r');
            if ($input_stream=== false)
            {
                $this->logging->log("Error reading update file ". $updateFile,2,'');
                return;
            }
            $newline='';
            $db_conn=$this->trapsDB->db_connect_trap();
            $db_conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            while (($line=fgets($input_stream)) !== false)
            {
                if (preg_match('/^#/', $line)) continue; // ignore comment lines
                $newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
                if (preg_match('/; *$/', $newline))
                {
                    $sql_req=$db_conn->prepare($newline);
                    if ($sql_req->execute() === false) {
                        $this->logging->log('Error create schema : '.$newline,1,'');
                    }
                    $cur_table_array=array();
                    if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/',$newline,$cur_table_array))
                    {
                        $cur_table=$cur_table_array[1] . ' SQL table '.$cur_table_array[2];
                    }
                    else
                    {
                        $cur_table='secret SQL stuff :-)';
                        //$cur_table=$newline;
                    }
                    $this->logging->log('Doing : ' . $cur_table,INFO );
                    
                    $newline='';
                }
            }
            fclose($input_stream);
            
            //$sql= $newline;
            //if ($db_conn->query($sql) === false) {
            //    $this->logging->log('Error updating schema : '.$sql,1,'');
            //}
            
            $sql='UPDATE '.$this->db_prefix.'db_config SET value='.$cur_version.' WHERE ( id = '.$db_version_id.' )';
            $this->logging->log('SQL query : '.$sql,DEBUG );
            if ($db_conn->query($sql) === false) {
                $this->logging->log('Cannot update db version. Query : ' . $sql,2);
                return;
            }
            
            $this->logging->log('Schema updated to version : '.$cur_version ,INFO);
        }
    }
    
    
    
}

1			<?php
2
3			namespace Trapdirector;
4
5			use Trapdirector\Logging;
6			use PDO;
7
8			class Mib
9			{
10
11			protected $logging; //< logging class
12			protected $trapsDB; //< Database class
13
14
15			/**
16			* Setup Mib Class
17			* @param Logging $logClass : where to log
18			* @param Database $dbClass : Database
19			*/
20			function __construct($logClass,$dbClass)
21			{
22			$this->logging=$logClass;
23			$this->trapsDB=$dbClass;
24			}
25
26			/** Create database schema
27			* @param $schema_file string File to read schema from
28			* @param $table_prefix string to replace #PREFIX# in schema file by this
29			*/
30			public function create_schema($schema_file,$table_prefix)
31			{
32			//Read data from snmptrapd from stdin
33			$input_stream=fopen($schema_file, 'r');
34
35			if ($input_stream=== false)
36			{
37			$this->logging->log("Error reading schema !",ERROR,'');
38			return;
39			}
40			$newline='';
41			$cur_table='';
42			$cur_table_array=array();
43			$db_conn=$this->trapsDB->db_connect_trap();
44
45			while (($line=fgets($input_stream)) !== false)
46			{
47			$newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
48			if (preg_match('/; *$/', $newline))
49			{
50			$sql= $newline;
51			if ($db_conn->query($sql) === false) {
52			$this->logging->log('Error create schema : '.$sql,ERROR,'');
53			return;
54			}
55			if (preg_match('/^ *CREATE TABLE ([^ ]+)/',$newline,$cur_table_array))
56			{
57			$cur_table='table '.$cur_table_array[1];
58			}
59			else
60			{
61			$cur_table='secret SQL stuff :-)';
62			}
63			$this->logging->log('Creating : ' . $cur_table,INFO );
64			$newline='';
65			}
66			}
67
68			$sql= $newline;
69			if ($sql != '' )
70			{
71			if ($db_conn->query($sql) === false) {
72			$this->logging->log('Error create schema : '.$sql,ERROR,'');
73			return;
74			}
75			}
76			$this->logging->log('Schema created',INFO);
77			}
78
79			/**
80			* Update database schema from current (as set in db) to $target_version
81			* @param $prefix string file prefix of sql update File
82			* @param $target_version int target db version number
83			* @param $table_prefix string to replace #PREFIX# in schema file by this
84			* @param bool $getmsg : only get messages from version upgrades
85			* @return string : if $getmsg=true, return messages.
86			*/
87			public function update_schema($prefix,$target_version,$table_prefix,$getmsg=false)
88			{
89			// Get current db number
90			$db_conn=$this->trapsDB->db_connect_trap();
91			$sql='SELECT id,value from '.$this->db_prefix.'db_config WHERE name=\'db_version\' ';
			0 ignored issues – show Bug Best Practice introduced 2019-11-11 15:21 UTC by Report Bug Copy Issue Report The property `db_prefix` does not exist on `Trapdirector\Mib`. Did you maybe forget to declare it? Loading history...
92			$this->logging->log('SQL query : '.$sql,DEBUG );
93			if (($ret_code=$db_conn->query($sql)) === false) {
94			$this->logging->log('Cannot get db version. Query : ' . $sql,2,'');
95			return;
96			}
97			$version=$ret_code->fetchAll();
98			$cur_version=$version[0]['value'];
99			$db_version_id=$version[0]['id'];
100
101			if ($this->trapsDB->trapDBType == 'pgsql')
102			{
103			$prefix .= 'update_pgsql/schema_';
104			}
105			else
106			{
107			$prefix .= 'update_sql/schema_';
108			}
109			//echo "version all :\n";print_r($version);echo " \n $cur_ver \n";
110			if ($getmsg === true)
111			{
112			$message='';
113			$this->logging->log('getting message for upgrade',DEBUG );
114			while($cur_version<$target_version)
115			{
116			$cur_version++;
117			$updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
118			$input_stream=fopen($updateFile, 'r');
119			if ($input_stream=== false)
120			{
121			$this->logging->log("Error reading update file ". $updateFile,2,'');
122			return;
123			}
124			do { $line=fgets($input_stream); }
125			while ($line !== false && !preg_match('/#MESSAGE/',$line));
126			if ($line === false)
127			{
128			$this->logging->log("No message in file ". $updateFile,2,'');
129			return;
130			}
131			$message .= ($cur_version-1) . '->' . $cur_version. ' : ' . preg_replace('/#MESSAGE : /','',$line)."\n";
132			}
133			return $message;
134			}
135			while($cur_version<$target_version)
136			{ // tODO : execute pre & post scripts
137			$cur_version++;
138			$this->logging->log('Updating to version : ' .$cur_version ,INFO );
139			$updateFile=$prefix.'v'.($cur_version-1).'_v'.$cur_version.'.sql';
140			$input_stream=fopen($updateFile, 'r');
141			if ($input_stream=== false)
142			{
143			$this->logging->log("Error reading update file ". $updateFile,2,'');
144			return;
145			}
146			$newline='';
147			$db_conn=$this->trapsDB->db_connect_trap();
148			$db_conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
149			while (($line=fgets($input_stream)) !== false)
150			{
151			if (preg_match('/^#/', $line)) continue; // ignore comment lines
152			$newline.=chop(preg_replace('/#PREFIX#/',$table_prefix,$line));
153			if (preg_match('/; *$/', $newline))
154			{
155			$sql_req=$db_conn->prepare($newline);
156			if ($sql_req->execute() === false) {
157			$this->logging->log('Error create schema : '.$newline,1,'');
158			}
159			$cur_table_array=array();
160			if (preg_match('/^ *([^ ]+) TABLE ([^ ]+)/',$newline,$cur_table_array))
161			{
162			$cur_table=$cur_table_array[1] . ' SQL table '.$cur_table_array[2];
163			}
164			else
165			{
166			$cur_table='secret SQL stuff :-)';
167			//$cur_table=$newline;
168			}
169			$this->logging->log('Doing : ' . $cur_table,INFO );
170
171			$newline='';
172			}
173			}
174			fclose($input_stream);
175
176			//$sql= $newline;
177			//if ($db_conn->query($sql) === false) {
178			// $this->logging->log('Error updating schema : '.$sql,1,'');
179			//}
180
181			$sql='UPDATE '.$this->db_prefix.'db_config SET value='.$cur_version.' WHERE ( id = '.$db_version_id.' )';
182			$this->logging->log('SQL query : '.$sql,DEBUG );
183			if ($db_conn->query($sql) === false) {
184			$this->logging->log('Cannot update db version. Query : ' . $sql,2);
185			return;
186			}
187
188			$this->logging->log('Schema updated to version : '.$cur_version ,INFO);
189			}
190			}
191
192
193
194			}

patrickpr / trapdirector

Push — master ( 27233f...bd4945 )

Mib::create_schema() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like