README.md

database

Simple flat file NoSQL database.

initialize a database

$db = database('blog.json');

get a collection

$posts = $db->get('posts');

insert or update a document

$posts->put([
  'id' => '1',
  'title' => 'Hello world!'
]);

delete a document

$posts->delete('1');

get a document

var_dump($posts->get('1'));

iterate a collection

foreach ($posts as $id => $post) {
  var_dump($id);
  var_dump($post);
}

database.php

<?php

function database($file) {
    static $databases = [];
    $database = @$databases[$file];
    if (!$database) {
        $database = new class($file) {
            private $file;
            private $previous;
            private $next;
            function __construct($file) {
                $this->file = $file;
                $json = @file_get_contents($file);
                if (!$json) {
                    $json = '{}';
                }
                $this->previous = json_decode($json);
                $this->next = json_decode($json); // deep copy
            }
            function __destruct() {
                if ($this->previous != $this->next) {
                    file_put_contents($this->file, json_encode($this->next), LOCK_EX);
                }
            }
            function get($name) {
                $documents = @$this->next->$name;
                if (!$documents) {
                    $documents = new stdClass();
                    $this->next->$name = $documents;
                }
                return new class($documents) implements IteratorAggregate
                {
                    private $documents;
                    function __construct($documents) {
                        $this->documents = $documents;
                    }
                    function get($id) {
                        return $this->documents->$id;
                    }
                    function put($next) {
                        $previous = @$this->documents->{$next['id']};
                        if ($previous) {
                            foreach ($next as $key => $value) {
                                $previous->$key = $value;
                            }
                        } else {
                            $this->documents->{$next['id']} = (object) $next;
                        }
                    }
                    function delete($id) {
                        unset($this->documents->$id);
                    }
                    function getIterator(): Traversable {
                        return new ArrayIterator($this->documents);
                    }
                };
            }
        };
        $databases[$file] = $database;
    }
    return $database;
}