#
/*
** 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;
*/

# include	"../ingres.h"
# include	"../aux.h"
# include	"../catalog.h"
# include	"../access.h"
# include	"../batch.h"
# include	"../unix.h"

modupdate()
{
	char			batchname[MAXNAME + 3];
	char			temprel[MAXNAME+ 3];
	char			relfile[MAXNAME + 3];
	register int		i;
	register int		j;
	struct stat		sbuf;
	char			aflag;
	struct tup_id		tid;
	struct descriptor	desx;
	struct attribute	atttup;
	struct relation		oldreltup;
	struct index		ikey, itup;
	char			*newpv[2];
	extern struct descriptor	Inddes, Attdes, Reldes;
	register struct descriptor	*desp;
	char			*trim_relname();
	long			ltemp1, ltemp2;


	desp =  &desx;
	concat(MODBATCH,Fileset,batchname);
	concat(MODTEMP, Fileset, temprel);

#	ifdef xZTR1
	if (tTf(20, 8))
		printf("Modupdate: %s, %s\n",batchname, temprel);
#	endif
	if ((Batch_fp = open(batchname, 0)) < 0)
		syserr("MODUPDATE:Can't open %s", batchname);
	Batch_cnt = BATCHSIZE;
	Batch_dirty = FALSE;
	getbatch(desp, sizeof *desp);
	ingresname(desp->relid, desp->relowner, relfile);

	/* don't loose old file before verifying new file */
	if (stat(temprel, &sbuf) != -1)
	{
		unlink(relfile);	/* Ok if failure */
		if (link(temprel, relfile) == -1)
			syserr("MODUPDATE:Can't link: %s, %s", temprel, relfile);
		unlink(temprel);
	}

	else
		if(stat(relfile, &sbuf) == -1 || !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->relid, "attribute   ", 12)) ||
		bequal(desp->relid, "relation    ", 12))
	{
		ingresname(desp->relid, desp->relowner, temprel);
		if ((i = open("admin", 2)) < 0)
			syserr("MODUPDATE:Can't open admin file");
		ltemp1 = sizeof Admin.adhdr;
		ltemp2 = sizeof *desp;
		if (lseek(i, ltemp1, 0) < 0 ||
			(aflag && lseek(i, ltemp2, 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.relid, Admin.adattd.relowner, temprel);
			if ((Admin.adattd.relfp = open(temprel, 2)) < 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, 2)) < 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);
	/* 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);

	/* update attribute relation */
	Admin.adattd.relopn = (Admin.adattd.relfp + 1) * -5;
	for (i = desp->relatts; 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);
	}

	if (i = cleanrel(&Admin.adattd))
		syserr("MODUPDATE:clean att %d", i);

	/* 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 < 0)
	{
		opencatalog("indexes", 2);
		setkey(&Inddes, &ikey, desp->relid, IRELIDI);
		setkey(&Inddes, &ikey, desp->relowner, IOWNERP);
		if ((i = getequal(&Inddes, &ikey, &itup, &tid)) == 0)
		{
			itup.irelspeci = desp->relspec;
			if ((i = replace(&Inddes, &tid, &itup, 0)) != 0)
				if (i < 0 || i == 2)
					syserr("MODUPDATE: rep(ix) %d", i);
		}
	}

	else if(desp->relindxd > 0)
	{
		/* destroy any secondary indexes on this primary */
		opencatalog("indexes", 2);
		setkey(&Inddes, &ikey, desp->relid, IRELIDP);
		setkey(&Inddes, &ikey, desp->relowner, IOWNERP);
		while ((i = getequal(&Inddes, &ikey, &itup, &tid)) == 0)
		{
			newpv[0] = itup.irelidi;
			newpv[1] = -1;
			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 */
	unlink(batchname);
#	ifdef xZTR1
	if (tTf(20, 8))
		printf("Leaving modupdate\n");
#	endif
	return (0);
}