// Copyright (c) 1999-2001  David Muse
// See the file COPYING for more information

#include <sqlrconnection.h>

void sqlrconnection_svr::rollbackCommand() {
	#ifdef SERVER_DEBUG
	debugPrint("connection",1,"rollback");
	#endif
	clientsock->write(rollback());
	flushWriteBuffer();
	commitorrollback=false;
}

bool sqlrconnection_svr::rollback() {

	#ifdef SERVER_DEBUG
	debugPrint("connection",1,"rollback...");
	#endif

	sqlrcursor_svr	*rollbackcur=initCursorUpdateStats();
	char	*rollbackquery="rollback";
	int	rollbackquerylen=8;
	bool	retval=false;
	if (rollbackcur->openCursor(0) &&
		rollbackcur->prepareQuery(rollbackquery,rollbackquerylen)) {
		retval=executeQueryUpdateStats(rollbackcur,rollbackquery,
						rollbackquerylen,true);
	}
	rollbackcur->cleanUpData(true,true);
	rollbackcur->closeCursor();
	deleteCursorUpdateStats(rollbackcur);

	#ifdef SERVER_DEBUG
	char	string[38];
	snprintf(string,38,"rollback result: %d",retval);
	debugPrint("connection",2,string);
	#endif

	return retval;
}