AuditCommand::auditColumnTypes() - Code Metrics - Inspection of "Merge pull request #30 from DimaNagorniy/aud-54" - SetBased/php-audit - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 742dfe...5d62cd )

by P.R.

created 2016-06-03 07:28 UTC

AuditCommand::auditColumnTypes() A

↳ Parent: Project

Complexity

Conditions	4
Paths	4

Size

Total Lines	20
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	20
rs	9.2
cc	4
eloc	12
nc	4
nop	0

<?php
//----------------------------------------------------------------------------------------------------------------------
namespace SetBased\Audit\MySql\Command;

use SetBased\Audit\Columns;
use SetBased\Audit\MySql\DataLayer;
use SetBased\Audit\Table;
use SetBased\Stratum\MySql\StaticDataLayer;
use SetBased\Stratum\Style\StratumStyle;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

//----------------------------------------------------------------------------------------------------------------------
/**
 * Command for creating audit tables and audit triggers.
 */
class AuditCommand extends MySqlCommand
{
  //--------------------------------------------------------------------------------------------------------------------
  /**
   * All tables in the in the audit schema.
   *
   * @var array
   */
  protected $auditSchemaTables;

  /**
   * Array of tables from data schema.
   *
   * @var array
   */
  protected $dataSchemaTables;

