1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/tdbms/t_dbscript.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,1493 @@
1.4 +// Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include <d32dbms.h>
1.20 +#include <f32file.h>
1.21 +#include <e32test.h>
1.22 +#include <e32math.h>
1.23 +#include <d32dbmsconstants.h>
1.24 +
1.25 +LOCAL_D RTest TheTest(_L("t_dbscript"));
1.26 +LOCAL_D CTrapCleanup* TheTrapCleanup;
1.27 +LOCAL_D RDbNamedDatabase TheDatabase;
1.28 +LOCAL_D RFs TheFs;
1.29 +LOCAL_D RDbView TheView;
1.30 +//
1.31 +const TPtrC KTestDatabase=_L("c:\\dbms-tst\\t_script.db");
1.32 +
1.33 +const TPtrC KRomScriptFile=_L("z:\\test\\t_script.txt");
1.34 +
1.35 +const TPtrC KOutputFile=_L("c:\\dbms-tst\\t_script.log");
1.36 +
1.37 +const TInt KTestCleanupStack=0x20;
1.38 +const TPtrC KDDLKeywords[]={_L("CREATE"),_L("DROP"),_L("ALTER")};
1.39 +const TPtrC KDMLKeywords[]={_L("INSERT"),_L("DELETE"),_L("UPDATE")};
1.40 +const TPtrC KQueryKeywords[]={_L("SELECT")};
1.41 +const TPtrC KScriptKeywords[]={_L("PRINT"),_L("ROWS"),_L("COMPARE"),_L("ERROR"),_L("!"),
1.42 + _L("POPULATE"),_L("RESULTS"),_L("BUILD"),_L("QUERY"),
1.43 + _L("NORMAL"),_L("FOLDED"),_L("COLLATED"),_L("START"),_L("STOP"),
1.44 + _L("LOAD"),_L("ECHO"),_L("WINDOW"),_L("ACCESS")};
1.45 +const TPtrC KRowIdColName=_L("Rw");
1.46 +enum TKeyword {EPrint,ERows,ECompare,EError,EComment,EPopulate,EResults,EBuild,EQuery,ENormal,
1.47 + EFolded,ECollated,EStart,EStop,ELoad,EEcho,EWindow,EAccess,ENumKeywords,EUnknown};
1.48 +//
1.49 +typedef TBuf<256> TScriptLine;
1.50 +typedef TBuf<256> TScriptToken;
1.51 +//
1.52 +#define ARRAY_SIZE(array) (sizeof(array)/sizeof(array[0]))
1.53 +
1.54 +class TScript;
1.55 +class TTimer
1.56 + {
1.57 +public:
1.58 + inline TTimer(TScript& aScript);
1.59 + void Start(const TDesC& aDes);
1.60 + void Stop(const TDesC& aDes);
1.61 +private:
1.62 + TUint iTicks;
1.63 + TScript& iScript;
1.64 + };
1.65 +
1.66 +class TResults
1.67 + {
1.68 +public:
1.69 + inline TResults();
1.70 +public:
1.71 + RDbView& iView;
1.72 + TInt iError;
1.73 + TInt iRows;
1.74 + TInt iLineNo;
1.75 + TScriptLine iLine;
1.76 + };
1.77 +
1.78 +class TSqlStatement
1.79 + {
1.80 +private:
1.81 + enum TSqlType {EDML,EDDL,EQuery,EUnknown};
1.82 +public:
1.83 + inline TSqlStatement(const TDesC& aSql,TResults& aResults);
1.84 + TInt Execute(TDbTextComparison aTextComparison=EDbCompareNormal,
1.85 + RDbRowSet::TAccess aAccess=RDbRowSet::EReadOnly,TBool aWindow=EFalse) const;
1.86 +private:
1.87 + void ExecuteSql(TDbTextComparison aTextComparison) const;
1.88 + void ExecuteQuery(RDbRowSet::TAccess aAccess,TBool aWindow) const;
1.89 + TSqlType SqlType() const;
1.90 +private:
1.91 + const TDesC& iSql;
1.92 + TResults& iResults;
1.93 + };
1.94 +
1.95 +class TScript
1.96 + {
1.97 +public:
1.98 + TScript();
1.99 + ~TScript()
1.100 + {
1.101 + iFile.Close();
1.102 + }
1.103 + TInt ReadNextStatement();
1.104 + void GetNextTokenFromStatement(TDes& aToken);
1.105 + void GetNextTokenFromLine(TDes& aToken);
1.106 + TPtrC Statement();
1.107 + TInt IntValue();
1.108 + void WriteLine(const TDesC& aLine);
1.109 + void WriteError(const TDesC& aLine);
1.110 + void WriteSqlError(const TResults& aResults,const TDesC& aLine);
1.111 + void WriteComment(const TDesC& aLine);
1.112 + TKeyword Keyword(const TDesC& aKeyword) const;
1.113 + void ConsumeLine();
1.114 + void ConsumeStatement();
1.115 + inline TInt LineNo() const;
1.116 +private:
1.117 + TInt ReadNextLine();
1.118 + TInt AppendNextLine();
1.119 + TBool IsStatement();
1.120 +private:
1.121 + TFileText iInput;
1.122 + TFileText iOutput;
1.123 + TScriptLine iBuf;
1.124 + TLex iStatement;
1.125 + TLex iLine;
1.126 + TInt iLineNo;
1.127 + RFile iFile;
1.128 + };
1.129 +
1.130 +class TScriptEngine
1.131 + {
1.132 +public:
1.133 + inline TScriptEngine();
1.134 + void RunL();
1.135 +private:
1.136 + void ExecuteL();
1.137 + TInt ExecuteScriptL();
1.138 + TInt ExecuteSql(const TDesC& aSql);
1.139 + TInt ExecuteSql();
1.140 + // keyword operations
1.141 + void DoPrintL();
1.142 + void DoComment();
1.143 + void DoError();
1.144 + void DoEcho();
1.145 + void DoWindow();
1.146 + void DoAccess();
1.147 + void DoRows();
1.148 + void DoCompareL();
1.149 + void DoPopulate();
1.150 + void DoResultsL();
1.151 + void DoBuildTable();
1.152 + void DoQuery();
1.153 + void DoTextComparison(TKeyword aKeyword);
1.154 + void DoStartTimer();
1.155 + void DoStopTimer();
1.156 + void DoLoadDb();
1.157 + //
1.158 + void PrintL(RDbRowSet& aRowSet);
1.159 + void CompareL(RDbRowSet& aRowSet);
1.160 + void CompareValues(RDbRowSet& aRowSet,TDbColNo ColNo,TDbColType aType,const TDesC& aToken);
1.161 + void FatalError(const TDesC& aLine);
1.162 + void FatalError();
1.163 + void FatalSqlError(const TDesC& aLine);
1.164 + void TestForNoError();
1.165 +private:
1.166 + TScript iScript;
1.167 + TResults iResults;
1.168 + TDbTextComparison iTextComparison;
1.169 + TTimer iTimer;
1.170 + TBool iEcho;
1.171 + TBool iWindow;
1.172 + RDbRowSet::TAccess iAccess;
1.173 +
1.174 + };
1.175 +
1.176 +//
1.177 +// class TTimer
1.178 +//
1.179 +
1.180 +inline TTimer::TTimer(TScript& aScript)
1.181 + : iScript(aScript)
1.182 + {}
1.183 +
1.184 +void TTimer::Start(const TDesC& aDes)
1.185 + {
1.186 + TScriptLine line;
1.187 + line.Format(_L("%S: "),&aDes);
1.188 + iScript.WriteLine(line);
1.189 + iTicks=User::TickCount();
1.190 + }
1.191 +
1.192 +void TTimer::Stop(const TDesC& aDes)
1.193 + {
1.194 + TScriptLine line;
1.195 + line.Format(_L("%S: "),&aDes);
1.196 +#ifdef __EPOC32__
1.197 +#define TICK_TIME 15625
1.198 +#else
1.199 +#define TICK_TIME 100000
1.200 +#endif
1.201 + TInt microSec=(User::TickCount()-iTicks)*TICK_TIME;
1.202 + TUint sec=microSec/1000000;
1.203 + TUint centi=(microSec/10000)-sec*100;
1.204 + line.AppendFormat(_L("%u.%02us\n"),sec,centi);
1.205 + iScript.WriteLine(line);
1.206 + }
1.207 +
1.208 +///////////////////////////////////////////////////////////////////////////////////////
1.209 +
1.210 +LOCAL_C void DeleteDataFile(const TDesC& aFullName)
1.211 + {
1.212 + RFs fsSession;
1.213 + TInt err = fsSession.Connect();
1.214 + if(err == KErrNone)
1.215 + {
1.216 + TEntry entry;
1.217 + if(fsSession.Entry(aFullName, entry) == KErrNone)
1.218 + {
1.219 + RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
1.220 + err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
1.221 + if(err != KErrNone)
1.222 + {
1.223 + RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
1.224 + }
1.225 + err = fsSession.Delete(aFullName);
1.226 + if(err != KErrNone)
1.227 + {
1.228 + RDebug::Print(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
1.229 + }
1.230 + }
1.231 + fsSession.Close();
1.232 + }
1.233 + else
1.234 + {
1.235 + RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
1.236 + }
1.237 + }
1.238 +
1.239 +///////////////////////////////////////////////////////////////////////////////////////
1.240 +///////////////////////////////////////////////////////////////////////////////////////
1.241 +//Tests macros and functions.
1.242 +//If (!aValue) then the test will be panicked, the test data files will be deleted.
1.243 +static void Check(TInt aValue, TInt aLine)
1.244 + {
1.245 + if(!aValue)
1.246 + {
1.247 + RDebug::Print(_L("*** Expression evaluated to false\r\n"));
1.248 + DeleteDataFile(KTestDatabase);
1.249 + DeleteDataFile(KOutputFile);
1.250 + TheTest(EFalse, aLine);
1.251 + }
1.252 + }
1.253 +//If (aValue != aExpected) then the test will be panicked, the test data files will be deleted.
1.254 +static void Check(TInt aValue, TInt aExpected, TInt aLine)
1.255 + {
1.256 + if(aValue != aExpected)
1.257 + {
1.258 + RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
1.259 + DeleteDataFile(KTestDatabase);
1.260 + DeleteDataFile(KOutputFile);
1.261 + TheTest(EFalse, aLine);
1.262 + }
1.263 + }
1.264 +//Use these to test conditions.
1.265 +#define TEST(arg) Check((arg), __LINE__)
1.266 +#define TEST2(aValue, aExpected) Check(aValue, aExpected, __LINE__)
1.267 +
1.268 +///////////////////////////////////////////////////////////////////////////////////////
1.269 +///////////////////////////////////////////////////////////////////////////////////////
1.270 +
1.271 +//
1.272 +// class TResults
1.273 +//
1.274 +
1.275 +inline TResults::TResults()
1.276 + : iView(TheView),iError(KErrNone)
1.277 + {}
1.278 +
1.279 +
1.280 +//
1.281 +// class TSqlStatement
1.282 +//
1.283 +
1.284 +inline TSqlStatement::TSqlStatement(const TDesC& aSql,TResults& aResults)
1.285 + : iSql(aSql),iResults(aResults)
1.286 + {}
1.287 +
1.288 +//
1.289 +// executes DML or DDL
1.290 +//
1.291 +void TSqlStatement::ExecuteSql(TDbTextComparison aTextComparison) const
1.292 + {
1.293 + TInt r=TheDatabase.Execute(iSql,aTextComparison);
1.294 + if (r<0)
1.295 + iResults.iError=r;
1.296 + else
1.297 + {
1.298 + iResults.iError=KErrNone;
1.299 + iResults.iRows=r;
1.300 + }
1.301 + }
1.302 +
1.303 +void TSqlStatement::ExecuteQuery(RDbRowSet::TAccess aAccess,TBool aWindow) const
1.304 + {
1.305 + iResults.iView.Close(); // discard any previous queries
1.306 + TInt& err=iResults.iError;
1.307 + if (aWindow)
1.308 + err=iResults.iView.Prepare(TheDatabase,iSql,KDbUnlimitedWindow,aAccess);
1.309 + else
1.310 + err=iResults.iView.Prepare(TheDatabase,iSql,aAccess);
1.311 + if (err==KErrNone)
1.312 + err=iResults.iView.EvaluateAll();
1.313 + }
1.314 +
1.315 +//
1.316 +// determines the type of sql statement by matching keywords
1.317 +//
1.318 +TSqlStatement::TSqlType TSqlStatement::SqlType() const
1.319 + {
1.320 + for (TUint i=0;i<ARRAY_SIZE(KDDLKeywords);++i)
1.321 + {
1.322 + if (iSql.FindF(KDDLKeywords[i])==0)
1.323 + return EDDL;
1.324 + }
1.325 + for (TUint ii=0;ii<ARRAY_SIZE(KDMLKeywords);++ii)
1.326 + {
1.327 + if (iSql.FindF(KDMLKeywords[ii])==0)
1.328 + return EDML;
1.329 + }
1.330 + for (TUint j=0;j<ARRAY_SIZE(KQueryKeywords);++j)
1.331 + {
1.332 + if (iSql.FindF(KQueryKeywords[j])==0)
1.333 + return EQuery;
1.334 + }
1.335 + return EUnknown;
1.336 + }
1.337 +
1.338 +//
1.339 +// executes the sql statement
1.340 +//
1.341 +TInt TSqlStatement::Execute(TDbTextComparison aTextComparison,RDbRowSet::TAccess aAccess,TBool aWindow) const
1.342 + {
1.343 + TInt r=KErrNone;
1.344 + switch (SqlType())
1.345 + {
1.346 + case EDDL:
1.347 + case EDML:
1.348 + ExecuteSql(aTextComparison);
1.349 + break;
1.350 + case EQuery:
1.351 + ExecuteQuery(aAccess,aWindow);
1.352 + break;
1.353 + case EUnknown:
1.354 + default:
1.355 + r=KErrNotFound;
1.356 + break;
1.357 + }
1.358 + return r;
1.359 + }
1.360 +
1.361 +
1.362 +//
1.363 +// class TScript
1.364 +//
1.365 +
1.366 +TScript::TScript()
1.367 + : iLineNo(0)
1.368 + {
1.369 + TheTest.Printf(_L("---TScript::TScript(), Open the script file \"%S\"\r\n"), &KRomScriptFile);
1.370 + RFile file;
1.371 + TInt r=file.Open(TheFs, KRomScriptFile, EFileRead);
1.372 + TEST2(r, KErrNone);
1.373 + iInput.Set(file);
1.374 + TheTest.Printf(_L("---TScript::TScript(), Create the file \"%S\"\r\n"), &KOutputFile);
1.375 + TEST2(file.Replace(TheFs, KOutputFile, EFileWrite), KErrNone);
1.376 + iOutput.Set(file);
1.377 + iFile = file;
1.378 + }
1.379 +
1.380 +inline TInt TScript::LineNo() const
1.381 + {return iLineNo;}
1.382 +
1.383 +//
1.384 +// checks for keywords which possibly conform to the usual statement format (ie end in ';')
1.385 +//
1.386 +TBool TScript::IsStatement()
1.387 + {
1.388 + if (iLine.Remainder().Length()==0) // null statement
1.389 + return ETrue;
1.390 + TPtrC line=iLine.Remainder();
1.391 + TKeyword keyword=Keyword(line);
1.392 + switch (keyword)
1.393 + {
1.394 + case EPrint:
1.395 + case ERows:
1.396 + case EBuild:
1.397 + case EError:
1.398 + case EQuery:
1.399 + case ENormal:
1.400 + case EFolded:
1.401 + case ECollated:
1.402 + case EStart:
1.403 + case EStop:
1.404 + case ELoad:
1.405 + case EEcho:
1.406 + case EWindow:
1.407 + case EAccess:
1.408 + case EUnknown: // could be sql
1.409 + return ETrue;
1.410 + case EComment:
1.411 + case EPopulate:
1.412 + case ECompare:
1.413 + case EResults:
1.414 + iStatement=line; // not a statement, so make it the whole line
1.415 + return EFalse;
1.416 + default:
1.417 + TEST(0);
1.418 + return EFalse;
1.419 + }
1.420 + }
1.421 +
1.422 +//
1.423 +// reads the next non-blank statement or line
1.424 +//
1.425 +TInt TScript::ReadNextStatement()
1.426 + {
1.427 + TInt r=ReadNextLine();
1.428 + if (r!=KErrNone || !IsStatement())
1.429 + return r;
1.430 + TChar c=0;
1.431 + while (c!=';')
1.432 + {
1.433 + c=iLine.Get();
1.434 + if (!c) // nothing left to read
1.435 + {
1.436 + r=AppendNextLine();
1.437 + if (r!=KErrNone)
1.438 + return r;
1.439 + }
1.440 + }
1.441 + iLine.UnGet(); // the semi-colon
1.442 + iStatement=iLine.MarkedToken();
1.443 + iLine.Get(); // the semi-colon
1.444 + iLine.SkipSpaceAndMark();
1.445 + return KErrNone;
1.446 + }
1.447 +
1.448 +TPtrC TScript::Statement()
1.449 + {
1.450 + return iStatement.Remainder();
1.451 + }
1.452 +
1.453 +void TScript::ConsumeLine()
1.454 + {
1.455 + iLine=TPtrC();
1.456 + iStatement=TPtrC();
1.457 + }
1.458 +
1.459 +void TScript::ConsumeStatement()
1.460 + {
1.461 + iLine=iLine.Remainder();
1.462 + iStatement=TPtrC();
1.463 + }
1.464 +
1.465 +//
1.466 +// reads the next non-blank line into iLine
1.467 +//
1.468 +TInt TScript::ReadNextLine()
1.469 + {
1.470 + while (iLine.Remainder().Length()==0)
1.471 + {
1.472 + TInt r=iInput.Read(iBuf);
1.473 + if (r!=KErrNone)
1.474 + return r;
1.475 + if (iBuf.Length()>0 && iBuf[0]==0xfeff) // unicode stream marker
1.476 + iBuf.Delete(0,1);
1.477 + iLineNo++;
1.478 + iLine=iBuf;
1.479 + iLine.SkipSpaceAndMark();
1.480 + }
1.481 + return KErrNone;
1.482 + }
1.483 +
1.484 +//
1.485 +// adds next line from file to iLine
1.486 +//
1.487 +TInt TScript::AppendNextLine()
1.488 + {
1.489 + TScriptLine line;
1.490 + do {
1.491 + TInt r=iInput.Read(line);
1.492 + if (r!=KErrNone)
1.493 + return r;
1.494 + iLineNo++;
1.495 + } while (line.Length()==0);
1.496 + iBuf=iLine.MarkedToken();
1.497 + iBuf.Append(line);
1.498 + iLine=iBuf;
1.499 + return KErrNone;
1.500 + }
1.501 +
1.502 +void TScript::WriteError(const TDesC& aLine)
1.503 + {
1.504 + TScriptLine line;
1.505 + line.Format(_L("Error at line %d: %S\n"),iLineNo,&aLine);
1.506 + WriteLine(line);
1.507 + TheTest.Printf(line);
1.508 + }
1.509 +
1.510 +void TScript::WriteSqlError(const TResults& aResults,const TDesC& aLine)
1.511 + {
1.512 + TScriptLine line;
1.513 + line.Format(_L("Error at line %d: %S :-\n"),aResults.iLineNo,&aLine);
1.514 + WriteLine(line);
1.515 + TheTest.Printf(line);
1.516 + line.Format(_L("\t%S\n"),&aResults.iLine);
1.517 + WriteLine(line);
1.518 + TheTest.Printf(line);
1.519 + }
1.520 +
1.521 +void TScript::WriteLine(const TDesC& aLine)
1.522 + {
1.523 + TScriptLine l=aLine;
1.524 + l.Append('\r');
1.525 + iOutput.Write(l);
1.526 + }
1.527 +
1.528 +void TScript::WriteComment(const TDesC& aLine)
1.529 + {
1.530 + TScriptLine line;
1.531 + line.Format(_L("\n%S"),&aLine);
1.532 + WriteLine(line);
1.533 + }
1.534 +
1.535 +//
1.536 +// returns the integer n from the ' = n ' which must follow in the statement
1.537 +//
1.538 +TInt TScript::IntValue()
1.539 + {
1.540 + TScriptToken keyword;
1.541 + GetNextTokenFromStatement(keyword);
1.542 + if (keyword.Compare(_L("="))!=0)
1.543 + WriteError(_L("expected '=' missing"));
1.544 + iStatement.SkipSpaceAndMark();
1.545 + TInt num=0;
1.546 + TInt err=iStatement.Val(num);
1.547 + if (err!=KErrNone)
1.548 + WriteError(_L("expected number missing"));
1.549 + return num;
1.550 + }
1.551 +
1.552 +TKeyword TScript::Keyword(const TDesC& aKeyword) const
1.553 + {
1.554 + for (TInt ii=0; ii<ENumKeywords; ++ii)
1.555 + {
1.556 + if (aKeyword.FindF(KScriptKeywords[ii])==0)
1.557 + return TKeyword(ii);
1.558 + }
1.559 + return EUnknown;
1.560 + }
1.561 +
1.562 +//
1.563 +// gets the next token from iStatement
1.564 +//
1.565 +void TScript::GetNextTokenFromStatement(TDes& aToken)
1.566 + {
1.567 + iStatement.SkipSpaceAndMark();
1.568 + TUint c;
1.569 + do
1.570 + {
1.571 + c=iStatement.Get();
1.572 + if (c=='=' || c=='!')
1.573 + break;
1.574 + } while (iStatement.Peek().IsAlphaDigit());
1.575 + aToken=iStatement.MarkedToken();
1.576 + iStatement.SkipSpaceAndMark();
1.577 + }
1.578 +
1.579 +//
1.580 +// gets the next token from iLine
1.581 +//
1.582 +void TScript::GetNextTokenFromLine(TDes& aToken)
1.583 + {
1.584 + iLine.SkipSpaceAndMark();
1.585 + TUint c=0;
1.586 + TChar cc=c;
1.587 + TBool literal=EFalse;
1.588 + do
1.589 + {
1.590 + c=iLine.Get();
1.591 + if (!c)
1.592 + {
1.593 + AppendNextLine();
1.594 + iLine.SkipSpaceAndMark();
1.595 + c=iLine.Get();
1.596 + }
1.597 + if (c=='\'' || c=='#')
1.598 + literal=!literal;
1.599 + if ((c==',' || c=='(' || c==')' || c=='{' || c=='}' || c=='!' ) && !literal)
1.600 + break;
1.601 + cc=iLine.Peek();
1.602 + } while (cc.IsAlphaDigit() || literal || TUint(cc)=='.' || TUint(cc)=='+' || TUint(cc)=='-');
1.603 + aToken=iLine.MarkedToken();
1.604 + if (TUint(cc)==';') // ignore semi-colons - they're optional
1.605 + iLine.Get();
1.606 + iLine.SkipSpaceAndMark();
1.607 + if (c=='!')
1.608 + {
1.609 + iStatement=iLine.Remainder();
1.610 + TPtrC comment=iStatement.Remainder();
1.611 + WriteComment(comment);
1.612 + iLine=TPtrC();
1.613 + GetNextTokenFromLine(aToken);
1.614 + }
1.615 + }
1.616 +
1.617 +
1.618 +//
1.619 +// class TScriptEngine
1.620 +//
1.621 +
1.622 +TScriptEngine::TScriptEngine()
1.623 + : iTextComparison(EDbCompareNormal),iTimer(iScript),iEcho(EFalse),iWindow(EFalse),iAccess(RDbRowSet::EReadOnly)
1.624 + {}
1.625 +
1.626 +
1.627 +//
1.628 +// runs the script file
1.629 +//
1.630 +void TScriptEngine::RunL()
1.631 + {
1.632 + while (iScript.ReadNextStatement()!=KErrEof)
1.633 + ExecuteL();
1.634 + TestForNoError();
1.635 + }
1.636 +
1.637 +void TScriptEngine::TestForNoError()
1.638 + {
1.639 + if (iResults.iError!=KErrNone)
1.640 + {
1.641 + TScriptLine line;
1.642 + line.Format(_L("unexpected error %d"),iResults.iError);
1.643 + FatalSqlError(line);
1.644 + }
1.645 + }
1.646 +
1.647 +void TScriptEngine::ExecuteL()
1.648 + {
1.649 + if (ExecuteScriptL()!=KErrNone && ExecuteSql()!=KErrNone)
1.650 + FatalSqlError(_L("syntax error"));
1.651 + }
1.652 +
1.653 +TInt TScriptEngine::ExecuteScriptL()
1.654 + {
1.655 + TKeyword keyword=iScript.Keyword(iScript.Statement());
1.656 + if (keyword!=EError)
1.657 + TestForNoError();
1.658 + switch (keyword)
1.659 + {
1.660 + case EPrint:
1.661 + DoPrintL();
1.662 + break;
1.663 + case ERows:
1.664 + DoRows();
1.665 + break;
1.666 + case ELoad:
1.667 + DoLoadDb();
1.668 + break;
1.669 + case EEcho:
1.670 + DoEcho();
1.671 + break;
1.672 + case EWindow:
1.673 + DoWindow();
1.674 + break;
1.675 + case EAccess:
1.676 + DoAccess();
1.677 + break;
1.678 + case ECompare:
1.679 + DoCompareL();
1.680 + break;
1.681 + case EError:
1.682 + DoError();
1.683 + break;
1.684 + case EPopulate:
1.685 + DoPopulate();
1.686 + break;
1.687 + case EComment:
1.688 + DoComment();
1.689 + break;
1.690 + case EResults:
1.691 + DoResultsL();
1.692 + break;
1.693 + case EBuild:
1.694 + DoBuildTable();
1.695 + break;
1.696 + case EQuery:
1.697 + DoQuery();
1.698 + break;
1.699 + case ENormal:
1.700 + case EFolded:
1.701 + case ECollated:
1.702 + DoTextComparison(keyword);
1.703 + break;
1.704 + case EStart:
1.705 + DoStartTimer();
1.706 + break;
1.707 + case EStop:
1.708 + DoStopTimer();
1.709 + break;
1.710 + case EUnknown:
1.711 + default:
1.712 + return KErrNotFound;
1.713 + }
1.714 + return KErrNone;
1.715 + }
1.716 +
1.717 +TInt TScriptEngine::ExecuteSql()
1.718 + {
1.719 + return ExecuteSql(iScript.Statement());
1.720 + }
1.721 +
1.722 +TInt TScriptEngine::ExecuteSql(const TDesC& aSql)
1.723 + {
1.724 + if (iEcho)
1.725 + {
1.726 + TScriptLine line(_L("\nSQL:\t"));
1.727 + line.Append(aSql);
1.728 + iScript.WriteLine(line);
1.729 + }
1.730 + iResults.iLineNo=iScript.LineNo();
1.731 + iResults.iLine=aSql;
1.732 + TSqlStatement statement(aSql,iResults);
1.733 + return statement.Execute(iTextComparison,iAccess,iWindow);
1.734 + }
1.735 +
1.736 +void TScriptEngine::DoStartTimer()
1.737 + {
1.738 + // test its right function
1.739 + TScriptToken keyword;
1.740 + iScript.GetNextTokenFromStatement(keyword);
1.741 + TEST2(keyword.CompareF(_L("START")), 0);
1.742 + iScript.GetNextTokenFromStatement(keyword);
1.743 + TEST2(keyword.CompareF(_L("TIMER")), 0);
1.744 + //
1.745 + iTimer.Start(_L("Timer started"));
1.746 + }
1.747 +
1.748 +void TScriptEngine::DoStopTimer()
1.749 + {
1.750 + // test its right function
1.751 + TScriptToken keyword;
1.752 + iScript.GetNextTokenFromStatement(keyword);
1.753 + TEST2(keyword.CompareF(_L("STOP")), 0);
1.754 + iScript.GetNextTokenFromStatement(keyword);
1.755 + TEST2(keyword.CompareF(_L("TIMER")), 0);
1.756 + //
1.757 + iTimer.Stop(_L("Timer stopped"));
1.758 + }
1.759 +
1.760 +void TScriptEngine::DoTextComparison(TKeyword aKeyword)
1.761 + {
1.762 + TPtrC line;
1.763 + switch (aKeyword)
1.764 + {
1.765 + case ENormal:
1.766 + iTextComparison=EDbCompareNormal;
1.767 + line.Set(_L("[Normal text comparison]"));
1.768 + break;
1.769 + case EFolded:
1.770 + iTextComparison=EDbCompareFolded;
1.771 + line.Set(_L("[Folded text comparison]"));
1.772 + break;
1.773 + case ECollated:
1.774 + iTextComparison=EDbCompareCollated;
1.775 + line.Set(_L("[Collated text comparison]"));
1.776 + break;
1.777 + default:
1.778 + TEST(0);
1.779 + }
1.780 + iScript.WriteLine(line);
1.781 + }
1.782 +
1.783 +void TScriptEngine::DoComment()
1.784 + {
1.785 + // test its right function
1.786 + TScriptToken keyword;
1.787 + iScript.GetNextTokenFromStatement(keyword);
1.788 + TEST2(keyword.CompareF(_L("!")), 0);
1.789 + //
1.790 + TPtrC comment=iScript.Statement();
1.791 + iScript.WriteComment(comment);
1.792 + iScript.ConsumeLine();
1.793 + }
1.794 +
1.795 +void TScriptEngine::DoError()
1.796 + {
1.797 + // test its right function
1.798 + TScriptToken keyword;
1.799 + iScript.GetNextTokenFromStatement(keyword);
1.800 + TEST2(keyword.CompareF(_L("ERROR")), 0);
1.801 + //
1.802 + TScriptLine line;
1.803 + if (iScript.Statement().Length()==0)
1.804 + {
1.805 + if (iResults.iError>=0)
1.806 + FatalSqlError(_L("no error when one was expected"));
1.807 + line=_L("\t\tERROR OK");
1.808 + }
1.809 + else
1.810 + {
1.811 + TInt err=iScript.IntValue();
1.812 + if (iResults.iError!=err)
1.813 + {
1.814 + line.Format(_L("expected error %d, actual error %d"),err,iResults.iError);
1.815 + FatalSqlError(line);
1.816 + }
1.817 + line.Format(_L("\t\tERROR=%D OK"),err);
1.818 + }
1.819 + iResults.iError=0;
1.820 + iScript.WriteLine(line);
1.821 + }
1.822 +
1.823 +void TScriptEngine::DoRows()
1.824 + {
1.825 + // test its right function
1.826 + TScriptToken keyword;
1.827 + iScript.GetNextTokenFromStatement(keyword);
1.828 + TEST2(keyword.CompareF(_L("ROWS")), 0);
1.829 + //
1.830 + TScriptLine line;
1.831 + TInt rows=iScript.IntValue();
1.832 + if (iResults.iRows!=rows)
1.833 + {
1.834 + line.Format(_L("expected rows %d, actual rows %d"),rows,iResults.iRows);
1.835 + FatalSqlError(line);
1.836 + }
1.837 + line.Format(_L("\t\tROWS=%D OK"),rows);
1.838 + iScript.WriteLine(line);
1.839 + }
1.840 +
1.841 +void TScriptEngine::DoLoadDb()
1.842 + {
1.843 + // test its right function
1.844 + TScriptToken token;
1.845 + iScript.GetNextTokenFromStatement(token);
1.846 + TEST2(token.CompareF(_L("LOAD")), 0);
1.847 + //
1.848 + TFileName database(iScript.Statement());
1.849 + TheDatabase.Close();
1.850 + TScriptLine line;
1.851 + line.Format(_L("Opening database: %S"),&database);
1.852 + iScript.WriteLine(line);
1.853 + TEST2(TheDatabase.Open(TheFs,database), KErrNone);
1.854 + }
1.855 +
1.856 +void TScriptEngine::DoEcho()
1.857 + {
1.858 + // test its right function
1.859 + TScriptToken keyword;
1.860 + iScript.GetNextTokenFromStatement(keyword);
1.861 + TEST2(keyword.CompareF(_L("ECHO")), 0);
1.862 + //
1.863 + iScript.GetNextTokenFromStatement(keyword);
1.864 + if (keyword.CompareF(_L("OFF"))==0)
1.865 + {
1.866 + iEcho=EFalse;
1.867 + iScript.WriteLine(_L("Echo is off"));
1.868 + }
1.869 + else if (keyword.CompareF(_L("ON"))==0)
1.870 + {
1.871 + iEcho=ETrue;
1.872 + iScript.WriteLine(_L("Echo is on"));
1.873 + }
1.874 + else
1.875 + FatalError(_L("Expected ON|OFF to follow ECHO statement"));
1.876 + }
1.877 +
1.878 +void TScriptEngine::DoWindow()
1.879 + {
1.880 + // test its right function
1.881 + TScriptToken keyword;
1.882 + iScript.GetNextTokenFromStatement(keyword);
1.883 + TEST2(keyword.CompareF(_L("WINDOW")), 0);
1.884 + //
1.885 + iScript.GetNextTokenFromStatement(keyword);
1.886 + if (keyword.CompareF(_L("OFF"))==0)
1.887 + {
1.888 + iWindow=EFalse;
1.889 + iScript.WriteLine(_L("Window is off"));
1.890 + }
1.891 + else if (keyword.CompareF(_L("ON"))==0)
1.892 + {
1.893 + iWindow=ETrue;
1.894 + iScript.WriteLine(_L("Window is on"));
1.895 + }
1.896 + else
1.897 + FatalError(_L("Expected ON|OFF to follow WINDOW statement"));
1.898 + }
1.899 +
1.900 +void TScriptEngine::DoAccess()
1.901 + {
1.902 + // test its right function
1.903 + TScriptToken keyword;
1.904 + iScript.GetNextTokenFromStatement(keyword);
1.905 + TEST2(keyword.CompareF(_L("ACCESS")), 0);
1.906 + //
1.907 + iScript.GetNextTokenFromStatement(keyword);
1.908 + if (keyword.CompareF(_L("UPDATE"))==0)
1.909 + {
1.910 + iAccess=RDbRowSet::EUpdatable;
1.911 + iScript.WriteLine(_L("Access is updateable"));
1.912 + }
1.913 + else if (keyword.CompareF(_L("READ"))==0)
1.914 + {
1.915 + iAccess=RDbRowSet::EReadOnly;
1.916 + iScript.WriteLine(_L("Access is read only"));
1.917 + }
1.918 + else if (keyword.CompareF(_L("INSERT"))==0)
1.919 + {
1.920 + iAccess=RDbRowSet::EInsertOnly;
1.921 + iScript.WriteLine(_L("Access is insert only"));
1.922 + }
1.923 + else
1.924 + FatalError(_L("Expected UPDATE|INSERT|READ to follow ACCESS statement"));
1.925 + }
1.926 +
1.927 +void TScriptEngine::DoResultsL()
1.928 + {
1.929 + // test its right function
1.930 + TScriptToken token;
1.931 + iScript.GetNextTokenFromLine(token);
1.932 + TEST2(token.CompareF(_L("RESULTS")), 0);
1.933 + //
1.934 + iScript.GetNextTokenFromLine(token);
1.935 + if (token.Compare(_L("{"))!=0)
1.936 + FatalError(_L("missing '{'"));
1.937 + iScript.GetNextTokenFromLine(token); // first value
1.938 + TLex value;
1.939 + RDbRowSet& rowset=iResults.iView;
1.940 + CDbColSet* colset=rowset.ColSetL();
1.941 + CleanupStack::PushL(colset);
1.942 + TDbColNo colno=colset->ColNo(KRowIdColName);
1.943 + CArrayFixFlat<TInt>* rowIdScript=new CArrayFixFlat<TInt>(4);
1.944 + CleanupStack::PushL(rowIdScript);
1.945 + CArrayFixFlat<TInt>* rowIdView=new CArrayFixFlat<TInt>(4);
1.946 + CleanupStack::PushL(rowIdView);
1.947 + rowset.BeginningL();
1.948 + while (rowset.NextL())
1.949 + {
1.950 + rowset.GetL();
1.951 + TUint rIdScript;
1.952 + value=token;
1.953 + if (value.Val(rIdScript)!=KErrNone)
1.954 + {
1.955 + TScriptLine line;
1.956 + line.Format(_L("Unable to extract row id from \"%S\""),&token);
1.957 + FatalError(line);
1.958 + }
1.959 + TUint rIdView=rowset.ColUint(colno);
1.960 + rowIdScript->AppendL(rIdScript);
1.961 + rowIdView->AppendL(rIdView);
1.962 + iScript.GetNextTokenFromLine(token);
1.963 + if (token.Compare(_L(","))==0 || token.Compare(_L("}"))==0)
1.964 + {
1.965 + if (rowIdScript->Count())
1.966 + {
1.967 + TKeyArrayFix key(0,ECmpTInt);
1.968 + rowIdScript->Sort(key);
1.969 + rowIdView->Sort(key);
1.970 + for (TInt ii=0;ii<rowIdScript->Count();++ii)
1.971 + {
1.972 + TInt expectedId=(*rowIdScript)[ii];
1.973 + TInt actualId=(*rowIdView)[ii];
1.974 + if (actualId!=expectedId)
1.975 + {
1.976 + TScriptLine line;
1.977 + line.Format(_L("expected row id %d, actual row id %d"),actualId,expectedId);
1.978 + FatalError(line);
1.979 + }
1.980 + }
1.981 + rowIdScript->Reset();
1.982 + rowIdView->Reset();
1.983 + }
1.984 + if (token.Compare(_L(","))==0)
1.985 + iScript.GetNextTokenFromLine(token);
1.986 + }
1.987 + }
1.988 + if (token.Compare(_L("}"))!=0)
1.989 + FatalError(_L("too many results expected"));
1.990 + CleanupStack::PopAndDestroy(3); // arrays + colset
1.991 + iScript.ConsumeStatement();
1.992 + }
1.993 +
1.994 +//
1.995 +// same as Sql create statement, but adds a counter
1.996 +//
1.997 +void TScriptEngine::DoBuildTable()
1.998 + {
1.999 + // test its right function
1.1000 + TScriptToken keyword;
1.1001 + iScript.GetNextTokenFromStatement(keyword);
1.1002 + TEST2(keyword.CompareF(_L("BUILD")), 0);
1.1003 + //
1.1004 + TScriptLine sql(_L("CREATE "));
1.1005 + sql.Append(iScript.Statement());
1.1006 + TInt pos=sql.Find(_L("("));
1.1007 + sql.Insert(++pos,_L("Rw COUNTER,"));
1.1008 + iScript.ConsumeStatement();
1.1009 + ExecuteSql(sql);
1.1010 + }
1.1011 +
1.1012 +//
1.1013 +// same as Sql select statement, but makes sure counter is included
1.1014 +//
1.1015 +void TScriptEngine::DoQuery()
1.1016 + {
1.1017 + // test its right function
1.1018 + TScriptToken keyword;
1.1019 + iScript.GetNextTokenFromStatement(keyword);
1.1020 + TEST2(keyword.CompareF(_L("QUERY")), 0);
1.1021 + //
1.1022 + TScriptLine sql(iScript.Statement());
1.1023 + if (sql.Find(_L("*"))!=0)
1.1024 + {
1.1025 + sql.Insert(0,_L(","));
1.1026 + sql.Insert(0,KRowIdColName);
1.1027 + }
1.1028 + sql.Insert(0,_L("SELECT "));
1.1029 + iScript.ConsumeStatement();
1.1030 + ExecuteSql(sql);
1.1031 + }
1.1032 +
1.1033 +void TScriptEngine::FatalError(const TDesC& aLine)
1.1034 + {
1.1035 + iScript.WriteError(aLine);
1.1036 + TEST(0);
1.1037 + }
1.1038 +
1.1039 +void TScriptEngine::FatalError()
1.1040 + {
1.1041 + FatalError(_L("wrong expected value"));
1.1042 + }
1.1043 +
1.1044 +void TScriptEngine::FatalSqlError(const TDesC& aLine)
1.1045 + {
1.1046 + iScript.WriteSqlError(iResults,aLine);
1.1047 + TEST(0);
1.1048 + }
1.1049 +
1.1050 +void TScriptEngine::DoPopulate()
1.1051 + {
1.1052 + // check its right function
1.1053 + TScriptToken token;
1.1054 + iScript.GetNextTokenFromLine(token);
1.1055 + TEST2(token.CompareF(_L("POPULATE")), 0);
1.1056 + //
1.1057 + TScriptLine sqlbase=_L("INSERT INTO ");
1.1058 + iScript.GetNextTokenFromLine(token); // table name
1.1059 + sqlbase.AppendFormat(_L("%S "),&token);
1.1060 + iScript.GetNextTokenFromLine(token);
1.1061 + if (token.Compare(_L("("))==0) // optional column names present?
1.1062 + {
1.1063 + for (;;)
1.1064 + {
1.1065 + sqlbase.AppendFormat(token);
1.1066 + if (token.Compare(_L(")"))==0)
1.1067 + break;
1.1068 + iScript.GetNextTokenFromLine(token);
1.1069 + }
1.1070 + iScript.GetNextTokenFromLine(token);
1.1071 + }
1.1072 + if (token.Compare(_L("{"))!=0)
1.1073 + FatalError(_L("missing '{'"));
1.1074 + sqlbase.AppendFormat(_L(" VALUES ("));
1.1075 + iScript.GetNextTokenFromLine(token); // first value
1.1076 + TheDatabase.Begin(); // all in same transaction
1.1077 + for (;;)
1.1078 + {
1.1079 + if (token.Compare(_L("}"))==0)
1.1080 + break;
1.1081 + TScriptLine sql=sqlbase;
1.1082 + for (;;)
1.1083 + {
1.1084 + sql.Append(token);
1.1085 + iScript.GetNextTokenFromLine(token);
1.1086 + if (token.Compare(_L(","))==0)
1.1087 + {
1.1088 + sql.Append(token); // comma
1.1089 + iScript.GetNextTokenFromLine(token);
1.1090 + }
1.1091 + else
1.1092 + break;
1.1093 + }
1.1094 + sql.AppendFormat(_L(")"));
1.1095 + ExecuteSql(sql);
1.1096 + TestForNoError();
1.1097 + }
1.1098 + TheDatabase.Commit();
1.1099 + iScript.ConsumeStatement();
1.1100 + }
1.1101 +
1.1102 +void TScriptEngine::DoPrintL()
1.1103 + {
1.1104 + // check its right function
1.1105 + TScriptToken keyword;
1.1106 + iScript.GetNextTokenFromStatement(keyword);
1.1107 + TEST2(keyword.CompareF(_L("PRINT")), 0);
1.1108 + //
1.1109 + iScript.GetNextTokenFromStatement(keyword);
1.1110 + if (keyword.CompareF(_L("VIEW"))==0)
1.1111 + PrintL(iResults.iView);
1.1112 + else if (keyword.CompareF(_L("TABLE"))==0)
1.1113 + {
1.1114 + iScript.GetNextTokenFromStatement(keyword); // name of table
1.1115 + RDbTable table;
1.1116 + TInt err=table.Open(TheDatabase,keyword,table.EReadOnly);
1.1117 + if (err!=KErrNone)
1.1118 + FatalError(_L("unable to open table"));
1.1119 + PrintL(table);
1.1120 + table.Close();
1.1121 + }
1.1122 + else
1.1123 + FatalError(_L("expected VIEW or TABLE keyword not present"));
1.1124 + }
1.1125 +
1.1126 +void TScriptEngine::DoCompareL()
1.1127 + {
1.1128 + // check its right function
1.1129 + TScriptToken keyword;
1.1130 + iScript.GetNextTokenFromLine(keyword);
1.1131 + TEST2(keyword.CompareF(_L("COMPARE")), 0);
1.1132 + //
1.1133 + iScript.GetNextTokenFromLine(keyword);
1.1134 + if (keyword.CompareF(_L("VIEW"))==0)
1.1135 + CompareL(iResults.iView);
1.1136 + else if (keyword.CompareF(_L("TABLE"))==0)
1.1137 + {
1.1138 + iScript.GetNextTokenFromLine(keyword); // name of table
1.1139 + RDbTable table;
1.1140 + TInt err=table.Open(TheDatabase,keyword,table.EReadOnly);
1.1141 + if (err!=KErrNone)
1.1142 + FatalError(_L("unable to open table"));
1.1143 + CompareL(table);
1.1144 + table.Close();
1.1145 + }
1.1146 + else
1.1147 + FatalError(_L("expected VIEW or TABLE keyword not present"));
1.1148 + }
1.1149 +
1.1150 +void TScriptEngine::CompareL(RDbRowSet& aRowSet)
1.1151 + {
1.1152 + TScriptToken token;
1.1153 + iScript.GetNextTokenFromLine(token);
1.1154 + TBool rowIdMode=EFalse;
1.1155 + CArrayFixFlat<TInt>* rowIdToTest=new CArrayFixFlat<TInt>(4);
1.1156 + CleanupStack::PushL(rowIdToTest);
1.1157 + if (token.Compare(_L("("))==0) // optional row ids present?
1.1158 + {
1.1159 + rowIdMode=ETrue;
1.1160 + iScript.GetNextTokenFromLine(token); // first value
1.1161 + TLex value;
1.1162 + TInt rowId;
1.1163 + for (;;)
1.1164 + {
1.1165 + value=token;
1.1166 + TEST2(value.Val(rowId), KErrNone);
1.1167 + rowIdToTest->AppendL(rowId); // add row id to array
1.1168 + iScript.GetNextTokenFromLine(token);
1.1169 + if (token.Compare(_L(")"))==0)
1.1170 + break;
1.1171 + if (token.Compare(_L(","))==0)
1.1172 + iScript.GetNextTokenFromLine(token);
1.1173 + }
1.1174 + iScript.GetNextTokenFromLine(token);
1.1175 + }
1.1176 + if (token.Compare(_L("{"))!=0)
1.1177 + FatalError(_L("missing '{'"));
1.1178 + TInt columns=aRowSet.ColCount();
1.1179 + CDbColSet* colset=aRowSet.ColSetL();
1.1180 + aRowSet.BeginningL();
1.1181 + while (aRowSet.NextL())
1.1182 + {
1.1183 + aRowSet.GetL();
1.1184 + if (rowIdMode)
1.1185 + {
1.1186 + TInt currentId=aRowSet.ColUint(colset->ColNo(KRowIdColName));
1.1187 + TBool toTest=EFalse;
1.1188 + for (TInt jj=0; jj<rowIdToTest->Count(); ++jj)
1.1189 + {
1.1190 + if (currentId==(*rowIdToTest)[jj])
1.1191 + toTest=ETrue;
1.1192 + }
1.1193 + if (!toTest)
1.1194 + continue;
1.1195 + }
1.1196 + for (TInt ii=1;ii<=columns;++ii)
1.1197 + {
1.1198 + if (rowIdMode && ii==colset->ColNo(KRowIdColName)) // ignore row id column
1.1199 + continue;
1.1200 + const TDbCol& col=(*colset)[ii];
1.1201 + iScript.GetNextTokenFromLine(token); // value
1.1202 + if (token.Compare(_L(","))==0)
1.1203 + iScript.GetNextTokenFromLine(token); // ignore comma
1.1204 + if (aRowSet.IsColNull(ii))
1.1205 + {
1.1206 + if (token.CompareF(_L("NULL"))!=0)
1.1207 + FatalError(_L("NULL expected"));
1.1208 + continue;
1.1209 + }
1.1210 + CompareValues(aRowSet,ii,col.iType,token);
1.1211 + }
1.1212 + }
1.1213 + delete colset;
1.1214 + CleanupStack::PopAndDestroy(); // rowIdToTest
1.1215 + iScript.GetNextTokenFromLine(token); // look for closing '}'
1.1216 + if (token.Compare(_L("}"))!=0)
1.1217 + FatalError(_L("missing '}'"));
1.1218 + iScript.ConsumeStatement();
1.1219 + }
1.1220 +
1.1221 +//
1.1222 +// compares the value from a rowset aRowset, colimn number aColNo and of type aType, with the value
1.1223 +// contained in the descriptor aToken
1.1224 +//
1.1225 +void TScriptEngine::CompareValues(RDbRowSet& aRowSet,TDbColNo ColNo,TDbColType aType,const TDesC& aToken)
1.1226 + {
1.1227 + TLex value=aToken;
1.1228 + switch (aType)
1.1229 + {
1.1230 + case EDbColInt32:
1.1231 + {
1.1232 + TInt num;
1.1233 + TEST2(value.Val(num), KErrNone);
1.1234 + if (num!=aRowSet.ColInt(ColNo))
1.1235 + FatalError();
1.1236 + break;
1.1237 + }
1.1238 + case EDbColInt8:
1.1239 + {
1.1240 + TInt8 num8;
1.1241 + TEST2(value.Val(num8), KErrNone);
1.1242 + if (num8!=aRowSet.ColInt8(ColNo))
1.1243 + FatalError();
1.1244 + break;
1.1245 + }
1.1246 + case EDbColInt16:
1.1247 + {
1.1248 + TInt16 num16;
1.1249 + TEST2(value.Val(num16), KErrNone);
1.1250 + if (num16!=aRowSet.ColInt16(ColNo))
1.1251 + FatalError();
1.1252 + break;
1.1253 + }
1.1254 + case EDbColInt64:
1.1255 + {
1.1256 + TInt64 num64;
1.1257 + TEST2(value.Val(num64), KErrNone);
1.1258 + if (num64!=aRowSet.ColInt64(ColNo))
1.1259 + FatalError();
1.1260 + break;
1.1261 + }
1.1262 + case EDbColUint8:
1.1263 + {
1.1264 + TUint8 numu8;
1.1265 + TEST2(value.Val(numu8,EDecimal), KErrNone);
1.1266 + if (numu8!=aRowSet.ColUint8(ColNo))
1.1267 + FatalError();
1.1268 + break;
1.1269 + }
1.1270 + case EDbColUint16:
1.1271 + {
1.1272 + TUint16 numu16;
1.1273 + TEST2(value.Val(numu16,EDecimal), KErrNone);
1.1274 + if (numu16!=aRowSet.ColUint16(ColNo))
1.1275 + FatalError();
1.1276 + break;
1.1277 + }
1.1278 + case EDbColUint32:
1.1279 + {
1.1280 + TUint32 numu32;
1.1281 + TEST2(value.Val(numu32,EDecimal), KErrNone);
1.1282 + if (numu32!=aRowSet.ColUint32(ColNo))
1.1283 + FatalError();
1.1284 + break;
1.1285 + }
1.1286 + case EDbColReal32:
1.1287 + {
1.1288 + TReal32 numr32;
1.1289 + TEST2(value.Val(numr32), KErrNone);
1.1290 + if (numr32!=aRowSet.ColReal32(ColNo))
1.1291 + FatalError();
1.1292 + break;
1.1293 + }
1.1294 + case EDbColReal64:
1.1295 + {
1.1296 + TReal64 numr64;
1.1297 + TEST2(value.Val(numr64), KErrNone);
1.1298 + if (numr64!=aRowSet.ColReal64(ColNo))
1.1299 + FatalError();
1.1300 + break;
1.1301 + }
1.1302 + case EDbColText8:
1.1303 + case EDbColText16:
1.1304 + {
1.1305 + TPtrC text=aToken.Mid(1,aToken.Length()-2); // skip quotes
1.1306 + if (text.CompareF(aRowSet.ColDes(ColNo))!=0)
1.1307 + FatalError();
1.1308 + break;
1.1309 + }
1.1310 + case EDbColDateTime:
1.1311 + {
1.1312 + TScriptLine time=aToken.Mid(1,aToken.Length()-2); // skip hashes
1.1313 + TTime t1;
1.1314 + t1.Parse(time);
1.1315 + TTime t2(aRowSet.ColTime(ColNo).DateTime());
1.1316 + if (t1!=t2)
1.1317 + FatalError();
1.1318 + break;
1.1319 + }
1.1320 + default:
1.1321 + break;
1.1322 + }
1.1323 + }
1.1324 +
1.1325 +void TScriptEngine::PrintL(RDbRowSet& aRowSet)
1.1326 + {
1.1327 + iScript.WriteLine(TPtrC());
1.1328 + TInt columns=aRowSet.ColCount();
1.1329 + CDbColSet* colset=aRowSet.ColSetL();
1.1330 + TScriptLine line;
1.1331 + for (TInt i=1;i<=columns;++i)
1.1332 + {
1.1333 + const TDbCol& col=(*colset)[i];
1.1334 + line.AppendFormat(_L("%S\t"),&col.iName);
1.1335 + }
1.1336 + iScript.WriteLine(line);
1.1337 + aRowSet.BeginningL();
1.1338 + while (aRowSet.NextL())
1.1339 + {
1.1340 + line=TPtrC();
1.1341 + for (TInt ii=1;ii<=columns;++ii)
1.1342 + {
1.1343 + const TDbCol& col=(*colset)[ii];
1.1344 + aRowSet.GetL();
1.1345 + if (aRowSet.IsColNull(ii))
1.1346 + {
1.1347 + line.AppendFormat(_L("NULL\t"));
1.1348 + continue;
1.1349 + }
1.1350 + switch (col.iType)
1.1351 + {
1.1352 + case EDbColInt32:
1.1353 + line.AppendFormat(_L("%d\t"),aRowSet.ColInt(ii));
1.1354 + break;
1.1355 + case EDbColInt8:
1.1356 + line.AppendFormat(_L("%d\t"),aRowSet.ColInt8(ii));
1.1357 + break;
1.1358 + case EDbColInt16:
1.1359 + line.AppendFormat(_L("%d\t"),aRowSet.ColInt16(ii));
1.1360 + break;
1.1361 + case EDbColInt64:
1.1362 + line.AppendFormat(_L("%ld\t"),aRowSet.ColInt64(ii));
1.1363 + break;
1.1364 + case EDbColUint8:
1.1365 + line.AppendFormat(_L("%u\t"),aRowSet.ColUint8(ii));
1.1366 + break;
1.1367 + case EDbColUint16:
1.1368 + line.AppendFormat(_L("%u\t"),aRowSet.ColUint16(ii));
1.1369 + break;
1.1370 + case EDbColUint32:
1.1371 + line.AppendFormat(_L("%u\t"),aRowSet.ColUint(ii));
1.1372 + break;
1.1373 + case EDbColReal32:
1.1374 + line.AppendFormat(_L("%f\t"),aRowSet.ColReal32(ii));
1.1375 + break;
1.1376 + case EDbColReal64:
1.1377 + line.AppendFormat(_L("%f\t"),aRowSet.ColReal64(ii));
1.1378 + break;
1.1379 + case EDbColText:
1.1380 + line.Append(aRowSet.ColDes(ii));
1.1381 + line.Append('\t');
1.1382 + break;
1.1383 + case EDbColDateTime:
1.1384 + {
1.1385 + TDateTime time(aRowSet.ColTime(ii).DateTime());
1.1386 + line.AppendFormat(_L("%d:%d:%d %d/%d/%d"),time.Hour(),time.Minute(),time.Second(),time.Day(),time.Month(),time.Year());
1.1387 + }
1.1388 + break;
1.1389 + case EDbColLongText:
1.1390 + {
1.1391 + RDbColReadStream blob;
1.1392 + blob.OpenLC(aRowSet,ii);
1.1393 + TScriptLine text;
1.1394 + blob.ReadL(text,aRowSet.ColLength(ii));
1.1395 + CleanupStack::PopAndDestroy();
1.1396 + line.AppendFormat(_L("%S\t"),&text);
1.1397 + }
1.1398 + default:
1.1399 + break;
1.1400 + }
1.1401 + }
1.1402 + iScript.WriteLine(line);
1.1403 + }
1.1404 + iScript.WriteLine(TPtrC());
1.1405 + delete colset;
1.1406 + }
1.1407 +
1.1408 +
1.1409 +//
1.1410 +// Create the database
1.1411 +//
1.1412 +LOCAL_C void CreateDatabase()
1.1413 + {
1.1414 + TEST2(TheDatabase.Replace(TheFs,KTestDatabase), KErrNone);
1.1415 + }
1.1416 +
1.1417 +//
1.1418 +// Close the database
1.1419 +//
1.1420 +LOCAL_C void CloseDatabase()
1.1421 + {
1.1422 + TheDatabase.Close();
1.1423 + }
1.1424 +
1.1425 +//
1.1426 +// Prepare the test directory.
1.1427 +//
1.1428 +LOCAL_C void SetupTestDirectory()
1.1429 + {
1.1430 + TInt err=TheFs.Connect();
1.1431 + TEST2(err, KErrNone);
1.1432 +//
1.1433 + err=TheFs.MkDir(KTestDatabase);
1.1434 + TEST(err==KErrNone || err==KErrAlreadyExists);
1.1435 + }
1.1436 +
1.1437 +//
1.1438 +// Initialise the cleanup stack.
1.1439 +//
1.1440 +LOCAL_C void SetupCleanup()
1.1441 + {
1.1442 + TheTrapCleanup=CTrapCleanup::New();
1.1443 + TEST(TheTrapCleanup!=NULL);
1.1444 + TRAPD(err,\
1.1445 + {\
1.1446 + for (TInt i=KTestCleanupStack;i>0;i--)\
1.1447 + CleanupStack::PushL((TAny*)0);\
1.1448 + CleanupStack::Pop(KTestCleanupStack);\
1.1449 + });
1.1450 + TEST2(err, KErrNone);
1.1451 + }
1.1452 +
1.1453 +/**
1.1454 +@SYMTestCaseID SYSLIB-DBMS-CT-0632
1.1455 +@SYMTestCaseDesc Executes the script files
1.1456 +@SYMTestPriority Medium
1.1457 +@SYMTestActions Start the script engine
1.1458 +@SYMTestExpectedResults Test must not fail
1.1459 +@SYMREQ REQ0000
1.1460 +*/
1.1461 +LOCAL_C void RunScriptL()
1.1462 + {
1.1463 + TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0632 Running script "));
1.1464 + CreateDatabase();
1.1465 + TScriptEngine script;
1.1466 + script.RunL();
1.1467 + CloseDatabase();
1.1468 + TheView.Close();
1.1469 + }
1.1470 +
1.1471 +//
1.1472 +// entry point
1.1473 +//
1.1474 +GLDEF_C TInt E32Main()
1.1475 + {
1.1476 + TheTest.Title();
1.1477 + SetupTestDirectory();
1.1478 + SetupCleanup();
1.1479 + __UHEAP_MARK;
1.1480 +//
1.1481 + TRAPD(err,RunScriptL());
1.1482 + TEST2(err, KErrNone);
1.1483 +
1.1484 + //deletion of data files must be done before call to end - DEF047652
1.1485 + ::DeleteDataFile(KTestDatabase);
1.1486 + ::DeleteDataFile(KOutputFile);//Comment this line if you want to keep "t_script.log" file.
1.1487 + TheTest.End();
1.1488 +//
1.1489 + __UHEAP_MARKEND;
1.1490 + delete TheTrapCleanup;
1.1491 +
1.1492 + TheFs.Close();
1.1493 + TheTest.Close();
1.1494 +
1.1495 + return 0;
1.1496 + }