Metacat

/**

 *  '$RCSfile$'

 *    Purpose: A Class that implements org.xml.sax.EntityResolver interface

 *             for resolving external entities

 *  Copyright: 2000 Regents of the University of California and the

 *             National Center for Ecological Analysis and Synthesis

 *    Authors: Jivka Bojilova, Matt Jones

 *

 *   '$Author: tao $'

 *     '$Date: 2016-03-23 15:57:25 -0700 (Wed, 23 Mar 2016) $'

 * '$Revision: 9583 $'

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 2 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA

 */

package edu.ucsb.nceas.metacat;

import java.sql.*;

import java.util.Vector;

import java.io.File;

import java.io.BufferedInputStream;

import java.io.FileWriter;

import java.io.BufferedWriter;

import java.io.InputStream;

import java.io.IOException;

import org.apache.log4j.Logger;

import org.xml.sax.SAXException;

import edu.ucsb.nceas.metacat.database.DBConnection;

import edu.ucsb.nceas.metacat.database.DBConnectionPool;

import edu.ucsb.nceas.metacat.service.ServiceService;

import edu.ucsb.nceas.metacat.service.XMLSchemaParser;

import edu.ucsb.nceas.metacat.service.XMLSchemaService;

import edu.ucsb.nceas.metacat.util.SystemUtil;

import edu.ucsb.nceas.utilities.PropertyNotFoundException;

/**

 * A database aware Class to handle schema location. If namespace is in the

 * xml_catalog table (public_id), the schema location specified in xml document

 * will be ignored by parser setting external schema location. If the

 * name space is not in the table, it will be download to metacat and register

 * in table

 */

public class SchemaLocationResolver

{

  private String nameSpace = null; //public id

  private String schemaLocation = null; // system id

  private String WHITESPACESTRING =" ";   

  private boolean downloadNewSchema = false;

  private static Logger logMetacat = Logger.getLogger(SchemaLocationResolver.class);

  public SchemaLocationResolver()

  {	  

  }

  /**

   * Construct an instance of the SchemaLocationResolver class

   *

   * @param  myNameSpaceAndLocation it is come from xsi:schemaLocation=

   *         "namespace location"

   */

  public SchemaLocationResolver(String myNameSpaceAndLocation)

  {

	  parse(myNameSpaceAndLocation);

  }

  /**

   * Construct an instance of the SchemaLocationResolver class

   *

   * @param  myNameSpaceAndLocation it is come from xsi:schemaLocation=

   *         "namespace location"

   */

  public SchemaLocationResolver(String myNameSpace, String myLocation)

  {

      nameSpace = myNameSpace;

      schemaLocation = myLocation;

  }

  /**

   * When got a name space, check if it is in the database, if it is do nothing

   * else upload it to metacat to store it and register it in catalog table

   */

  public void resolveNameSpace ()

  {

    // if name space is not in table

    if (nameSpace !=null && schemaLocation != null &&

        !XMLSchemaService.getInstance().getNameSpaceList().contains(nameSpace))

    {

       try

       {

        // upload schema into metacat

        String newURLInMetacat = uploadSchemaFromURL(schemaLocation);

        ServiceService.refreshService("XMLSchemaService");

        // check the name space list again.  It may not have appeared the first time 

        // because the schema was in the db but there was no file on disk.  If that's 

        // the case, it will show up in the name space list now.  If it doesn't we need

        // to register the schema in the database.

        if (!XMLSchemaService.getInstance().getNameSpaceList().contains(nameSpace)) {

        	registerSchema(newURLInMetacat);

        	ServiceService.refreshService("XMLSchemaService");

        }

        downloadNewSchema = true;

        //handle included schema in above schema

        String externalBaseURL = XMLSchemaService.getBaseUrlFromSchemaURL(schemaLocation);

        //System.out.println("==========the externalBaseURL is "+externalBaseURL);

        handleIncludedSchema(newURLInMetacat, externalBaseURL);

       }

       catch(Exception e)

       {

         logMetacat.error("Error in SchemaLocation.resolveNameSpace" +

                                  e.getMessage());

       }

    }//if

  }

