cirno/plan9port
1
0
Fork 0
mirror of https://github.com/9fans/plan9port.git synced 2025-01-12 11:10:07 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

ndbquery: compatibility with ndb/query

Browse source 
Added the -m and -a flags to ndbquery as in Plan 9's ndb/query.
This commit is contained in:
gornorn 2024-08-06 14:36:25 +02:00 committed by GitHub
parent a2567fcac9
commit 89137059ed
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 84 additions and 53 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

137
src/cmd/ndb/ndbquery.c
View file

@ -3,79 +3,110 @@
#include <bio.h>
#include <ndb.h>
static int all, multiple;
/*
* search the database for matches
*/
void
usage(void)
{
fprint(2, "usage: query attr value [returned attribute]\n");
exits("usage");
fprint(2, "usage: ndbquery [-am] [-f ndbfile] attr value [returned attribute]\n");
exits("usage");
}
static void
prmatch(Ndbtuple *nt, char *rattr)
{
for(; nt; nt = nt->entry)
if(strcmp(nt->attr, rattr) == 0)
print("%s\n", nt->val);
}
void
search(Ndb *db, char *attr, char *val, char *rattr)
{
Ndbs s;
Ndbtuple *t;
Ndbtuple *nt;
char *p;
Ndbs s;
Ndbtuple *t;
Ndbtuple *nt;
char *p;
if(rattr){
p = ndbgetvalue(db, &s, attr, val, rattr, nil);
if(p){
print("%s\n", p);
free(p);
}
return;
}
if(rattr && !all){
p = ndbgetvalue(db, &s, attr, val, rattr, &t);
if(multiple)
prmatch(t, rattr);
else if(p){
print("%s\n", p);
}
ndbfree(t);
free(p);
return;
}
t = ndbsearch(db, &s, attr, val);
while(t){
for(nt = t; nt; nt = nt->entry)
print("%s=%s ", nt->attr, nt->val);
print("\n");
ndbfree(t);
t = ndbsnext(&s, attr, val);
}
/* all entries with matching rattrs */
if(rattr){
t = ndbsearch(db, &s, attr, val);
while(t != nil){
prmatch(t, rattr);
ndbfree(t);
t = ndbsnext(&s, attr, val);
}
return;
}
/* all entries */
t = ndbsearch(db, &s, attr, val);
while(t){
for(nt = t; nt; nt = nt->entry)
print("%s=%s ", nt->attr, nt->val);
print("\n");
ndbfree(t);
t = ndbsnext(&s, attr, val);
}
}
void
main(int argc, char **argv)
{
char *rattr = 0;
Ndb *db;
char *dbfile = 0;
int reps = 1;
char *rattr = 0;
Ndb *db;
char *dbfile = 0;
int reps = 1;
ARGBEGIN{
case 'f':
dbfile = ARGF();
break;
}ARGEND;
ARGBEGIN{
case 'a':
all++;
break;
case 'm':
multiple++;
break;
case 'f':
dbfile = ARGF();
break;
}ARGEND;
switch(argc){
case 4:
reps = atoi(argv[3]);
/* fall through */
case 3:
rattr = argv[2];
break;
case 2:
rattr = 0;
break;
default:
usage();
}
switch(argc){
case 4:
reps = atoi(argv[3]);
/* fall through */
case 3:
rattr = argv[2];
break;
case 2:
rattr = 0;
break;
default:
usage();
}
db = ndbopen(dbfile);
if(db == 0){
fprint(2, "no db files\n");
exits("no db");
}
while(reps--)
search(db, argv[0], argv[1], rattr);
ndbclose(db);
db = ndbopen(dbfile);
if(db == 0){
fprint(2, "no db files\n");
exits("no db");
}
while(reps--)
search(db, argv[0], argv[1], rattr);
ndbclose(db);
exits(0);
exits(0);
}