Skip to content
Snippets Groups Projects
Commit 23bcb641 authored by Scrutinizer Auto-Fixer's avatar Scrutinizer Auto-Fixer Committed by Tim van Dijen
Browse files

Whitespace fixes 

This commit consists of patches automatically generated for this project on https://scrutinizer-ci.com
parent fcb79175
No related branches found
No related tags found
No related merge requests found
Hide whitespace changes
Inline Side-by-side
modules/core/lib/Storage/SQLPermanentStorage.php
+ 144
− 144
View file @ 23bcb641
...@@ -11,30 +11,30 @@ ...@@ -11,30 +11,30 @@
*/ */
class sspmod_core_Storage_SQLPermanentStorage { class sspmod_core_Storage_SQLPermanentStorage {
private $db; private $db;
function __construct($name, $config = NULL) { function __construct($name, $config = NULL) {
if (is_null($config)) if (is_null($config))
$config = SimpleSAML_Configuration::getInstance(); $config = SimpleSAML_Configuration::getInstance();
$datadir = $config->getPathValue('datadir', 'data/'); $datadir = $config->getPathValue('datadir', 'data/');
if (!is_dir($datadir)) if (!is_dir($datadir))
throw new Exception('Data directory [' . $datadir. '] does not exist'); throw new Exception('Data directory [' . $datadir. '] does not exist');
if (!is_writable($datadir)) if (!is_writable($datadir))
throw new Exception('Data directory [' . $datadir. '] is not writable'); throw new Exception('Data directory [' . $datadir. '] is not writable');
$sqllitedir = $datadir . 'sqllite/'; $sqllitedir = $datadir . 'sqllite/';
if (!is_dir($sqllitedir)) { if (!is_dir($sqllitedir)) {
mkdir($sqllitedir); mkdir($sqllitedir);
} }
$dbfile = $sqllitedir . $name . '.sqllite'; $dbfile = $sqllitedir . $name . '.sqllite';
if ($this->db = new SQLiteDatabase($dbfile)) { if ($this->db = new SQLiteDatabase($dbfile)) {
$q = @$this->db->query('SELECT key1 FROM data LIMIT 1'); $q = @$this->db->query('SELECT key1 FROM data LIMIT 1');
if ($q === false) { if ($q === false) {
$this->db->queryExec(' $this->db->queryExec('
CREATE TABLE data ( CREATE TABLE data (
key1 text, key1 text,
key2 text, key2 text,
...@@ -46,157 +46,157 @@ class sspmod_core_Storage_SQLPermanentStorage { ...@@ -46,157 +46,157 @@ class sspmod_core_Storage_SQLPermanentStorage {
PRIMARY KEY (key1,key2,type) PRIMARY KEY (key1,key2,type)
); );
'); ');
} }
} else { } else {
throw new Exception('Error creating SQL lite database [' . $dbfile . '].'); throw new Exception('Error creating SQL lite database [' . $dbfile . '].');
} }
} }
public function set($type, $key1, $key2, $value, $duration = NULL) { public function set($type, $key1, $key2, $value, $duration = NULL) {
if ($this->exists($type, $key1, $key2)) { if ($this->exists($type, $key1, $key2)) {
$this->update($type, $key1, $key2, $value, $duration); $this->update($type, $key1, $key2, $value, $duration);
} else { } else {
$this->insert($type, $key1, $key2, $value, $duration); $this->insert($type, $key1, $key2, $value, $duration);
} }
} }
private function insert($type, $key1, $key2, $value, $duration = NULL) { private function insert($type, $key1, $key2, $value, $duration = NULL) {
$setDuration = ''; $setDuration = '';
if (is_null($duration)) { if (is_null($duration)) {
$setDuration = 'NULL'; $setDuration = 'NULL';
} else { } else {
$setDuration = "'" . sqlite_escape_string(time() + $duration) . "'"; $setDuration = "'" . sqlite_escape_string(time() + $duration) . "'";
} }
$query = "INSERT INTO data (key1,key2,type,created,updated,expire,value) VALUES (" . $query = "INSERT INTO data (key1,key2,type,created,updated,expire,value) VALUES (" .
"'" . sqlite_escape_string($key1) . "'," . "'" . sqlite_escape_string($key1) . "'," .
"'" . sqlite_escape_string($key2) . "'," . "'" . sqlite_escape_string($key2) . "'," .
"'" . sqlite_escape_string($type) . "'," . "'" . sqlite_escape_string($type) . "'," .
"'" . sqlite_escape_string(time()) . "'," . "'" . sqlite_escape_string(time()) . "'," .
"'" . sqlite_escape_string(time()) . "'," . "'" . sqlite_escape_string(time()) . "'," .
$setDuration . "," . $setDuration . "," .
"'" . sqlite_escape_string(serialize($value)) . "')"; "'" . sqlite_escape_string(serialize($value)) . "')";
$results = $this->db->queryExec($query); $results = $this->db->queryExec($query);
return $results; return $results;
} }
private function update($type, $key1, $key2, $value, $duration = NULL) { private function update($type, $key1, $key2, $value, $duration = NULL) {
$setDuration = ''; $setDuration = '';
if (is_null($duration)) { if (is_null($duration)) {
$setDuration = ", expire = NULL "; $setDuration = ", expire = NULL ";
} else { } else {
$setDuration = ", expire = '" . sqlite_escape_string(time() + $duration) . "' "; $setDuration = ", expire = '" . sqlite_escape_string(time() + $duration) . "' ";
} }
$query = "UPDATE data SET " . $query = "UPDATE data SET " .
"updated = '" . sqlite_escape_string(time()) . "'," . "updated = '" . sqlite_escape_string(time()) . "'," .
"value = '" . sqlite_escape_string(serialize($value)) . "'" . "value = '" . sqlite_escape_string(serialize($value)) . "'" .
$setDuration . $setDuration .
"WHERE " . "WHERE " .
"key1 = '" . sqlite_escape_string($key1) . "' AND " . "key1 = '" . sqlite_escape_string($key1) . "' AND " .
"key2 = '" . sqlite_escape_string($key2) . "' AND " . "key2 = '" . sqlite_escape_string($key2) . "' AND " .
"type = '" . sqlite_escape_string($type) . "'"; "type = '" . sqlite_escape_string($type) . "'";
$results = $this->db->queryExec($query); $results = $this->db->queryExec($query);
return $results; return $results;
} }
public function get($type = NULL, $key1 = NULL, $key2 = NULL) { public function get($type = NULL, $key1 = NULL, $key2 = NULL) {
$condition = self::getCondition($type, $key1, $key2); $condition = self::getCondition($type, $key1, $key2);
$query = "SELECT * FROM data WHERE " . $condition; $query = "SELECT * FROM data WHERE " . $condition;
$results = $this->db->arrayQuery($query, SQLITE_ASSOC); $results = $this->db->arrayQuery($query, SQLITE_ASSOC);
if (count($results) !== 1) return NULL; if (count($results) !== 1) return NULL;
$res = $results[0]; $res = $results[0];
$res['value'] = unserialize($res['value']); $res['value'] = unserialize($res['value']);
return $res; return $res;
} }
/* /*
* Return the value directly (not in a container) * Return the value directly (not in a container)
*/ */
public function getValue($type = NULL, $key1 = NULL, $key2 = NULL) { public function getValue($type = NULL, $key1 = NULL, $key2 = NULL) {
$res = $this->get($type, $key1, $key2); $res = $this->get($type, $key1, $key2);
if ($res === NULL) return NULL; if ($res === NULL) return NULL;
return $res['value']; return $res['value'];
} }
public function exists($type, $key1, $key2) { public function exists($type, $key1, $key2) {
$query = "SELECT * FROM data WHERE " . $query = "SELECT * FROM data WHERE " .
"key1 = '" . sqlite_escape_string($key1) . "' AND " . "key1 = '" . sqlite_escape_string($key1) . "' AND " .
"key2 = '" . sqlite_escape_string($key2) . "' AND " . "key2 = '" . sqlite_escape_string($key2) . "' AND " .
"type = '" . sqlite_escape_string($type) . "' LIMIT 1"; "type = '" . sqlite_escape_string($type) . "' LIMIT 1";
$results = $this->db->arrayQuery($query, SQLITE_ASSOC); $results = $this->db->arrayQuery($query, SQLITE_ASSOC);
return (count($results) == 1); return (count($results) == 1);
} }
public function getList($type = NULL, $key1 = NULL, $key2 = NULL) { public function getList($type = NULL, $key1 = NULL, $key2 = NULL) {
$condition = self::getCondition($type, $key1, $key2); $condition = self::getCondition($type, $key1, $key2);
$query = "SELECT * FROM data WHERE " . $condition; $query = "SELECT * FROM data WHERE " . $condition;
$results = $this->db->arrayQuery($query, SQLITE_ASSOC); $results = $this->db->arrayQuery($query, SQLITE_ASSOC);
if (count($results) == 0) return NULL; if (count($results) == 0) return NULL;
foreach($results AS $key => $value) { foreach($results AS $key => $value) {
$results[$key]['value'] = unserialize($results[$key]['value']); $results[$key]['value'] = unserialize($results[$key]['value']);
} }
return $results; return $results;
} }
public function getKeys($type = NULL, $key1 = NULL, $key2 = NULL, $whichKey = 'type') { public function getKeys($type = NULL, $key1 = NULL, $key2 = NULL, $whichKey = 'type') {
if (!in_array($whichKey, array('key1', 'key2', 'type'), true)) if (!in_array($whichKey, array('key1', 'key2', 'type'), true))
throw new Exception('Invalid key type'); throw new Exception('Invalid key type');
$condition = self::getCondition($type, $key1, $key2); $condition = self::getCondition($type, $key1, $key2);
$query = "SELECT DISTINCT " . $whichKey . " FROM data WHERE " . $condition; $query = "SELECT DISTINCT " . $whichKey . " FROM data WHERE " . $condition;
$results = $this->db->arrayQuery($query, SQLITE_ASSOC); $results = $this->db->arrayQuery($query, SQLITE_ASSOC);
if (count($results) == 0) return NULL; if (count($results) == 0) return NULL;
$resarray = array(); $resarray = array();
foreach($results AS $key => $value) { foreach($results AS $key => $value) {
$resarray[] = $value[$whichKey]; $resarray[] = $value[$whichKey];
} }
return $resarray; return $resarray;
} }
public function remove($type, $key1, $key2) { public function remove($type, $key1, $key2) {
$query = "DELETE FROM data WHERE " . $query = "DELETE FROM data WHERE " .
"key1 = '" . sqlite_escape_string($key1) . "' AND " . "key1 = '" . sqlite_escape_string($key1) . "' AND " .
"key2 = '" . sqlite_escape_string($key2) . "' AND " . "key2 = '" . sqlite_escape_string($key2) . "' AND " .
"type = '" . sqlite_escape_string($type) . "'"; "type = '" . sqlite_escape_string($type) . "'";
$results = $this->db->arrayQuery($query, SQLITE_ASSOC); $results = $this->db->arrayQuery($query, SQLITE_ASSOC);
return (count($results) == 1); return (count($results) == 1);
} }
public function removeExpired() { public function removeExpired() {
$query = "DELETE FROM data WHERE expire NOT NULL AND expire < " . time(); $query = "DELETE FROM data WHERE expire NOT NULL AND expire < " . time();
$this->db->arrayQuery($query, SQLITE_ASSOC); $this->db->arrayQuery($query, SQLITE_ASSOC);
$changes = $this->db->changes(); $changes = $this->db->changes();
return $changes; return $changes;
} }
/** /**
* Create a SQL condition statement based on parameters * Create a SQL condition statement based on parameters
*/ */
private static function getCondition($type = NULL, $key1 = NULL, $key2 = NULL) { private static function getCondition($type = NULL, $key1 = NULL, $key2 = NULL) {
$conditions = array(); $conditions = array();
if (!is_null($type)) $conditions[] = "type = '" . sqlite_escape_string($type) . "'"; if (!is_null($type)) $conditions[] = "type = '" . sqlite_escape_string($type) . "'";
if (!is_null($key1)) $conditions[] = "key1 = '" . sqlite_escape_string($key1) . "'"; if (!is_null($key1)) $conditions[] = "key1 = '" . sqlite_escape_string($key1) . "'";
if (!is_null($key2)) $conditions[] = "key2 = '" . sqlite_escape_string($key2) . "'"; if (!is_null($key2)) $conditions[] = "key2 = '" . sqlite_escape_string($key2) . "'";
$conditions[] = "(expire = NULL OR expire >= ".time().")"; $conditions[] = "(expire = NULL OR expire >= ".time().")";
return join(' AND ', $conditions); return join(' AND ', $conditions);
} }
} }
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment