New Homepage

Changelog diff is:

diff --git Changes Changes
index b22c1b5..3386ce5 100644
--- Changes
+++ Changes
@@ -2,6 +2,10 @@ Revision history for Perl extension Unqlite

 {{$NEXT}}

+0.05 2014-12-23T22:55:15Z
+
+    - Doc fix
+
 0.04 2014-08-30T09:33:52Z

     - Fixed packaging issue.

Build.PL

@@ -12,8 +12,6 @@ use utf8;
 use Module::Build;
 use File::Basename;
 use File::Spec;
-use CPAN::Meta;
-use CPAN::Meta::Prereqs;
 
 my %args = (
     license              => 'perl',
@@ -29,9 +27,12 @@ my %args = (
 
     script_files => [glob('script/*'), glob('bin/*')],
     c_source     => [qw(unqlite)],
+    PL_files => {},
 
     test_files           => ((-d '.git' || $ENV{RELEASE_TESTING}) && -d 'xt') ? 't/ xt/' : 't/',
     recursive_test_files => 1,
+
+
 );
 if (-d 'share') {
     $args{share_dir} = 'share';
@@ -50,20 +51,15 @@ my $builder = Module::Build->subclass(
 )->new(%args);
 $builder->create_build_script();
 
-my $mbmeta = CPAN::Meta->load_file('MYMETA.json');
+use File::Copy;
-my $meta = CPAN::Meta->load_file('META.json');
+
-my $prereqs_hash = CPAN::Meta::Prereqs->new(
+print "cp META.json MYMETA.json\n";
-    $meta->prereqs
+copy("META.json","MYMETA.json") or die "Copy failed(META.json): $!";
-)->with_merged_prereqs(
+
-    CPAN::Meta::Prereqs->new($mbmeta->prereqs)
+if (-f 'META.yml') {
-)->as_string_hash;
+    print "cp META.yml MYMETA.yml\n";
-my $mymeta = CPAN::Meta->new(
+    copy("META.yml","MYMETA.yml") or die "Copy failed(META.yml): $!";
-    {
+} else {
-        %{$meta->as_struct},
+    print "There is no META.yml... You may install this module from the repository...\n";
-        prereqs => $prereqs_hash
+}
-    }
+
-);
-print "Merging cpanfile prereqs to MYMETA.yml\n";
-$mymeta->save('MYMETA.yml', { version => 1.4 });
-print "Merging cpanfile prereqs to MYMETA.json\n";
-$mymeta->save('MYMETA.json', { version => 2 });

Changes

@@ -2,6 +2,27 @@ Revision history for Perl extension Unqlite
 
 {{$NEXT}}
 
+0.05 2014-12-23T22:55:15Z
+
+    - Doc fix
+
+0.04 2014-08-30T09:33:52Z
+
+    - Fixed packaging issue.
+
+0.03 2013-07-18T03:14:07Z
+
+    - more OPEN consts as mode argument
+      we do not only want to create databases
+      (Reini Urban)
+
+0.02 2013-07-05T06:42:59Z
+
+    - Store RC to magic to fix race condition
+      (charsbar)
+    - Added `tie` interface.
+      (charsbar)
+
 0.01 2013-07-03T19:02:44Z
 
     - original version

META.json

@@ -4,7 +4,7 @@
       "tokuhirom <tokuhirom@gmail.com>"
    ],
    "dynamic_config" : 0,
-   "generated_by" : "Minilla/v0.5.5, CPAN::Meta::Converter version 2.130880",
+   "generated_by" : "Minilla/v2.2.0, CPAN::Meta::Converter version 2.141520",
    "license" : [
       "perl_5"
    ],
@@ -21,21 +21,21 @@
          "share",
          "eg",
          "examples",
-         "author"
+         "author",
+         "builder"
       ]
    },
    "prereqs" : {
       "configure" : {
          "requires" : {
-            "CPAN::Meta" : "0",
-            "CPAN::Meta::Prereqs" : "0",
             "Module::Build" : "0.38"
          }
       },
       "develop" : {
          "requires" : {
             "Test::CPAN::Meta" : "0",
-            "Test::MinimumVersion" : "0.10108",
+            "Test::MinimumVersion::Fast" : "0.04",
+            "Test::PAUSE::Permissions" : "0.04",
             "Test::Pod" : "1.41",
             "Test::Spellunker" : "v0.2.7"
          }
@@ -63,5 +63,9 @@
          "web" : "https://github.com/tokuhirom/UnQLite"
       }
    },
