4.3BSD/usr/ingres/source/dbu/modupdate.c
# include <pv.h>
# include <ingres.h>
# include <aux.h>
# include <catalog.h>
# include <access.h>
# include <batch.h>
# include <opsys.h>
# include <btree.h>
# include <symbol.h>
# include <sccs.h>
SCCSID(@(#)modupdate.c 8.4 1/18/85)
/*
** MODUPDATE
** This routine is used to exicute the updates
** for modifies so they are recoverable.
** It is also used by restore to complete an aborted modify.
** During a restore the Batch_recover flag should be set to 1;
*/
modupdate()
{
char batchname[MAXNAME + 3];
char temprel[MAXNAME+ 3];
char relfile[MAXNAME + 3];
char btreesec[MAXNAME + 3];
register int i;
register int j;
struct stat sbuf;
char aflag;
struct tup_id tid;
DESC desx;
struct attribute attkey, atttup;
struct relation oldreltup;
struct index ikey, itup;
PARM newpv[2];
extern DESC Inddes, Attdes, Reldes;
register DESC *desp;
extern char *trim_relname();
extern int errno;
char btree[MAXNAME + 4], temp_btree[MAXNAME + 4];
int numatts, key;
extern int NLidKeys;
desp = &desx;
concat(MODBATCH,Fileset,batchname);
concat(MODTEMP, Fileset, temprel);
# ifdef xZTR1
if (tTf(34, 8))
printf("Modupdate: %s, %s\n",batchname, temprel);
# endif
if ((Batch_fp = open(batchname, O_RDONLY)) < 0)
syserr("MODUPDATE:Can't open %s", batchname);
Batch_cnt = BATCHSIZE;
Batch_dirty = FALSE;
getbatch(desp, sizeof *desp);
ingresname(desp->reldum.relid, desp->reldum.relowner, relfile);
if (!desp->reldum.reldim || NLidKeys > 0)
{
/* don't loose old file before verifying new file */
if (stat(temprel, &sbuf) >= 0)
{
unlink(relfile); /* Ok if failure */
errno = 0;
if (link(temprel, relfile) == -1)
syserr("MODUPDATE:Can't link: %s, %s", temprel, relfile);
if (unlink(temprel) < 0)
syserr("modupdate:unlink(%s)", temprel);
}
else
if(stat(relfile, &sbuf) < 0 || !Batch_recovery)
syserr("MODUPDATE:Relation and/or temporary files for %s are missing",
relfile);
}
/* Update admin if this is relation or atribute relations */
/* Should only happen in Sysmod */
if ((aflag = bequal(desp->reldum.relid, "attribute ", MAXNAME)) ||
bequal(desp->reldum.relid, "relation ", MAXNAME))
{
ingresname(desp->reldum.relid, desp->reldum.relowner, temprel);
if ((i = open("admin", O_RDWR)) < 0)
syserr("MODUPDATE:Can't open admin file");
if (lseek(i, (long) sizeof Admin.adhdr, 0) < 0 ||
(aflag && lseek(i, (long) sizeof *desp, 1) < 0))
syserr("MODUPDATE:Seek error");
if (write(i, desp, sizeof *desp) != sizeof *desp)
syserr("MODUPDATE:Write error on admin");
close(i);
if (aflag)
{
closer(&Attdes);
cleanrel(&Admin.adattd);
close(Admin.adattd.relfp);
bmove(desp, &Admin.adattd, sizeof *desp);
ingresname(Admin.adattd.reldum.relid, Admin.adattd.reldum.relowner, temprel);
if ((Admin.adattd.relfp = open(temprel, O_RDWR)) < 0)
syserr("MODUPDATE: open wr Admin.adattd %d", Admin.adattd.relfp);
Admin.adattd.relopn = (Admin.adattd.relfp + 1) * -5;
}
else
{
closer(&Reldes);
cleanrel(&Admin.adreld);
close(Admin.adreld.relfp);
bmove(desp, &Admin.adreld, sizeof *desp);
if ((Admin.adreld.relfp = open(temprel, O_RDWR)) < 0)
syserr("MODUPDATE: open Admin.adreld %d",
Admin.adreld.relfp);
Admin.adreld.relopn = (Admin.adreld.relfp + 1) * -5;
}
}
if (i = get(&Admin.adreld, &desp->reltid, &desp->reltid, &oldreltup, FALSE))
syserr("MODUPDATE: get oldrel=%d",i);
btreename(desp->reldum.relid, btree);
if (oldreltup.reldim > 0)
/* relation formerly ordered */
{
capital(trim_relname(desp->reldum.relid), btreesec);
newpv[0].pv_val.pv_str = btreesec;
newpv[1].pv_type = PV_EOF;
if (destroy(1, newpv))
syserr("can't destroy btreesec");
unlink(btree);
/* remove tuple corresponding to LID field from attribute
** relation
*/
setkey(&Admin.adattd, &attkey, desp->reldum.relid, ATTRELID);
setkey(&Admin.adattd, &attkey, desp->reldum.relowner, ATTOWNER);
numatts = oldreltup.relatts - oldreltup.reldim + 1;
for (i = oldreltup.reldim; i > 0; i--, numatts++)
{
setkey(&Admin.adattd, &attkey, &numatts, ATTID);
if (getequal(&Admin.adattd, &attkey, &atttup, &tid) == 0)
if (delete(&Admin.adattd, &tid) < 0)
syserr("MODUPDATE: Can't delete LID field from attribute relation");
}
}
/* update attribute relation */
Admin.adattd.relopn = (Admin.adattd.relfp + 1) * -5;
numatts = desp->reldum.relatts - desp->reldum.reldim;
for (i = numatts; i > 0; i--)
{
getbatch(&tid, sizeof tid);
getbatch(&atttup, sizeof atttup);
if (j = replace(&Admin.adattd, &tid, &atttup, FALSE))
if (j < 0 || j == 2)
syserr("MODUPDATE:Replace error(att): %d", j);
}
for (i = desp->reldum.reldim; i > 0; i--)
{
/* insert tuple corresponding to LID field into attribute relation */
getbatch(&atttup, sizeof atttup);
if ((j = insert(&Admin.adattd, &tid, &atttup, FALSE) < 0))
syserr("MODUPDATE: Insert error (att): %d", j);
}
unlink(batchname);
if (i = cleanrel(&Admin.adattd))
syserr("MODUPDATE:clean att %d", i);
/* update relation relation */
if ((i = replace(&Admin.adreld, &desp->reltid, desp, FALSE)))
if (i < 0 || i == 2)
syserr("MODUPDATE:Replace error(rel): %d", i);
if (i = cleanrel(&Admin.adreld))
syserr("MODUPDATE:clean rel %d", i);
if (desp->reldum.reldim > 0)
/* link temporary BTree file to permanent storage */
{
concat(BTREE, Fileset, temp_btree);
if (link(temp_btree, btree) == -1)
syserr("MODUPDATE: can't link: %s, %s", temp_btree, btree);
if (unlink(temp_btree) < 0)
syserr("modupdate: unlink %s", temp_btree);
}
/* make the admin readonly */
Admin.adattd.relopn = (Admin.adattd.relfp + 1) * 5;
close(Batch_fp);
/* if this is an index, change the relspec in the index catalog */
if (oldreltup.relindxd == SECINDEX)
{
opencatalog("indexes", OR_WRITE);
setkey(&Inddes, &ikey, desp->reldum.relid, IRELIDI);
setkey(&Inddes, &ikey, desp->reldum.relowner, IOWNERP);
if ((i = getequal(&Inddes, &ikey, &itup, &tid)) == 0)
{
itup.irelspeci = desp->reldum.relspec;
if ((i = replace(&Inddes, &tid, &itup, 0)) != 0)
if (i < 0 || i == 2)
syserr("MODUPDATE: rep(ix) %d", i);
}
}
else if (desp->reldum.relindxd == SECBASE)
{
/* destroy any secondary indexes on this primary */
opencatalog("indexes", OR_WRITE);
setkey(&Inddes, &ikey, desp->reldum.relid, IRELIDP);
setkey(&Inddes, &ikey, desp->reldum.relowner, IOWNERP);
while ((i = getequal(&Inddes, &ikey, &itup, &tid)) == 0)
{
newpv[0].pv_val.pv_str = itup.irelidi;
newpv[1].pv_type = PV_EOF;
printf("destroying secondary index %s\n", trim_relname(itup.irelidi));
if (destroy(1, newpv))
syserr("MODUPDATE:Can't destroy %s", itup.irelidi);
}
}
if (i < 0)
syserr("MODUPDATE: geteq(ix)b %d", i);
/* clean things up and exit */
# ifdef xZTR1
if (tTf(34, 8))
printf("Leaving modupdate\n");
# endif
return (0);
}