cassandra: CassandraArchivaManager.java CassandraMetadataRepository.java DefaultCassandraArchivaManager.java

olamy Thu, 20 Mar 2014 16:23:33 -0700

Author: olamy
Date: Thu Mar 20 23:22:31 2014
New Revision: 1579820

URL: http://svn.apache.org/r1579820
Log:
some cleanup


Modified:
    
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraArchivaManager.java
    
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
    
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraArchivaManager.java

Modified: 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraArchivaManager.java
URL: 
http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraArchivaManager.java?rev=1579820&r1=1579819&r2=1579820&view=diff
==============================================================================
--- 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraArchivaManager.java
 (original)
+++ 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraArchivaManager.java
 Thu Mar 20 23:22:31 2014
@@ -38,4 +38,8 @@ public interface CassandraArchivaManager
 
     Cluster getCluster();
 
+    String getRepositoryFamilyName();
+
+    String getNamespaceFamilyName();
+
 }

Modified: 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
URL: 
http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java?rev=1579820&r1=1579819&r2=1579820&view=diff
==============================================================================
--- 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
 (original)
+++ 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/CassandraMetadataRepository.java
 Thu Mar 20 23:22:31 2014
@@ -96,7 +96,7 @@ public class CassandraMetadataRepository
         QueryResult<OrderedRows<String, String, String>> result = HFactory //
             .createRangeSlicesQuery( keyspace, StringSerializer.get(), 
StringSerializer.get(),
                                      StringSerializer.get() ) //
-            .setColumnFamily( "repository" ) //
+            .setColumnFamily( 
cassandraArchivaManager.getRepositoryFamilyName() ) //
             .setColumnNames( "id", "name" ) //
             .addEqualsExpression( "id", repositoryId ) //
             .execute();
@@ -110,12 +110,13 @@ public class CassandraMetadataRepository
             {
                 MutationResult mutationResult = HFactory.createMutator( 
keyspace, StringSerializer.get() ) //
                     //  values
-                    .addInsertion( repositoryId, "repository",
+                    .addInsertion( repositoryId, //
+                                   
cassandraArchivaManager.getRepositoryFamilyName(), //
                                    CassandraUtils.column( "id", 
repository.getId() ) ) //
-                    .addInsertion( repositoryId, "repository",
+                    .addInsertion( repositoryId, //
+                                   
cassandraArchivaManager.getRepositoryFamilyName(), //
                                    CassandraUtils.column( "name", 
repository.getName() ) ) //
                     .execute();
-                logger.debug( "" );
                 return repository;
             }
             catch ( HInvalidRequestException e )
@@ -137,7 +138,7 @@ public class CassandraMetadataRepository
         QueryResult<OrderedRows<String, String, String>> result = HFactory //
             .createRangeSlicesQuery( keyspace, StringSerializer.get(), 
StringSerializer.get(),
                                      StringSerializer.get() ) //
-            .setColumnFamily( "repository" ) //
+            .setColumnFamily( 
cassandraArchivaManager.getRepositoryFamilyName() ) //
             .setColumnNames( "id", "name" ) //
             .addEqualsExpression( "id", repositoryId ) //
             .execute();
@@ -167,9 +168,11 @@ public class CassandraMetadataRepository
                 namespace = new Namespace( namespaceId, repository );
                 HFactory.createMutator( keyspace, StringSerializer.get() )
                     //  values
-                    .addInsertion( namespace.getId(), "namespace", //
+                    .addInsertion( namespace.getId(), //
+                                   
cassandraArchivaManager.getNamespaceFamilyName(), //
                                    CassandraUtils.column( "name", 
namespace.getName() ) ) //
-                    .addInsertion( namespace.getId(), "namespace", //
+                    .addInsertion( namespace.getId(), //
+                                   
cassandraArchivaManager.getNamespaceFamilyName(), //
                                    CassandraUtils.column( "repositoryId", 
repository.getId() ) ) //
                     .execute();
             }
@@ -191,7 +194,7 @@ public class CassandraMetadataRepository
                                      StringSerializer.get(), //
                                      StringSerializer.get(), //
                                      StringSerializer.get() ) //
-            .setColumnFamily( "namespace" ) //
+            .setColumnFamily( cassandraArchivaManager.getNamespaceFamilyName() 
) //
             .setColumnNames( "repositoryId", "name" ) //
             .addEqualsExpression( "repositoryId", repositoryId ) //
             .addEqualsExpression( "name", namespaceId ) //
@@ -217,8 +220,9 @@ public class CassandraMetadataRepository
                 new Namespace.KeyBuilder().withNamespace( namespaceId 
).withRepositoryId( repositoryId ).build();
 
             MutationResult result =
-                HFactory.createMutator( cassandraArchivaManager.getKeyspace(), 
new StringSerializer() ).addDeletion(
-                    key, "namespace" ).execute();
+                HFactory.createMutator( cassandraArchivaManager.getKeyspace(), 
new StringSerializer() ) //
+                    .addDeletion( key, 
cassandraArchivaManager.getNamespaceFamilyName() ) //
+                    .execute();
 
 
         }
@@ -247,7 +251,7 @@ public class CassandraMetadataRepository
                                      StringSerializer.get(), //
                                      StringSerializer.get(), //
                                      StringSerializer.get() ) //
