6 * Copyright (C) 1987, 1988 by the Massachusetts Institute of Technology
11 static char *rcsid_qrtn_qc = "$Header$";
15 #include "sms_server.h"
19 static int ingres_errno = 0;
23 #define INGRES_BAD_INT 4111
24 #define INGRES_BAD_DATE 4302
25 #define INGRES_DEADLOCK 4700
28 * ingerr: (supposedly) called when Ingres indicates an error.
29 * I have not yet been able to get this to work to intercept a
30 * database open error.
33 static int ingerr(num)
40 ingres_errno = SMS_INTEGER;
43 ingres_errno = SMS_DATE;
46 ingres_errno = SMS_DEADLOCK;
49 ingres_errno = SMS_INGRES_ERR;
50 com_err(whoami, SMS_INGRES_ERR, " code %d\n", *num);
51 sprintf(buf, "Ingres error %d", *num);
52 send_zgram("ingres_error", buf);
58 int sms_open_database()
63 /* initialize local argv */
64 for (i = 0; i < 16; i++)
65 Argv[i] = malloc(ARGLEN);
71 /* open the database */
76 int sms_close_database()
81 sms_check_access(cl, name, argc, argv_ro)
88 struct query *get_query_by_name();
90 q = get_query_by_name(name, cl->args->sms_version_no);
91 if (q == (struct query *)0)
92 return(SMS_NO_HANDLE);
94 return(sms_verify_query(cl, q, argc, argv_ro));
97 sms_process_query(cl, name, argc, argv_ro, action, actarg)
105 register struct query *q;
107 register struct validate *v;
113 struct save_queue *sq;
114 struct query *get_query_by_name();
116 struct save_queue *sq_create();
119 /* list queries command */
120 if (!strcmp(name, "_list_queries")) {
121 list_queries(cl->args->sms_version_no, action, actarg);
125 /* help query command */
126 if (!strcmp(name, "_help")) {
129 q = get_query_by_name(argv_ro[0], cl->args->sms_version_no);
130 if (q == (struct query *)0) return(SMS_NO_HANDLE);
131 help_query(q, action, actarg);
135 /* get query structure, return error if named query does not exist */
136 q = get_query_by_name(name, cl->args->sms_version_no);
137 if (q == (struct query *)0) return(SMS_NO_HANDLE);
140 if (q->type != RETRIEVE)
143 /* setup argument vector, verify access and arguments */
144 if ((status = sms_verify_query(cl, q, argc, argv_ro)) != SMS_SUCCESS)
147 /* perform any special query pre-processing */
148 if (v && v->pre_rtn) {
149 status = (*v->pre_rtn)(q, Argv, cl, 0);
150 if (status != SMS_SUCCESS)
156 /* for queries that do not permit wildcarding, check if row
159 status = validate_row(q, Argv, v);
160 if (status != SMS_EXISTS) break;
163 /* build "where" clause if needed */
165 build_qual(q->qual, q->argc, Argv, qual);
171 /* build "sort" clause if needed */
172 if (v && v->valobj) {
173 psort = build_sort(v, sort);
178 /* if there is a followup routine, then we must save the results */
179 /* of the first query for use by the followup routine */
180 /* if q->rvar = NULL, perform post_rtn only */
182 if (v && v->post_rtn) {
184 status = do_retrieve(q, pqual, psort, sq_save_args, sq);
185 if (status != SMS_SUCCESS) {
189 status = (*v->post_rtn)(q, sq, v, action, actarg, cl);
191 /* normal retrieve */
192 status = do_retrieve(q, pqual, psort, action, actarg);
194 if (status != SMS_SUCCESS) break;
196 ## repeat replace tblstats (retrieves = tblstats.retrieves + 1)
197 ## where tblstats.#table = @table
199 status = (*v->post_rtn)(q, Argv, cl, action, actarg);
205 /* see if row already exists */
207 status = validate_row(q, Argv, v);
208 if (status != SMS_EXISTS) break;
211 /* build "where" clause and perform update */
212 /* if q->rvar = NULL, perform post_rtn only */
214 build_qual(q->qual, q->argc, Argv, qual);
215 status = do_update(q, &Argv[q->argc], qual, action, actarg);
216 if (status != SMS_SUCCESS) break;
218 if (strcmp(q->shortname, "sshi") && strcmp(q->shortname, "ssif")) {
219 ## repeat replace tblstats (updates = tblstats.updates + 1,
221 ## where tblstats.#table = @table
225 /* execute followup routine (if any) */
226 if (v->post_rtn) status = (*v->post_rtn)(q, Argv, cl);
231 /* see if row already exists */
233 status = validate_row(q, Argv, v);
234 if (status != SMS_NO_MATCH) break;
237 /* increment id number if necessary */
239 status = set_next_object_id(v->object_id, q->rtable);
240 if (status != SMS_SUCCESS) break;
243 /* build "where" clause if needed */
245 build_qual(q->qual, q->argc, Argv, qual);
251 /* perform the append */
252 /* if q->rvar = NULL, perform post_rtn only */
254 status = do_append(q, &Argv[q->argc], pqual, action, actarg);
255 if (status != SMS_SUCCESS) break;
257 ## repeat replace tblstats (appends = tblstats.appends + 1,
259 ## where tblstats.#table = @table
262 /* execute followup routine */
263 if (v->post_rtn) status = (*v->post_rtn)(q, Argv, cl);
267 /* see if row already exists */
269 status = validate_row(q, Argv, v);
270 if (status != SMS_EXISTS) break;
273 /* build "where" clause and perform delete */
274 /* if q->rvar = NULL, perform post_rtn only */
276 build_qual(q->qual, q->argc, Argv, qual);
277 status = do_delete(q, qual, action, actarg);
278 if (status != SMS_SUCCESS) break;
280 ## repeat replace tblstats (deletes = tblstats.deletes + 1,
282 ## where tblstats.#table = @table
285 /* execute followup routine */
286 if (v->post_rtn) status = (*v->post_rtn)(q, Argv, cl);
292 if (q->type != RETRIEVE) {
293 if (status == SMS_SUCCESS) {
294 ## end transaction /* commit to this */
300 fprintf(journal, "%% %s %s %s",
301 cl->clname, cl->entity, ctime(&now));
302 fprintf(journal, "%s[%d] ", q->name, cl->args->sms_version_no);
303 for (i = 0; i < argc; i++) {
307 requote(buf, argv_ro[i], sizeof(buf));
314 ## abort /* it never happened */
318 if (status != SMS_SUCCESS && log_flags & LOG_RES)
319 com_err(whoami, status, " (Query failed)");
323 build_qual(fmt, argc, argv, qual)
335 for (i = 0; i < argc; i++) {
337 if (c++ == (char *)0) return(SMS_ARGS);
341 *(int *)&args[i] = *(int *)argv[i]; /* sigh */
343 return(SMS_INGRES_ERR);
352 sprintf(qual, fmt, args[0]);
356 sprintf(qual, fmt, args[0], args[1]);
360 sprintf(qual, fmt, args[0], args[1], args[2]);
364 sprintf(qual, fmt, args[0], args[1], args[2], args[3]);
372 register struct validate *v;
375 register struct valobj *vo;
384 if (vo->type == V_SORT) {
385 sprintf(elem, "RET_VAR%d", vo->index + 1);
386 if (*sort) strcat(sort, ", ");
392 return ((*sort) ? sort : 0);
396 /* Build arguement vector, verify query and arguments */
398 sms_verify_query(cl, q, argc, argv_ro)
406 register struct validate *v = q->validate;
408 register int privileged = 0;
410 /* copy the arguments into a local argv that we can modify */
411 for (i = 0; i < argc; i++) {
412 if (strlen(argv_ro[i]) < ARGLEN)
413 strcpy(Argv[i], argv_ro[i]);
415 return(SMS_ARG_TOO_LONG);
418 /* check initial query access */
419 status = check_query_access(q, Argv, cl);
420 if (status != SMS_SUCCESS && status != SMS_PERM)
422 if (status == SMS_SUCCESS)
425 /* check argument count */
427 if (q->type == UPDATE || q->type == APPEND) argreq += q->vcnt;
428 if (argc != argreq) return(SMS_ARGS);
430 /* validate arguments */
431 if (v && v->valobj) {
432 status = validate_fields(q, Argv, v->valobj, v->objcnt);
433 if (status != SMS_SUCCESS) return(status);
436 /* perform special query access check */
437 if (!privileged && v && v->acs_rtn) {
438 status = (*v->acs_rtn)(q, Argv, cl);
439 if (status != SMS_SUCCESS && status != SMS_PERM)
441 if (status == SMS_SUCCESS)
445 return(privileged ? SMS_SUCCESS : SMS_PERM);
448 check_query_access(q, argv, cl)
458 ## static int def_uid;
463 /* get query access control list */
465 ## repeat retrieve (acl_id = capacls.list_id) where capacls.tag = @name
466 ## inquire_equel (rowcount = "rowcount", errorno = "errorno")
467 if (errorno != 0) return(SMS_INGRES_ERR);
468 if (rowcount == 0) return(SMS_PERM);
470 /* initialize default uid */
472 ## retrieve (def_uid = users.users_id) where users.login = "default"
475 /* check for default access */
476 ## range of m is members
477 ## repeat retrieve (exists = any(m.#member_id where m.list_id = @acl_id and
478 ## m.member_type = "USER" and m.#member_id = def_uid))
479 if (exists) return(SMS_SUCCESS);
481 /* parse client name */
482 status = get_client(cl, &client_type, &client_id);
483 if (status != SMS_SUCCESS) return(status);
485 /* see if client is in the list (or any of its sub-lists) */
486 exists = find_member("LIST", acl_id, client_type, client_id, 0);
487 return ((exists) ? SMS_SUCCESS : SMS_PERM);
490 get_client(cl, client_type, client_id)
500 if (cl->clname == NULL)
503 /* for now ignore instances */
506 /* if client is from local realm, get users_id */
507 if (!strcmp(krb->realm, krb_realm)) {
508 *client_id = cl->users_id;
509 *client_type = "USER";
513 /* otherwise use string_id */
515 ## repeat retrieve (member_id = strings.string_id)
516 ## where strings.string = @name
518 /* make sure we found a users or string id */
519 ## inquire_equel (rowcount = "rowcount")
520 if (rowcount == 0) return(SMS_PERM);
522 *client_type = "STRING";
523 *client_id = member_id;
527 ##find_member(list_type, list_id, member_type, member_id, sq)
530 ## char *member_type;
532 struct save_queue *sq;
537 struct save_queue *sq_create();
539 /* see if client is a direct member of list */
540 ## repeat retrieve (exists = any(m.#member_id where
541 ## m.#list_id = @list_id and
542 ## m.#member_type = @member_type and
543 ## m.#member_id = @member_id))
544 if (exists) return(1);
546 /* are there any sub-lists? */
547 ## repeat retrieve (exists = any(m.#member_id where m.#list_id = @list_id and
548 ## m.#member_type = "LIST"))
549 if (!exists) return(0);
551 /* yes; now recurse through sublists */
553 /* create a save queue */
554 if (sq == (struct save_queue *)0) {
561 /* save all sublist ids */
562 ## range of m is members
563 ## retrieve (sublist = m.#member_id)
564 ## where m.#list_id = list_id and m.#member_type = "LIST"
566 sq_save_unique_data(sq, sublist);
569 if (child) return(0);
571 /* at top-level, check sub-lists for client (breadth-first search) */
572 while (sq_get_data(sq, &sublist)) {
573 exists = find_member(list_type, sublist, member_type, member_id, sq);
584 do_retrieve(q, pqual, psort, action, actarg)
585 register struct query *q;
597 static char **vaddrs = (char **)NULL;
602 if ((vaddrs = (char **)malloc(sizeof(char *) * QMAXARGS)) == NULL) {
603 com_err(whoami, SMS_NO_MEM, "setting up static argv");
606 for (i = 0; i < QMAXARGS; i++) {
607 if ((vaddrs[i] = malloc(QMAXARGSIZE)) == NULL) {
608 com_err(whoami, SMS_NO_MEM, "setting up static argv");
617 ## range of rvar is rtable
624 ## retrieve unique (param (q->tlist, vaddrs)) where cqual
627 (*action)(q->vcnt, vaddrs, actarg);
630 ## retrieve unique (param (q->tlist, vaddrs))
633 (*action)(q->vcnt, vaddrs, actarg);
640 ## retrieve unique (param (q->tlist, vaddrs)) where cqual
642 (*action)(q->vcnt, vaddrs, actarg);
645 ## retrieve unique (param (q->tlist, vaddrs))
647 (*action)(q->vcnt, vaddrs, actarg);
652 ## inquire_equel (rowcount = "rowcount", errorno = "errorno")
653 if (errorno != 0) return(SMS_INGRES_ERR);
654 return ((rowcount == 0) ? SMS_NO_MATCH : SMS_SUCCESS);
657 do_update(q, argv, qual, action, actarg)
658 register struct query *q;
671 ## range of rvar is rtable
674 ## replace rvar (param (q->tlist, argv))
677 ## inquire_equel (errorno = "errorno")
678 if (errorno == INGRES_BAD_INT)
680 else if (errorno != 0)
681 return(SMS_INGRES_ERR);
685 do_append(q, argv, pqual, action, actarg)
686 register struct query *q;
699 ## range of rvar is rtable
703 ## append to rtable (param (q->tlist, argv)) where cqual
705 ## append to rtable (param (q->tlist, argv))
708 ## inquire_equel (errorno = "errorno")
709 if (errorno == INGRES_BAD_INT)
711 else if (errorno != 0)
712 return(SMS_INGRES_ERR);
716 do_delete(q, qual, action, actarg)
717 register struct query *q;
729 ## range of rvar is rtable
732 ## delete rvar where cqual
734 ## inquire_equel (errorno = "errorno")
735 if (errorno != 0) return(SMS_INGRES_ERR);
741 ** set_next_object_id - set next object id in values table
743 ** Inputs: object - object name in values table and in objects
744 ** table - name of table objects are found in
746 ** - called before an APPEND operation to set the next object id to
747 ** be used for the new record to the next free value
751 set_next_object_id(object, table)
756 ## int rowcount, exists, value;
760 ## range of v is values
761 ## repeat retrieve (value = v.#value) where v.#name = @name
762 ## inquire_equel(rowcount = "rowcount")
766 ## retrieve (exists = any(tbl.name where tbl.name = value))
767 ## inquire_equel(rowcount = "rowcount")
772 if (value > MAX_ID_VALUE)
773 value = MIN_ID_VALUE;
774 ## retrieve (exists = any(tbl.name where tbl.name = value))
778 com_err(whoami, 0, "setting ID %s to %d", name, value);
779 ## repeat replace v (#value = @value) where v.#name = @name
784 /* For now this just checks the argc's. It should also see that there
785 * are no duplicate names.
788 sanity_check_queries()
791 int maxv = 0, maxa = 0;
792 extern int QueryCount1, QueryCount2;
793 extern struct query Queries1[], Queries2[];
794 #define MAX(x,y) ((x) > (y) ? (x) : (y))
796 for (i = 0; i < QueryCount1; i++) {
797 maxv = MAX(maxv, Queries1[i].vcnt);
798 maxa = MAX(maxa, Queries1[i].argc);
800 for (i = 0; i < QueryCount2; i++) {
801 maxv = MAX(maxv, Queries2[i].vcnt);
802 maxa = MAX(maxa, Queries2[i].argc);
804 if (MAX(maxv, maxa) > QMAXARGS) {
805 com_err(whoami, 0, "A query has more args than QMAXARGS");
815 * c-continued-statement-offset: 4
817 * c-argdecl-indent: 4