rdfio/RDFIO

<?php

/**
 * Class for importing RDF data, either from RDF Import Special page, or
 * from SPARQL Update queries in the SPARQL Endpoint Special Page.
 */
class RDFIORDFImporter {

    function __construct() { }

    /**
     * Import RDF/XML, e.g. from the RDF Import Special Page.
     * @param string $importData
     */
    public function importRdfXml( $importData ) {
        // Parse RDF/XML to triples
        $arc2rdfxmlparser = ARC2::getRDFXMLParser();
        $arc2rdfxmlparser->parseData( $importData );

        // Receive the data
        $triples = $arc2rdfxmlparser->triples;
        $tripleIndex = $arc2rdfxmlparser->getSimpleIndex();
        $namespaces = $arc2rdfxmlparser->nsp;

        $this->importFromArc2Data( $triples, $tripleIndex, $namespaces );
        $output = array(
            'triples' => $triples,
            'tripleIndex' => $tripleIndex,
            'namespaces' => $namespaces
        );
        return $output;
    }

    /**
     * Import RDF in turtle format, e.g. from the RDF Import Special Page.
     * @param string $importData
     */
    public function importTurtle( $importData ) {
        // Parse RDF/XML to triples
        $arc2turtleparser = ARC2::getTurtleParser( $importData );
        $arc2turtleparser->parseData( $importData );

        // Receive the data
        $triples = $arc2turtleparser->triples;
        $tripleIndex = $arc2turtleparser->getSimpleIndex();
        $namespaces = $arc2turtleparser->nsp;

        $this->importFromArc2Data( $triples, $tripleIndex, $namespaces );
        $output = array(
            'triples' => $triples,
            'tripleIndex' => $tripleIndex,
            'namespaces' => $namespaces
        );
        return $output;
    }

    /**
     * Import triples, e.g. from the SPARQL Endpoint Special Page.
     * @param array $triples
     */
    public function importTriples( $triples ) {
        $this->importFromArc2Data( $triples );
        $output = array( 'triples' => $triples );
        return $output;
    }

    /**
     * Do the actual import, after having parsed the data into ARC2 data structures
     * @param array $triples
     * @param array $tripleIndex
     * @param array $namespaces
     * @return array $triples
     */
    private function importFromArc2Data( $triples, $tripleIndex = "", $namespaces = "" ) {
        // Parse data from ARC2 triples to custom data structure holding wiki pages
        $arc2towikiconverter = new RDFIOARC2ToWikiConverter();
        $wikiPages = $arc2towikiconverter->convert( $triples, $tripleIndex, $namespaces );

        // Import pages into wiki
        $smwPageWriter = new RDFIOSMWPageWriter();

        // Separate property pages and other pages
        $propertyPages = array();
        $otherPages = array();
        foreach ( $wikiPages as $pageTitle => $wikiPage ) {
            if ( $wikiPage->isProperty() ) {
                $propertyPages[$pageTitle] = $wikiPage;
            } else {
                $otherPages[$pageTitle] = $wikiPage;
            }
        }

        // Import property pages first (to get proper data type of facts using them)
        $smwPageWriter->import( $propertyPages );
        $smwPageWriter->import( $otherPages );

        $output = array( 'triples' => $triples );
        return $output;
    }

    function addDataSource( $dataSourceUrl, $importType ) {
        $dataSourcePage = new RDFIOWikiPage( $dataSourceUrl );
        $dataSourcePage->addEquivalentURI( $dataSourceUrl );
        $dataSourcePage->addFact( array( 'p' => 'RDFIO Import Type', 'o' => $importType ) );
        $dataSourcePage->addCategory( 'RDFIO Data Source' );

        $smwPageWriter = new RDFIOSMWPageWriter();
        $smwPageWriter->import( array( $dataSourceUrl => $dataSourcePage ) );
    }

    function showImportedTriples( $triples ) {
        $output = "";
        $styleCss = <<<EOD
                table .rdfio- th {
                    font-weight: bold;
                    padding: 2px 4px;
                }
                table.rdfio-table td,
                table.rdfio-table th {
                    font-size: 11px;
                }
EOD;
        $output .= '<style>' . $styleCss . '</style>';
        $output .= '<h3>Imported ' . count( $triples ) . ' triples:</h3>';
        $output .= '<table class="wikitable sortable rdfio-table"><tbody><tr><th>Subject</th><th>Predicate</th><th>Object</th></tr>';

        foreach ( $triples as $triple ) {
            $s = $triple['s'];
            $p = $triple['p'];
            $o = $triple['o'];
            if ( $this->isUri( $s ) ) {
                $s = "<a href=\"$s\">$s</a>";
            }
            if ( $this->isUri( $p ) ) {
                $p = "<a href=\"$p\">$p</a>";
            }
            if ( $this->isUri( $o ) ) {
                $o = "<a href=\"$o\">$o</a>";
            }
            $output .= "<tr><td>$s</td><td>$p</td><td>$o</td></tr>";
        }

        $output .= "</tbody></table>";
        return $output;
    }

    function isUri( $str ) {
        return ( substr( $str, 0, 4 ) === 'http' );
    }
}