sqlite = new sqlite3(DATA_PATH . DBNAME); } public function __destruct() { $this->sqlite->close(); } public function exec($sql) { $return = $this->sqlite->exec($sql); if(!$return) { throw new Exception($this->lastErrorMsg()); } return $return; } public function query($sql) { return $this->sqlite->query($sql); } public function queryArray($sql) { $data = array(); $return = $this->sqlite->query($sql); while($row = $return->fetchArray(SQLITE3_ASSOC)) { $data[] = $row; } return $data; } public function prepare($sql) { return $this->sqlite->prepare($sql); } public function preparedQueryArray($sql, array $keyValue) { $preparedQuery = $this->prepare($sql); foreach($keyValue as $key => $value) { $preparedQuery->bindValue(':' . $key, $value); } $result = $preparedQuery->execute(); $resultData = array(); while($row = $result->fetchArray(SQLITE3_ASSOC)) { $resultData[] = $row; } return $resultData; } public function lastErrorMsg() { return $this->sqlite->lastErrorMsg(); } }