/ - Diff - Metacat - Ecoinformatics Redmine

« Previous | Next »

Revision 4427

Added by daigle about 16 years ago

Use XMLSchemaService to access persistent schema information.

     import java.sql.*;
     import java.io.File;
     import java.io.Reader;
     import java.io.BufferedReader;
     import java.io.BufferedInputStream;
     import java.io.FileWriter;
     import java.io.BufferedWriter;
     import java.io.InputStream;
     import java.io.IOException;
     import java.net.URL;
     import java.net.URLConnection;
     import java.net.MalformedURLException;
     import java.util.Vector;
     import org.apache.log4j.Logger;
     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
-...
       private String nameSpace = null; //public id
       private String schemaLocation = null; // system id
       private Vector nameSpaceList = new Vector();// name space in the table
       private String nameSpaceAndLocationString = null; // the parameter will be set
                                                   // in external property in parser
     //  private Vector<String> nameSpaceList = new Vector<String>();// name space in the table
     //  private String nameSpaceAndLocationString = ""; // the parameter will be set
     //                                              // in external property in parser
       //private String schemaFileName = null;
       // constant
       //private String SCHEMATYPE ="Schema";
-...
       private static Logger logMetacat = Logger.getLogger(SchemaLocationResolver.class);
       public SchemaLocationResolver()
+      {
         createNameSpaceAndLocationStringFromDB();
+      {
+      }
       /**
        * Construct an instance of the SchemaLocationResolver class
+       *
-...
        */
       public SchemaLocationResolver(String myNameSpaceAndLocation)
+      {
         parse(myNameSpaceAndLocation);
     	  parse(myNameSpaceAndLocation);
+      }
       /**
        * A method to get nameSpaceAndLocationString
        * Construct an instance of the SchemaLocationResolver class
+       *
        * @param  myNameSpaceAndLocation it is come from xsi:schemaLocation=
        *         "namespace location"
        */
       public String getNameSpaceAndLocationString()
       public SchemaLocationResolver(String myNameSpace, String myLocation)
+      {
         logMetacat.info("namespace and location list is: " +
                                  nameSpaceAndLocationString);
         return nameSpaceAndLocationString;
           nameSpace = myNameSpace;
           schemaLocation = myLocation;
+      }
       /**
-...
        */
       public void resolveNameSpace ()
+      {
         //get name space lists
         createNameSpaceListFromDB();
         // if name space is not in table
         if (nameSpace !=null && schemaLocation != null &&
             !nameSpaceList.contains(nameSpace))
             !XMLSchemaService.getNameSpaceList().contains(nameSpace))
+        {
            try
+           {
-...
             InputStream in = DBEntityResolver.checkURLConnection(schemaLocation);
             String newURLInMetacat = uploadSchemaFromURL(in);
             XMLSchemaService.refresh();
             // reigister schema
             registerSchema(newURLInMetacat);
             // 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.getNameSpaceList().contains(nameSpace)) {
             	registerSchema(newURLInMetacat);
             	XMLSchemaService.refresh();
+            }
             downloadNewSchema = true;
+           }
-...
+      }
       /*
     	 * This method will take look xml_catalog table and create a string look
     	 * like "namespace1 location namespacke2 location". This string will be set
     	 * as a extenalschemalocation in SAX parser. Then when parser check the it
     	 * will ignore the schema location specified by xml document
     	 */
     	private void createNameSpaceAndLocationStringFromDB() {
     		DBConnection conn = null;
     		int serialNumber = -1;
     		PreparedStatement pstmt = null;
     		ResultSet result = null;
     		String sql = "SELECT public_id, system_id FROM xml_catalog where "
     				+ "entry_type ='" + DocumentImpl.SCHEMA + "'";
     		try {
     			// check out DBConnection
     			conn = DBConnectionPool.getDBConnection("SchemaLocationResl.createName");
     			serialNumber = conn.getCheckOutSerialNumber();
     			pstmt = conn.prepareStatement(sql);
     			pstmt.execute();
     			result = pstmt.getResultSet();
     			// Get string for namespace and location form DB
     			boolean hasRow = result.next();
     			StringBuffer buffer = new StringBuffer();
     			boolean firstTime = true;
     			while (hasRow) {
     				String namespace = result.getString(1);
     				String location = result.getString(2);
     				// system id may not have server url on front. Add it if not.
     				if (!location.startsWith("http://")) {
     					try {
     						location = SystemUtil.getContextURL() + location;
     					} catch (PropertyNotFoundException pnfe) {
     						throw new SQLException("Could not find property: "
     								+ pnfe.getMessage());
+    					}
+    				}
     				String pairOfNameSpaceAndLocation = namespace + WHITESPACESTRING
     						+ location;
     				if (!firstTime) {
     					buffer.append(WHITESPACESTRING);
+    				}
     				buffer.append(pairOfNameSpaceAndLocation);
     				firstTime = false;
     				hasRow = result.next();
+    			}
     			// give the buffer to the string if buffer has something in it
     			if (buffer.length() != 0) {
     				nameSpaceAndLocationString = buffer.toString();
+    			}
     			result.close();
     			pstmt.close();
     		} catch (SQLException e) {
     			logMetacat.error("schemaLocation.createNameSpaceAndLocationString: "
     					+ e.getMessage());
     		} finally {
     			try {
     				pstmt.close();
     			}// try
     			catch (SQLException sqlE) {
     				logMetacat.error("Error in schema.createNameSpaceAndLocation "
     						+ sqlE.getMessage());
     			}// catch
     			DBConnectionPool.returnDBConnection(conn, serialNumber);
     		}// finally
+    	}
       /*
     	 * This method will take look xml_catalog table and create a name space
     	 * vector already in the table
     	 */
       private void createNameSpaceListFromDB()
