Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*
  * Copyright (c) 2012-2015 Savoir Technologies, Inc.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
  *
  *      http://www.apache.org/licenses/LICENSE-2.0
  *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.savoirtech.hecate.test;
public class CassandraTestCase extends AbstractTestCase {
//----------------------------------------------------------------------------------------------------------------------
// Fields
//----------------------------------------------------------------------------------------------------------------------
    protected static final String KEYSPACE_NAME = "hecate";
    private Cluster cluster;
    private Session session;
//----------------------------------------------------------------------------------------------------------------------
// Getter/Setter Methods
//----------------------------------------------------------------------------------------------------------------------
    public Cluster getCluster() {
        return ;
    }
    protected Session getSession() {
        return ;
    }
//----------------------------------------------------------------------------------------------------------------------
// Other Methods
//----------------------------------------------------------------------------------------------------------------------
    @After
    public void closeSession() {
        .close();
    }
    @Before
    public void initializeCassandra() throws Exception {
        EmbeddedCassandraServerHelper.startEmbeddedCassandra();
        EmbeddedCassandraServerHelper.cleanEmbeddedCassandra();
         = Cluster.builder().addContactPoint("localhost").withPort(9142).build();
        Session session = .newSession();
        .debug("Creating keyspace {}...");
        session.execute(String.format("CREATE KEYSPACE IF NOT EXISTS %s WITH replication = {'class':'SimpleStrategy', 'replication_factor':1};"));
        .debug("Keyspace {} created successfully.");
        session.close();
        this. = connect();
    }
    private Session connect() {
        return .connect();
    }
    protected void withSession(Consumer<Sessionconsumer) {
        try (Session session = connect()) {
            consumer.accept(session);
        }
    }
New to GrepCode? Check out our FAQ X