#!perl

# Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

# All rights reserved.

# This component and the accompanying materials are made available

# under the terms of "Eclipse Public License v1.0"

# which accompanies this distribution, and is available

# at the URL "http://www.eclipse.org/legal/epl-v10.html".

#

# Initial Contributors:

# Nokia Corporation - initial contribution.

#

# Contributors:

#

# Description:

# Script to upload performance or other data embedded as SQL statements

# in test execute output logs.

#

# This script keys off "SQL_UPLOAD_VERSION_0:" and "SQL_SESSION_ID=" tags for

# data extraction.

use Getopt::Long;

use File::Basename;

use File::Find;

use Cwd;

# The default perl install does not provide the mysql database driver, needed

# to connect to a MySQL database.  For convenience we deliver a pure perl

# implementation locally.  This application can use such GPL modules under the

# System Library exception of GPL.  If this script needs to be called from

# another directory, then the 'use lib ".";' directive won't work.  To resolve

# this problem, run the script "perl installmysqlperlmodule.pl" first.

use lib ".";

use MySQL;

use strict;

use warnings;

our ($searchRoot, $helpOnUsage, $jobId);

our @globalFileList;

our @globalSessionTransaction;

our @bulkSqlTransaction;

sub Usage

	{

	my ($aRequireParameter,$aMissingParameter) = @_;

	$aRequireParameter = 0 if not defined $aRequireParameter;

  	print <<END_OF_USAGE_TEXT;

Usage: perl uploadsqlfromtestrun.pl --dir=searchRootDir --job=jobID [--help]

Note this script requires the Net::MySQL package to either be installed or

to be supplied in the search path.  An example such commandline is:

   Q:\\>perl -IQ:\\epoc32\\release\\winscw\\udeb\\z\\uibench

   \\epoc32\\release\\winscw\\udeb\\z\\uibench\\uploadsqlfromtestrun.pl

   --dir=\\epoc32\\winscw\\c\\logs\\testexecute

   --job=655433

This script recurses through searchRootDir looking for htm files containing

<prefix>SQL_UPLOAD_VERSION_0:<sql commands>

upon which it invokes those <sql commands>

It also looks for 

<prefix>SQL_SESSION_ID=<session value>

upon which it associates the supplied integer jobID with the <session value>

in the database.  In the database these identifiers are unsigned integers:

jobid         int(10)    unsigned

sessionid     bigint(20) unsigned

The jobID would normally come from the overnight build system.  Low numbered

jobIDs, i.e. those <10000, would not collide with the build system and so can

be used when running this script interactively outside the context of a build

system.

The help option (--help, -h or -?) prints this message

END_OF_USAGE_TEXT

	if (defined $aMissingParameter)

		{	

  		print "Error: Parameter \"--$aMissingParameter\" missing\n"

  		}

 	exit $aRequireParameter;

	}

sub RemoveBackSlashes

	{

	my ($aPath) = @_;

	$aPath =~ s/\\/\//g;

	return $aPath;

	}

sub AddToGlobalFileList

	{

	my $aFile = $_;

	if (-f $aFile && $aFile =~ /.*.htm$/i)

		{

		push @main::globalFileList, $File::Find::name;

		}

	}

sub ParseFiles()

	{

	foreach my $file (@main::globalFileList)

		{

		open (FILE, "$file");		

		foreach my $line (<FILE>)

			{

			if ($line =~ /.*SQL_UPLOAD_VERSION_0:*/i)

				{

				$line =~ s/.*SQL_UPLOAD_VERSION_0://g;

				push @main::bulkSqlTransaction, $line;

				}

			if ($line =~ /.*SQL_SESSION_ID=/i)

				{

				$line =~ s/.*SQL_SESSION_ID=//g;

				chomp $line;

				$line = "INSERT INTO performance.jobsessionmap (jobid, sessionid) VALUES ('"

						. $main::jobId . "', '"

						. $line . "');\n"

						;

				push @main::globalSessionTransaction, $line;

				}

			}

		close FILE;

		}

	}

sub connectToSqlDatabase

	{

	return

		Net::MySQL->new(

		hostname => '4GBD02346',

		database => 'performance',

		user     => 'uibench',

		password => 'grui'

		);

	}

sub UploadSqlData()

	{

	my $dbHandle;

	$dbHandle = connectToSqlDatabase();

	$dbHandle->query(@bulkSqlTransaction);

	die if ($dbHandle->is_error);

	$dbHandle->close;

	# We are re-creating the connection to the database because this forces

	# the underlying client-server transaction to flush its socket.  There

	# is no flush API that the MySQL perl module gives us.  If we don't do

	# this, the transaction completes without errors, but does not actually

	# put the session rows into the database!

	$dbHandle = connectToSqlDatabase();

	$dbHandle->query(@globalSessionTransaction);

	$dbHandle->close;

	}

GetOptions ('dir=s' => \$searchRoot,

            'job=s' => \$jobId,

            'help|h|?' =>\$helpOnUsage) || Usage();

Usage(0) if $helpOnUsage;

Usage(1,'dir') if not defined $searchRoot;

Usage(1,'job') if not defined $jobId;

$searchRoot = RemoveBackSlashes($searchRoot);

@globalFileList = ();

find(\&AddToGlobalFileList, ($searchRoot));

@bulkSqlTransaction = ();

@globalSessionTransaction  = ();

ParseFiles();

UploadSqlData();