database.cpp

一个symbian操作系统的

#include "database.h"
#include <utf.h>
#include <aknnotewrappers.h>
#include "HeatMeter2Container.h"

CDataBase* CDataBase::NewL(MContainerObserver *aCallBack)
{
    CDataBase* self = NewLC(aCallBack);
    CleanupStack::Pop(); // self
    return self;
}

CDataBase* CDataBase::NewLC(MContainerObserver *aCallBack)
{
    CDataBase* self = new (ELeave) CDataBase();
    CleanupStack::PushL(self);
    self->ConstructL(aCallBack);
    return self;
}


void CDataBase::ConstructL(MContainerObserver *aCallBack)
{
	//initialize with default values
	iVersion=0;
	iClientID=1125;

	//set database and ini file location
	iCallBack=aCallBack;
	fileName=(_L("\\System\\Apps\\HeatMeter2\\HeatMeter.db"));
	iniFileName=(_L("\\System\\Apps\\HeatMeter2\\HeatMeter.ini"));
	iGprsClient=CGprsClient::NewL(this);
	if (OpenDb()!=KErrNone) 
	{
		//create a DB first if does not exist
		User::LeaveIfError(CreateDb());
		User::LeaveIfError(OpenDb());
	}
}

//creates the database
TInt CDataBase::CreateDb()
{
	//Create Database
	SaveIniFile();
	iFs.Connect();
	iHeatMeterDb.Replace(iFs, fileName);

	//Create Tables
	TDbCol subs_id(_L("subs_id"), EDbColUint32);
	TDbCol addr(_L("addr"), EDbColText);
	TDbCol name(_L("name"), EDbColText);
	TDbCol state(_L("state"), EDbColUint32);
	CDbColSet *heatMeterColSet=CDbColSet::NewLC();
	heatMeterColSet->AddL(subs_id);
	heatMeterColSet->AddL(addr);
	heatMeterColSet->AddL(name);
	heatMeterColSet->AddL(state);
	iHeatMeterDb.CreateTable(_L("heatmeter"), *heatMeterColSet);
	CleanupStack::PopAndDestroy(heatMeterColSet);

	CDbKey *heatMeterIndex=CDbKey::NewLC();
	TDbKeyCol addrKeyCol(_L("addr"));
	heatMeterIndex->AddL(addrKeyCol);
	iHeatMeterDb.CreateIndex(_L("TheIndex"), _L("heatmeter"), *heatMeterIndex);
	CleanupStack::PopAndDestroy(heatMeterIndex);
	iHeatMeterDb.Close();
	iFs.Close();
	return 1;

}

//opens the database
TInt CDataBase::OpenDb()
{
	iDbSession.Connect();	
	TInt ret=iHeatMeterDb.Open(iDbSession, fileName);
	if (ret!=KErrNone) iDbSession.Close();
	else
	{
		//read ini file
		iFs.Connect();
		RFile iniFile;
		iniFile.Open(iFs, iniFileName, EFileRead);
		TFileText tFileText;
		tFileText.Set(iniFile);
		TBuf<100> nowLine;
		tFileText.Read(nowLine);
		TLex lex(nowLine);
		lex.SkipCharacters();
		lex.SkipSpace();
		lex.Val(iVersion);
		tFileText.Read(nowLine);
		TLex lex2(nowLine);
		lex2.SkipCharacters();
		lex2.SkipSpace();
		lex2.Val(iClientID);
		tFileText.Read(nowLine);
		TInt index=nowLine.Locate(' ');
		((CHeatMeter2Container*)iCallBack)->iServerAddr.Input(nowLine.Mid(index+1));		//"ServerAddress 192.168.0.1"
		iniFile.Close();
		iFs.Close();
	}
	return ret;
}

CDataBase::~CDataBase()
{
	iHeatMeterDb.Close();
	iDbSession.Close();
	SaveIniFile();
	delete iGprsClient;
}


//fills listbox array with values read from database
void CDataBase::FillArrays(CDesCArray *aListBoxArray, CArrayFixFlat<TInt> *aValues, CArrayFixFlat<TInt> *aIDs)
{
	RDbView view;
	aListBoxArray->Reset();
	aValues->Reset();
	aIDs->Reset();
	view.Prepare(iHeatMeterDb, TDbQuery(_L("SELECT * FROM HEATMETER")), view.EReadOnly);
	CleanupClosePushL(view);
	view.EvaluateAll();
	for (view.FirstL(); view.AtRow(); view.NextL())
	{
		view.GetL();
		TBuf<200> text;
		TBuf<100> addr=view.ColDes16(3);
		TBuf<100> name=view.ColDes16(2);
		TInt value=view.ColUint32(4);
		if (value==0) text.Format(_L("\t%S\t%S\t0"), &addr, &name);
		else text.Format(_L("\t%S\t%S [%d]\t1"), &addr, &name, value);
		aListBoxArray->AppendL(text);
		aValues->AppendL(value);
		aIDs->AppendL(view.ColUint32(1));
	}
	CleanupStack::PopAndDestroy();
}

