db.php

Go to the documentation of this file.

<?php


class DB_Virtuoso
{
  private $db_host;

  private $db_user;

  private $db_pass;

  private $dsn;

  private $resultset;

  private $db_link;

  private $queryProcessTime = 0; // In milliseconds

  public function DB_Virtuoso($username, $password, $dsn, $host)
  {
    // Connection Database informations
    $this->db_host = $host;
    $this->db_user = $username;
    $this->db_pass = $password;
    $this->dsn = $dsn;

    $this->connect();
  }

  private function connect()
  {
    $this->db_link = odbc_connect($this->dsn, $this->db_user, $this->db_pass, SQL_CUR_USE_ODBC);

    //    odbc_binmode(0, 1);
    //    odbc_longreadlen(0, 65534);

    //    ini_set("odbc.defaultlrl", "65534");

    return;
  }

  public function getError() { return (odbc_error($this->db_link)); }

  public function getErrorMsg() { return (odbc_errormsg($this->db_link)); }

  public function query($db_query, $benchmark = FALSE)
  {
    if(isset($_GET['benchmark']) && $_GET['benchmark'] == 1)
    {
      //  Start TIMER
      //  -----------
      $stimer = explode(' ', microtime());
      $stimer = $stimer[1] + $stimer[0];
      //  -----------

      $resultset = odbc_exec($this->db_link, $db_query);

      //  End TIMER
      //  ---------
      $etimer = explode(' ', microtime());
      $etimer = $etimer[1] + $etimer[0];
      //  ---------

      $this->queryProcessTime = (($etimer - $stimer) * 1000);

      echo "<div>";

      echo "Sparql query: <em>" . str_replace(array ("<", ">"), array ("&lt;", "&gt;"), $db_query) . "</em><br>";

      echo "Execution time: " . $this->queryProcessTime . " milliseconds<br><br>\n";

      echo "</div>";
    }

    if((isset($_GET['debug']) && $_GET['debug'] == 2) || $benchmark === TRUE)
    {
      //  Start TIMER
      //  -----------
      $stimer = explode(' ', microtime());
      $stimer = $stimer[1] + $stimer[0];
      //  -----------

      $resultset = odbc_exec($this->db_link, $db_query);

      //  End TIMER
      //  ---------
      $etimer = explode(' ', microtime());
      $etimer = $etimer[1] + $etimer[0];
      //  ---------

      $this->queryProcessTime = (($etimer - $stimer) * 1000);

      if(isset($_GET['debug']) && $_GET['debug'] == 2)
      {
        echo '<p style="margin:auto; text-align:center">';
        printf("Query <em>" . str_replace(array ("<", ">"), array ("&lt;", "&gt;"), $db_query)
          . "</em> loaded in <b>%f</b> milliseconds.", $this->queryProcessTime);

        echo '</p>';
      }

      return ($resultset);
    }

    return (@odbc_exec($this->db_link, $db_query));
  }


  public function close()
  {
    @odbc_close($this->db_link);

    $this->delete();
  }


  private function delete() { unset($this); }

  public function build_sparql_query($query, $query_variables, $sponger)
  {
    $sparql_query = "exst('";

    if(count($query_variables) > 0)
    {
      $sparql_query .= "select ";

      foreach($query_variables as $variable)
      {
        $sparql_query .= $variable . " as " . $variable . ", ";
      }
      $sparql_query = substr($sparql_query, 0, strlen($sparql_query) - 2);
      $sparql_query .= " from (";
    }
    else
    {
      $sparql_query .= "select * from (";
    }

    $sparql_query .= "SPARQL ";

    if($sponger == TRUE)
    {
      $sparql_query .= " define get:soft \"replacing\" ";
    //    $sparql_query .= " define get:soft \"soft\" ";
    }

    $sparql_query .= $query;

    $sparql_query .= ") sub')";

    return $sparql_query;
  }
}


?>