mirror/FreshRSS
0
0
Fork 0
mirror of https://github.com/FreshRSS/FreshRSS.git synced 2026-04-16 12:27:20 -04:00
Code Issues Packages Projects Releases Wiki Activity

DatabaseDAO for PostgreSQL

Browse Source 
From
be2b15d12c/app/Models/DatabaseDAOpgSQL.php
This commit is contained in:
Alexandre Alapetite
2016-08-02 23:02:47 +02:00
parent 7c1b5e322c
commit d5382ff0d0
1 changed files with 43 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

43
app/Models/DatabaseDAOPGSQL.php Normal file
View File

@@ -0,0 +1,43 @@
<?php
/**
* This class is used to test database is well-constructed.
*/
class FreshRSS_DatabaseDAOPGSQL extends FreshRSS_DatabaseDAO {
public function tablesAreCorrect() {
$db = FreshRSS_Context::$system_conf->db;
$dbowner = $db['user'];
$sql = 'SELECT * FROM pg_catalog.pg_tables where tableowner=?';
$stm = $this->bd->prepare($sql);
$values = array($dbowner);
$stm->execute($values);
$res = $stm->fetchAll(PDO::FETCH_ASSOC);
$tables = array(
$this->prefix . 'category' => false,
$this->prefix . 'feed' => false,
$this->prefix . 'entry' => false,
);
foreach ($res as $value) {
$tables[array_pop($value)] = true;
}
return count(array_keys($tables, true, true)) == count($tables);
}
public function getSchema($table) {
$sql = 'select column_name as field, data_type as type, column_default as default, is_nullable as null from INFORMATION_SCHEMA.COLUMNS where table_name = ?';
$stm = $this->bd->prepare($sql);
$stm->execute(array($this->prefix . $table));
return $this->listDaoToSchema($stm->fetchAll(PDO::FETCH_ASSOC));
}
public function daoToSchema($dao) {
return array(
'name' => $dao['field'],
'type' => strtolower($dao['type']),
'notnull' => (bool)$dao['null'],
'default' => $dao['default'],
);
}
}