]>
git.immae.eu Git - github/wallabag/wallabag.git/blob - inc/store/sqlite.class.php
4bfbb29e83632d26f353647574a313dc2809cd94
3 * poche, a read it later open source system
6 * @author Nicolas LÅ“uillet <support@inthepoche.com>
8 * @license http://www.wtfpl.net/ see COPYING file
11 class Sqlite
extends Store
{
13 public static $db_path = 'sqlite:./db/poche.sqlite';
16 function __construct() {
17 parent
::__construct();
19 $this->handle
= new PDO(self
::$db_path);
20 $this->handle
->setAttribute(PDO
::ATTR_ERRMODE
, PDO
::ERRMODE_EXCEPTION
);
23 private function getHandle() {
27 public function isInstalled() {
28 $sql = "SELECT name FROM sqlite_sequence WHERE name=?";
29 $query = $this->executeQuery($sql, array('config'));
30 $hasConfig = $query->fetchAll();
32 if (count($hasConfig) == 0)
35 if (!$this->getLogin() || !$this->getPassword())
41 public function install($login, $password) {
42 $this->getHandle()->exec('CREATE TABLE IF NOT EXISTS "config" ("id" INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL UNIQUE , "name" VARCHAR UNIQUE, "value" BLOB)');
44 $this->handle
->exec('CREATE TABLE IF NOT EXISTS "entries" ("id" INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL UNIQUE , "title" VARCHAR, "url" VARCHAR UNIQUE , "is_read" INTEGER DEFAULT 0, "is_fav" INTEGER DEFAULT 0, "content" BLOB)');
46 if (!$this->getLogin()) {
47 $sql_login = 'INSERT INTO config ( name, value ) VALUES (?, ?)';
48 $params_login = array('login', $login);
49 $query = $this->executeQuery($sql_login, $params_login);
52 if (!$this->getPassword()) {
53 $sql_pass = 'INSERT INTO config ( name, value ) VALUES (?, ?)';
54 $params_pass = array('password', $password);
55 $query = $this->executeQuery($sql_pass, $params_pass);
61 public function getLogin() {
62 $sql = "SELECT value FROM config WHERE name=?";
63 $query = $this->executeQuery($sql, array('login'));
64 $login = $query->fetchAll();
66 return isset($login[0]['value']) ? $login[0]['value'] : FALSE;
69 public function getPassword() {
70 $sql = "SELECT value FROM config WHERE name=?";
71 $query = $this->executeQuery($sql, array('password'));
72 $pass = $query->fetchAll();
74 return isset($pass[0]['value']) ? $pass[0]['value'] : FALSE;
77 private function executeQuery($sql, $params) {
80 $query = $this->getHandle()->prepare($sql);
81 $query->execute($params);
86 logm('execute query error : '.$e->getMessage());
90 public function retrieveAll() {
91 $sql = "SELECT * FROM entries ORDER BY id";
92 $query = $this->executeQuery($sql, array());
93 $entries = $query->fetchAll();
98 public function retrieveOneById($id) {
99 parent
::__construct();
102 $sql = "SELECT * FROM entries WHERE id=?";
103 $params = array(intval($id));
104 $query = $this->executeQuery($sql, $params);
105 $entry = $query->fetchAll();
110 public function getEntriesByView($view) {
111 parent
::__construct();
113 switch ($_SESSION['sort'])
116 $order = 'ORDER BY id';
119 $order = 'ORDER BY id DESC';
122 $order = 'ORDER BY lower(title)';
125 $order = 'ORDER BY lower(title) DESC';
128 $order = 'ORDER BY id';
135 $sql = "SELECT * FROM entries WHERE is_read=? " . $order;
139 $sql = "SELECT * FROM entries WHERE is_fav=? " . $order;
143 $sql = "SELECT * FROM entries WHERE is_read=? " . $order;
148 $query = $this->executeQuery($sql, $params);
149 $entries = $query->fetchAll();
154 public function add($url, $title, $content) {
155 parent
::__construct();
156 $sql_action = 'INSERT INTO entries ( url, title, content ) VALUES (?, ?, ?)';
157 $params_action = array($url, $title, $content);
158 $query = $this->executeQuery($sql_action, $params_action);
162 public function deleteById($id) {
163 parent
::__construct();
164 $sql_action = "DELETE FROM entries WHERE id=?";
165 $params_action = array($id);
166 $query = $this->executeQuery($sql_action, $params_action);
170 public function favoriteById($id) {
171 parent
::__construct();
172 $sql_action = "UPDATE entries SET is_fav=~is_fav WHERE id=?";
173 $params_action = array($id);
174 $query = $this->executeQuery($sql_action, $params_action);
177 public function archiveById($id) {
178 parent
::__construct();
179 $sql_action = "UPDATE entries SET is_read=~is_read WHERE id=?";
180 $params_action = array($id);
181 $query = $this->executeQuery($sql_action, $params_action);
184 public function getLastId() {
185 parent
::__construct();
186 return $this->getHandle()->lastInsertId();
189 public function updateContentById($id) {
190 parent
::__construct();
191 $sql_update = "UPDATE entries SET content=? WHERE id=?";
192 $params_update = array($content, $id);
193 $query = $this->executeQuery($sql_update, $params_update);