source.dussan.org Git - archiva.git/blob

   1 package org.apache.archiva.metadata.repository.cassandra;
   2
   3 /*
   4  * Licensed to the Apache Software Foundation (ASF) under one
   5  * or more contributor license agreements.  See the NOTICE file
   6  * distributed with this work for additional information
   7  * regarding copyright ownership.  The ASF licenses this file
   8  * to you under the Apache License, Version 2.0 (the
   9  * "License"); you may not use this file except in compliance
  10  * with the License.  You may obtain a copy of the License at
  11  *
  12  *  http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing,
  15  * software distributed under the License is distributed on an
  16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
  17  * KIND, either express or implied.  See the License for the
  18  * specific language governing permissions and limitations
  19  * under the License.
  20  */
  21
  22 import com.datastax.oss.driver.api.core.CqlSession;
  23 import com.datastax.oss.driver.api.core.CqlSessionBuilder;
  24 import com.datastax.oss.driver.api.core.config.DefaultDriverOption;
  25 import com.datastax.oss.driver.api.core.config.DriverConfigLoader;
  26 import com.datastax.oss.driver.api.core.type.DataTypes;
  27 import com.datastax.oss.driver.api.querybuilder.schema.CreateIndex;
  28 import com.datastax.oss.driver.api.querybuilder.schema.CreateKeyspace;
  29 import com.datastax.oss.driver.api.querybuilder.schema.CreateTableWithOptions;
  30 import org.apache.archiva.metadata.repository.RepositorySessionFactoryBean;
  31 import org.apache.commons.lang3.StringUtils;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34 import org.springframework.beans.factory.annotation.Value;
  35 import org.springframework.context.ApplicationContext;
  36 import org.springframework.stereotype.Service;
  37
  38 import javax.annotation.PostConstruct;
  39 import javax.annotation.PreDestroy;
  40 import javax.inject.Inject;
  41 import java.time.Duration;
  42 import java.util.ArrayList;
  43 import java.util.Arrays;
  44 import java.util.List;
  45
  46 import static com.datastax.oss.driver.api.querybuilder.SchemaBuilder.*;
  47 import static org.apache.archiva.metadata.repository.cassandra.model.ColumnNames.*;
  48
  49 /**
  50  * FIXME make all configuration not hardcoded :-)
  51  *
  52  * @author Olivier Lamy
  53  * @since 2.0.0
  54  */
  55 @Service( "archivaEntityManagerFactory#cassandra" )
  56 public class DefaultCassandraArchivaManager
  57     implements CassandraArchivaManager
  58 {
  59
  60     private static final Logger logger = LoggerFactory.getLogger( DefaultCassandraArchivaManager.class );
  61
  62     @Inject
  63     private ApplicationContext applicationContext;
  64
  65     private static final String CLUSTER_NAME = "archiva";
  66
  67     private static final String KEYSPACE_NAME = "ArchivaKeySpace";
  68
  69     private boolean started;
  70
  71     // configurable???
  72     private String repositoryFamilyName = "repository";
  73
  74     private String namespaceFamilyName = "namespace";
  75
  76     private String projectFamilyName = PROJECT.toString( );
  77
  78     private String projectVersionMetadataFamilyName = "projectversionmetadata";
  79
  80     private String artifactMetadataFamilyName = "artifactmetadata";
  81
  82     private String metadataFacetFamilyName = "metadatafacet";
  83
  84     private String mailingListFamilyName = "mailinglist";
  85
  86     private String licenseFamilyName = "license";
  87
  88     private String dependencyFamilyName = "dependency";
  89
  90     private String checksumFamilyName = "checksum";
  91
  92
  93     private static String[] projectVersionMetadataColumns;
  94
  95
  96     static
  97     {
  98         projectVersionMetadataColumns = new String[]{
  99             DEFAULT_PRIMARY_KEY,
 100             NAMESPACE_ID.toString( ),
 101             REPOSITORY_NAME.toString( ),
 102             PROJECT_VERSION.toString( ),
 103             PROJECT_ID.toString( ),
 104             DESCRIPTION.toString( ),
 105             URL.toString( ),
 106             NAME.toString( ),
 107             VERSION.toString( ),
 108             VERSION_PROPERTIES.toString( ),
 109             "incomplete",
 110             "ciManagement.system",
 111             "ciManagement.url",
 112             "issueManagement.system",
 113             "issueManagement.url",
 114             "organization.name",
 115             "organization.url",
 116             "scm.url",
 117             "scm.connection",
 118             "scm.developerConnection"
 119         };
 120         Arrays.sort( projectVersionMetadataColumns );
 121     }
 122
 123     @Value( "${cassandra.host}" )
 124     private String cassandraHost;
 125
 126     @Value( "${cassandra.port}" )
 127     private String cassandraPort;
 128
 129     @Value( "${cassandra.maxActive}" )
 130     private int maxActive;
 131
 132     @Value( "${cassandra.readConsistencyLevel}" )
 133     private String readConsistencyLevel;
 134
 135     @Value( "${cassandra.writeConsistencyLevel}" )
 136     private String writeConsistencyLevel;
 137
 138     @Value( "${cassandra.replicationFactor}" )
 139     private int replicationFactor;
 140
 141     @Value( "${cassandra.keyspace.name}" )
 142     private String keyspaceName;
 143
 144     @Value( "${cassandra.cluster.name}" )
 145     private String clusterName;
 146
 147     @Inject
 148     private RepositorySessionFactoryBean repositorySessionFactoryBean;
 149
 150     DriverConfigLoader configLoader;
 151
 152     CqlSession cqlSession;
 153
 154     @Override
 155     public CqlSessionBuilder getSessionBuilder( )
 156     {
 157         return CqlSession.builder( ).withConfigLoader( configLoader ).withKeyspace( keyspaceName ).withLocalDatacenter( "datacenter1" );
 158     }
 159
 160     @Override
 161     public CqlSession getSession( )
 162     {
 163         if (cqlSession==null || cqlSession.isClosed()) {
 164             this.cqlSession = getSessionBuilder( ).build( );
 165         }
 166         return this.cqlSession;
 167     }
 168
 169     @PostConstruct
 170     public void initialize( )
 171     {
 172         // skip initialisation if not cassandra
 173         if ( !StringUtils.equals( repositorySessionFactoryBean.getId( ), "cassandra" ) )
 174         {
 175             return;
 176         }
 177
 178         List<String> hostNames = new ArrayList<>( );
 179         hostNames.add( cassandraHost + ":" + cassandraPort );
 180         System.out.println( "Contact point: " + cassandraHost + ":" + cassandraPort );
 181         configLoader =
 182             DriverConfigLoader.programmaticBuilder( )
 183
 184                 .withStringList( DefaultDriverOption.CONTACT_POINTS, hostNames )
 185                 .withInt( DefaultDriverOption.CONNECTION_POOL_LOCAL_SIZE, maxActive )
 186                 .withInt( DefaultDriverOption.CONNECTION_POOL_REMOTE_SIZE, maxActive )
 187                 //.withInt( DefaultDriverOption.CONNECTION_MAX_REQUESTS, maxActive )
 188                 .withString( DefaultDriverOption.REQUEST_CONSISTENCY, readConsistencyLevel )
 189                 .withDuration( DefaultDriverOption.REQUEST_TIMEOUT, Duration.ofSeconds( 10 ) )
 190                 .build( );
 191
 192         {
 193
 194             CreateKeyspace cKeySpace = createKeyspace( keyspaceName ).ifNotExists( ).withSimpleStrategy( replicationFactor );
 195             CqlSession.builder( ).withConfigLoader( configLoader ).withLocalDatacenter( "datacenter1" ).build().execute( cKeySpace.build( ) );
 196         }
 197
 198         CqlSession session = getSession( );
 199
 200         {
 201
 202             // namespace table
 203             {
 204                 String tableName = getNamespaceFamilyName( );
 205                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 206                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 207                     .withColumn( NAME.toString( ), DataTypes.TEXT )
 208                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 209                     .withCompactStorage( );
 210                 session.execute( table.build( ) );
 211                 CreateIndex index = createIndex( NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAME.toString( ) );
 212                 session.execute( index.build( ) );
 213                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 214                 session.execute( index.build( ) );
 215             }
 216
 217             // Repository Table
 218             {
 219                 String tableName = getRepositoryFamilyName( );
 220                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 221                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 222                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 223                     .withCompactStorage( );
 224                 session.execute( table.build( ) );
 225                 CreateIndex index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 226                 session.execute( index.build( ) );
 227
 228             }
 229
 230             // Project table
 231             {
 232                 String tableName = getProjectFamilyName( );
 233                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 234                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 235                     .withColumn( PROJECT_ID.toString( ), DataTypes.TEXT )
 236                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 237                     .withColumn( NAMESPACE_ID.toString( ), DataTypes.TEXT )
 238                     .withColumn( PROJECT_PROPERTIES.toString( ), DataTypes.frozenMapOf( DataTypes.TEXT, DataTypes.TEXT ) )
 239                     .withCompactStorage( );
 240                 session.execute( table.build( ) );
 241                 CreateIndex index = createIndex( PROJECT_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_ID.toString( ) );
 242                 session.execute( index.build( ) );
 243                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 244                 session.execute( index.build( ) );
 245                 index = createIndex( NAMESPACE_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAMESPACE_ID.toString( ) );
 246                 session.execute( index.build( ) );
 247
 248             }
 249
 250             // Project Version Metadata Model
 251             {
 252                 String tableName = getProjectVersionMetadataFamilyName( );
 253                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 254                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 255                     .withColumn( NAMESPACE_ID.toString( ), DataTypes.TEXT )
 256                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 257                     .withColumn( PROJECT_VERSION.toString( ), DataTypes.TEXT )
 258                     .withColumn( PROJECT_ID.toString( ), DataTypes.TEXT )
 259                     .withColumn( DESCRIPTION.toString( ), DataTypes.TEXT )
 260                     .withColumn( URL.toString( ), DataTypes.TEXT )
 261                     .withColumn( NAME.toString(), DataTypes.TEXT )
 262                     .withColumn( VERSION.toString(), DataTypes.TEXT )
 263                     .withColumn( VERSION_PROPERTIES.toString(), DataTypes.mapOf( DataTypes.TEXT, DataTypes.TEXT ) )
 264                     .withColumn( "incomplete", DataTypes.BOOLEAN )
 265                     .withColumn( "\"ciManagement.system\"", DataTypes.TEXT )
 266                     .withColumn( "\"ciManagement.url\"", DataTypes.TEXT )
 267                     .withColumn( "\"issueManagement.system\"", DataTypes.TEXT )
 268                     .withColumn( "\"issueManagement.url\"", DataTypes.TEXT )
 269                     .withColumn( "\"organization.name\"", DataTypes.TEXT )
 270                     .withColumn( "\"organization.url\"", DataTypes.TEXT )
 271                     .withColumn( "\"scm.url\"", DataTypes.TEXT )
 272                     .withColumn( "\"scm.connection\"", DataTypes.TEXT )
 273                     .withColumn( "\"scm.developerConnection\"", DataTypes.TEXT );
 274                 session.execute( table.build( ) );
 275                 CreateIndex index = createIndex( NAMESPACE_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAMESPACE_ID.toString( ) );
 276                 session.execute( index.build( ) );
 277                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 278                 session.execute( index.build( ) );
 279                 index = createIndex( PROJECT_VERSION.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_VERSION.toString( ) );
 280                 session.execute( index.build( ) );
 281                 index = createIndex( PROJECT_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_ID.toString( ) );
 282                 session.execute( index.build( ) );
 283                 index = createIndex( VERSION_PROPERTIES.toString( ) + "_idx" ).ifNotExists( ).onTable( tableName ).andColumnEntries(  VERSION_PROPERTIES.toString( ) );
 284                 session.execute( index.build( ) );
 285             }
 286
 287             // Artifact Metadata Model
 288             {
 289                 String tableName = getArtifactMetadataFamilyName( );
 290                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 291                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 292                     .withColumn( ID.toString( ), DataTypes.TEXT )
 293                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 294                     .withColumn( NAMESPACE_ID.toString( ), DataTypes.TEXT )
 295                     .withColumn( PROJECT_ID.toString( ), DataTypes.TEXT )
 296                     .withColumn( PROJECT_VERSION.toString( ), DataTypes.TEXT )
 297                     .withColumn( VERSION.toString( ), DataTypes.TEXT )
 298                     .withColumn( WHEN_GATHERED.toString( ), DataTypes.BIGINT )
 299                     .withColumn( SHA1.toString( ), DataTypes.TEXT )
 300                     .withColumn( MD5.toString( ), DataTypes.TEXT )
 301                     .withColumn( FILE_LAST_MODIFIED.toString(), DataTypes.BIGINT)
 302                     .withColumn( SIZE.toString(), DataTypes.BIGINT )
 303                     .withCompactStorage( );
 304                 session.execute( table.build( ) );
 305
 306                 CreateIndex index = createIndex( ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( ID.toString( ) );
 307                 session.execute( index.build( ) );
 308                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 309                 session.execute( index.build( ) );
 310                 index = createIndex( NAMESPACE_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAMESPACE_ID.toString( ) );
 311                 session.execute( index.build( ) );
 312                 index = createIndex( PROJECT_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_ID.toString( ) );
 313                 session.execute( index.build( ) );
 314                 index = createIndex( PROJECT_VERSION.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_VERSION.toString( ) );
 315                 session.execute( index.build( ) );
 316                 index = createIndex( VERSION.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( VERSION.toString( ) );
 317                 session.execute( index.build( ) );
 318                 index = createIndex( WHEN_GATHERED.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( WHEN_GATHERED.toString( ) );
 319                 session.execute( index.build( ) );
 320                 index = createIndex( SHA1.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( SHA1.toString( ) );
 321                 session.execute( index.build( ) );
 322                 index = createIndex( MD5.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( MD5.toString( ) );
 323                 session.execute( index.build( ) );
 324
 325             }
 326             // Metadata Facet Model
 327             {
 328                 String tableName = getMetadataFacetFamilyName( );
 329                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 330                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 331                     .withColumn( FACET_ID.toString( ), DataTypes.TEXT )
 332                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 333                     .withColumn( NAME.toString( ), DataTypes.TEXT )
 334                     .withColumn( NAMESPACE_ID.toString( ), DataTypes.TEXT )
 335                     .withColumn( PROJECT_ID.toString( ), DataTypes.TEXT )
 336                     .withColumn( PROJECT_VERSION.toString( ), DataTypes.TEXT )
 337                     .withColumn( KEY.toString(), DataTypes.TEXT )
 338                     .withColumn( VALUE.toString(), DataTypes.TEXT)
 339                     .withColumn( WHEN_GATHERED.toString(), DataTypes.BIGINT )
 340                     .withCompactStorage( );
 341                 session.execute( table.build( ) );
 342
 343                 CreateIndex index = createIndex( FACET_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( FACET_ID.toString( ) );
 344                 session.execute( index.build( ) );
 345                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 346                 session.execute( index.build( ) );
 347                 index = createIndex( NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAME.toString( ) );
 348                 session.execute( index.build( ) );
 349                 index = createIndex( NAMESPACE_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( NAMESPACE_ID.toString( ) );
 350                 session.execute( index.build( ) );
 351                 index = createIndex( PROJECT_ID.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_ID.toString( ) );
 352                 session.execute( index.build( ) );
 353                 index = createIndex( PROJECT_VERSION.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( PROJECT_VERSION.toString( ) );
 354                 session.execute( index.build( ) );
 355             }
 356             // Checksum Table
 357             {
 358                 String tableName = getChecksumFamilyName( );
 359                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 360                     .withPartitionKey( DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 361                     .withColumn( "\"artifactMetadataModel.key\"", DataTypes.TEXT )
 362                     .withColumn( CHECKSUM_ALG.toString( ), DataTypes.TEXT )
 363                     .withColumn( CHECKSUM_VALUE.toString( ), DataTypes.TEXT )
 364                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 365                     .withCompactStorage( );
 366                 session.execute( table.build( ) );
 367
 368                 CreateIndex index = createIndex( CHECKSUM_ALG.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( CHECKSUM_ALG.toString( ) );
 369                 session.execute( index.build( ) );
 370                 index = createIndex( CHECKSUM_VALUE.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( CHECKSUM_VALUE.toString( ) );
 371                 session.execute( index.build( ) );
 372                 index = createIndex( REPOSITORY_NAME.toString( ) ).ifNotExists( ).onTable( tableName ).andColumn( REPOSITORY_NAME.toString( ) );
 373                 session.execute( index.build( ) );
 374             }
 375             // Mailinglist Table
 376             {
 377                 String tableName = getMailingListFamilyName( );
 378                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 379                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 380                     .withColumn( NAME.toString(), DataTypes.TEXT )
 381                     .withColumn( "\"projectVersionMetadataModel.key\"", DataTypes.TEXT )
 382                     .withColumn( "mainArchiveUrl", DataTypes.TEXT )
 383                     .withColumn( "postAddress", DataTypes.TEXT )
 384                     .withColumn( "subscribeAddress", DataTypes.TEXT )
 385                     .withColumn( "unsubscribeAddress", DataTypes.TEXT )
 386                     .withColumn( "otherArchive", DataTypes.frozenListOf( DataTypes.TEXT ) )
 387                     .withCompactStorage( );
 388                 session.execute( table.build( ) );
 389
 390                 CreateIndex index = createIndex( "\"projectVersionMetadataModel_key\"" ).ifNotExists( ).onTable( tableName ).andColumn( "\"\"projectVersionMetadataModel.key\"\"" );
 391                 session.execute( index.build( ) );
 392             }
 393
 394             // License Table
 395             {
 396                 String tableName = getLicenseFamilyName( );
 397                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 398                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 399                     .withColumn( "\"projectVersionMetadataModel.key\"", DataTypes.TEXT )
 400                     .withColumn( NAME.toString(), DataTypes.TEXT )
 401                     .withColumn( URL.toString(), DataTypes.TEXT )
 402                     .withCompactStorage( );
 403                 session.execute( table.build( ) );
 404
 405                 CreateIndex index = createIndex( "\"projectVersionMetadataModel_key\"" ).ifNotExists( ).onTable( tableName ).andColumn( "\"\"projectVersionMetadataModel.key\"\"" );
 406                 session.execute( index.build( ) );
 407             }
 408
 409             // Dependency Table
 410             {
 411                 String tableName = getDependencyFamilyName( );
 412                 CreateTableWithOptions table = createTable( keyspaceName, tableName ).ifNotExists( )
 413                     .withPartitionKey( CassandraArchivaManager.DEFAULT_PRIMARY_KEY, DataTypes.TEXT )
 414                     .withColumn( REPOSITORY_NAME.toString( ), DataTypes.TEXT )
 415                     .withColumn( GROUP_ID.toString( ), DataTypes.TEXT )
 416                     .withColumn( ARTIFACT_ID.toString( ), DataTypes.TEXT )
 417                     .withColumn( VERSION.toString( ), DataTypes.TEXT )
 418                     .withColumn( "\"projectVersionMetadataModel.key\"", DataTypes.TEXT )
 419                     .withColumn( "classifier", DataTypes.TEXT )
 420                     .withColumn( "optional", DataTypes.TEXT )
 421                     .withColumn( "scope", DataTypes.TEXT )
 422                     .withColumn( "systemPath", DataTypes.TEXT )
 423                     .withColumn( "type", DataTypes.TEXT )
 424                     .withCompactStorage( );
 425
 426                 session.execute( table.build( ) );
 427
 428                 CreateIndex index = createIndex( "groupIdIdx" ).ifNotExists( ).onTable( tableName ).andColumn( GROUP_ID.toString( ) );
 429                 session.execute( index.build( ) );
 430                 index = createIndex( "\"projectVersionMetadataModel_key\"" ).ifNotExists( ).onTable( tableName ).andColumn( "\"\"projectVersionMetadataModel.key\"\"" );
 431                 session.execute( index.build( ) );
 432
 433             }
 434
 435         }
 436
 437
 438     }
 439
 440     @Override
 441     public void start( )
 442     {
 443     }
 444
 445     @PreDestroy
 446     @Override
 447     public void shutdown( )
 448     {
 449         if (this.cqlSession!=null) {
 450             this.cqlSession.close( );
 451         }
 452     }
 453
 454
 455     @Override
 456     public boolean started( )
 457     {
 458         return started;
 459     }
 460
 461
 462     @Override
 463     public String getRepositoryFamilyName( )
 464     {
 465         return repositoryFamilyName;
 466     }
 467
 468     @Override
 469     public String getNamespaceFamilyName( )
 470     {
 471         return namespaceFamilyName;
 472     }
 473
 474     @Override
 475     public String getProjectFamilyName( )
 476     {
 477         return projectFamilyName;
 478     }
 479
 480     @Override
 481     public String getProjectVersionMetadataFamilyName( )
 482     {
 483         return projectVersionMetadataFamilyName;
 484     }
 485
 486     public String[] getProjectVersionMetadataColumns() {
 487         return projectVersionMetadataColumns;
 488     }
 489
 490     @Override
 491     public String getArtifactMetadataFamilyName( )
 492     {
 493         return artifactMetadataFamilyName;
 494     }
 495
 496     @Override
 497     public String getMetadataFacetFamilyName( )
 498     {
 499         return metadataFacetFamilyName;
 500     }
 501
 502     @Override
 503     public String getMailingListFamilyName( )
 504     {
 505         return mailingListFamilyName;
 506     }
 507
 508     @Override
 509     public String getLicenseFamilyName( )
 510     {
 511         return licenseFamilyName;
 512     }
 513
 514     @Override
 515     public String getDependencyFamilyName( )
 516     {
 517         return dependencyFamilyName;
 518     }
 519
 520     @Override
 521     public String getChecksumFamilyName( )
 522     {
 523         return checksumFamilyName;
 524     }
 525
 526     @Override
 527     public DriverConfigLoader getConfigLoader( )
 528     {
 529         return configLoader;
 530     }
 531
 532     @Override
 533     public String getKeyspaceName( )
 534     {
 535         return keyspaceName;
 536     }
 537 }