summaryrefslogtreecommitdiff
path: root/appl/cmd/dbm
diff options
context:
space:
mode:
Diffstat (limited to 'appl/cmd/dbm')
-rwxr-xr-xappl/cmd/dbm/delete.b34
-rwxr-xr-xappl/cmd/dbm/fetch.b37
-rwxr-xr-xappl/cmd/dbm/keys.b32
-rwxr-xr-xappl/cmd/dbm/list.b34
-rw-r--r--appl/cmd/dbm/mkfile19
-rwxr-xr-xappl/cmd/dbm/store.b69
6 files changed, 225 insertions, 0 deletions
diff --git a/appl/cmd/dbm/delete.b b/appl/cmd/dbm/delete.b
new file mode 100755
index 00000000..dcdde8c0
--- /dev/null
+++ b/appl/cmd/dbm/delete.b
@@ -0,0 +1,34 @@
+implement Dbmdelete;
+
+include "sys.m";
+ sys: Sys;
+
+include "draw.m";
+
+include "dbm.m";
+ dbm: Dbm;
+ Datum, Dbf: import dbm;
+
+Dbmdelete: module
+{
+ init: fn(nil: ref Draw->Context, args: list of string);
+};
+
+init(nil: ref Draw->Context, args: list of string)
+{
+ sys = load Sys Sys->PATH;
+ dbm = load Dbm Dbm->PATH;
+
+ dbm->init();
+
+ args = tl args;
+ db := Dbf.open(hd args, Sys->ORDWR);
+ if(db == nil){
+ sys->fprint(sys->fildes(2), "dbm/delete: %s: %r\n", hd args);
+ raise "fail:open";
+ }
+ args = tl args;
+ key := hd args;
+ if(db.delete(array of byte key) < 0)
+ sys->fprint(sys->fildes(2), "not found\n");
+}
diff --git a/appl/cmd/dbm/fetch.b b/appl/cmd/dbm/fetch.b
new file mode 100755
index 00000000..3ebbc7d6
--- /dev/null
+++ b/appl/cmd/dbm/fetch.b
@@ -0,0 +1,37 @@
+implement Dbmfetch;
+
+include "sys.m";
+ sys: Sys;
+
+include "draw.m";
+
+include "dbm.m";
+ dbm: Dbm;
+ Datum, Dbf: import dbm;
+
+Dbmfetch: module
+{
+ init: fn(nil: ref Draw->Context, args: list of string);
+};
+
+init(nil: ref Draw->Context, args: list of string)
+{
+ sys = load Sys Sys->PATH;
+ dbm = load Dbm Dbm->PATH;
+
+ dbm->init();
+
+ args = tl args;
+ db := Dbf.open(hd args, Sys->OREAD);
+ if(db == nil){
+ sys->fprint(sys->fildes(2), "dbm/fetch: %s: %r\n", hd args);
+ raise "fail:open";
+ }
+ args = tl args;
+ key := hd args;
+ data := db.fetch(array of byte key);
+ if(data == nil)
+ sys->fprint(sys->fildes(2), "not found\n");
+ else
+ sys->write(sys->fildes(1), data, len data);
+}
diff --git a/appl/cmd/dbm/keys.b b/appl/cmd/dbm/keys.b
new file mode 100755
index 00000000..750d734c
--- /dev/null
+++ b/appl/cmd/dbm/keys.b
@@ -0,0 +1,32 @@
+implement Dbmkeys;
+
+include "sys.m";
+ sys: Sys;
+
+include "draw.m";
+
+include "dbm.m";
+ dbm: Dbm;
+ Datum, Dbf: import dbm;
+
+Dbmkeys: module
+{
+ init: fn(nil: ref Draw->Context, args: list of string);
+};
+
+init(nil: ref Draw->Context, args: list of string)
+{
+ sys = load Sys Sys->PATH;
+ dbm = load Dbm Dbm->PATH;
+
+ dbm->init();
+
+ args = tl args;
+ db := Dbf.open(hd args, Sys->OREAD);
+ if(db == nil){
+ sys->fprint(sys->fildes(2), "dbm/keys: %s: %r\n", hd args);
+ raise "fail:open";
+ }
+ for(key := db.firstkey(); key != nil; key = db.nextkey(key))
+ sys->print("%s\n", string key);
+}
diff --git a/appl/cmd/dbm/list.b b/appl/cmd/dbm/list.b
new file mode 100755
index 00000000..6c0e71f5
--- /dev/null
+++ b/appl/cmd/dbm/list.b
@@ -0,0 +1,34 @@
+implement Dbmlist;
+
+include "sys.m";
+ sys: Sys;
+
+include "draw.m";
+
+include "dbm.m";
+ dbm: Dbm;
+ Datum, Dbf: import dbm;
+
+Dbmlist: module
+{
+ init: fn(nil: ref Draw->Context, args: list of string);
+};
+
+init(nil: ref Draw->Context, args: list of string)
+{
+ sys = load Sys Sys->PATH;
+ dbm = load Dbm Dbm->PATH;
+
+ dbm->init();
+
+ args = tl args;
+ db := Dbf.open(hd args, Sys->OREAD);
+ if(db == nil){
+ sys->fprint(sys->fildes(2), "dbm/list: %s: %r\n", hd args);
+ raise "fail:open";
+ }
+ for(key := db.firstkey(); key != nil; key = db.nextkey(key)){
+ d := db.fetch(key);
+ sys->print("%s %s\n", string key, string d);
+ }
+}
diff --git a/appl/cmd/dbm/mkfile b/appl/cmd/dbm/mkfile
new file mode 100644
index 00000000..7ab434c9
--- /dev/null
+++ b/appl/cmd/dbm/mkfile
@@ -0,0 +1,19 @@
+<../../../mkconfig
+
+TARG=\
+ fetch.dis\
+ delete.dis\
+ keys.dis\
+ list.dis\
+ store.dis\
+
+SYSMODULES=\
+ arg.m\
+ sys.m\
+ draw.m\
+ bufio.m\
+ dbm.m\
+
+DISBIN=$ROOT/dis/dbm
+
+<$ROOT/mkfiles/mkdis
diff --git a/appl/cmd/dbm/store.b b/appl/cmd/dbm/store.b
new file mode 100755
index 00000000..0587c4b7
--- /dev/null
+++ b/appl/cmd/dbm/store.b
@@ -0,0 +1,69 @@
+implement Dbmstore;
+
+include "sys.m";
+ sys: Sys;
+
+include "draw.m";
+
+include "bufio.m";
+ bufio: Bufio;
+ Iobuf: import bufio;
+
+include "dbm.m";
+ dbm: Dbm;
+ Datum, Dbf: import dbm;
+
+Dbmstore: module
+{
+ init: fn(nil: ref Draw->Context, args: list of string);
+};
+
+init(nil: ref Draw->Context, args: list of string)
+{
+ sys = load Sys Sys->PATH;
+ dbm = load Dbm Dbm->PATH;
+ bufio = load Bufio Bufio->PATH;
+
+ dbm->init();
+
+ args = tl args;
+ db := Dbf.open(hd args, Sys->ORDWR);
+ if(db == nil){
+ sys->fprint(sys->fildes(2), "dbm/store: %s: %r\n", hd args);
+ raise "fail:open";
+ }
+ args = tl args;
+ if(args == nil){
+ err := 0;
+ f := bufio->fopen(sys->fildes(0), Bufio->OREAD);
+ while((s := f.gets('\n')) != nil){
+ s = s[0:len s-1];
+ key: string;
+ for(i :=0; i < len s; i++)
+ if(s[i] == ' ' || s[i] == '\t'){
+ key = s[0:i];
+ s = s[i+1:];
+ break;
+ }
+ if(key == nil){
+ sys->fprint(sys->fildes(2), "dbm/store: bad input\n");
+ raise "fail:error";
+ }
+ if(store(db, key, s))
+ err = 1;
+ }
+ if(err)
+ raise "fail:store";
+ }else if(store(db, hd args, hd tl args))
+ raise "fail:store";
+}
+
+store(db: ref Dbf, key: string, dat: string): int
+{
+ r := db.store(array of byte key, array of byte dat, 0);
+ if(r < 0)
+ sys->fprint(sys->fildes(2), "bad store\n");
+ else if(r)
+ sys->fprint(sys->fildes(2), "%q exists\n", key);
+ return r;
+}