Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -540,8 +540,8 @@ public void should_set_routing_key_on_case_sensitive_keyspace_and_table() {
session()
.execute(
"CREATE KEYSPACE \"Test\" WITH replication = { "
+ " 'class': 'SimpleStrategy',"
+ " 'replication_factor': '1'"
+ " 'class': 'NetworkTopologyStrategy',"
+ " 'datacenter1': '1'"
+ "}");
session().execute("CREATE TABLE \"Test\".\"Foo\" (i int PRIMARY KEY)");

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ public class MapperKeyspaceTest extends CCMTestsSupport {
@Override
public void onTestContextInitialized() {
execute(
"CREATE KEYSPACE IF NOT EXISTS MapperKeyspaceTest WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}",
"CREATE KEYSPACE IF NOT EXISTS MapperKeyspaceTest WITH replication = {'class': 'NetworkTopologyStrategy', 'datacenter1': 1}",
"CREATE TYPE IF NOT EXISTS MapperKeyspaceTest.address(street text)",
"CREATE TABLE IF NOT EXISTS MapperKeyspaceTest.user(name text PRIMARY KEY, address frozen<address>)",
"CREATE KEYSPACE IF NOT EXISTS MapperKeyspaceTest2 WITH replication = {'class': 'SimpleStrategy', 'replication_factor': 1}",
"CREATE KEYSPACE IF NOT EXISTS MapperKeyspaceTest2 WITH replication = {'class': 'NetworkTopologyStrategy', 'datacenter1': 1}",
"CREATE TYPE IF NOT EXISTS MapperKeyspaceTest2.address(street text)",
"CREATE TABLE IF NOT EXISTS MapperKeyspaceTest2.user(name text PRIMARY KEY, address frozen<address>)");
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ public void udt_and_tables_with_ks_created_in_another_session_should_be_mapped()
// Create type and table
session1.execute(
"create keyspace if not exists java_509 "
+ "with replication = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };");
+ "with replication = { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 1 };");
session1.execute("create type java_509.my_tuple (" + "type text, " + "value text);");
session1.execute(
"create table java_509.my_hash ("
Expand Down Expand Up @@ -75,7 +75,7 @@ public void udt_and_tables_without_ks_created_in_another_session_should_be_mappe
Session session1 = cluster1.connect();
session1.execute(
"create keyspace if not exists java_509b "
+ "with replication = { 'class' : 'SimpleStrategy', 'replication_factor' : 1 };");
+ "with replication = { 'class' : 'NetworkTopologyStrategy', 'datacenter1' : 1 };");
session1.execute("use java_509b");
session1.execute("create type my_tuple (" + "type text, " + "value text);");
session1.execute(
Expand Down
Loading