OpenStructs

structWSF
Code Documentation

• Login
• Blog

• Home
• structWSF
• Resources
• Downloads

CrudCreate.php

Go to the documentation of this file.

<?php


class CrudCreate extends WebService
{
  private $db;

  private $conneg;

  private $dtdURL;

  public static $supportedSerializations =
    array ("application/json", "application/rdf+xml", "application/rdf+n3", "application/*", "text/xml", "text/*",
      "*/*");

  private $registered_ip = "";

  private $dataset;

  private $document = array();

  private $mime = "";

  private $requester_ip = "";

  private $errorMessenger =
    '{
                        "ws": "/ws/crud/create/",
                        "_200": {
                          "id": "WS-CRUD-CREATE-200",
                          "level": "Warning",
                          "name": "No RDF document to index",
                          "description": "No RDF document has been defined for this query"
                        },
                        "_201": {
                          "id": "WS-CRUD-CREATE-201",
                          "level": "Warning",
                          "name": "Unknown MIME type for this RDF document",
                          "description": "An unknown MIME type has been defined for this RDF document"
                        },
                        "_202": {
                          "id": "WS-CRUD-CREATE-202",
                          "level": "Warning",
                          "name": "No dataset specified",
                          "description": "No dataset URI defined for this query"
                        },
                        "_300": {
                          "id": "WS-CRUD-CREATE-300",
                          "level": "Fatal",
                          "name": "Can\'t create data",
                          "description": "Can\'t create data of the specified format"
                        },
                        "_301": {
                          "id": "WS-CRUD-CREATE-301",
                          "level": "Warning",
                          "name": "Can\'t parse RDF document",
                          "description": "Can\'t parse the specified RDF document"
                        },
                        "_302": {
                          "id": "WS-CRUD-CREATE-302",
                          "level": "Warning",
                          "name": "Syntax error in the RDF document",
                          "description": "A syntax error exists in the specified RDF document"
                        },
                        "_303": {
                          "id": "WS-CRUD-CREATE-303",
                          "level": "Fatal",
                          "name": "Can\'t update the Solr index",
                          "description": "An error occured when we tried to update the Solr index"
                        },
                        "_304": {
                          "id": "WS-CRUD-CREATE-304",
                          "level": "Fatal",
                          "name": "Can\'t commit changes to the Solr index",
                          "description": "An error occured when we tried to commit changes to the Solr index"
                        }  
                      }';


  function __construct($document, $mime, $mode, $dataset, $registered_ip, $requester_ip)
  {
    parent::__construct();

    $this->db = new DB_Virtuoso($this->db_username, $this->db_password, $this->db_dsn, $this->db_host);

    $this->registered_ip = $registered_ip;
    $this->requester_ip = $requester_ip;
    $this->dataset = $dataset;

    $this->document = utf8_encode($document);
    $this->mime = $mime;
    $this->mode = $mode;

    if($this->registered_ip == "")
    {
      $this->registered_ip = $requester_ip;
    }

    if(strtolower(substr($this->registered_ip, 0, 4)) == "self")
    {
      $pos = strpos($this->registered_ip, "::");

      if($pos !== FALSE)
      {
        $account = substr($this->registered_ip, $pos + 2, strlen($this->registered_ip) - ($pos + 2));

        $this->registered_ip = $requester_ip . "::" . $account;
      }
      else
      {
        $this->registered_ip = $requester_ip;
      }
    }

    $this->uri = $this->wsf_base_url . "/wsf/ws/crud/create/";
    $this->title = "Crud Create Web Service";
    $this->crud_usage = new CrudUsage(TRUE, FALSE, FALSE, FALSE);
    $this->endpoint = $this->wsf_base_url . "/ws/crud/create/";

    $this->dtdURL = "auth/CrudCreate.dtd";

    $this->errorMessenger = json_decode($this->errorMessenger);
  }

  function __destruct()
  {
    parent::__destruct();

    if(isset($this->db))
    {
      @$this->db->close();
    }
  }

  protected function validateQuery()
  {
    // Validation of the "requester_ip" to make sure the system that is sending the query as the rights.
    $ws_av = new AuthValidator($this->requester_ip, $this->dataset, $this->uri);

    $ws_av->pipeline_conneg($this->conneg->getAccept(), $this->conneg->getAcceptCharset(),
      $this->conneg->getAcceptEncoding(), $this->conneg->getAcceptLanguage());

    $ws_av->process();

    if($ws_av->pipeline_getResponseHeaderStatus() != 200)
    {
      $this->conneg->setStatus($ws_av->pipeline_getResponseHeaderStatus());
      $this->conneg->setStatusMsg($ws_av->pipeline_getResponseHeaderStatusMsg());
      $this->conneg->setStatusMsgExt($ws_av->pipeline_getResponseHeaderStatusMsgExt());
      $this->conneg->setError($ws_av->pipeline_getError()->id, $ws_av->pipeline_getError()->webservice,
        $ws_av->pipeline_getError()->name, $ws_av->pipeline_getError()->description,
        $ws_av->pipeline_getError()->debugInfo, $ws_av->pipeline_getError()->level);

      return;
    }

    unset($ws_av);

    // Validation of the "registered_ip" to make sure the user of this system has the rights
    $ws_av = new AuthValidator($this->registered_ip, $this->dataset, $this->uri);

    $ws_av->pipeline_conneg($this->conneg->getAccept(), $this->conneg->getAcceptCharset(),
      $this->conneg->getAcceptEncoding(), $this->conneg->getAcceptLanguage());

    $ws_av->process();

    if($ws_av->pipeline_getResponseHeaderStatus() != 200)
    {
      $this->conneg->setStatus($ws_av->pipeline_getResponseHeaderStatus());
      $this->conneg->setStatusMsg($ws_av->pipeline_getResponseHeaderStatusMsg());
      $this->conneg->setStatusMsgExt($ws_av->pipeline_getResponseHeaderStatusMsgExt());
      $this->conneg->setError($ws_av->pipeline_getError()->id, $ws_av->pipeline_getError()->webservice,
        $ws_av->pipeline_getError()->name, $ws_av->pipeline_getError()->description,
        $ws_av->pipeline_getError()->debugInfo, $ws_av->pipeline_getError()->level);
      return;
    }
  }

  public function pipeline_getError() { return ($this->conneg->error); }


  public function pipeline_getResultset() { return ""; }

  public function injectDoctype($xmlDoc)
  {
    $posHeader = strpos($xmlDoc, '"?>') + 3;
    $xmlDoc = substr($xmlDoc, 0, $posHeader)
      . "\n<!DOCTYPE resultset PUBLIC \"-//Structured Dynamics LLC//Crud Create DTD 0.1//EN\" \"" . $this->dtdBaseURL
        . $this->dtdURL . "\">" . substr($xmlDoc, $posHeader, strlen($xmlDoc) - $posHeader);

    return ($xmlDoc);
  }

  public function ws_conneg($accept, $accept_charset, $accept_encoding, $accept_language)
  {
    $this->conneg =
      new Conneg($accept, $accept_charset, $accept_encoding, $accept_language, CrudCreate::$supportedSerializations);

    // Check for errors

    if($this->document == "")
    {
      $this->conneg->setStatus(400);
      $this->conneg->setStatusMsg("Bad Request");
      $this->conneg->setStatusMsgExt($this->errorMessenger->_200->name);
      $this->conneg->setError($this->errorMessenger->_200->id, $this->errorMessenger->ws,
        $this->errorMessenger->_200->name, $this->errorMessenger->_200->description, "",
        $this->errorMessenger->_200->level);
      return;
    }

    if($this->mime != "application/rdf+xml" && $this->mime != "application/rdf+n3")
    {
      $this->conneg->setStatus(400);
      $this->conneg->setStatusMsg("Bad Request");
      $this->conneg->setStatusMsgExt($this->errorMessenger->_201->name);
      $this->conneg->setError($this->errorMessenger->_201->id, $this->errorMessenger->ws,
        $this->errorMessenger->_201->name, $this->errorMessenger->_201->description, ($this->mime),
        $this->errorMessenger->_201->level);
      return;
    }

    if($this->dataset == "")
    {
      $this->conneg->setStatus(400);
      $this->conneg->setStatusMsg("Bad Request");
      $this->conneg->setStatusMsgExt($this->errorMessenger->_202->name);
      $this->conneg->setError($this->errorMessenger->_202->id, $this->errorMessenger->ws,
        $this->errorMessenger->_202->name, $this->errorMessenger->_202->description, "",
        $this->errorMessenger->_202->level);
      return;
    }

    // Check if the dataset is created

    $ws_dr = new DatasetRead($this->dataset, "false", "self",
      $this->wsf_local_ip); // Here the one that makes the request is the WSF (internal request).

    $ws_dr->pipeline_conneg($this->conneg->getAccept(), $this->conneg->getAcceptCharset(),
      $this->conneg->getAcceptEncoding(), $this->conneg->getAcceptLanguage());

    $ws_dr->process();

    if($ws_dr->pipeline_getResponseHeaderStatus() != 200)
    {
      $this->conneg->setStatus($ws_dr->pipeline_getResponseHeaderStatus());
      $this->conneg->setStatusMsg($ws_dr->pipeline_getResponseHeaderStatusMsg());
      $this->conneg->setStatusMsgExt($ws_dr->pipeline_getResponseHeaderStatusMsgExt());
      $this->conneg->setError($ws_dr->pipeline_getError()->id, $ws_dr->pipeline_getError()->webservice,
        $ws_dr->pipeline_getError()->name, $ws_dr->pipeline_getError()->description,
        $ws_dr->pipeline_getError()->debugInfo, $ws_dr->pipeline_getError()->level);
      return;
    }
  }

  public function pipeline_conneg($accept, $accept_charset, $accept_encoding, $accept_language)
    { $this->ws_conneg($accept, $accept_charset, $accept_encoding, $accept_language); }

  public function pipeline_getResponseHeaderStatus() { return $this->conneg->getStatus(); }

  public function pipeline_getResponseHeaderStatusMsg() { return $this->conneg->getStatusMsg(); }

  public function pipeline_getResponseHeaderStatusMsgExt() { return $this->conneg->getStatusMsgExt(); }

  public function pipeline_serialize() { return ""; }

  public function pipeline_serialize_reification() { return ""; }

  public function ws_serialize() { return ""; }

  public function ws_respond($content)
  {
    // First send the header of the request
    $this->conneg->respond();

    // second, send the content of the request

    // Make sure there is no error.
    if($this->conneg->getStatus() == 200)
    {
      echo $content;
    }

    $this->__destruct();
  }


  public function process()
  {
    // Make sure there was no conneg error prior to this process call
    if($this->conneg->getStatus() == 200)
    {
      $this->validateQuery();

      // If the query is still valid
      if($this->conneg->getStatus() == 200)
      {
        if($this->mime != "application/rdf+xml" && $this->mime != "application/rdf+n3")
        {
          $this->conneg->setStatus(400);
          $this->conneg->setStatusMsg("Bad Request");
          $this->conneg->setStatusMsgExt($this->errorMessenger->_300->name);
          $this->conneg->setError($this->errorMessenger->_300->id, $this->errorMessenger->ws,
            $this->errorMessenger->_300->name, $this->errorMessenger->_300->description,
            "Can't create data of format: " . $this->mime, $this->errorMessenger->_300->level);

          return;
        }

        // Get triples from ARC for some offline processing.
        $parser = ARC2::getRDFParser();
        $parser->parse($this->dataset, $this->document);
        $rdfxmlSerializer = ARC2::getRDFXMLSerializer();

        $resourceIndex = $parser->getSimpleIndex(0);

        if(count($parser->getErrors()) > 0)
        {
          $errorsOutput = "";
          $errors = $parser->getErrors();

          foreach($errors as $key => $error)
          {
            $errorsOutput .= "[Error #$key] $error\n";
          }

          $this->conneg->setStatus(400);
          $this->conneg->setStatusMsg("Bad Request");
          $this->conneg->setError($this->errorMessenger->_301->id, $this->errorMessenger->ws,
            $this->errorMessenger->_301->name, $this->errorMessenger->_301->description, $errorsOutput,
            $this->errorMessenger->_301->level);

          return;
        }

        // First: check for a void:Dataset description to add to the "dataset description graph" of structWSF
        $break = FALSE;
        $datasetUri;

        foreach($resourceIndex as $resource => $description)
        {
          foreach($description as $predicate => $values)
          {
            if($predicate == "http://www.w3.org/1999/02/22-rdf-syntax-ns#type")
            {
              foreach($values as $value)
              {
                if($value["type"] == "uri" && $value["value"] == "http://rdfs.org/ns/void#Dataset")
                {
                  $datasetUri = $resource;
                  break;
                }
              }
            }

            if($break)
            {
              break;
            }
          }

          if($break)
          {
            break;
          }
        }


        // Second: get all the reification statements
        $break = FALSE;
        $statementsUri = array();

        foreach($resourceIndex as $resource => $description)
        {
          foreach($description as $predicate => $values)
          {
            if($predicate == "http://www.w3.org/1999/02/22-rdf-syntax-ns#type")
            {
              foreach($values as $value)
              {
                if($value["type"] == "uri" && $value["value"] == "http://www.w3.org/1999/02/22-rdf-syntax-ns#Statement")
                {
                  array_push($statementsUri, $resource);
                  break;
                }
              }
            }

            if($break)
            {
              break;
            }
          }

          if($break)
          {
            break;
          }
        }

        // Third, get all references of all instance records resources (except for the statement resources)
        $irsUri = array();

        foreach($resourceIndex as $resource => $description)
        {
          if($resource != $datasetUri && array_search($resource, $statementsUri) === FALSE)
          {
            array_push($irsUri, $resource);
          }
        }

        // Index all the instance records in the dataset
        if($this->mode == "full" || $this->mode == "triplestore")
        {
          $irs = array();

          foreach($irsUri as $uri)
          {
            $irs[$uri] = $resourceIndex[$uri];
          }

          $this->db->query("DB.DBA.RDF_LOAD_RDFXML_MT('"
            . str_replace("'", "\'", $rdfxmlSerializer->getSerializedIndex($irs)) . "', '" . $this->dataset . "', '"
            . $this->dataset . "')");

          if(odbc_error())
          {
            $this->conneg->setStatus(400);
            $this->conneg->setStatusMsg("Bad Request");
            $this->conneg->setError($this->errorMessenger->_302->id, $this->errorMessenger->ws,
              $this->errorMessenger->_302->name, $this->errorMessenger->_302->description, odbc_errormsg(),
              $this->errorMessenger->_302->level);

            return;
          }

          unset($irs);

          // Index all the reification statements into the statements graph
          $statements = array();

          foreach($statementsUri as $uri)
          {
            $statements[$uri] = $resourceIndex[$uri];
          }

          $this->db->query("DB.DBA.RDF_LOAD_RDFXML_MT('"
            . str_replace("'", "\'", $rdfxmlSerializer->getSerializedIndex($statements)) . "', '" . $this->dataset
              . "reification/', '" . $this->dataset . "reification/')");

          if(odbc_error())
          {
            $this->conneg->setStatus(400);
            $this->conneg->setStatusMsg("Bad Request");
            $this->conneg->setError($this->errorMessenger->_302->id, $this->errorMessenger->ws,
              $this->errorMessenger->_302->name, $this->errorMessenger->_302->description, odbc_errormsg(),
              $this->errorMessenger->_302->level);
            return;
          }

          unset($statements);

// Link the dataset description of the file, by using the wsf:meta property, to its internal description (dataset graph description)
          if($datasetUri != "")
          {
            $datasetRes[$datasetUri] = $resourceIndex[$datasetUri];

            $datasetRes[$this->dataset] =
              array( "http://purl.org/ontology/wsf#meta" => array( array ("value" => $datasetUri, "type" => "uri") ) );

            $datasetDescription = $resourceIndex[$datasetRes];

// Make the link between the dataset description and its "meta" description (all other information than its basic description)
            $this->db->query("DB.DBA.RDF_LOAD_RDFXML_MT('"
              . str_replace("'", "\'", $rdfxmlSerializer->getSerializedIndex($datasetRes)) . "', '" . $this->wsf_graph
                . "datasets/', '" . $this->wsf_graph . "datasets/')");

            if(odbc_error())
            {
              $this->conneg->setStatus(400);
              $this->conneg->setStatusMsg("Bad Request");
              $this->conneg->setError($this->errorMessenger->_302->id, $this->errorMessenger->ws,
                $this->errorMessenger->_302->name, $this->errorMessenger->_302->description, "",
                $this->errorMessenger->_302->level);
              return;
            }

            unset($datasetRes);
          }
        }

        if($this->mode == "full" || $this->mode == "searchindex")
        {
          $labelProperties = array (Namespaces::$iron . "prefLabel", Namespaces::$iron . "altLabel",
            Namespaces::$skos_2008 . "prefLabel", Namespaces::$skos_2008 . "altLabel",
            Namespaces::$skos_2004 . "prefLabel", Namespaces::$skos_2004 . "altLabel", Namespaces::$rdfs . "label",
            Namespaces::$dcterms . "title", Namespaces::$foaf . "name", Namespaces::$foaf . "givenName",
            Namespaces::$foaf . "family_name");

          $descriptionProperties = array (Namespaces::$iron . "description", Namespaces::$dcterms . "description",
            Namespaces::$skos_2008 . "definition", Namespaces::$skos_2004 . "definition");

          /*    
                   $resultset = $this->db->query("select * from SD.WSF.ws_ontologies where struct_type = 'class'");
                  
                  odbc_binmode($resultset, ODBC_BINMODE_PASSTHRU);
                  odbc_longreadlen($resultset, 16384);       
                  
                  odbc_fetch_row($resultset);
                  $classHierarchy = unserialize(odbc_result($resultset, "struct"));
                  
                  if (odbc_error())
                  {
                    $this->conneg->setStatus(500);
                    $this->conneg->setStatusMsg("Internal Error");
                    $this->conneg->setStatusMsgExt("Error #crud-create-103");  
                    return;
                  }          
          */

          $filename = rtrim($this->ontological_structure_folder, "/") . "/classHierarchySerialized.srz";

          $file = fopen($filename, "r");
          $classHierarchy = fread($file, filesize($filename));
          $classHierarchy = unserialize($classHierarchy);
          fclose($file);

          // Index in Solr

          $solr = new Solr($this->wsf_solr_core, $this->solr_host);

          foreach($irsUri as $subject)
          {
            // Skip Bnodes indexation in Solr
            // One of the prerequise is that each records indexed in Solr (and then available in Search and Browse)
            // should have a URI. Bnodes are simply skiped.

            if(stripos($subject, "_:arc") !== FALSE)
            {
              continue;
            }

            $add = "<add><doc><field name=\"uid\">" . md5($this->dataset . $subject) . "</field>";
            $add .= "<field name=\"uri\">$subject</field>";
            $add .= "<field name=\"dataset\">" . $this->dataset . "</field>";

            // Get types for this subject.
            $types = array();

            foreach($resourceIndex[$subject]["http://www.w3.org/1999/02/22-rdf-syntax-ns#type"] as $value)
            {
              array_push($types, $value["value"]);

              $add .= "<field name=\"type\">" . $value["value"] . "</field>";
            }

            // get the preferred and alternative labels for this resource
            $prefLabelFound = FALSE;

            foreach($labelProperties as $property)
            {
              if(isset($resourceIndex[$subject][$property]) && !$prefLabelFound)
              {
                $prefLabelFound = TRUE;
                $add .= "<field name=\"prefLabel\">" . $this->xmlEncode($resourceIndex[$subject][$property][0]["value"])
                  . "</field>";
                $add .= "<field name=\"attribute\">" . $this->xmlEncode(Namespaces::$iron . "prefLabel") . "</field>";
              }
              elseif(isset($resourceIndex[$subject][$property]))
              {
                foreach($resourceIndex[$subject][$property] as $value)
                {
                  $add .= "<field name=\"altLabel\">" . $this->xmlEncode($value["value"]) . "</field>";
                  $add .= "<field name=\"attribute\">" . $this->xmlEncode(Namespaces::$iron . "altLabel") . "</field>";
                }
              }
            }

            // get the description of the resource
            foreach($descriptionProperties as $property)
            {
              if(isset($resourceIndex[$subject][$property]))
              {
                $add .= "<field name=\"description\">"
                  . $this->xmlEncode($resourceIndex[$subject][$property][0]["value"]) . "</field>";
                $add .= "<field name=\"attribute\">" . $this->xmlEncode(Namespaces::$iron . "description") . "</field>";
                break;
              }
            }

            // Add the prefURL if available
            if(isset($resourceIndex[$subject][$iron . "prefURL"]))
            {
              $add .= "<field name=\"prefURL\">"
                . $this->xmlEncode($resourceIndex[$subject][$iron . "prefURL"][0]["value"]) . "</field>";
              $add .= "<field name=\"attribute\">" . $this->xmlEncode(Namespaces::$iron . "prefURL") . "</field>";
            }

            // Get properties with the type of the object
            foreach($resourceIndex[$subject] as $predicate => $values)
            {
              if(array_search($predicate, $labelProperties) === FALSE
                && array_search($predicate, $descriptionProperties) === FALSE && $predicate != Namespaces::$iron
                . "prefURL") // skip label & description & prefURL properties
              {
                foreach($values as $value)
                {
                  if($value["type"] == "literal")
                  {
                    $add .= "<field name=\"" . urlencode($predicate) . "_attr\">" . $this->xmlEncode($value["value"])
                      . "</field>";
                    $add .= "<field name=\"attribute\">" . $this->xmlEncode($predicate) . "</field>";

// Check if there is a reification statement for that triple. If there is one, we index it in the index as:
// <property> <text>
// Note: Eventually we could want to update the Solr index to include a new "reifiedText" field.
                    foreach($statementsUri as $statementUri)
                    {
                      if($resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#subject"][0]["value"]
                        == $subject
                          && $resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#predicate"][0][
                            "value"] == $predicate
                          && $resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#object"][0][
                            "value"] == $value["value"])
                      {
                        foreach($resourceIndex[$statementUri] as $reiPredicate => $reiValues)
                        {
                          if($reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#type"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#subject"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#predicate"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#object")
                          {
                            foreach($reiValues as $reiValue)
                            {
                              if($reiValue["type"] == "literal")
                              {
                                // Attribute used to reify information to a statement.
                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_attr\">"
                                  . $this->xmlEncode($predicate) .
                                  "</field>";

                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_obj\">"
                                  . $this->xmlEncode($value["value"]) .
                                  "</field>";

                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_value\">"
                                  . $this->xmlEncode($reiValue["value"]) .
                                  "</field>";

                                $add .= "<field name=\"attribute\">" . $this->xmlEncode($reiPredicate) . "</field>";
                              }
                            }
                          }
                        }
                      }
                    }
                  }
                  elseif($value["type"] == "uri")
                  {
                    // If it is an object property, we want to bind labels of the resource referenced by that
                    // object property to the current resource. That way, if we have "paul" -- know --> "bob", and the
                    // user send a seach query for "bob", then "paul" will be returned as well.
                    $query = $this->db->build_sparql_query("select ?p ?o from <" . $this->dataset . "> where {<"
                      . $value["value"] . "> ?p ?o.}", array ('p', 'o'), FALSE);

                    $resultset3 = $this->db->query($query);

                    $subjectTriples = array();

                    while(odbc_fetch_row($resultset3))
                    {
                      $p = odbc_result($resultset3, 1);
                      $o = odbc_result($resultset3, 2);

                      if(!isset($subjectTriples[$p]))
                      {
                        $subjectTriples[$p] = array();
                      }

                      array_push($subjectTriples[$p], $o);
                    }

                    unset($resultset3);

                    // We allign all label properties values in a single string so that we can search over all of them.
                    $labels = "";

                    foreach($labelProperties as $property)
                    {
                      if(isset($subjectTriples[$property]))
                      {
                        $labels .= $subjectTriples[$property][0] . " ";
                      }
                    }

                    if($labels != "")
                    {
                      $add .= "<field name=\"" . urlencode($predicate) . "_attr_obj\">" . $this->xmlEncode($labels)
                        . "</field>";
                      $add .= "<field name=\"" . urlencode($predicate) . "_attr_obj_uri\">"
                        . $this->xmlEncode($value["value"]) . "</field>";
                      $add .= "<field name=\"attribute\">" . $this->xmlEncode($predicate) . "</field>";
                    }

// Check if there is a reification statement for that triple. If there is one, we index it in the index as:
// <property> <text>
// Note: Eventually we could want to update the Solr index to include a new "reifiedText" field.
                    $statementAdded = FALSE;

                    foreach($statementsUri as $statementUri)
                    {
                      if($resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#subject"][0]["value"]
                        == $subject
                          && $resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#predicate"][0][
                            "value"] == $predicate
                          && $resourceIndex[$statementUri]["http://www.w3.org/1999/02/22-rdf-syntax-ns#object"][0][
                            "value"] == $value["value"])
                      {
                        foreach($resourceIndex[$statementUri] as $reiPredicate => $reiValues)
                        {
                          if($reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#type"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#subject"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#predicate"
                            && $reiPredicate != "http://www.w3.org/1999/02/22-rdf-syntax-ns#object")
                          {
                            foreach($reiValues as $reiValue)
                            {
                              if($reiValue["type"] == "literal")
                              {
                                // Attribute used to reify information to a statement.
                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_attr_obj\">"
                                  . $this->xmlEncode($predicate) .
                                  "</field>";

                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_obj\">"
                                  . $this->xmlEncode($value["value"]) .
                                  "</field>";

                                $add .= "<field name=\"" . urlencode($reiPredicate) . "_reify_value\">"
                                  . $this->xmlEncode($reiValue["value"]) .
                                  "</field>";

                                $add .= "<field name=\"attribute\">" . $this->xmlEncode($reiPredicate) . "</field>";
                                $statementAdded = TRUE;
                                break;
                              }
                            }
                          }

                          if($statementAdded)
                          {
                            break;
                          }
                        }
                      }
                    }
                  }
                }
              }
            }

            // Get all types by inference
            foreach($types as $type)
            {
              $superClasses = $classHierarchy->getSuperClasses($type);

              foreach($superClasses as $sc)
              {
                $add .= "<field name=\"inferred_type\">" . $this->xmlEncode($sc->name) . "</field>";
              }
            }

            $add .= "</doc></add>";

            if(!$solr->update($add))
            {
              $this->conneg->setStatus(500);
              $this->conneg->setStatusMsg("Internal Error");
              $this->conneg->setError($this->errorMessenger->_303->id, $this->errorMessenger->ws,
                $this->errorMessenger->_303->name, $this->errorMessenger->_303->description, "",
                $this->errorMessenger->_303->level);
              return;
            }
          }

          if($this->solr_auto_commit === FALSE)
          {
            if(!$solr->commit())
            {
              $this->conneg->setStatus(500);
              $this->conneg->setStatusMsg("Internal Error");
              $this->conneg->setError($this->errorMessenger->_304->id, $this->errorMessenger->ws,
                $this->errorMessenger->_304->name, $this->errorMessenger->_304->description, "",
                $this->errorMessenger->_304->level);
              return;
            }
          }
        }
      /*        
              // Optimisation can be time consuming "on-the-fly" (which decrease user's experience)
              if(!$solr->optimize())
              {
                $this->conneg->setStatus(500);
                $this->conneg->setStatusMsg("Internal Error");
                $this->conneg->setStatusMsgExt("Error #crud-create-106");
                return;          
              }
      */
      }
    }
  }
}



?>

Copyright © 2009. Structured Dynamics LLC. All rights reserved.