statisticsBroker.php

Go to the documentation of this file.

<?php
    
   
  /*
    Set this variable to TRUE is you want to make your statistics available publicly.
    If this variable is set to TRUE, it means that anybody will be able to get statistics
    of your structWSF instance by query the script at this address:
      
      http://[your-web-site]/ws/statisticsBroker.php
      
    If you don't want to, you can simply remove this file from your web server.  
  */
  $enableStatisticsBroadcast = FALSE;
  
  
  if($enableStatisticsBroadcast) 
  {
    include_once("framework/WebService.php");
    include_once("framework/db.php");

    $data_ini = parse_ini_file(WebService::$data_ini . "data.ini", TRUE);

    $db = new DB_Virtuoso($data_ini["triplestore"]["username"], $data_ini["triplestore"]["password"],
      $data_ini["triplestore"]["dsn"], $data_ini["triplestore"]["host"]);
                  

    $sparql = " select count(?record) as ?nb_records
                from <".$data_ini["datasets"]["wsf_graph"]."datasets/>
                where
                {
                  ?dataset a <http://rdfs.org/ns/void#Dataset>.
                  graph ?dataset
                  {
                    ?record a ?type.
                  }
                }";
    
                             
    $resultset = @$db->query($db->build_sparql_query(str_replace(array ("\n", "\r", "\t"), " ", $sparql), array(), FALSE));

    $nbRecords = "0";  
    if(!odbc_error())
    {
      $nbRecords = odbc_result($resultset, 1);
    }        

    $sparql = " select count(?dataset) as ?nb_datasets
                from <".$data_ini["datasets"]["wsf_graph"]."datasets/>
                where
                {
                  ?dataset a <http://rdfs.org/ns/void#Dataset>.
                }";
    
                             
    $resultset = @$db->query($db->build_sparql_query(str_replace(array ("\n", "\r", "\t"), " ", $sparql), array(), FALSE));

    $nbDatasets = "0";  
    if(!odbc_error())
    {
      $nbDatasets = odbc_result($resultset, 1);
    }       
    
    $sparql = " select count(?o) as ?nb_triples
                from <".$data_ini["datasets"]["wsf_graph"]."datasets/>
                where
                {
                  ?dataset a <http://rdfs.org/ns/void#Dataset>.
                  graph ?dataset
                  {
                    ?record ?p ?o.
                  }
                }";
    
                             
    $resultset = @$db->query($db->build_sparql_query(str_replace(array ("\n", "\r", "\t"), " ", $sparql), array(), FALSE));

    $nbTriples = "0";  
    if(!odbc_error())
    {
      $nbTriples = odbc_result($resultset, 1);
    }        
     


    $statisticsXML = "<statistics>\n";
    
    $statisticsXML .= "  <datasets nb=\"$nbDatasets\" nbTriples=\"$nbTriples\" nbRecords=\"$nbRecords\" />\n";

    
    
    $statisticsXML .= "  <webservices>\n";

    $resultset = @$db->query("select distinct requested_web_service from ".$data_ini["triplestore"]["log_table"]);

    $webservices = array();
    
    if(!odbc_error())
    {
      while(odbc_fetch_row($resultset))
      {     
          array_push($webservices, odbc_result($resultset, 1));
      }
    }        
    
    foreach($webservices as $ws)
    {
      $resultset = @$db->query("select count(*) from ".$data_ini["triplestore"]["log_table"]." where requested_web_service = '$ws'");

      $nbQueries = "0";    
      if(!odbc_error())
      {
        $nbQueries = odbc_result($resultset, 1);
      }      
      

      $resultset = @$db->query("select avg(request_processing_time) as average from ".$data_ini["triplestore"]["log_table"]." where 
                                requested_web_service = '$ws'");

      $averageTime = "0";    
      if(!odbc_error())
      {
        $averageTime = odbc_result($resultset, 1);
      }      
      
      $statisticsXML .= "    <".str_replace("/", "_", $ws)." nbQueries=\"$nbQueries\" averageTimePerQuery=\"$averageTime\">\n";
      
      $statisticsXML .= "      <httpMessages>\n";
      
      $resultset = @$db->query("select distinct request_http_response_status, count(request_http_response_status) as nb 
                                from ".$data_ini["triplestore"]["log_table"]." where requested_web_service = '$ws' 
                                group by request_http_response_status");

      if(!odbc_error())
      {
        while(odbc_fetch_row($resultset))
        {     
            $statisticsXML .= "        <msg type=\"".odbc_result($resultset, 1)."\" count=\"".odbc_result($resultset, 2).
                              "\" />\n";
        }
      }    
      
      $statisticsXML .= "      </httpMessages>\n";


      $statisticsXML .= "      <requestedMimes>\n";
      
      $resultset = @$db->query("select distinct requested_mime, count(requested_mime) as nb from ".$data_ini["triplestore"]["log_table"]." ".
                               "where requested_web_service = '$ws' group by requested_mime");

      if(!odbc_error())
      {
        while(odbc_fetch_row($resultset))
        {     
            $statisticsXML .= "        <mime type=\"".odbc_result($resultset, 1)."\" count=\"".odbc_result($resultset, 2).
                              "\" />\n";
        }
      }    
      
      $statisticsXML .= "      </requestedMimes>\n";

      
      $statisticsXML .= "    </".str_replace("/", "_", $ws).">\n";
    }  
    
    $statisticsXML .= "  </webservices>\n";

    
    
    $statisticsXML .= "</statistics>\n";
   
    header("Content-Type: text/xml; charset=utf-8");
    
    echo $statisticsXML;
  }
   
   
?>