  /*

   * Some schemas (parent schema)also include other schemas (children) in 

   * its definition. The syntax is:  <xsd:include schemaLocation="product.xsd"/>

   * The included schemas need to be downloaded as well. 

   * The included schemas always have the same target namespace. So there

   * is no need to register the schema into xml_catalog table.

   * Note: the included schemas may have included schemas (grandchildren) as well.

   */

  private void handleIncludedSchema(String parentSchemaNewURLInMetacat, 

                                                                          String externalBaseURL) 

                                                          throws SAXException, IOException,PropertyNotFoundException 

  {

    //Gets the included schema information from parent schema

    //System.out.println("the parent schema new url in metacat ============="+parentSchemaNewURLInMetacat);

    if(externalBaseURL != null)

    {

      InputStream in = DBEntityResolver.checkURLConnection(SystemUtil.getContextURL()+parentSchemaNewURLInMetacat);

      XMLSchemaParser parser = new XMLSchemaParser(in);

      parser.parse();

      Vector<String> includedSchemaPaths = parser.getIncludedSchemaFilePathes();

      //System.out.println("the include schema paths is ============ "+includedSchemaPaths);

      if(includedSchemaPaths!=  null)

      {

        for(int i=0; i<includedSchemaPaths.size(); i++)

        {

          String schemaFilePath = includedSchemaPaths.elementAt(i);

          //System.out.println("start to handle the included path ========="+schemaFilePath);

          try

          {

            String newShemaURLInMetacat = 

                           uploadSchemaFromURL(externalBaseURL+schemaFilePath);

            //System.out.println("success download the included schema and new url is  ========="+newShemaURLInMetacat);

            //recursively download the included schema

            handleIncludedSchema(newShemaURLInMetacat, externalBaseURL);

          }

          catch(Exception e)

          {

            logMetacat.warn("Warning on SchemaLocationResolver.handleIncludedSchema"+e.getMessage());

          }

        }

      }

    }

  }

  /**

   * Upload new Schema located at outside URL to Metacat file system

   */

  private String uploadSchemaFromURL(String schemaLocationURL) throws Exception

  {

	  String relativeSchemaPath = XMLSchemaService.SCHEMA_DIR;

    String fullSchemaPath = SystemUtil.getContextDir() + relativeSchemaPath;

    String schemaURL = SystemUtil.getContextURL()  + relativeSchemaPath;

    // get filename from systemId

    String filename = XMLSchemaService.getSchemaFileNameFromUri(schemaLocationURL);

    if (filename != null && !(filename.trim()).equals(""))

    {

      int slash = Math.max(filename.lastIndexOf('/'), filename.lastIndexOf('\\'));

      if ( slash > -1 ) 

      {

        filename = filename.substring(slash + 1);

      }

    }

    else

    {

      return null;

    }

    // writing schema text on Metacat file system as filename

    try {

      InputStream istream = DBEntityResolver.checkURLConnection(schemaLocationURL);

      // create a buffering character-input stream

      // that uses a default-sized input buffer

      BufferedInputStream in = new BufferedInputStream(istream);

      // open file writer to write the input into it

      File f = new File(fullSchemaPath, filename);

      synchronized (f) 

      {

        try 

        {

          if ( f.exists() ) 

          {

           throw new IOException("File already exist: " + f.getCanonicalFile());

          }

        } 

        catch (SecurityException se) 

        {

         // if a security manager exists,

          throw se;

       }

      // create a buffered character-output stream

      // that uses a default-sized output buffer

      FileWriter fw = new FileWriter(f);

      BufferedWriter out = new BufferedWriter(fw);

      // read the input and write into the file writer

      int inputByte;

      while ( (inputByte = in.read()) != -1 ) 

      {

        out.write(inputByte);

        //out.newLine(); //instead of out.write('\r\n');

      }

      // the input and the output streams must be closed

      in.close();

      out.flush();

      out.close();

      fw.close();

     } // end of synchronized

    } 

    catch (Exception e) 

    {

      throw new Exception

      ("shemaLocationResolver.uploadSchemaFromURL(): " + e.getMessage());

    } 

    logMetacat.warn("new schema location is: " + schemaURL + 

                              filename);

    return  relativeSchemaPath + filename;

  }