-   "version" : "0.01"
+   "version" : "0.05",
+   "x_contributors" : [
+      "Kenichi Ishigaki <ishigaki@cpan.org>",
+      "Reini Urban <rurban@cpanel.net>"
+   ]
 }

README.md

@@ -6,23 +6,28 @@ UnQLite - Perl bindings for UnQLite
 
     use UnQLite;
 
-    my $db = UnQLite->open('foo.db');
+    my $db = UnQLite->open('foo.db', UnQLite::UNQLITE_OPEN_READWRITE|UnQLite::UNQLITE_OPEN_CREATE);
     $db->kv_store('foo', 'bar');
     say $db->kv_fetch('foo'); # => bar
     $db->kv_delete('foo');
     undef $db; # close database
 
+    # tie interface
+    tie my %hash, 'UnQLite', 'foo.db', UnQLite::UNQLITE_OPEN_READWRITE;
+    $hash{foo} = 'bar';
+    say $hash{foo}; # => bar
+
 # DESCRIPTION
 
 UnQLite is a in-process software library which implements a self-contained, serverless, zero-configuration, transactional NoSQL database engine. UnQLite is a document store database similar to MongoDB, Redis, CouchDB etc. as well a standard Key/Value store similar to BerkeleyDB, LevelDB, etc.  
 
 This module is Perl5 binding for UnQLite.
 
