Initial implementation SQLite

api.php

@@ -569,6 +569,194 @@ class SQLServer implements DatabaseInterface {
 	}
 }
 
+class SQLite implements DatabaseInterface {
+
+	protected $db;
+	protected $queries;
+
+	public function __construct() {
+		$this->queries = array(
+			'list_tables'=>'SELECT
+					"name", ""
+				FROM
+					"sys/tables"',
+			'reflect_table'=>'SELECT
+					"name"
+				FROM
+					"sys/tables"
+				WHERE
+					"name"=?',
+			'reflect_pk'=>'SELECT
+					"name"
+				FROM
+					"sys/columns"
+				WHERE
+					"pk"=1 AND
+					"self"=?',
+			'reflect_belongs_to'=>'SELECT
+					"self", "from",
+					"table", "to"
+				FROM
+					"sys/foreign_keys"
+				WHERE
+					"self" = ? AND
+					"table" IN ? AND
+					? like "%" AND
+					? like "%"',
+			'reflect_has_many'=>'SELECT
+					"self", "from",
+					"table", "to"
+				FROM
+					"sys/foreign_keys"
+				WHERE
+					"self" IN ? AND
+					"table" = ? AND
+					? like "%" AND
+					? like "%"',
+			'reflect_habtm'=>'SELECT
+					k1."self", k1."from",
+					k1."table", k1."to",
+					k2."self", k2."from",
+					k2."table", k2."to"
+				FROM
+					"sys/foreign_keys" k1,
+					"sys/foreign_keys" k2
+				WHERE
+					? like "%" AND
+					? like "%" AND
+					? like "%" AND
+					? like "%" AND
+					k1."self" = k2."self" AND
+					k1."table" = ? AND
+					k2."table" IN ?'
+		);
+	}
+
+	public function getSql($name) {
+		return isset($this->queries[$name])?$this->queries[$name]:false;
+	}
+
+	public function connect($hostname,$username,$password,$database,$port,$socket,$charset) {
+		$this->db = new SQLite3($database);
+		// optimizations
+		$this->db->querySingle('PRAGMA synchronous = NORMAL');
+		$this->db->querySingle('PRAGMA foreign_keys = on');
+		$reflection = $this->db->querySingle('SELECT name FROM sqlite_master WHERE type = "table" and name like "sys/%"');
+		if (!$reflection) {
+			//create reflection tables
+			$this->query('CREATE table "sys/version" ("version" integer)');
+			$this->query('CREATE table "sys/tables" ("name" text)');
+			$this->query('CREATE table "sys/columns" ("self" text,"cid" integer,"name" text,"type" integer,"notnull" integer,"dflt_value" integer,"pk" integer)');
+			$this->query('CREATE table "sys/foreign_keys" ("self" text,"id" integer,"seq" integer,"table" text,"from" text,"to" text,"on_update" text,"on_delete" text,"match" text)');
+		}
+		$version = $this->db->querySingle('pragma schema_version');
+		if ($version != $this->db->querySingle('SELECT "version" from "sys/version"')) {
+			// update version data
+			$this->query('DELETE FROM "sys/version"');
+			$this->query('INSERT into "sys/version" ("version") VALUES (?)',array($version));
+			// update tables data
+			$this->query('DELETE FROM "sys/tables"');
+			$result = $this->query('SELECT * FROM sqlite_master WHERE type = "table" and name not like "sys/%" and name<>"sqlite_sequence"');
+			$tables = array();
+			while ($row = $this->fetchAssoc($result)) {
+				$tables[] = $row['name'];
+				$this->query('INSERT into "sys/tables" ("name") VALUES (?)',array($row['name']));
+			}
+			// update columns and foreign_keys data
+			$this->query('DELETE FROM "sys/columns"');
+			$this->query('DELETE FROM "sys/foreign_keys"');
+			foreach ($tables as $table) {
+				$result = $this->query('pragma table_info(!)',array($table));
+				while ($row = $this->fetchRow($result)) {
+					array_unshift($row, $table);
+					$this->query('INSERT into "sys/columns" ("self","cid","name","type","notnull","dflt_value","pk") VALUES (?,?,?,?,?,?,?)',$row);
+				}
+				$result = $this->query('pragma foreign_key_list(!)',array($table));
+				while ($row = $this->fetchRow($result)) {
+					array_unshift($row, $table);
+					$this->query('INSERT into "sys/foreign_keys" ("self","id","seq","table","from","to","on_update","on_delete","match") VALUES (?,?,?,?,?,?,?,?,?)',$row);
+				}
+			}
+		}
+	}
+
+	public function query($sql,$params=array()) {
+		$db = $this->db;
+		$sql = preg_replace_callback('/\!|\?/', function ($matches) use (&$db,&$params) {
+			$param = array_shift($params);
+			if ($matches[0]=='!') return preg_replace('/[^a-zA-Z0-9\-_=<> ]/','',$param);
+			if (is_array($param)) return '('.implode(',',array_map(function($v) use (&$db) {
+				return "'".$db->escapeString($v)."'";
+			},$param)).')';
+			if (is_object($param) && $param->type=='base64') {
+				return "'".$db->escapeString(base64_decode($param->data))."'";
+			}
+			if ($param===null) return 'NULL';
+			return "'".$db->escapeString($param)."'";
+		}, $sql);
+		//echo "\n$sql\n";
+		try {	$result=$db->query($sql); } catch(\Exception $e) { $result=null; }
+		return $result;
+	}
+
+	public function fetchAssoc($result) {
+		$values = $result->fetchArray(SQLITE3_ASSOC);
+		if ($values) $values = array_map(function($v){ return is_null($v)?null:(string)$v; },$values);
+		return $values;
+	}
+
+	public function fetchRow($result) {
+		$values = $result->fetchArray(SQLITE3_NUM);
+		if ($values) $values = array_map(function($v){ return is_null($v)?null:(string)$v; },$values);
+		return $values;
+	}
+
+	public function insertId($result) {
+		return $this->db->lastInsertRowID();
+	}
+
+	public function affectedRows($result) {
+		return $this->db->changes();
+	}
+
+	public function close($result) {
+		return $result->finalize();
+	}
+
+	public function fetchFields($result) {
+		$values = $result->fetchArray();
+		$fields = array();
+		for($i = 0; $i < $result->numColumns() ; $i++){
+			$tab = array();
+			$tab['type'] = $result->columnType($i);
+			$tab['name'] = $result->columnName($i);
+			$fields[strtolower($tab['name'])] = (object)$tab;
+		}
+		return $fields;
+	}
+
+	public function addLimitToSql($sql,$limit,$offset) {
+		return "$sql LIMIT $limit OFFSET $offset";
+	}
+
+	public function likeEscape($string) {
+		return addcslashes($string,'%_');
+	}
+
+	public function isBinaryType($field) {
+		return ($field->type==4);
+	}
+
+	public function base64Encode($string) {
+		return base64_encode($string);
+	}
+
+	public function getDefaultCharset() {
+		return 'utf8';
+	}
+
+}
+
 class PHP_CRUD_API {
 
 	protected $db;

tests/blog_sqlite.sql

@@ -0,0 +1,80 @@
+-- Adminer 4.2.4 SQLite 3 dump
+
+DROP TABLE IF EXISTS "categories";
+CREATE TABLE "categories" (
+  "id" integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "name" text(255) NOT NULL,
+  "icon" blob NULL
+);
+
+INSERT INTO "categories" ("id", "name", "icon") VALUES (1,	'anouncement',	NULL);
+INSERT INTO "categories" ("id", "name", "icon") VALUES (2,	'article',	NULL);
+
+DROP TABLE IF EXISTS "comments";
+CREATE TABLE "comments" (
+  "id" integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "post_id" integer NOT NULL,
+  "message" text NOT NULL,
+  FOREIGN KEY ("post_id") REFERENCES "posts" ("id")
+);
+
+CREATE INDEX "comments_post_id" ON "comments" ("post_id");
+
+INSERT INTO "comments" ("id", "post_id", "message") VALUES (1,	1,	'great');
+INSERT INTO "comments" ("id", "post_id", "message") VALUES (2,	1,	'fantastic');
+INSERT INTO "comments" ("id", "post_id", "message") VALUES (3,	2,	'thank you');
+INSERT INTO "comments" ("id", "post_id", "message") VALUES (4,	2,	'awesome');
+
+DROP TABLE IF EXISTS "post_tags";
+CREATE TABLE "post_tags" (
+  "id" integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "post_id" integer NOT NULL,
+  "tag_id" integer NOT NULL,
+  FOREIGN KEY ("tag_id") REFERENCES "tags" ("id"),
+  FOREIGN KEY ("post_id") REFERENCES "posts" ("id") ON DELETE RESTRICT ON UPDATE RESTRICT
+);
+
+CREATE UNIQUE INDEX "post_tags_post_id_tag_id" ON "post_tags" ("post_id", "tag_id");
+
+INSERT INTO "post_tags" ("id", "post_id", "tag_id") VALUES (1,	1,	1);
+INSERT INTO "post_tags" ("id", "post_id", "tag_id") VALUES (2,	1,	2);
+INSERT INTO "post_tags" ("id", "post_id", "tag_id") VALUES (3,	2,	1);
+INSERT INTO "post_tags" ("id", "post_id", "tag_id") VALUES (4,	2,	2);
+
+DROP TABLE IF EXISTS "posts";
+CREATE TABLE "posts" (
+  "id" integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  "user_id" integer NOT NULL,
+  "category_id" integer NOT NULL,
+  "content" text NOT NULL,
+  FOREIGN KEY ("user_id") REFERENCES "users" ("id") ON DELETE RESTRICT ON UPDATE RESTRICT,
+  FOREIGN KEY ("category_id") REFERENCES "categories" ("id") ON DELETE RESTRICT ON UPDATE RESTRICT
+);
+
+CREATE INDEX "posts_user_id" ON "posts" ("user_id");
+
+CREATE INDEX "posts_category_id" ON "posts" ("category_id");
+
+INSERT INTO "posts" ("id", "user_id", "category_id", "content") VALUES (1,	1,	1,	'blog started');
+INSERT INTO "posts" ("id", "user_id", "category_id", "content") VALUES (2,	1,	2,	'It works!');
+
+DROP TABLE IF EXISTS "tags";
+CREATE TABLE `tags` (
+  `id` integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  `name` text(255) NOT NULL
+);
+
+INSERT INTO "tags" ("id", "name") VALUES (1,	'funny');
+INSERT INTO "tags" ("id", "name") VALUES (2,	'important');
+
+DROP TABLE IF EXISTS "users";
+CREATE TABLE `users` (
+  `id` integer NOT NULL PRIMARY KEY AUTOINCREMENT,
+  `username` text(255) NOT NULL,
+  `password` text(255) NOT NULL
+);
+
+INSERT INTO "users" ("id", "username", "password") VALUES (1,	'user1',	'pass1');
+INSERT INTO "users" ("id", "username", "password") VALUES (2,	'user2',	'pass2');
+
+--

tests/config.php.dist

@@ -2,7 +2,7 @@
 
 class PHP_CRUD_API_Config
 {
-	public static $dbengine='MySQL';             // 'MySQL', 'SQLServer' or 'PostgreSQL'
+	public static $dbengine='MySQL';             // 'MySQL', 'SQLServer', 'PostgreSQL' or 'SQLite'
 	public static $hostname='{{test_hostname}}'; // 'localhost' for mysql or '(Local)' for mssql
 	public static $username='{{test_username}}'; // May be empty on mssql
 	public static $password='{{test_password}}'; // May be empty on mssql

tests/tests.php

@@ -164,6 +164,21 @@ class PHP_CRUD_API_Test extends PHPUnit_Framework_TestCase
 			}
 			pg_close($db);
 
+		} elseif ($dbengine == 'SQLite') {
+
+			$db = new SQLite3($database);
+			if (!$db) {
+				die("Could not open '$database' SQLite database: ".SQLite3::lastErrorMsg().' ('.SQLite3::lastErrorCode().")\n");
+			}
+			$queries = preg_split('/;\s*\n/', file_get_contents($fixture));
+			array_pop($queries);
+			foreach ($queries as $i=>$query) {
+				if (!$db->query($query.';')) {
+					$i++;
+					die("Loading '$fixture' failed on statemement #$i with error:\n".$db->lastErrorCode().': '.$db->lastErrorMsg()."\n");
+				}
+			}
+			$db->close();
 		}
 	}