Skip to content

Commit

Permalink
test: create cassandra integration test
Browse files Browse the repository at this point in the history
Signed-off-by: Otavio Santana <otaviopolianasantana@gmail.com>
  • Loading branch information
otaviojava committed May 19, 2023
1 parent d8b6bd4 commit 5b0178e
Show file tree
Hide file tree
Showing 4 changed files with 32 additions and 31 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@
import java.util.Map;
import java.util.function.Supplier;

enum ColumnDatabase implements Supplier<CassandraColumnManagerFactory> {
public enum ColumnDatabase implements Supplier<CassandraColumnManagerFactory> {

INSTANCE;

Expand All @@ -42,10 +42,18 @@ public CassandraColumnManagerFactory get() {
return cassandraConfiguration.apply(settings);
}

Settings getSettings() {
public Settings getSettings() {
Map<String, Object> configuration = new HashMap<>(ConfigurationReader.from("cassandra.properties"));
configuration.put(CassandraConfigurations.HOST.get()+".1", cassandra.getHost());
configuration.put(CassandraConfigurations.PORT.get(), cassandra.getFirstMappedPort());
configuration.put(CassandraConfigurations.HOST.get()+".1", host());
configuration.put(CassandraConfigurations.PORT.get(), port());
return Settings.of(configuration);
}

public String host() {
return cassandra.getHost();
}

public int port() {
return cassandra.getFirstMappedPort();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
import jakarta.nosql.Id;

@Entity
public record Book(@Id String id, @Column("title") String title, @Column("edition") int edition) {
public record Book(@Id("id") String id, @Column("title") String title, @Column("edition") int edition) {


}
Original file line number Diff line number Diff line change
Expand Up @@ -12,46 +12,53 @@
*
* Otavio Santana
*/
package org.eclipse.jnosql.databases.mongodb.integration;
package org.eclipse.jnosql.databases.cassandra.integration;


import jakarta.inject.Inject;
import jakarta.nosql.document.DocumentTemplate;
import org.eclipse.jnosql.databases.mongodb.communication.MongoDBDocumentConfigurations;
import jakarta.nosql.column.ColumnTemplate;
import org.eclipse.jnosql.communication.driver.ConfigurationReader;
import org.eclipse.jnosql.databases.cassandra.communication.CassandraConfigurations;
import org.eclipse.jnosql.databases.cassandra.communication.ColumnDatabase;
import org.eclipse.jnosql.mapping.Convert;
import org.eclipse.jnosql.mapping.column.ColumnEntityConverter;
import org.eclipse.jnosql.mapping.column.spi.ColumnExtension;
import org.eclipse.jnosql.mapping.config.MappingConfigurations;
import org.eclipse.jnosql.mapping.document.DocumentEntityConverter;
import org.eclipse.jnosql.mapping.document.spi.DocumentExtension;
import org.eclipse.jnosql.mapping.reflection.EntityMetadataExtension;
import org.jboss.weld.junit5.auto.AddExtensions;
import org.jboss.weld.junit5.auto.AddPackages;
import org.jboss.weld.junit5.auto.EnableAutoWeld;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledIfSystemProperty;

import java.util.HashMap;
import java.util.Map;
import java.util.Optional;

import static java.util.UUID.randomUUID;
import static org.assertj.core.api.Assertions.assertThat;
import static org.eclipse.jnosql.communication.driver.IntegrationTest.MATCHES;
import static org.eclipse.jnosql.communication.driver.IntegrationTest.NAMED;
import static org.eclipse.jnosql.databases.mongodb.communication.DocumentDatabase.INSTANCE;

@EnableAutoWeld
@AddPackages(value = {Convert.class, DocumentEntityConverter.class})
@AddPackages(value = {Convert.class, ColumnEntityConverter.class})
@AddPackages(Book.class)
@AddExtensions({EntityMetadataExtension.class,
DocumentExtension.class})
ColumnExtension.class})
@EnabledIfSystemProperty(named = NAMED, matches = MATCHES)
class TemplateIntegrationTest {

@Inject
private DocumentTemplate template;
private ColumnTemplate template;

static {
INSTANCE.get("library");
System.setProperty(MongoDBDocumentConfigurations.HOST.get() + ".1", INSTANCE.host());
System.setProperty(MappingConfigurations.DOCUMENT_DATABASE.get(), "library");
Map<String, Object> configuration = new HashMap<>(ConfigurationReader.from("mapping.properties"));
for (Map.Entry<String, Object> entry : configuration.entrySet()) {
System.setProperty(entry.getKey(), entry.getValue().toString());
}
System.setProperty(MappingConfigurations.COLUMN_DATABASE.get(), "library");
System.setProperty(CassandraConfigurations.HOST.get()+".1", ColumnDatabase.INSTANCE.host());
System.setProperty(CassandraConfigurations.PORT.get(), Integer.toString(ColumnDatabase.INSTANCE.port()));
}

@Test
Expand Down
14 changes: 0 additions & 14 deletions jnosql-cassandra/src/test/resources/cassandra.properties
Original file line number Diff line number Diff line change
@@ -1,17 +1,3 @@
#
# Copyright (c) 2017 Otávio Santana and others
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Eclipse Public License v1.0
# and Apache License v2.0 which accompanies this distribution.
# The Eclipse Public License is available at http://www.eclipse.org/legal/epl-v10.html
# and the Apache License v2.0 is available at http://www.opensource.org/licenses/apache2.0.php.
#
# You may elect to redistribute this code under either of these licenses.
#
# Contributors:
#
# Otavio Santana
#
jnosql.cassandra.host.1=localhost
jnosql.cassandra.port=9142
jnosql.cassandra.query.1=CREATE KEYSPACE IF NOT EXISTS newKeySpace WITH replication = {'class': 'SimpleStrategy', 'replication_factor' : 3};
Expand Down

0 comments on commit 5b0178e

Please sign in to comment.