svn commit: r1488964 - /archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java

[olamy]

Author: olamy
Date: Mon Jun  3 11:48:54 2013
New Revision: 1488964

URL: http://svn.apache.org/r1488964
Log:
fix getProjectVersion

Modified:
    
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java

Modified: 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
URL: 
http://svn.apache.org/viewvc/archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java?rev=1488964&r1=1488963&r2=1488964&view=diff
==============================================================================
--- 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
 (original)
+++ 
archiva/sandbox/trunk/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
 Mon Jun  3 11:48:54 2013
@@ -770,6 +770,22 @@ public class CassandraMetadataRepository
             throw new MetadataRepositoryException( e.getMessage(), e );
         }
 
+        key = new ProjectVersionMetadataModel.KeyBuilder().withRepository( 
repositoryId ).withNamespace(
+            namespace ).withProjectId( projectId ).withId( projectVersion 
).build();
+
+        ProjectVersionMetadataModel projectVersionMetadataModel = 
projectVersionMetadataModelEntityManager.get( key );
+
+        if ( projectVersionMetadataModel == null )
+        {
+            projectVersionMetadataModel = new ProjectVersionMetadataModel();
+            projectVersionMetadataModel.setRowId( key );
+            projectVersionMetadataModel.setProjectId( projectId );
+            projectVersionMetadataModel.setId( projectVersion );
+            projectVersionMetadataModel.setNamespace( namespace );
+            projectVersionMetadataModelEntityManager.put( 
projectVersionMetadataModel );
+            // FIXME collections  ???
+        }
+
         // now facets
         updateFacets( artifactMeta, artifactMetadataModel );
 
@@ -1464,6 +1480,14 @@ public class CassandraMetadataRepository
 
         if ( projectVersionMetadataModel == null )
         {
+            projectVersionMetadataModelEntityManager.visitAll( new 
Function<ProjectVersionMetadataModel, Boolean>()
+            {
+                @Override
+                public Boolean apply( ProjectVersionMetadataModel 
projectVersionMetadataModel )
+                {
+                    return Boolean.TRUE;
+                }
+            } );
             return null;
         }