topical media & game development
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

talk show tell print

server-php-xml-class-rdql-db-class-rdql-db.php / php



  <?php
  //   
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
###





















  // Title                     : RDQL_db (class_rdql_db.php)
  // Version                   : 1.0 
  // Author                    : Luis Argerich (lrargerich@yahoo.com)
  // Last modification date    : 07-03-2002
  // Description               : This class implements the RDQL language
  //                             for RDF documents stored in a MySQL database
  //                             methds to store and rertieve RDF documents
  //                             from a MySQL database are provided as well.
  //   
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
###





















  // History: 
  // 07-03-2002                : First release of this class
  //   
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
###





















  // To-Dos:
  //   
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
###





















  // How to use it: First read the README, then check the documentation in
  //                class_rdql_db.html and the example in example.php
  //   
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
#  
###





















  
  include_once("class_rdql.php");
  include_once("class_rdf_parser.php");
  
  class RDQL_query_db {
    // Queries documents passed as urls or filenames (use urls or filenames in the FROM part of the RDQL query)
    function rdql_query_db(query)              
    {
      iterator = new RDF_rdqldb_iterator();
      q = new RDQL_query(iterator);
      res = q->parse_query(query);
      // Now process the query result 
      return res;
    }
  } // end of class
  
  // This class provides 
  class RDQL_db {
    var error='';
    var warning_mode=0;
    var collection;
    var key;
    var statements;
  
    function get_error() {
      return this->error; 
    }
    
    // Sets warning mode, if true all the errors produce a PHP warning
    function set_warning_mode(b) {
      this->warning_mode=b; 
    }
  
    function _throw_error(msg) 
    {
      this->error = msg; 
      if(this->warning_mode) {
        trigger_error(this->error,E_USER_WARNING); 
      }
      return false;
    }  
    
    function remove_rdf_document(key) {
      query = "delete from rdf_documents where docKey='key'";
      mysql_query(query);
      query = "delete from rdf_data where docKey='key'";
      mysql_query(query);
      return true; 
    }
    
    function store_rdf_document(url,key)
    {
      this->key = key;
      this->statements = 0;
      query = "select count(*) from rdf_documents where docKey='key'";
      result = mysql_query(query);
      res = mysql_fetch_row(result);
      exist = res[0];
      if(exist) {
        this->_throw_error("The collection collection already has a document with key=key"); 
        return false;
      }
      fp = fopen(url,"r");
      if(!fp) {
        this->_throw_error("The url or filename url cannot be opened"); 
        return false;
      }
      rdf_parser=new Rdf_parser();
      rdf_parser->rdf_parser_create( NULL );
      rdf_parser->rdf_set_statement_handler( "_class_rdf_store_statement_handler" );
      rdf_parser->rdf_set_user_data( this );
      size = 0;
      date = date("U");
      query = "insert into rdf_documents(date,docKey,type,data)
                       values(date,'key','rdf','')";
      result = mysql_query(query);                     
      if(!result) {
        this->_throw_error(mysql_error()." in: ".query);
        return false;
      }
      while(!feof(fp)) {
        buf = fread(fp,512);
        size+=strlen(buf);
        bufd=addslashes(buf);
        if (!rdf_parser->rdf_parse(buf, strlen(data), feof(fp))) {
          this->_throw_error("XML error while parsing the document in line:".xml_get_current_line_number(rdf_parser->rdf_get_xml_parser()));
          return false;
        }
        query = "update rdf_documents set data = concat(data,'bufd') where docKey='key'";
        mysql_query(query);
      }
      query="update rdf_documents set size='size' where docKey='key'";
      mysql_query(query);
      query = "update rdf_documents set statements='this->statements' where docKey='key'";
      mysql_query(query);
      rdf_parser->rdf_parser_free();
      return true;
    }
  
    function get_rdf_document(key)
    {
      query = "select data from rdf_documents where docKey='key'";
      result = mysql_query(query);
      if(mysql_num_rows(result)==0) {
        this->_throw_error("No key document was found in collection collection"); 
        return false;
      }
      res = mysql_fetch_array(result);
      return res["data"];
    }
    
    
  } //end of class
  
  /* This function is used by the class as a hander to the RDF_parser */
  function _class_rdf_store_statement_handler(&user_data,subject_type,subject,predicate,ordinal,object_type,object,xml_lang) {
    //Just store the information in a database row.   
    key = user_data->key;
    collection = user_data->collection;
    query="insert into rdf_data(docKey,subject_type,subject,predicate,object_type,object,ordinal) 
            values('key',subject_type,'subject','predicate',object_type,'object',ordinal)";
    mysql_query(query);        
    user_data->statements++;
  }
  
  class RDF_rdqldb_iterator extends RDF_iterator {
    var tuples;
    var collection;
    
    function init(sources) {
      
    }
    
    function set_collection(id) {
      this->collection=id; 
    }
    
    function get_tuple() {
      
    }
    
    function find_tuples(sources,subject,predicate,object) {
      this->tuples=Array();
      
      // If sources is * then select all documents in the collection 
      
      if(count(sources)==1 && ((trim(sources[0])=='*')||(trim(sources[0])=='<*>') )) {
        sources=Array();
        query="select docKey from rdf_documents";
        result=mysql_query(query);
        while(res=mysql_fetch_array(result)) {
          sources[]='<'.res["docKey"].'>';
        } 
      }
      // And now we have the sources
      
      foreach(sources as source) {
        preg_match("/\<([^>]*)\>/",source,reqs);
        source=reqs[1];
        query="select subject,predicate,object from rdf_data where docKey='source'";
        //print(query);die;
        sql_result=mysql_query(query);
        if(!sql_result) {
         die(mysql_error()); 
        }
        while(res=mysql_fetch_array(sql_result)) {
          result=Array();
          if(this->tuple_match(subject,res["subject"]) &&
             this->tuple_match(predicate,res["predicate"]) &&
             this->tuple_match(object,res["object"])) {
             result=Array();
             if(subject{0}=='?') {
               result[subject]=res["subject"]; 
             }
             if(predicate{0}=='?') {
               result[predicate]=res["predicate"]; 
             }    
             if(object{0}=='?') {
               result[object]=res["object"]; 
             }
             if(count(result)>0) {
               this->tuples[]=result; 
             }
          }   
        } 
        
      }    
      return this->tuples;
    }
  
    function RDF_mysql_iterator() {
      
    } 
    
  }
  
  ?>
[] readme course(s) preface I 1 2 II 3 4 III 5 6 7 IV 8 9 10 V 11 12 afterthought(s) appendix reference(s) example(s) resource(s) _

(C) Æliens 20/2/2008

You may not copy or print any of this material without explicit permission of the author or the publisher. In case of other copyright issues, contact the author.