onto_store = $onto_store;
} else {
//on récupère les stores...
$onto_store_class = "onto_store_".$onto_store;
$this->onto_store = new $onto_store_class($onto_store_config);
$this->onto_store->set_namespaces($tab_namespaces);
//chargement de l'ontologie dans son store
if($ontology_filepath){
$this->onto_store->load($ontology_filepath);
}
}
if (is_object($data_store)) {
$this->data_store = $data_store;
} else {
$data_store_class = "onto_store_".$data_store;
$this->data_store = new $data_store_class($data_store_config);
$this->data_store->set_namespaces($tab_namespaces);
}
$this->default_display_label=$default_display_label;
} // end of member function __construct
/**
* PARTIE DATASTORE
*/
/**
* revoie les assertion à inserer pour un item
*
* @param string $uri
*
* @return array
*/
public function get_assertions($uri){
$assertions = array();
$query = "select * where {
<".$uri."> ?predicate ?object .
optional {
?object rdf:type ?type
}
}";
$this->data_store->query($query);
$results = $this->data_store->get_result();
foreach($results as $assertion){
$object_properties = array();
foreach($assertion as $key=>$value){
if(substr($key,0,strlen("object_")) == "object_"){
$object_properties[substr($key,strlen("object_"))] = $value;
}
}
if($object_properties['type'] == "literal"){
$type = "http://www.w3.org/2000/01/rdf-schema#Literal";
}else{
$type = (!empty($assertion->type) ? $assertion->type : "");
if(!$type){
$tmp = $this->ontology->get_property_pmb_datatype($assertion->predicate);
if($tmp == 'http://www.pmbservices.fr/ontology#resource_pmb_selector'){
$type = substr($assertion->object,0,strrpos($assertion->object,'_'));
}else if($tmp == 'http://www.pmbservices.fr/ontology#marclist'){
$type = $this->ontology->get_property_pmb_datatype($assertion->predicate);
}else{
$type = $assertion->predicate;
}
}else{
/**
* TODO: Récupérer le display label dans le cas dun resource pmb selector +
* Affichage correct au niveau du datatype UI (Autre chose que l'uri de la propriété)
* @var unknown
*/
$displayLabel = $this->get_display_label($assertion->type);
$query="select ?display_label where {
<".$assertion->object."> <".$displayLabel."> ?display_label
}";
$this->data_store->query($query);
if($this->data_store->num_rows()){
$result = $this->data_store->get_result();
$object_properties['display_label'] = $result[0]->display_label;
} else {//cas particulier pour les assertions qui auraient directement un displayLabel
$query="select ?display_label where {
<".$assertion->object."> pmb:displayLabel ?display_label
}";
$this->data_store->query($query);
if($this->data_store->num_rows()){
$result = $this->data_store->get_result();
$object_properties['display_label'] = $result[0]->display_label;
}
}
}
}
$assertions[] = new onto_assertion($uri, $assertion->predicate, $assertion->object, $type,$object_properties);
}
return $assertions;
}
/**
* Fonction d'accès aux requetes sparql dans le data store
*
* @param string $query
*
*/
public function data_query($query){
$this->data_store->query($query);
if($this->data_store->num_rows()){
return true;
}elseif ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
/**
* Fonction d'accès aux requetes sparql dans le data store
* renvoi le résultat
*
* @return array result
*/
public function data_result(){
if($this->data_store->num_rows()){
return $this->data_store->get_result();
}elseif ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
/**
* Fonction d'accès aux requetes sparql dans le data store
* renvoi le nombre de résultat
*
* @return integer num rows
*/
public function data_num_rows(){
if($this->data_store->num_rows()){
return $this->data_store->num_rows();
}elseif ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
public function get_data_label($uri){
global $lang;
$displayLabel=$this->get_display_label($uri);
$query = "select * where {
<".$uri."> <".$displayLabel."> ?label
}";
$this->data_store->query($query);
if($this->data_store->num_rows()){
$results = $this->data_store->get_result();
foreach($results as $key=>$result){
if(isset($result->label_lang) && $result->label_lang==substr($lang,0,2)){
return $result->label;
}
}
//pas de langue de l'interface trouvée
foreach($results as $key=>$result){
return $result->label;
}
}
}
public function get_nb_elements($class_uri,$more=""){
if(!isset($this->nb_elements[$class_uri.$more]) || !$this->nb_elements[$class_uri.$more]){
$query="";
$query.="select count(?elem) as ?nb_elem where {
?elem rdf:type <".$class_uri.">";
if($more){
if(substr(trim($more),0,1) == '.'){
$query.=$more;
}else{
$query.=' . '.$more;
}
}
$query.="}";
$this->data_store->query($query);
$results = $this->data_store->get_result();
$this->nb_elements[$class_uri.$more] = $results[0]->nb_elem;
}
return $this->nb_elements[$class_uri.$more];
}
/**
* Supprime et recrée les déclarations de l'instance passée en paramètre
*
* @param onto_common_item $item Instance à sauvegarder
*
* @return bool
*
* @access public
*/
public function save( $item ) {
global $opac_url_base, $area_id, $action;
if ($item->check_values()) {
if(onto_common_uri::is_temp_uri($item->get_uri())){
$item->replace_temp_uri();
}
$assertions = $item->get_assertions();
$nb_assertions = count($assertions);
$i = 0;
// On commence par supprimer ce qui existe
$query = "delete {
<".$item->get_uri()."> ?prop ?obj
}";
$this->data_store->query($query);
if ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
// On peut y aller
$query = "insert into {
";
foreach ($assertions as $assertion) {
if ($assertion->offset_get_object_property("type") == "literal"){
$object = "'".addslashes($assertion->get_object())."'";
$object_properties = $assertion->get_object_properties();
if(!empty($object_properties['lang'])){
$object.="@".$object_properties['lang'];
}
} else {
$object = $assertion->get_object();
// On traite le cas où on récupère l'id
if ($object*1) {
$object = $object*1;
$object = onto_common_uri::get_uri($object);
}
$object = "<".addslashes($object).">";
}
$query.= "<".addslashes($assertion->get_subject())."> <".addslashes($assertion->get_predicate())."> ".$object;
$i++;
if ($i < $nb_assertions) $query.=" .";
$query.="\n";
}
$query.="}";
$this->data_store->query($query);
if ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}else{
$onto_index = onto_index::get_instance($this->get_onto_name());
$onto_index->set_handler($this);
$onto_index->maj(0, $item->get_uri());
}
} else {
return $item->get_checking_errors();
}
return true;
} // end of member function save
/**
* Détruit une instance (l'ensemble de ses déclarations)
*
* @param onto_common_item $item Instance à supprimer (l'ensemble de ses déclarations)
* @param bool $force_delete Si false, renvoie un tableau des assertions où l'item est objet. Si true, supprime toutes les occurences de l'item
*
* @return bool
* @access public
*/
public function delete($item, $force_delete = false) {
global $dbh;
// On stockera dans un tableau tous les triplets desquels l'item est l'objet
$is_object_of = array();
$query = "select * where {
?subject ?predicate <".$item->get_uri().">
}";
$this->data_store->query($query);
$result = $this->data_store->get_result();
foreach ($result as $assertion) {
$is_object_of[] = new onto_assertion($assertion->subject, $assertion->predicate, $item->get_uri());
}
$query = "select uri_id from onto_uri where uri = '".$item->get_uri()."'";
$result = pmb_mysql_query($query, $dbh);
if(pmb_mysql_num_rows($result)){
$usage=aut_pperso::delete_pperso(AUT_TABLE_CONCEPT, pmb_mysql_result($result, 0, 0) ,1) ;
}
if ($force_delete || !count($is_object_of)) {
$query = "delete {
<".$item->get_uri()."> ?prop ?obj
}";
$this->data_store->query($query);
if ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
} else {
$query = "delete {
?subject ?predicate <".$item->get_uri().">
}";
$result = $this->data_store->query($query);
if ($errs = $this->data_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}else{
// On met à jour l'index
$onto_index = onto_index::get_instance($this->get_onto_name());
$onto_index->set_handler($this);
$onto_index->maj(0,$item->get_uri());
if (count($is_object_of)) {
foreach ($is_object_of as $object) {
$index->maj(0,$assertion->subject);
}
}
//on a tout viré on supprime aussi l'URI dans la table
$query = "delete from onto_uri where uri = '".$item->get_uri()."'";
pmb_mysql_query($query, $dbh);
}
}
}
return $is_object_of;
} // end of member function delete
/**
* PARTIE DATASTORE
*/
/**
* Retourne l'item le plus approprié pour définir l'URI passée en paramètre
*
* @param string class_uri URI de la classe de l'ontologie à instancier
* @param string uri URI de l'instance à créer
*
* @return onto_common_item $item
*
* @access public
*/
public function get_item($class_uri,$uri) {
$item_class = "onto_".$this->ontology->name."_".$this->get_class_pmb_name($class_uri)."_item";
if(!class_exists($item_class)){
$item_class = "onto_".$this->ontology->name."_item";
}
if(!class_exists($item_class)){
$item_class = "onto_common_item";
}
$item = new $item_class($this->ontology->get_class($class_uri),$uri);
$item->set_assertions($this->get_assertions($uri));
if(!$uri){
//pas d'uri, on instancie les assertions par défaut...
$assertions = array();
foreach($this->ontology->get_class_properties($class_uri) as $uri_property){
$property=$this->ontology->get_property($class_uri,$uri_property);
if(count($property->default_value)){
global ${$property->default_value['value']};
if(isset(${$property->default_value['value']})){
$assertions[] = new onto_assertion($item->get_uri(),$uri_property,onto_common_uri::get_uri(${$property->default_value['value']}),$property->range[0], array('type' => "uri",'display_label' => $this->get_data_label(onto_common_uri::get_uri(${$property->default_value['value']}))));
}
}
}
if(count($assertions)){
$item->set_assertions($assertions);
}
}
return $item;
} // end of member function get_item
/**
* PARTIE ONTOLOGIE
*/
/**
* retourne les uri des classes de l'ontologie
*
* @return array
*/
public function get_classes(){
return $this->ontology->get_classes_uri();
}
/**
* Retourne le nom de la classe ontologie en fonction de son uri
*
* @param string $uri_class
*/
public function get_class_label($uri_class){
return $this->ontology->get_class_label($uri_class);
}
/**
* Renvoie le premier nom de classe de l'ontologie (choisi par défaut)
*
* @return string
*/
public function get_first_ontology_class_name(){
$classes = $this->get_classes();
reset($classes);
return current($classes)->pmb_name;
}
/**
* Renvoie l'uri d'une classe en fonction de son nom pmb
*
* @param string $class_name
*/
public function get_class_uri($class_name){
$classes = $this->get_classes();
$class_uri = "";
foreach($classes as $class){
if($class->pmb_name == $class_name){
$class_uri = $class->uri;
break;
}
}
return $class_uri;
}
/**
* Renvoie le nom PMB d'une classe en fonction de son uri
*
* @param string $class_uri
*/
public function get_class_pmb_name($class_uri){
$classes = $this->get_classes();
$class_pmb_name = "";
foreach($classes as $class){
if($class->uri == $class_uri){
$class_pmb_name = $class->pmb_name;
break;
}
}
return $class_pmb_name;
}
/**
* Renvoi le titre de l'ontologie
*
* @return string
*/
public function get_title(){
return $this->ontology->title;
}
/**
* renvoie le nom de l'ontologie
*
* @return string
*/
public function get_onto_name(){
return $this->ontology->name;
}
/**
* Instancie et renvoie la valeur labels
* Contient les libellés des mots présents dans le data_store
*
* @return array
*/
public function get_labels(){
if(!isset($this->labels) || !$this->labels){
$this->labels = array();
$query="select * where {
?uri pmb:name ?name .
?uri rdfs:label ?label .
optional {
?uri pmb:displayLabel ?displayLabel .
?uri pmb:searchLabel ?searchLabel
}
}";
$this->onto_store->query($query);
$results = $this->onto_store->get_result();
foreach($results as $result){
$this->labels[$result->name]['uri'] = $result->uri;
$this->labels[$result->name]['name'] = $result->name;
if(isset($result->displayLabel) && $result->displayLabel){
$this->labels[$result->name]['displayLabel'] = $result->displayLabel;
}
if(isset($result->searchLabel) && $result->searchLabel){
$this->labels[$result->name]['searchLabel'] = $result->searchLabel;
}
if(!isset($labels[$result->name]['label']['default'])){
$this->labels[$result->name]['label']['default'] = $result->label;
}
$this->labels[$result->name]['label'][$result->label_lang] = $result->label;
}
}
return $this->labels;
}
public function get_display_label($class_uri,$recurse=true){
if(isset(self::$display_labels[$class_uri])){
return self::$display_labels[$class_uri];
}
$query = "select ?displayLabel where {
<".$class_uri."> pmb:displayLabel ?displayLabel
}";
$this->onto_store->query($query);
$displayLabel = $this->default_display_label;
if($this->onto_store->num_rows()){
$result = $this->onto_store->get_result();
$displayLabel = $result[0]->displayLabel;
}else{
$query = "select ?type where {
<".$class_uri."> rdf:type ?type .
}";
$this->data_store->query($query);
if($this->data_store->num_rows()){
$result = $this->data_store->get_result();
if($recurse){
$displayLabel = $this->get_display_label($result[0]->type,false);
}
}
}
self::$display_labels[$class_uri] = $displayLabel;
return self::$display_labels[$class_uri];
}
/**
* Renvoie un libellé en fonction du nom ou de l'uri
*
* @param string $name
*/
public function get_label($name){
global $msg,$lang;
$label= "";
//@todo recherche SPARQL sur un libelle?
if(!isset($this->labels) || !$this->labels){
$this->get_labels();
}
foreach($this->labels as $key => $infos){
if($name == $key || $name == $infos['uri']){
if(isset($msg['onto_'.$this->get_onto_name().'_'.$infos['name']])){
//le message PMB spécifique pour l'ontologie courante
$label = $msg['onto_'.$this->get_onto_name().'_'.$infos['name']];
}else if (isset($msg['onto_common_'.$infos['name']])){
//le message PMB générique
$label = $msg['onto_common_'.$infos['name']];
}else if (isset($infos['label'][substr($lang,0,2)])){
//le label de l'ontologie dans la langue de l'interface
$label = $infos['label'][substr($lang,0,2)];
}else{
//le label générique de l'ontologie
$label = $infos['label']['default'];
}
break;
}
}
return $label;
}
/**
* Renvoie les propriétés en fonction d'un nom de classe pmb
*
* @param string $pmb_name
*
* @return array
*/
public function get_onto_property_from_pmb_name($pmb_name) {
$properties_uri = $this->ontology->get_properties();
foreach ($properties_uri as $uri => $info) {
if ($info->pmb_name == $pmb_name) {
return $this->ontology->get_property("", $uri);
}
}
}
/**
* Retourne une instance de l'ontologie chargée à partir de onto_store
*
* @return onto_ontology
*
* @access public
*/
public function get_ontology() {
if(!isset($this->ontology )){
$this->ontology = new onto_ontology($this->onto_store);
}
$this->ontology->set_data_store($this->data_store);
return $this->ontology;
} // end of member function get_ontology
/**
* Fonction d'accès aux requetes sparql dans l'onto store
*
* @param string $query
*
*/
public function onto_query($query){
$this->onto_store->query($query);
if($this->onto_store->num_rows()){
return true;
}elseif ($errs = $this->onto_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
/**
* Fonction d'accès aux requetes sparql dans l'onto store
* renvoi le résultat
*
* @return array result
*/
public function onto_result(){
if($this->onto_store->num_rows()){
return $this->onto_store->get_result();
}elseif ($errs = $this->onto_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
/**
* Fonction d'accès aux requetes sparql dans l'onto store
* renvoi le nombre de résultat
*
* @return integer num rows
*/
public function onto_num_rows(){
if($this->onto_store->num_rows()){
return $this->onto_store->num_rows();
}elseif ($errs = $this->onto_store->get_errors()) {
print "
Erreurs:
";
print "";print_r($errs);print "
";
}
return false;
}
/**
* Retourne vrai si la classe est une sous classe d'une indexation, faux sinon
* @param string $class_uri URI d'une classe
*/
public function class_is_indexed($class_uri){
$query = "select ?subclass {
<".$class_uri."> ?subclass .
?subclass rdf:type pmb:indexation }";
$this->onto_query($query);
if($this->onto_num_rows()){
return true;
}
return false;
}
/**
*
* @return onto_store
*/
public function get_data_store() {
return $this->data_store;
}
/**
*
* @return onto_common_index
*/
public function get_onto_index() {
if (empty($this->onto_index)) {
$onto_index_class_name = $this->search_index_class_name();
$this->onto_index = new $onto_index_class_name();
$this->onto_index->set_handler($this);
}
return $this->onto_index;
}
/**
*
* @return string
*/
protected function search_index_class_name(){
$suffixe = "_index";
$prefix="onto_";
if(class_exists($prefix.$this->get_onto_name().$suffixe)){
return $prefix.$this->get_onto_name().$suffixe;
}else{
return 'onto_index';
}
}
} // end of onto_handler