  /**
   * If true remove all column information from config file.
   *
   * @var boolean
   */
  private $pruneOption;

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * Compares the tables listed in the config file and the tables found in the audit schema
   *
   * @param string  $tableName Name of table
   * @param Columns $columns   The table columns.
   */
  public function getColumns($tableName, $columns)
  {
    $newColumns = [];
    foreach ($columns->getColumns() as $column)
    {
      $newColumns[] = ['column_name' => $column['column_name'],
                       'column_type' => $column['column_type']];
    }
    $this->config['table_columns'][$tableName] = $newColumns;

    if ($this->pruneOption)
    {
      $this->config['table_columns'] = [];
    }
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * Getting list of all tables from information_schema of database from config file.
   */
  public function listOfTables()
  {
    $this->dataSchemaTables = DataLayer::getTablesNames($this->config['database']['data_schema']);

    $this->auditSchemaTables = DataLayer::getTablesNames($this->config['database']['audit_schema']);
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * Found tables in config file
   *
   * Compares the tables listed in the config file and the tables found in the data schema
   */
  public function unknownTables()
  {
    foreach ($this->dataSchemaTables as $table)
    {
      if (isset($this->config['tables'][$table['table_name']]))
      {
        if (!isset($this->config['tables'][$table['table_name']]['audit']))
        {
          $this->io->writeln(sprintf('<info>AuditApplication flag is not set in table %s</info>', $table['table_name']));
        }
        else
        {
          if ($this->config['tables'][$table['table_name']]['audit'])
          {
            if(!isset($this->config['tables'][$table['table_name']]['alias']))
            {
              $this->config['tables'][$table['table_name']]['alias'] = Table::getRandomAlias();
            }
          }
        }
      }
      else
      {
        $this->io->writeln(sprintf('<info>Found new table %s</info>', $table['table_name']));
        $this->config['tables'][$table['table_name']] = ['audit' => false,
                                                         'alias' => null,
                                                         'skip'  => null];
      }
    }
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * {@inheritdoc}
   */
  protected function configure()
  {
    $this->setName('audit')
         ->setDescription('Create (missing) audit table and (re)creates audit triggers')
         ->addArgument('config file', InputArgument::OPTIONAL, 'The audit configuration file', 'etc/audit.json');
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * {@inheritdoc}
   */
  protected function execute(InputInterface $input, OutputInterface $output)
  {
    $this->io = new StratumStyle($input, $output);

    $this->configFileName = $input->getArgument('config file');
    $this->readConfigFile();

    // Create database connection with params from config file
    $this->connect($this->config);

    $this->auditColumnTypes();

    $this->listOfTables();

    $this->unknownTables();

    foreach ($this->dataSchemaTables as $table)
    {
      if ($this->config['tables'][$table['table_name']]['audit'])
      {
        $tableColumns = [];
        if (isset($this->config['table_columns'][$table['table_name']]))
        {
          $tableColumns = $this->config['table_columns'][$table['table_name']];
        }
        $currentTable = new Table($this->io,
                                  $table['table_name'],
                                  $this->config['database']['data_schema'],
                                  $this->config['database']['audit_schema'],
                                  $tableColumns,
                                  $this->config['audit_columns'],
                                  $this->config['tables'][$table['table_name']]['alias'],
                                  $this->config['tables'][$table['table_name']]['skip']);
        $res          = StaticDataLayer::searchInRowSet('table_name', $currentTable->getTableName(), $this->auditSchemaTables);
        if (!isset($res))
        {
          $currentTable->createMissingAuditTable();
        }

        $columns        = $currentTable->main($this->config['additional_sql']);
        $alteredColumns = $columns['altered_columns']->getColumns();
        if (empty($alteredColumns))
        {
          $this->getColumns($currentTable->getTableName(), $columns['full_columns']);
        }
      }
    }

    // Drop database connection
    DataLayer::disconnect();

    $this->rewriteConfig();
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * Get canonical column types for audit columns.
   */
  protected function auditColumnTypes()
  {
    $schema = $this->config['database']['audit_schema'];
    $table  = 'temp';
    DataLayer::createTempTable($schema, $this->config['audit_columns']);
    $auditColumns = DataLayer::getTableColumns($schema, $table);
    foreach ($auditColumns as $column)
    {
      $key = StaticDataLayer::searchInRowSet('column_name', $column['column_name'], $this->config['audit_columns']);
      if (isset($key))
      {
        $this->config['audit_columns'][$key]['column_type'] = $column['column_type'];
        if ($column['is_nullable']==='NO')
        {
          $this->config['audit_columns'][$key]['column_type'] = sprintf('%s not null', $this->config['audit_columns'][$key]['column_type']);
        }
      }
    }
    DataLayer::dropTable($schema, $table);
  }

  //--------------------------------------------------------------------------------------------------------------------
  /**
   * Write new data to config file.
   */
  private function rewriteConfig()
  {
    $this->writeTwoPhases($this->configFileName, json_encode($this->config, JSON_PRETTY_PRINT));
  }

  //--------------------------------------------------------------------------------------------------------------------
}

//----------------------------------------------------------------------------------------------------------------------


1			<?php
2			//----------------------------------------------------------------------------------------------------------------------
3			namespace SetBased\Audit\MySql\Command;
4
5			use SetBased\Audit\Columns;
6			use SetBased\Audit\MySql\DataLayer;
7			use SetBased\Audit\Table;
8			use SetBased\Stratum\MySql\StaticDataLayer;
9			use SetBased\Stratum\Style\StratumStyle;
10			use Symfony\Component\Console\Input\InputArgument;
11			use Symfony\Component\Console\Input\InputInterface;
12			use Symfony\Component\Console\Output\OutputInterface;
13
14			//----------------------------------------------------------------------------------------------------------------------
15			/**
16			* Command for creating audit tables and audit triggers.
17			*/
18			class AuditCommand extends MySqlCommand
19			{
20			//--------------------------------------------------------------------------------------------------------------------
21			/**
22			* All tables in the in the audit schema.
23			*
24			* @var array
25			*/
26			protected $auditSchemaTables;
27
28			/**
29			* Array of tables from data schema.
30			*
31			* @var array
32			*/
33			protected $dataSchemaTables;
34
35			/**
36			* If true remove all column information from config file.
37			*
38			* @var boolean
39			*/
40			private $pruneOption;
41
42			//--------------------------------------------------------------------------------------------------------------------
43			/**
44			* Compares the tables listed in the config file and the tables found in the audit schema
45			*
46			* @param string $tableName Name of table
47			* @param Columns $columns The table columns.
48			*/
49			public function getColumns($tableName, $columns)
50			{
51			$newColumns = [];
52			foreach ($columns->getColumns() as $column)
53			{
54			$newColumns[] = ['column_name' => $column['column_name'],
55			'column_type' => $column['column_type']];
56			}
57			$this->config['table_columns'][$tableName] = $newColumns;
58
59			if ($this->pruneOption)
60			{
61			$this->config['table_columns'] = [];
62			}
63			}
64
65			//--------------------------------------------------------------------------------------------------------------------
66			/**
67			* Getting list of all tables from information_schema of database from config file.
68			*/
69			public function listOfTables()
70			{
71			$this->dataSchemaTables = DataLayer::getTablesNames($this->config['database']['data_schema']);
72
73			$this->auditSchemaTables = DataLayer::getTablesNames($this->config['database']['audit_schema']);
74			}
75
76			//--------------------------------------------------------------------------------------------------------------------
77			/**
78			* Found tables in config file
79			*
80			* Compares the tables listed in the config file and the tables found in the data schema
81			*/
82			public function unknownTables()
83			{
84			foreach ($this->dataSchemaTables as $table)
85			{
86			if (isset($this->config['tables'][$table['table_name']]))
87			{
88			if (!isset($this->config['tables'][$table['table_name']]['audit']))
89			{
90			$this->io->writeln(sprintf('<info>AuditApplication flag is not set in table %s</info>', $table['table_name']));
91			}
92			else
93			{
94			if ($this->config['tables'][$table['table_name']]['audit'])
95			{
96			if(!isset($this->config['tables'][$table['table_name']]['alias']))
97			{
98			$this->config['tables'][$table['table_name']]['alias'] = Table::getRandomAlias();
99			}
100			}
101			}
102			}
103			else
104			{
105			$this->io->writeln(sprintf('<info>Found new table %s</info>', $table['table_name']));
106			$this->config['tables'][$table['table_name']] = ['audit' => false,
107			'alias' => null,
108			'skip' => null];
109			}
110			}
111			}
112
113			//--------------------------------------------------------------------------------------------------------------------
114			/**
115			* {@inheritdoc}
116			*/
117			protected function configure()
118			{
119			$this->setName('audit')
120			->setDescription('Create (missing) audit table and (re)creates audit triggers')
121			->addArgument('config file', InputArgument::OPTIONAL, 'The audit configuration file', 'etc/audit.json');
122			}
123
124			//--------------------------------------------------------------------------------------------------------------------
125			/**
126			* {@inheritdoc}
127			*/
128			protected function execute(InputInterface $input, OutputInterface $output)
129			{
130			$this->io = new StratumStyle($input, $output);
131
132			$this->configFileName = $input->getArgument('config file');
133			$this->readConfigFile();
134
135			// Create database connection with params from config file
136			$this->connect($this->config);
137
138			$this->auditColumnTypes();
139
140			$this->listOfTables();
141
142			$this->unknownTables();
143
144			foreach ($this->dataSchemaTables as $table)
145			{
146			if ($this->config['tables'][$table['table_name']]['audit'])
147			{
148			$tableColumns = [];
149			if (isset($this->config['table_columns'][$table['table_name']]))
150			{
151			$tableColumns = $this->config['table_columns'][$table['table_name']];
152			}
153			$currentTable = new Table($this->io,
154			$table['table_name'],
155			$this->config['database']['data_schema'],
156			$this->config['database']['audit_schema'],
157			$tableColumns,
158			$this->config['audit_columns'],
159			$this->config['tables'][$table['table_name']]['alias'],
160			$this->config['tables'][$table['table_name']]['skip']);
161			$res = StaticDataLayer::searchInRowSet('table_name', $currentTable->getTableName(), $this->auditSchemaTables);
162			if (!isset($res))
163			{
164			$currentTable->createMissingAuditTable();
165			}
166
167			$columns = $currentTable->main($this->config['additional_sql']);
168			$alteredColumns = $columns['altered_columns']->getColumns();
169			if (empty($alteredColumns))
170			{
171			$this->getColumns($currentTable->getTableName(), $columns['full_columns']);
172			}
173			}
174			}
175
176			// Drop database connection
177			DataLayer::disconnect();
178
179			$this->rewriteConfig();
180			}
181
182			//--------------------------------------------------------------------------------------------------------------------
183			/**
184			* Get canonical column types for audit columns.
185			*/
186			protected function auditColumnTypes()
187			{
188			$schema = $this->config['database']['audit_schema'];
189			$table = 'temp';
190			DataLayer::createTempTable($schema, $this->config['audit_columns']);
191			$auditColumns = DataLayer::getTableColumns($schema, $table);
192			foreach ($auditColumns as $column)
193			{
194			$key = StaticDataLayer::searchInRowSet('column_name', $column['column_name'], $this->config['audit_columns']);
195			if (isset($key))
196			{
197			$this->config['audit_columns'][$key]['column_type'] = $column['column_type'];
198			if ($column['is_nullable']==='NO')
199			{
200			$this->config['audit_columns'][$key]['column_type'] = sprintf('%s not null', $this->config['audit_columns'][$key]['column_type']);
201			}
202			}
203			}
204			DataLayer::dropTable($schema, $table);
205			}
206
207			//--------------------------------------------------------------------------------------------------------------------
208			/**
209			* Write new data to config file.
210			*/
211			private function rewriteConfig()
212			{
213			$this->writeTwoPhases($this->configFileName, json_encode($this->config, JSON_PRETTY_PRINT));
214			}
215
216			//--------------------------------------------------------------------------------------------------------------------
217			}
218
219			//----------------------------------------------------------------------------------------------------------------------
220

SetBased / php-audit

Push — master ( 742dfe...5d62cd )

AuditCommand::auditColumnTypes() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like