-If you want to know more information about UnQLite, see [http://unqlite.org/](http://unqlite.org/).
+If you want to know more information about UnQLite, see [https://unqlite.symisc.net/](https://unqlite.symisc.net/).
 
 This version of UnQLite.pm does not provides document store feature. Patches welcome.
 
-__You can use UnQLite.pm as DBM__.
+**You can use UnQLite.pm as DBM**.
 
 # METHODS
 
@@ -30,6 +35,17 @@ __You can use UnQLite.pm as DBM__.
 
     Open the database.
 
+    Modes:
+
+        UnQLite::UNQLITE_OPEN_CREATE      (Default)
+        UnQLite::UNQLITE_OPEN_READONLY
+        UnQLite::UNQLITE_OPEN_READWRITE
+        UnQLite::UNQLITE_OPEN_EXCLUSIVE
+        UnQLite::UNQLITE_OPEN_TEMP_DB
+        UnQLite::UNQLITE_OPEN_OMIT_JOURNALING
+        UnQLite::UNQLITE_OPEN_IN_MEMORY
+        UnQLite::UNQLITE_OPEN_MMAP
+
 - `$db->kv_store($key, $value);`
 
     Store the entry to database.
@@ -102,11 +118,11 @@ Here is example code:
 
     Return true if succeeded, false otherwise.
 
-- `$cursor->seek($key, $opt=UNQLITE_CURSOR_MATCH_EXACT)`
+- `$cursor->seek($key, $opt=UnQLite::UNQLITE_CURSOR_MATCH_EXACT)`
 
     Seek cursor to ` $key `.
 
-    You can specify the option as ` $opt `. Please see [http://unqlite.org/c\_api/unqlite\_kv\_cursor.html](http://unqlite.org/c\_api/unqlite\_kv\_cursor.html) for more details.
+    You can specify the option as ` $opt `. Please see [http://unqlite.org/c\_api/unqlite\_kv\_cursor.html](http://unqlite.org/c_api/unqlite_kv_cursor.html) for more details.
 
     Return true if succeeded, false otherwise.
 

lib/UnQLite.pm

@@ -2,17 +2,29 @@ package UnQLite;
 use 5.008005;
 use strict;
 use warnings;
+use Carp ();
 
-our $VERSION = "0.01";
+our $VERSION = "0.05";
 our $rc = 0;
 
 use XSLoader;
 XSLoader::load(__PACKAGE__, $VERSION);
 
-sub rc { $UnQLite::rc }
+sub TIEHASH {
+    my $class = shift;
+    my $self = $class->open(@_) or Carp::croak $class->errstr;
+    $self->cursor_init;
+}
+
+sub rc {
+    my $self = shift;
+    my $_rc = _rc($self);
+    defined $_rc ? $rc = $_rc : $rc;
+}
 
 sub errstr {
     my $self = shift;
+    my $rc = $self->rc;
     if ($rc==UnQLite::UNQLITE_OK()) { return "UNQLITE_OK" }
     if ($rc==UNQLITE_NOMEM()) { return "UNQLITE_NOMEM" }
     if ($rc==UNQLITE_ABORT()) { return "UNQLITE_ABORT" }
@@ -46,6 +58,12 @@ sub cursor_init {
 
 package UnQLite::Cursor;
 
+sub rc {
+    my $self = shift;
+    my $_rc = _rc($self->[0]);
+    defined $_rc ? $UnQLite::rc = $_rc : $UnQLite::rc;
+}
+
 sub first_entry {
     my $self = shift;
     _first_entry($self->[0]);
@@ -96,6 +114,62 @@ sub DESTROY {
     _release($self->[0], $self->[1]);
 }
 
+# tie interface
+
+sub FETCH {
+    my ($self, $key) = @_;
+    $self->[1]->kv_fetch($key);
+}
+
+sub STORE {
+    my ($self, $key, $value) = @_;
+    $self->[1]->kv_store($key, $value) or Carp::croak $self->[1]->errstr;
+    $value;
+}
+
+sub DELETE {
+    my ($self, $key) = @_;
+    my $prev = $self->[1]->kv_fetch($key);
+    my $errstr = $self->[1]->errstr;
+    return unless $errstr && $errstr eq 'UNQLITE_OK';
+    $self->[1]->kv_delete($key) or Carp::croak $self->[1]->errstr;
+    $prev;
+}
+
+sub FIRSTKEY {
+    my $self = shift;
+    $self->first_entry or return;
+    $self->key;
+}
+
+sub NEXTKEY {
+    my $self = shift;
+    $self->next_entry or return;
+    $self->key;
+}
+
+sub EXISTS {
+    my ($self, $key) = @_;
+    $self->[1]->kv_fetch($key) and return 1;
+    my $errstr = $self->[1]->errstr;
+    return $errstr && $errstr eq 'UNQLITE_OK' ? 1 : 0;
+}
+
+sub CLEAR {
+    my $self = shift;
+    $self->first_entry or return;
+    $self->delete_entry while $self->valid_entry;
+    return;
+}
+
+sub SCALAR {
+    my $self = shift;
+    $self->first_entry or return;
+    my $ct = 1;
+    $ct++ while $self->next_entry && $self->valid_entry;
+    return $ct;
+}
+
 1;
 __END__
 
@@ -111,12 +185,17 @@ UnQLite - Perl bindings for UnQLite
 
     use UnQLite;
 
-    my $db = UnQLite->open('foo.db');
+    my $db = UnQLite->open('foo.db', UnQLite::UNQLITE_OPEN_READWRITE|UnQLite::UNQLITE_OPEN_CREATE);
     $db->kv_store('foo', 'bar');
     say $db->kv_fetch('foo'); # => bar
     $db->kv_delete('foo');
     undef $db; # close database
 
+    # tie interface
+    tie my %hash, 'UnQLite', 'foo.db', UnQLite::UNQLITE_OPEN_READWRITE;
+    $hash{foo} = 'bar';
+    say $hash{foo}; # => bar
+
 =head1 DESCRIPTION
 
 UnQLite is a in-process software library which implements a self-contained, serverless, zero-configuration, transactional NoSQL database engine. UnQLite is a document store database similar to MongoDB, Redis, CouchDB etc. as well a standard Key/Value store similar to BerkeleyDB, LevelDB, etc.  
@@ -137,6 +216,17 @@ B<You can use UnQLite.pm as DBM>.
 
 Open the database.
 
+Modes:
+
+    UnQLite::UNQLITE_OPEN_CREATE      (Default)
+    UnQLite::UNQLITE_OPEN_READONLY
+    UnQLite::UNQLITE_OPEN_READWRITE
+    UnQLite::UNQLITE_OPEN_EXCLUSIVE
+    UnQLite::UNQLITE_OPEN_TEMP_DB
+    UnQLite::UNQLITE_OPEN_OMIT_JOURNALING
+    UnQLite::UNQLITE_OPEN_IN_MEMORY
+    UnQLite::UNQLITE_OPEN_MMAP
+
 =item C<< $db->kv_store($key, $value); >>
 
 Store the entry to database.
@@ -213,7 +303,7 @@ Seek cursor to previous entry.
 
 Return true if succeeded, false otherwise.
 
-=item C<< $cursor->seek($key, $opt=UNQLITE_CURSOR_MATCH_EXACT) >>
+=item C<< $cursor->seek($key, $opt=UnQLite::UNQLITE_CURSOR_MATCH_EXACT) >>
 
 Seek cursor to C< $key >.
 

lib/UnQLite.xs

@@ -19,14 +19,21 @@ extern "C" {
 
 #define XS_STRUCT2OBJ(sv, class, obj) \
     sv = newSViv(PTR2IV(obj));  \
+    sv_magic(sv, sv_2mortal(newSViv(UNQLITE_OK)), PERL_MAGIC_ext, NULL, 0); \
     sv = newRV_noinc(sv); \
     sv_bless(sv, gv_stashpv(class, 1)); \
     SvREADONLY_on(sv);
 
-#define SETRC(rc) \
+#define SETRC(rc, self) \
     { \
         SV * i = get_sv("UnQLite::rc", GV_ADD); \
         SvIV_set(i, rc); \
+        if (SvROK(self)) { \
+            MAGIC *_mg = mg_find(SvRV(self), PERL_MAGIC_ext); \
+            if (_mg) { \
+                SvIV_set(_mg->mg_obj, rc); \
+            } \
+        } \
     }
 
 MODULE = UnQLite    PACKAGE = UnQLite
@@ -35,34 +42,44 @@ PROTOTYPES: DISABLE
 
 BOOT:
     HV* stash = gv_stashpvn("UnQLite", strlen("UnQLite"), TRUE);
-    newCONSTSUB(stash, "UNQLITE_OK", newSViv(UNQLITE_OK));
+#define _XSTR(s) _STR(s)
-    newCONSTSUB(stash, "UNQLITE_NOMEM", newSViv(UNQLITE_NOMEM));
+#define _STR(s)  #s
-    newCONSTSUB(stash, "UNQLITE_ABORT", newSViv(UNQLITE_ABORT));
+#define UnConst(c) newCONSTSUB(stash, "UNQ"_XSTR(c), newSViv(UNQ##c))
-    newCONSTSUB(stash, "UNQLITE_IOERR", newSViv(UNQLITE_IOERR));
+    UnConst(LITE_OK);
-    newCONSTSUB(stash, "UNQLITE_CORRUPT", newSViv(UNQLITE_CORRUPT));
+    UnConst(LITE_NOMEM);
-    newCONSTSUB(stash, "UNQLITE_LOCKED", newSViv(UNQLITE_LOCKED));
+    UnConst(LITE_ABORT);
-    newCONSTSUB(stash, "UNQLITE_BUSY", newSViv(UNQLITE_BUSY));
+    UnConst(LITE_IOERR);
-    newCONSTSUB(stash, "UNQLITE_DONE", newSViv(UNQLITE_DONE));
+    UnConst(LITE_CORRUPT);
-    newCONSTSUB(stash, "UNQLITE_PERM", newSViv(UNQLITE_PERM));
+    UnConst(LITE_LOCKED);
-    newCONSTSUB(stash, "UNQLITE_NOTIMPLEMENTED", newSViv(UNQLITE_NOTIMPLEMENTED));
+    UnConst(LITE_BUSY);
-    newCONSTSUB(stash, "UNQLITE_NOTFOUND", newSViv(UNQLITE_NOTFOUND));
+    UnConst(LITE_DONE);
-    newCONSTSUB(stash, "UNQLITE_NOOP", newSViv(UNQLITE_NOOP));
+    UnConst(LITE_PERM);
-    newCONSTSUB(stash, "UNQLITE_INVALID", newSViv(UNQLITE_INVALID));
+    UnConst(LITE_NOTIMPLEMENTED);
-    newCONSTSUB(stash, "UNQLITE_EOF", newSViv(UNQLITE_EOF));
+    UnConst(LITE_NOTFOUND);
-    newCONSTSUB(stash, "UNQLITE_UNKNOWN", newSViv(UNQLITE_UNKNOWN));
+    UnConst(LITE_NOOP);
-    newCONSTSUB(stash, "UNQLITE_LIMIT", newSViv(UNQLITE_LIMIT));
+    UnConst(LITE_INVALID);
-    newCONSTSUB(stash, "UNQLITE_EXISTS", newSViv(UNQLITE_EXISTS));
+    UnConst(LITE_EOF);
-    newCONSTSUB(stash, "UNQLITE_EMPTY", newSViv(UNQLITE_EMPTY));
+    UnConst(LITE_UNKNOWN);
-    newCONSTSUB(stash, "UNQLITE_COMPILE_ERR", newSViv(UNQLITE_COMPILE_ERR));
+    UnConst(LITE_LIMIT);
-    newCONSTSUB(stash, "UNQLITE_VM_ERR", newSViv(UNQLITE_VM_ERR));
+    UnConst(LITE_EXISTS);
-    newCONSTSUB(stash, "UNQLITE_FULL", newSViv(UNQLITE_FULL));
+    UnConst(LITE_EMPTY);
-    newCONSTSUB(stash, "UNQLITE_CANTOPEN", newSViv(UNQLITE_CANTOPEN));
+    UnConst(LITE_COMPILE_ERR);
-    newCONSTSUB(stash, "UNQLITE_READ_ONLY", newSViv(UNQLITE_READ_ONLY));
+    UnConst(LITE_VM_ERR);
-    newCONSTSUB(stash, "UNQLITE_LOCKERR", newSViv(UNQLITE_LOCKERR));
+    UnConst(LITE_FULL);
-
+    UnConst(LITE_CANTOPEN);
-    newCONSTSUB(stash, "UNQLITE_CURSOR_MATCH_EXACT", newSViv(UNQLITE_CURSOR_MATCH_EXACT));
+    UnConst(LITE_READ_ONLY);
-    newCONSTSUB(stash, "UNQLITE_CURSOR_MATCH_LE", newSViv(UNQLITE_CURSOR_MATCH_LE));
+    UnConst(LITE_LOCKERR);
-    newCONSTSUB(stash, "UNQLITE_CURSOR_MATCH_GE", newSViv(UNQLITE_CURSOR_MATCH_GE));
+    UnConst(LITE_OPEN_READONLY);
+    UnConst(LITE_OPEN_READWRITE);
+    UnConst(LITE_OPEN_CREATE);
+    UnConst(LITE_OPEN_EXCLUSIVE);
+    UnConst(LITE_OPEN_TEMP_DB);
+    UnConst(LITE_OPEN_OMIT_JOURNALING);
+    UnConst(LITE_OPEN_IN_MEMORY);
+    UnConst(LITE_OPEN_MMAP);
+    UnConst(LITE_CURSOR_MATCH_EXACT);
+    UnConst(LITE_CURSOR_MATCH_LE);
+    UnConst(LITE_CURSOR_MATCH_GE);
 
 SV*
 open(klass, filename, mode=UNQLITE_OPEN_CREATE)
@@ -75,10 +92,29 @@ PREINIT:
     int rc;
 CODE:
     rc = unqlite_open(&pdb, filename, mode);
-    SETRC(rc);
     if (rc == UNQLITE_OK) {
         XS_STRUCT2OBJ(sv, klass, pdb);
+        SETRC(rc, sv);
         RETVAL = sv;
+    } else {
+        SETRC(rc, &PL_sv_undef);
+        RETVAL = &PL_sv_undef;
+    }
+OUTPUT:
+    RETVAL
+
+SV* _rc(self)
+    SV *self
+PREINIT:
+    MAGIC *mg;
+CODE:
+    if (SvROK(self)) {
+        mg = mg_find(SvRV(self), PERL_MAGIC_ext);
+        if (mg) {
+            RETVAL = newSVsv(mg->mg_obj);
+        } else {
+            RETVAL = &PL_sv_undef;
+        }
     } else {
         RETVAL = &PL_sv_undef;
     }
@@ -101,7 +137,7 @@ CODE:
     key_c = SvPV(key_sv, key_l);
     data_c = SvPV(data_sv, data_l);
     rc = unqlite_kv_store(pdb, key_c, key_l, data_c, data_l);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc==UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -126,7 +162,7 @@ CODE:
     key_c = SvPV(key_sv, key_l);
     data_c = SvPV(data_sv, data_l);
     rc = unqlite_kv_append(pdb, key_c, key_l, data_c, data_l);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc==UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -147,7 +183,7 @@ CODE:
     unqlite *pdb = XS_STATE(unqlite*, self);
     key_c = SvPV(key_sv, key_l);
     rc = unqlite_kv_delete(pdb, key_c, key_l);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc==UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -173,14 +209,14 @@ CODE:
 
     /* Allocate a buffer big enough to hold the record content */
     rc = unqlite_kv_fetch(pdb, key_c, key_l, NULL, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc!=UNQLITE_OK) {
         RETVAL = &PL_sv_undef;
         goto last;
     }
     Newxz(buf, nbytes, char);
     rc = unqlite_kv_fetch(pdb, key_c, key_l, buf, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     sv = newSVpv(buf, nbytes);
     Safefree(buf);
     RETVAL = sv;
@@ -196,7 +232,7 @@ PREINIT:
 CODE:
     unqlite *pdb = XS_STATE(unqlite*, self);
     rc = unqlite_close(pdb);
-    SETRC(rc);
+    SETRC(rc, &PL_sv_undef);
 
 SV*
 _cursor_init(self)
@@ -208,9 +244,10 @@ PREINIT:
 CODE:
     unqlite *pdb = XS_STATE(unqlite*, self);
     rc = unqlite_kv_cursor_init(pdb, &cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         sv = newSViv(PTR2IV(cursor));
+        sv_magic(sv, sv_2mortal(newSViv(UNQLITE_OK)), PERL_MAGIC_ext, NULL, 0);
         sv = newRV_noinc(sv);
         SvREADONLY_on(sv);
         RETVAL = sv;
@@ -223,6 +260,24 @@ OUTPUT:
 
 MODULE = UnQLite    PACKAGE = UnQLite::Cursor
 
+SV* _rc(self)
+    SV *self
+PREINIT:
+    MAGIC *mg;
+CODE:
+    if (SvROK(self)) {
+        mg = mg_find(SvRV(self), PERL_MAGIC_ext);
+        if (mg) {
+            RETVAL = newSVsv(mg->mg_obj);
+        } else {
+            RETVAL = &PL_sv_undef;
+        }
+    } else {
+        RETVAL = &PL_sv_undef;
+    }
+OUTPUT:
+    RETVAL
+
 SV*
 _first_entry(self)
     SV * self;
@@ -232,7 +287,7 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_first_entry(cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -264,7 +319,7 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_next_entry(cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -282,7 +337,7 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_last_entry(cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -300,7 +355,7 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_prev_entry(cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -320,14 +375,14 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_key(cursor, NULL, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc!=UNQLITE_OK) {
         RETVAL = &PL_sv_undef;
         goto last;
     }
     Newxz(buf, nbytes, char);
     rc = unqlite_kv_cursor_key(cursor, buf, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     sv = newSVpv(buf, nbytes);
     Safefree(buf);
     RETVAL = sv;
@@ -346,14 +401,14 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_data(cursor, NULL, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc!=UNQLITE_OK) {
         RETVAL = &PL_sv_undef;
         goto last;
     }
     Newxz(buf, nbytes, char);
     rc = unqlite_kv_cursor_data(cursor, buf, &nbytes);
-    SETRC(rc);
+    SETRC(rc, self);
     sv = newSVpv(buf, nbytes);
     Safefree(buf);
     RETVAL = sv;
@@ -383,7 +438,7 @@ CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     key = SvPV(key_s, len);
     rc = unqlite_kv_cursor_seek(cursor, key, len, opt);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {
@@ -400,7 +455,7 @@ PREINIT:
 CODE:
     unqlite_kv_cursor *cursor = XS_STATE(unqlite_kv_cursor*, self);
     rc = unqlite_kv_cursor_delete_entry(cursor);
-    SETRC(rc);
+    SETRC(rc, self);
     if (rc == UNQLITE_OK) {
         RETVAL = &PL_sv_yes;
     } else {

t/03_tie.t

@@ -0,0 +1,46 @@
+use strict;
+use Test::More;
+
+use File::Temp qw(tempdir);
+use UnQLite;
+
+my $tmp = tempdir( CLEANUP => 1 );
+
+{
+    my $db = UnQLite->open("$tmp/foo.db");
+    isa_ok($db, 'UnQLite');
+
+    ok($db->kv_store("foo", "bar"));
+    is($db->kv_fetch('foo'), 'bar');
+    ok($db->kv_delete('foo'));
+    is($db->kv_fetch('foo'), undef);
+    $db->kv_store('yay', 'yap');
+    $db->kv_append('yay', 'po');
+    is($db->kv_fetch('yay'), 'yappo');
+    is($db->rc,0);
+}
+
+{
+    ok -e "$tmp/foo.db", "foo.db exists";
+    tie my %hash, 'UnQLite', "$tmp/foo.db";
+
+    # stored data can be retrieved again?
+    is($hash{yay}, 'yappo');
+    $hash{foo} = 'baz';
+    is($hash{foo}, 'baz');
+    $hash{delete} = 'delete';
+    is(delete $hash{delete}, 'delete');
+    is(delete $hash{delete}, undef);
+    ok(exists $hash{foo});
+    ok(!exists $hash{delete});
+
+    is(join(" ", sort keys %hash), "foo yay");
+    is(join(" ", sort values %hash), "baz yappo");
+    is(scalar %hash, 2);
+    %hash = ();
+    is(join(" ", sort keys %hash), "");
+    is(join(" ", sort values %hash), "");
+    is(scalar %hash, undef);
+}
+
+done_testing;

unqlite/license.txt

@@ -1,5 +1,4 @@
-/*
+ * Copyright (C) 2012, 2013, 2014, 2015, 2016, 2017, 2018, 2019 Symisc Systems, S.U.A.R.L [M.I.A.G Mrad Chems Eddine <chm@symisc.net>].
- * Copyright (C) 2012, 2013 Symisc Systems, S.U.A.R.L [M.I.A.G Mrad Chems Eddine <chm@symisc.net>].
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -22,4 +21,3 @@
  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE
  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
  * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
- */

unqlite/unqlite.h

@@ -1,10 +1,14 @@
 /* This file was automatically generated.  Do not edit (Except for compile time directives)! */ 
 #ifndef _UNQLITE_H_
 #define _UNQLITE_H_
+/* Make sure we can call this stuff from C++ */
+#ifdef __cplusplus
+ extern "C" {
+#endif 
 /*
  * Symisc UnQLite: An Embeddable NoSQL (Post Modern) Database Engine.
- * Copyright (C) 2012-2013, Symisc Systems http://unqlite.org/
+ * Copyright (C) 2012-2019, Symisc Systems http://unqlite.org/
- * Version 1.1.6
+ * Version 1.1.9
  * For information on licensing, redistribution of this file, and for a DISCLAIMER OF ALL WARRANTIES
  * please contact Symisc Systems via:
  *       legal@symisc.net
@@ -14,7 +18,7 @@
  *      http://unqlite.org/licensing.html
  */
 /*
- * Copyright (C) 2012, 2013 Symisc Systems, S.U.A.R.L [M.I.A.G Mrad Chems Eddine <chm@symisc.net>].
+ * Copyright (C) 2012, 2019 Symisc Systems, S.U.A.R.L [M.I.A.G Mrad Chems Eddine <chm@symisc.net>].
  * All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
@@ -38,7 +42,7 @@
  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
  * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  */
- /* $SymiscID: unqlite.h v1.1 UNIX|WIN32/64 2012-11-02 02:10 stable <chm@symisc.net> $ */
+ /* $SymiscID: unqlite.h v1.3 Win10 2108-04-27 02:35:11 stable <chm@symisc.net>  $ */
 #include <stdarg.h> /* needed for the definition of va_list */
 /*
  * Compile time engine version, signature, identification in the symisc source tree
@@ -49,18 +53,18 @@
  * [unqlite_lib_copyright()] for more information.
  */
 /*
- * The UNQLITE_VERSION C preprocessor macroevaluates to a string literal
+ * The UNQLITE_VERSION C preprocessor macro evaluates to a string literal
  * that is the unqlite version in the format "X.Y.Z" where X is the major
  * version number and Y is the minor version number and Z is the release
  * number.
  */
-#define UNQLITE_VERSION "1.1.6"
+#define UNQLITE_VERSION "1.1.9"
 /*
  * The UNQLITE_VERSION_NUMBER C preprocessor macro resolves to an integer
  * with the value (X*1000000 + Y*1000 + Z) where X, Y, and Z are the same
  * numbers used in [UNQLITE_VERSION].
  */
-#define UNQLITE_VERSION_NUMBER 1001006
+#define UNQLITE_VERSION_NUMBER 1001009
 /*
  * The UNQLITE_SIG C preprocessor macro evaluates to a string
  * literal which is the public signature of the unqlite engine.
@@ -68,14 +72,14 @@
  * generated Server MIME header as follows:
  *   Server: YourWebServer/x.x unqlite/x.x.x \r\n
  */
-#define UNQLITE_SIG "unqlite/1.1.6"
+#define UNQLITE_SIG "unqlite/1.1.9"
 /*
  * UnQLite identification in the Symisc source tree:
  * Each particular check-in of a particular software released
  * by symisc systems have an unique identifier associated with it.
  * This macro hold the one associated with unqlite.
  */
-#define UNQLITE_IDENT "unqlite:b172a1e2c3f62fb35c8e1fb2795121f82356cad6"
+#define UNQLITE_IDENT "unqlite:29c173b1-ac2c-4b49-93ba-e600619e304e"
 /*
  * Copyright notice.
  * If you have any questions about the licensing situation, please
@@ -85,7 +89,7 @@
  *   licensing@symisc.net
  *   contact@symisc.net
  */
-#define UNQLITE_COPYRIGHT "Copyright (C) Symisc Systems, S.U.A.R.L [Mrad Chems Eddine <chm@symisc.net>] 2012-2013, http://unqlite.org/"
+#define UNQLITE_COPYRIGHT "Copyright (C) Symisc Systems, S.U.A.R.L [Mrad Chems Eddine <chm@symisc.net>] 2012-2019, http://unqlite.org/"
 
 /* Forward declaration to public objects */
 typedef struct unqlite_io_methods unqlite_io_methods;
@@ -399,7 +403,7 @@ typedef sxi64 unqlite_int64;
  * Each options require a variable number of arguments.
  * The [unqlite_vm_config()] interface will return UNQLITE_OK on success, any other return
  * value indicates failure.
- * There are many options but the most importants are: UNQLITE_VM_CONFIG_OUTPUT which install
+ * There are many options but the most important are: UNQLITE_VM_CONFIG_OUTPUT which install
  * a VM output consumer callback, UNQLITE_VM_CONFIG_HTTP_REQUEST which parse and register
  * a HTTP request and UNQLITE_VM_CONFIG_ARGV_ENTRY which populate the $argv array.
  * For a full discussion on the configuration verbs and their expected parameters, please
@@ -651,14 +655,14 @@ struct unqlite_vfs {
 typedef sxu64 pgno;
 /*
  * A database disk page is represented by an instance
- * of the follwoing structure.
+ * of the following structure.
  */
 typedef struct unqlite_page unqlite_page;
 struct unqlite_page
 {
   unsigned char *zData;       /* Content of this page */
   void *pUserData;            /* Extra content */
-  pgno pgno;                  /* Page number for this page */
+  pgno iPage;                 /* Page number for this page */
 };
 /*
  * UnQLite handle to the underlying Key/Value Storage Engine (See below).
@@ -783,9 +787,9 @@ struct unqlite_kv_methods
 #define UNQLITE_JOURNAL_FILE_SUFFIX "_unqlite_journal"
 #endif
 /*
- * Call Context - Error Message Serverity Level.
+ * Call Context - Error Message Severity Level.
  *
- * The following constans are the allowed severity level that can
+ * The following constants are the allowed severity level that can
  * passed as the second argument to the [unqlite_context_throw_error()] or
  * [unqlite_context_throw_error_format()] interfaces.
  * Refer to the official documentation for additional information.
@@ -803,6 +807,7 @@ UNQLITE_APIEXPORT int unqlite_open(unqlite **ppDB,const char *zFilename,unsigned
 UNQLITE_APIEXPORT int unqlite_config(unqlite *pDb,int nOp,...);
 UNQLITE_APIEXPORT int unqlite_close(unqlite *pDb);
 
+
 /* Key/Value (KV) Store Interfaces */
 UNQLITE_APIEXPORT int unqlite_kv_store(unqlite *pDb,const void *pKey,int nKeyLen,const void *pData,unqlite_int64 nDataLen);
 UNQLITE_APIEXPORT int unqlite_kv_append(unqlite *pDb,const void *pKey,int nKeyLen,const void *pData,unqlite_int64 nDataLen);
@@ -945,5 +950,7 @@ UNQLITE_APIEXPORT const char * unqlite_lib_version(void);
 UNQLITE_APIEXPORT const char * unqlite_lib_signature(void);
 UNQLITE_APIEXPORT const char * unqlite_lib_ident(void);
 UNQLITE_APIEXPORT const char * unqlite_lib_copyright(void);
-
+#ifdef __cplusplus
+ }
+#endif
 #endif /* _UNQLITE_H_ */