How to use getDatabaseDelegate method of org.testcontainers.containers.CassandraContainer class

Best Testcontainers-java code snippet using org.testcontainers.containers.CassandraContainer.getDatabaseDelegate

Source:CassandraContainer.java

...74                    logger().warn("Could not load classpath init script: {}", initScriptPath);75                    throw new ScriptLoadException("Could not load classpath init script: " + initScriptPath + ". Resource not found.");76                }77                String cql = IOUtils.toString(resource, StandardCharsets.UTF_8);78                DatabaseDelegate databaseDelegate = getDatabaseDelegate();79                ScriptUtils.executeDatabaseScript(databaseDelegate, initScriptPath, cql);80            } catch (IOException e) {81                logger().warn("Could not load classpath init script: {}", initScriptPath);82                throw new ScriptLoadException("Could not load classpath init script: " + initScriptPath, e);83            } catch (ScriptException e) {84                logger().error("Error while executing init script: {}", initScriptPath, e);85                throw new ScriptUtils.UncategorizedScriptException("Error while executing init script: " + initScriptPath, e);86            }87        }88    }89    /**90     * Map (effectively replace) directory in Docker with the content of resourceLocation if resource location is not null91     *92     * Protected to allow for changing implementation by extending the class93     *94     * @param pathNameInContainer path in docker95     * @param resourceLocation    relative classpath to resource96     */97    protected void optionallyMapResourceParameterAsVolume(String pathNameInContainer, String resourceLocation) {98        Optional.ofNullable(resourceLocation)99                .map(MountableFile::forClasspathResource)100                .ifPresent(mountableFile -> withCopyFileToContainer(mountableFile, pathNameInContainer));101    }102    /**103     * Initialize Cassandra with the custom overridden Cassandra configuration104     * <p>105     * Be aware, that Docker effectively replaces all /etc/cassandra content with the content of config location, so if106     * Cassandra.yaml in configLocation is absent or corrupted, then Cassandra just won't launch107     *108     * @param configLocation relative classpath with the directory that contains cassandra.yaml and other configuration files109     */110    public SELF withConfigurationOverride(String configLocation) {111        this.configLocation = configLocation;112        return self();113    }114    /**115     * Initialize Cassandra with init CQL script116     * <p>117     * CQL script will be applied after container is started (see using WaitStrategy)118     *119     * @param initScriptPath relative classpath resource120     */121    public SELF withInitScript(String initScriptPath) {122        this.initScriptPath = initScriptPath;123        return self();124    }125    /**126     * Initialize Cassandra client with JMX reporting enabled or disabled127     */128    public SELF withJmxReporting(boolean enableJmxReporting) {129        this.enableJmxReporting = enableJmxReporting;130        return self();131    }132    /**133     * Get username134     *135     * By default Cassandra has authenticator: AllowAllAuthenticator in cassandra.yaml136     * If username and password need to be used, then authenticator should be set as PasswordAuthenticator137     * (through custom Cassandra configuration) and through CQL with default cassandra-cassandra credentials138     * user management should be modified139     */140    public String getUsername() {141        return USERNAME;142    }143    /**144     * Get password145     *146     * By default Cassandra has authenticator: AllowAllAuthenticator in cassandra.yaml147     * If username and password need to be used, then authenticator should be set as PasswordAuthenticator148     * (through custom Cassandra configuration) and through CQL with default cassandra-cassandra credentials149     * user management should be modified150     */151    public String getPassword() {152        return PASSWORD;153    }154    /**155     * Get configured Cluster156     *157     * Can be used to obtain connections to Cassandra in the container158     */159    public Cluster getCluster() {160        return getCluster(this, enableJmxReporting);161    }162    public static Cluster getCluster(ContainerState containerState, boolean enableJmxReporting) {163        final Cluster.Builder builder = Cluster.builder()164            .addContactPoint(containerState.getHost())165            .withPort(containerState.getMappedPort(CQL_PORT));166        if (!enableJmxReporting) {167            builder.withoutJMXReporting();168        }169        return builder.build();170    }171    public static Cluster getCluster(ContainerState containerState) {172        return getCluster(containerState, false);173    }174    private DatabaseDelegate getDatabaseDelegate() {175        return new CassandraDatabaseDelegate(this);176    }177}...

