Ubiquity\db\providers\pdo\drivers\SqliteDriverMetas

Complexity

Total Complexity

10

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	4
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getPrimaryKeys()	0	10	3
A	groupConcat()	0	2	1
A	getFieldsInfos()	0	8	2
A	getRowNum()	0	6	2
A	getForeignKeys()	0	5	1
A	getTablesName()	0	3	1

<?php

namespace Ubiquity\db\providers\pdo\drivers;

/**
 * Ubiquity\db\providers\pdo\drivers$SqliteDriverMetas
 * This class is part of Ubiquity
 *
 * @author Ulaş SAYGIN
 * @version 1.0.0
 *
 */
class SqliteDriverMetas extends AbstractDriverMetaDatas {

	public function getForeignKeys($tableName, $pkName, $dbName = null): array {

		// SQL lite may return error if key is not found when manual model editing can cause it by mistype of model field name.
		$recordset = $this->dbInstance->query ( "SELECT \"TABLE\" as TABLE_NAME , \"to\" as COLUMN_NAME , \"from\" as REFERENCED_TABLE_SCHEMA FROM pragma_foreign_key_list('" . $tableName . "') WHERE \"to\"='" . $pkName . "';" );
		return $recordset->fetchAll ( \PDO::FETCH_ASSOC );
	}

	public function getTablesName(): array {
		$query = $this->dbInstance->query ( 'SELECT name FROM sqlite_master WHERE type=\'table\';' );
		return $query->fetchAll ( \PDO::FETCH_COLUMN );
	}

	public function getPrimaryKeys($tableName): array {
		$fieldkeys = array ();
		$recordset = $this->dbInstance->query ( "PRAGMA TABLE_INFO(" . $tableName . ");" );
		$keys = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
		foreach ( $keys as $key ) {
			if ($key ['pk'] == 1) {
				$fieldkeys [] = $key ['name'];
			}
		}
		return $fieldkeys;
	}

	public function getFieldsInfos($tableName): array {
		$fieldsInfos = array ();
		$recordset = $this->dbInstance->query ( "PRAGMA TABLE_INFO(" . $tableName . ");" );
		$fields = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
		foreach ( $fields as $field ) {
			$fieldsInfos [$field ['name']] = [ "Type" => $field ['type'],"Nullable" => $field ["notnull"] ];
		}
		return $fieldsInfos;
	}

	public function getRowNum(string $tableName, string $pkName, string $condition): int {
		$query = $this->dbInstance->query ( "SELECT num FROM (SELECT *,row_number() OVER (ORDER BY {$pkName}) AS num FROM \"{$tableName}\") x where " . $condition );
		if ($query) {
			return $query->fetchColumn ( 0 );
		}
		return 0;
	}

	public function groupConcat(string $fields, string $separator): string {
		return "GROUP_CONCAT({$fields},'{$separator}')";
	}
}