//called by GPRS receiver class when a response is received from the server
void CDataBase::ResponseReceived(TDesC8 &aResponse)
{
	//return if error
	if (aResponse.Length()<10)	//probably empty response
	{
		iCallBack->SynchFailed(0);
		return;
	}
	TInt pos0=aResponse.Find(_L8("\r\n\r\nError"));
	if (pos0>=0)  //error occured, but HTTP packet is ok
	{
		iCallBack->SynchFailed(1);
		return;
	}
	TInt pos=aResponse.Find(_L8("\r\n\r\n"))+4; //start position of actual data (body)

	TBuf8<10000> *response8=new (ELeave) TBuf8<10000>;
	TBuf16<5000> *response16=new (ELeave) TBuf16<5000>;
	response8->Copy(aResponse.Ptr()+pos);

	CnvUtfConverter::ConvertToUnicodeFromUtf8(*response16, *response8);
	delete response8;
	
	//start a transaction
	iHeatMeterDb.Begin();

	//read new database version
	TLex16 lex(*response16);
	lex.Val(iVersion);
	lex.SkipSpace();
	while (lex.Eos()==false)
	{
		TBuf<6> action;
		TInt ID;
		lex.Mark();
		lex.SkipCharacters();
		action=lex.MarkedToken();
		lex.SkipSpace();

		//update database
		if (action==_L("DELETE"))
		{
			lex.Val(ID);
			lex.SkipSpace();
			TBuf<200> command;

			command.Format(_L("DELETE FROM heatmeter WHERE subs_id=%d"), ID);
			iHeatMeterDb.Execute(command);
		}
		else if (action==_L("RENAME"))
		{
			TInt nextLength;
			TBuf<100> newName;
			lex.Val(ID);
			lex.SkipSpace();

			lex.Val(nextLength);
			lex.SkipSpace();
			lex.Mark();
			lex.Inc(nextLength);
			newName=lex.MarkedToken();
			lex.SkipSpace();

			TBuf<200> command;
			command.Format(_L("UPDATE heatmeter SET name='%S' WHERE subs_id=%d"), &newName, ID);
			iHeatMeterDb.Execute(command);
		}
		else if (action==_L("ADDNEW"))
		{
			TInt nextLength;
			TBuf<100> newName;
			TBuf<100> newAddr;
			lex.Val(ID);
			lex.SkipSpace();

			lex.Val(nextLength);
			lex.SkipSpace();
			lex.Mark();
			lex.Inc(nextLength);
			newAddr=lex.MarkedToken();
			lex.SkipSpace();

			lex.Val(nextLength);
			lex.SkipSpace();
			lex.Mark();
			lex.Inc(nextLength);
			newName=lex.MarkedToken();
			lex.SkipSpace();

			TBuf<200> command;
			command.Format(_L("INSERT INTO heatmeter (subs_id, addr, name, state) VALUES (%d, '%S\', '%S', 0)"), ID, &newAddr, &newName);
			iHeatMeterDb.Execute(command);
		}
	}

	delete response16;
	//commit database changes
	iHeatMeterDb.Commit();
	//save new database version
	SaveIniFile();
	//reset all state entries
	iHeatMeterDb.Execute(_L("UPDATE heatmeter SET state=0"));
	//tell the view that synch is complete
	iCallBack->SynchReady();
}


//called by the view to start synchronisation
void CDataBase::Synch(TInetAddr &aIpAddress, TDesC&/* aPath*/)
{

	//create the http body for synch
	TBuf16<1000> *content16=new (ELeave) TBuf16<1000>;
	TBuf8<2000> *content8=new (ELeave) TBuf8<2000>;
	content16->Num(iVersion);
	content16->Append(_L("\n"));
	content16->AppendNum(iClientID);
	content16->Append(_L("\n"));

	RDbView view;
	view.Prepare(iHeatMeterDb, TDbQuery(_L("SELECT * FROM HEATMETER WHERE state>0")), view.EReadOnly);
	CleanupClosePushL(view);
	view.EvaluateAll();
	for (view.FirstL(); view.AtRow(); view.NextL())
	{
		view.GetL();
		content16->AppendNum(view.ColUint32(1), EDecimal); //id
		content16->Append(_L("\n"));
		content16->AppendNum(view.ColUint32(4), EDecimal); //state
		content16->Append(_L("\n"));
		
	}
	CleanupStack::PopAndDestroy();

	//convert it to UTF8 to be smaller
	CnvUtfConverter::ConvertFromUnicodeToUtf8(*content8, *content16);
	
	//create HTTP header
	TBuf8<3000> *httpBuffer8=new (ELeave) TBuf8<3000>;
	*httpBuffer8=_L8("POST /gaz/gaz HTTP/1.0\r\nContent-Type: text/plain; charset=UTF-8\r\nContent-Length: ");
	httpBuffer8->AppendNum(content8->Length());
	httpBuffer8->Append(_L("\r\n\r\n"));
	httpBuffer8->Append(*content8);

	//send the packet and wait for response
	iGprsClient->SendL(aIpAddress, *httpBuffer8);
	delete httpBuffer8;
	delete content8;
	delete content16;
	
}

//update a heatmeter state in the database
void CDataBase::UpdateItemValue(TInt aID, TInt aState)
{
	TBuf<200> command;
	command.Format(_L("UPDATE heatmeter SET state=%d WHERE subs_id=%d"), aState, aID);
	iHeatMeterDb.Execute(command);

}

//saves ini file
void CDataBase::SaveIniFile()
{
	RFs iFs;
	iFs.Connect();
	RFile iniFile;
	iniFile.Replace(iFs, iniFileName, EFileWrite);
	TFileText tFileText;
	tFileText.Set(iniFile);
	TBuf<100> nowLine;
	nowLine.Format(_L("DatabaseVersion %d"), iVersion);
	tFileText.Write(nowLine);
	nowLine.Format(_L("ClientID %d"), iClientID);
	tFileText.Write(nowLine);
	TBuf<20> addrStr;
	((CHeatMeter2Container*)iCallBack)->iServerAddr.Output(addrStr);
	nowLine.Format(_L("ServerAddress %S"), &addrStr);
	tFileText.Write(nowLine);
	
	iniFile.Close();
	iFs.Close();

}

void CDataBase::ResetDataBase()
{
	iHeatMeterDb.Execute(_L("DELETE FROM heatmeter"));
	iVersion=0;
}