getDatabaseDelegate

Using AI Code Generation

1        CassandraContainer cassandraContainer = new CassandraContainer();2        cassandraContainer.start();3        Session session = cassandraContainer.getDatabaseDelegate().getSession();4        session.execute("CREATE KEYSPACE IF NOT EXISTS test WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };");5        session.execute("CREATE TABLE IF NOT EXISTS test.mytable (id int PRIMARY KEY, name text);");6        session.execute("INSERT INTO test.mytable (id, name) VALUES (1, 'test');");7        cassandraContainer.stop();

getDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.containers.CassandraContainer2import org.testcontainers.containers.wait.strategy.Wait3import org.testcontainers.utility.DockerImageName4def cassandraContainer = new CassandraContainer(DockerImageName.parse("cassandra:3.11.9"))5cassandraContainer.start()6def databaseDelegate = cassandraContainer.getDatabaseDelegate()7def connection = databaseDelegate.getConnection("cassandra", "cassandra")8def statement = connection.createStatement()9def resultSet = statement.executeQuery("select release_version from system.local")10while (resultSet.next()) {11    println resultSet.getString("release_version")12}13cassandraContainer.stop()14import org.testcontainers.containers.CassandraContainer15import org.testcontainers.containers.wait.strategy.Wait16import org.testcontainers.utility.DockerImageName17def cassandraContainer = new CassandraContainer(DockerImageName.parse("cassandra:3.11.9"))18cassandraContainer.start()19def jdbcUrl = cassandraContainer.getJdbcUrl()20def connection = DriverManager.getConnection(jdbcUrl, "cassandra", "cassandra")21def statement = connection.createStatement()22def resultSet = statement.executeQuery("select release_version from system.local")23while (resultSet.next()) {24    println resultSet.getString("release_version")25}26cassandraContainer.stop()

getDatabaseDelegate

Using AI Code Generation

1import org.testcontainers.containers.CassandraContainer2import org.testcontainers.containers.output.Slf4jLogConsumer3import org.testcontainers.containers.output.OutputFrame4import org.testcontainers.containers.output.ToStringConsumer5import org.testcontainers.containers.output.BaseConsumer6import org.testcontainers.containers.output.OutputFrame.OutputType7import org.testcontainers.containers.output.OutputFrame.getUtf8String8import org.testcontainers.containers.output.WaitingConsumer9import org.testcontainers.containers.output.ToStringConsumer10import org.testcontainers.containers.output.Slf4jLogConsumer11import org.testcontainers.containers.output.OutputFrame12import org.testcontainers.containers.output.BaseConsumer13import org.testcontainers.containers.output.OutputFrame.OutputType14import org.testcontainers.containers.output.OutputFrame.getUtf8String15import org.testcontainers.containers.output.WaitingConsumer16import org.testcontainers.containers.output.ToStringConsumer17import org.testcontainers.containers.output.Slf4jLogConsumer18import org.testcontainers.containers.output.OutputFrame19import org.testcontainers.containers.output.BaseConsumer20import org.testcontainers.containers.output.OutputFrame.OutputType21import org.testcontainers.containers.output.OutputFrame.getUtf8String22import org.testcontainers.containers.output.WaitingConsumer23import org.testcontainers.containers.output.ToStringConsumer24import org.testcontainers.containers.output.Slf4jLogConsumer25import org.testcontainers.containers.output.OutputFrame26import org.testcontainers.containers.output.BaseConsumer27import org.testcontainers.containers.output.OutputFrame.OutputType28import org.testcontainers.containers.output.OutputFrame.getUtf8String29import org.testcontainers.containers.output.WaitingConsumer30import org.testcontainers.containers.output.ToStringConsumer31import org.testcontainers.containers.output.Slf4jLogConsumer32import org.testcontainers.containers.output.OutputFrame33import org.testcontainers.containers.output.BaseConsumer34import org.testcontainers.containers.output.OutputFrame.OutputType35import org.testcontainers.containers.output.OutputFrame.getUtf8String36import org.testcontainers.containers.output.WaitingConsumer37import org.testcontainers.containers.output.ToStringConsumer38import org.testcontainers.containers.output.Slf4jLogConsumer39import org

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.