+      {
         DBConnection conn = null;
         int serialNumber = -1;
         PreparedStatement pstmt = null;
         ResultSet result = null;
         String sql = "SELECT public_id FROM xml_catalog where " +
                      "entry_type ='" + DocumentImpl.SCHEMA +"'";
         try
+        {
           //check out DBConnection
           conn=DBConnectionPool.getDBConnection("SchemaLocationResl.createNameList");
           serialNumber=conn.getCheckOutSerialNumber();
           pstmt = conn.prepareStatement(sql);
           pstmt.execute();
           result = pstmt.getResultSet();
           // Get string for namespace form DB and store in the vector
           boolean hasRow = result.next();
           while (hasRow)
+          {
             String namespace = result.getString(1);
             nameSpaceList.addElement(namespace);
             hasRow = result.next();
+          }
           pstmt.close();
           result.close();
+        }
         catch (SQLException e)
+        {
           logMetacat.error("schemaLocation.createNameSpaceList: " +
                              e.getMessage());
+        }
         finally
+        {
           try
+          {
             pstmt.close();
           }//try
           catch (SQLException sqlE)
+          {
             logMetacat.error("Error in schemaLocation.createNameSpaceList: "
                                         +sqlE.getMessage());
           }//catch
           DBConnectionPool.returnDBConnection(conn, serialNumber);
         }//finally
+      }
       /**
        * Upload new Schema located at outside URL to Metacat file system
        */
       private String uploadSchemaFromURL(InputStream istream) throws Exception
+      {
         String schemaPath = SystemUtil.getContextDir() + "/schema/";
         String schemaURL = SystemUtil.getContextURL()  + "/schema/";
     	String relativeSchemaPath = XMLSchemaService.SCHEMA_DIR;
         String fullSchemaPath = SystemUtil.getContextDir() + relativeSchemaPath;
         String schemaURL = SystemUtil.getContextURL()  + relativeSchemaPath;
         // get filename from systemId
         String filename = schemaLocation;
         String filename = XMLSchemaService.getSchemaFileNameFromUri(schemaLocation);
         if (filename != null && !(filename.trim()).equals(""))
+        {
-...
           BufferedInputStream in = new BufferedInputStream(istream);
           // open file writer to write the input into it
           File f = new File(schemaPath, filename);
           File f = new File(fullSchemaPath, filename);
           synchronized (f)
+          {
             try
-...
+        }
         logMetacat.warn("new schema location is: " + schemaURL +
                                   filename);
         return  schemaURL + filename;
         return  relativeSchemaPath + filename;
+      }
-...
+      {
         // check systemid is not null
         if (systemId == null || nameSpace == null || (nameSpace.trim()).equals(""))
+        {
+        {
           return;
+        }
-...
                                         +sqlE.getMessage());
           }//catch
           DBConnectionPool.returnDBConnection(conn, serialNumber);
         }//finally
         XMLSchemaService.populateRegisteredSchemaList();
+      }
       /*
-...
            // Print out a empty schema list
            SchemaLocationResolver schema = new SchemaLocationResolver();
            logMetacat.warn("Namespace and Location String: "+
                                     schema.getNameSpaceAndLocationString());
                                     XMLSchemaService.getNameSpaceAndLocationString());
            // input a schemalocation
            SchemaLocationResolver schema2 = new SchemaLocationResolver(
                                             "eml://ecoinformatics.org/eml-2.0.0 " +
-...
            // print out new schema list in db
            SchemaLocationResolver schema4 = new SchemaLocationResolver();
            logMetacat.warn("Namespace and Location String: "+
                                     schema4.getNameSpaceAndLocationString());
         		   XMLSchemaService.getNameSpaceAndLocationString());
+         }
          catch(Exception e)
+         {

Also available in: Unified diff

Project

General

Profile

Metacat

Revision 4427

Added by daigle about 16 years ago