  /*

   * Register new schema identified by @systemId in Metacat XML Catalog

   */

  private void registerSchema(String systemId )

  {

    // check systemid is not null

    if (systemId == null || nameSpace == null || (nameSpace.trim()).equals(""))

    {    

      return;

    }

    DBConnection conn = null;

    int serialNumber = -1;

    PreparedStatement pstmt = null;

    String sql = "INSERT INTO xml_catalog " +

             "(entry_type, public_id, system_id) " +

             "VALUES ('" + DocumentImpl.SCHEMA + "', ?, ?)";

    try 

    {

      //check out DBConnection

      conn=DBConnectionPool.getDBConnection("schemaLocation.registerSchema");

      serialNumber=conn.getCheckOutSerialNumber();

      pstmt = conn.prepareStatement(sql);

      // Bind the values to the query

      pstmt.setString(1, nameSpace);

      pstmt.setString(2, systemId);

      // Do the insertion

      pstmt.execute();

      pstmt.close();

    } 

    catch (SQLException e) 

    {

      logMetacat.error("SchemaLocation.egisterSchema(): " + e.getMessage());

    }

    finally

    {

      try

      {

        pstmt.close();

      }//try

      catch (SQLException sqlE)

      {

        logMetacat.error("Error in SchemaLocation.egisterSchema(): "

                                    +sqlE.getMessage());

      }//catch

      DBConnectionPool.returnDBConnection(conn, serialNumber);

    }//finally

    XMLSchemaService.getInstance().populateRegisteredSchemaList();

  }

  /*

   * A method to parse the value for xis:schemaLocation="namespace location"

   * and store the namespace in nameSpace and location in schemaLocaion

   */

  private void parse(String nameSpaceAndLocation)

  {

    // check the parameter

    if (nameSpaceAndLocation == null||(nameSpaceAndLocation.trim()).equals(""))

    {

      return;

    }

    //Get white space index (delimiter)

    int indexOfWhiteSpace = nameSpaceAndLocation.lastIndexOf(WHITESPACESTRING);

    if (indexOfWhiteSpace != -1)

    {

      // before white space is namespace

      nameSpace = nameSpaceAndLocation.substring(0,indexOfWhiteSpace);

      // after white sapce is schema location

      schemaLocation = nameSpaceAndLocation.substring(indexOfWhiteSpace+1);

      // Gebug message

      logMetacat.info("Namespace after parsing: " + nameSpace);

      logMetacat.info("Location after parsing: " + schemaLocation);

    } 

  }

  /*public static void main(String[] argus)

  {

     try

     {

       DBConnectionPool pool = DBConnectionPool.getInstance();

       // Print out a empty schema list

       SchemaLocationResolver schema = new SchemaLocationResolver();

       logMetacat.warn("Namespace and Location String: "+ 

                                XMLSchemaService.getInstance().getNameSpaceAndLocationString());

       // input a schemalocation

       SchemaLocationResolver schema2 = new SchemaLocationResolver(

                                        "eml://ecoinformatics.org/eml-2.0.0 " +

                                "http://dev.nceas.ucsb.edu/tao/schema/eml.xsd");

       schema2.resolveNameSpace();

       // input a wrong name space location

       SchemaLocationResolver schema3 = new SchemaLocationResolver(

                                        "http://www.xm.org/schema/stmml " +

                              "http://dev.nceas.ucsb.edu/tao/schema/stmml.xsd");

       schema3.resolveNameSpace();

       // print out new schema list in db

       SchemaLocationResolver schema4 = new SchemaLocationResolver();

       logMetacat.warn("Namespace and Location String: "+ 

    		   XMLSchemaService.getInstance().getNameSpaceAndLocationString());

     }

     catch(Exception e)

     {

       logMetacat.error("erorr in Schemalocation.main: " + 

                                e.getMessage());

     }

  }*/

  /**

   * Gets the downloadNewSchema's value.

   * @return

   */

 public boolean getDownloadNewSchema()

 {

	 return this.downloadNewSchema;

 }

}