source: Dev/trunk/classes/AnswerSetConnector.php @ 173

<?php

/**
 * Description of AnswerSetConnector
 *
 * @author jkraaijeveld
 */
class AnswerSetConnector extends Connector{
    protected $db;

        /**
         * Constructor for the AnswerSetConnector
         */
        public function __construct()
        {
                $this->fileName = 'data/answers/answersets.rdf';
                //Ensure the required folder for this connector exists
                if(!is_dir('data/answers'))
                        mkdir('data/answers');
        }

        /**
         * function get()
         * @param type $arguments : An array having one ore more of the following elements:
         * 'uid', 'survey', 'respondent', 'answers'.
         */
        public function get($arguments)
        {
                $this->load();

                //Build the query string
                $querystring = '
                        PREFIX predicates: <' . SURVEYTOOL_PREDICATES_NAMESPACE . '>
                        PREFIX resources: <' . SURVEYTOOL_RESOURCES_NAMESPACE . '>
                        SELECT DISTINCT ?uid, ?for_survey, ?by_respondent
                        WHERE
                        {
                                _answerset      predicates:resource_type        resources:answerset ;
                                predicates:uid ?uid ;
                                predicates:for_survey ?for_survey ;
                                predicates:by_respondent ?by_respondent ;
                                ' . $this->createArguments($arguments) . '
                        }';
                //Query the model
                $results = $this->model->sparqlQuery($querystring);
                $answerSets = array();
                if(!empty($results))
                {
                        $this->db = new DatabaseInterface();
                        foreach($results as $result)
                        {
                                $survey = $this->db->get("survey", array("uid" => $result['?for_survey']->label));
                                $respondent = $this->db->get("respondent", array("uid" => $result['?by_respondent']->label));
                                $answers =      $this->getAnswers($result['?uid']->label);
                                $answerSets[] = new AnswerSet($result['?uid']->label, $survey[0], $respondent[0], $answers);
                        }
                }
                return $answerSets;
        }

        /**
         * function getAnswers()
         * @param type $uid : the uid for which the answers should be retrieved.
         */
        private function getAnswers($uid)
        {
                $result = $this->model->findRegex("[(".$uid.")]", "[(given_answer)]", null);
                $iterator = $result->getStatementIterator();
                $answers = array();
                while($iterator->hasNext())
                {
                        $element = $iterator->next();
                        $answersR = $this->db->get("answer", array("uid" => $element->getLabelObject()));
                        $answers[] = $answersR[0];
                }
                return $answers;
        }

        /**
         * function set()
         * @param type $rToolObject : The ResearchToolObject to be saved.
         */
        public function set($rToolObject)
        {
                $this->load();
                $resourceAnswerSet = new Resource(ANSWERSET . '/' . $rToolObject->uid);
                //Remove the old value stored with the given id
                $this->model->subtract($this->model->find($resourceAnswerSet, null, null));

                //Set the new values
                $resourceAnswerSetType = new Resource(ANSWERSET);
                $predicateRType = new Resource(RTYPE);
                $this->model->add(new Statement($resourceAnswerSet, $predicateRType, $resourceAnswerSetType));

                $answerSetId = new Literal($rToolObject->uid);
                $predicateId = new Resource(UID);
                $this->model->add(new Statement($resourceAnswerSet, $predicateId, $answerSetId));

                $surveyId = new Literal($rToolObject->survey->uid);
                $predicateSurvey = new Resource(FOR_SURVEY);
                $this->model->add(new Statement($resourceAnswerSet, $predicateSurvey, $surveyId));

                $respondentId = new Literal($rToolObject->respondent->uid);
                $predicateRespondent = new Resource(BY_RESPONDENT);
                $this->model->add(new Statement($resourceAnswerSet, $predicateRespondent, $respondentId));
                
                if(isset($rToolObject->answers))
                {
                        foreach($rToolObject->answers as $answer)
                        {
                                $answerId = new Literal($answer->uid);
                                $predicateAnswer = new Resource(GIVEN_ANSWER);
                                $this->model->add(new Statement($resourceAnswerSet, $predicateAnswer, $answerId));
                        }
                }
                $this->save();
        }
}