You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by lu...@apache.org on 2013/01/16 21:33:26 UTC

svn commit: r1434369 - in /oodt/trunk/filemgr/src/main: java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java resources/cas-filemgr-dyn-catalog-schema.sql

Author: luca
Date: Wed Jan 16 20:33:26 2013
New Revision: 1434369

URL: http://svn.apache.org/viewvc?rev=1434369&view=rev
Log:
Inserting primary key in metadata table for database-based File Manager implementation (OODT-551).

Modified:
    oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java
    oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java
    oodt/trunk/filemgr/src/main/resources/cas-filemgr-dyn-catalog-schema.sql

Modified: oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java
URL: http://svn.apache.org/viewvc/oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java?rev=1434369&r1=1434368&r2=1434369&view=diff
==============================================================================
--- oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java (original)
+++ oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/DataSourceCatalog.java Wed Jan 16 20:33:26 2013
@@ -17,7 +17,7 @@
 
 package org.apache.oodt.cas.filemgr.catalog;
 
-// OODT imports
+//OODT imports
 import org.apache.oodt.cas.filemgr.structs.BooleanQueryCriteria;
 import org.apache.oodt.cas.filemgr.structs.Element;
 import org.apache.oodt.cas.filemgr.structs.Product;
@@ -824,7 +824,7 @@ public class DataSourceCatalog implement
 
             String getProductRefSql = "SELECT * FROM "
                     + product.getProductType().getName() + "_reference"
-                    + " WHERE product_id = " + quoteIt(product.getProductId());
+                    + " WHERE product_id = " + quoteIt(product.getProductId()) + " ORDER BY pkey";
 
             LOG.log(Level.FINE, "getProductReferences: Executing: "
                     + getProductRefSql);
@@ -1060,8 +1060,8 @@ public class DataSourceCatalog implement
             statement = conn.createStatement();
 
             String metadataSql = "SELECT * FROM "
-                    + product.getProductType().getName() + "_metadata "
-                    + " WHERE product_id = " + quoteIt(product.getProductId());
+                    + product.getProductType().getName() + "_metadata"
+                    + " WHERE product_id = " + quoteIt(product.getProductId())+" ORDER BY pkey";
 
             LOG.log(Level.FINE, "getMetadata: Executing: " + metadataSql);
             rs = statement.executeQuery(metadataSql);
@@ -1152,7 +1152,8 @@ public class DataSourceCatalog implement
             }
             String metadataSql = "SELECT element_id,metadata_value FROM "
                     + product.getProductType().getName() + "_metadata"
-                    + " WHERE product_id = " + quoteIt(product.getProductId()) + elementIds;
+                    + " WHERE product_id = " + quoteIt(product.getProductId()) + elementIds
+                    + " ORDER BY pkey";
 
             LOG.log(Level.FINE, "getMetadata: Executing: " + metadataSql);
             rs = statement.executeQuery(metadataSql);

Modified: oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java
URL: http://svn.apache.org/viewvc/oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java?rev=1434369&r1=1434368&r2=1434369&view=diff
==============================================================================
--- oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java (original)
+++ oodt/trunk/filemgr/src/main/java/org/apache/oodt/cas/filemgr/catalog/LenientDataSourceCatalog.java Wed Jan 16 20:33:26 2013
@@ -226,7 +226,7 @@ public class LenientDataSourceCatalog ex
 
             String metadataSql = "SELECT * FROM "
                     + product.getProductType().getName() + "_metadata "
-                    + " WHERE product_id = '" + product.getProductId()+"'";
+                    + "WHERE product_id = '" + product.getProductId()+"' ORDER BY pkey" ;
 
             LOG.log(Level.FINE, "getMetadata: Executing: " + metadataSql);
             rs = statement.executeQuery(metadataSql);
@@ -358,7 +358,7 @@ public class LenientDataSourceCatalog ex
             }
             String metadataSql = "SELECT element_id,metadata_value FROM "
                     + product.getProductType().getName() + "_metadata"
-                    + " WHERE product_id = " + quoteIt(product.getProductId()) + elementIds;
+                    + " WHERE product_id = " + quoteIt(product.getProductId()) + elementIds + " ORDER BY pkey";
 
             LOG.log(Level.FINE, "getMetadata: Executing: " + metadataSql);
             rs = statement.executeQuery(metadataSql);

Modified: oodt/trunk/filemgr/src/main/resources/cas-filemgr-dyn-catalog-schema.sql
URL: http://svn.apache.org/viewvc/oodt/trunk/filemgr/src/main/resources/cas-filemgr-dyn-catalog-schema.sql?rev=1434369&r1=1434368&r2=1434369&view=diff
==============================================================================
--- oodt/trunk/filemgr/src/main/resources/cas-filemgr-dyn-catalog-schema.sql (original)
+++ oodt/trunk/filemgr/src/main/resources/cas-filemgr-dyn-catalog-schema.sql Wed Jan 16 20:33:26 2013
@@ -16,6 +16,7 @@
 
 CREATE TABLE YourProductTypeName_metadata
 (
+  pkey int(10) unsigned primary KEY AUTO_INCREMENT, 
   product_id int NOT NULL,
   element_id varchar(1000) NOT NULL,
   metadata_value varchar(2500) NOT NULL