diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/mapping/CassandraMappingContextUnitTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/mapping/CassandraMappingContextUnitTests.java index f23922d7d..27550697e 100755 --- a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/mapping/CassandraMappingContextUnitTests.java +++ b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/mapping/CassandraMappingContextUnitTests.java @@ -389,6 +389,15 @@ public class CassandraMappingContextUnitTests { assertThat(mappingContext.usesTable(tableMetadata.getName())).isFalse(); } + @Test // DATACASS-747 + public void shouldQuoteFieldName() { + + BasicCassandraPersistentEntity entity = mappingContext.getRequiredPersistentEntity(UnsupportedFieldNames.class); + + CassandraPersistentProperty property = entity.getRequiredPersistentProperty("_ent1"); + assertThat(property.getColumnName()).isEqualTo(CqlIdentifier.fromCql("\"_ent1\"")); + } + @Table private static class InvalidEntityWithIdAndPrimaryKeyColumn { @Id String foo; @@ -447,4 +456,9 @@ public class CassandraMappingContextUnitTests { public static class AnotherNested { String str; } + + class UnsupportedFieldNames { + String _ent1; + String _ent2; + } }