-            .setColumnFamily( "namespace" ) //
+            .setColumnFamily( cassandraArchivaManager.getNamespaceFamilyName() 
) //
             .setColumnNames( "repositoryId", "name" ) //
             .addEqualsExpression( "repositoryId", repositoryId ) //
             .execute();
@@ -258,12 +262,12 @@ public class CassandraMetadataRepository
         }
 
         HFactory.createMutator( cassandraArchivaManager.getKeyspace(), new 
StringSerializer() ) //
-            .addDeletion( namespacesKey, "namespace" ) //
+            .addDeletion( namespacesKey, 
cassandraArchivaManager.getNamespaceFamilyName() ) //
             .execute();
 
         //delete repositoryId
         HFactory.createMutator( cassandraArchivaManager.getKeyspace(), new 
StringSerializer() ) //
-            .addDeletion( repositoryId, "repository" ) //
+            .addDeletion( repositoryId, 
cassandraArchivaManager.getRepositoryFamilyName() ) //
             .execute();
 
 /*
@@ -434,7 +438,7 @@ public class CassandraMetadataRepository
                                      StringSerializer.get(), //
                                      StringSerializer.get(), //
                                      StringSerializer.get() ) //
-            .setColumnFamily( "namespace" ) //
+            .setColumnFamily( cassandraArchivaManager.getNamespaceFamilyName() 
) //
             .setColumnNames( "name" ) //
             .addEqualsExpression( "repositoryId", repoId ) //
             .execute();
@@ -473,7 +477,7 @@ public class CassandraMetadataRepository
                                      StringSerializer.get(), //
                                      StringSerializer.get(), //
                                      StringSerializer.get() ) //
-            .setColumnFamily( "namespace" ) //
+            .setColumnFamily( cassandraArchivaManager.getNamespaceFamilyName() 
) //
             .setColumnNames( "name" ) //
             .addEqualsExpression( "repositoryId", repoId ) //
             .execute();

Modified: 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraArchivaManager.java
URL: 
http://svn.apache.org/viewvc/archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraArchivaManager.java?rev=1579820&r1=1579819&r2=1579820&view=diff
==============================================================================
--- 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraArchivaManager.java
 (original)
+++ 
archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra/DefaultCassandraArchivaManager.java
 Thu Mar 20 23:22:31 2014
@@ -48,7 +48,7 @@ import java.util.List;
  * @author Olivier Lamy
  * @since 2.0.0
  */
-@Service( "archivaEntityManagerFactory#cassandra" )
+@Service("archivaEntityManagerFactory#cassandra")
 public class DefaultCassandraArchivaManager
     implements CassandraArchivaManager
 {
@@ -68,6 +68,11 @@ public class DefaultCassandraArchivaMana
 
     private Keyspace keyspace;
 
+    // configurable???
+    private String repositoryFamilyName = "repository";
+
+    private String namespaceFamilyName = "namespace";
+
 
     @PostConstruct
     public void initialize()
@@ -180,4 +185,14 @@ public class DefaultCassandraArchivaMana
     {
         return cluster;
     }
+
+    public String getRepositoryFamilyName()
+    {
+        return repositoryFamilyName;
+    }
+
+    public String getNamespaceFamilyName()
+    {
+        return namespaceFamilyName;
+    }
 }

svn commit: r1579820 - in /archiva/trunk/archiva-modules/plugins/metadata-store-cassandra/src/main/java/org/apache/archiva/metadata/repository/cassandra: CassandraArchivaManager.java CassandraMetadataRepository.java DefaultCassandraArchivaManager.java

Reply via email to