adds get name incassandra

Author: otaviojava

cassandra-driver/src/main/java/org/jnosql/diana/cassandra/column/QueryUtils.java

@@ -86,7 +86,7 @@ private static void insertUDT(UDT udt, String keyspace, Session session, Insert
 
         Iterable elements = Iterable.class.cast(udt.get());
         Object udtValue = getUdtValue(userType, elements);
-        insert.value(udt.getName(), udtValue);
+        insert.value(getName(udt), udtValue);
     }
 
     private static Object getUdtValue(UserType userType, Iterable elements) {
@@ -98,7 +98,7 @@ private static Object getUdtValue(UserType userType, Iterable elements) {
                 Column column = Column.class.cast(object);
                 Object convert = ValueUtil.convert(column.getValue());
                 TypeCodec<Object> objectTypeCodec = CodecRegistry.DEFAULT_INSTANCE.codecFor(convert);
-                udtValue.set(column.getName(), convert, objectTypeCodec);
+                udtValue.set(getName(column), convert, objectTypeCodec);
 
             } else if (Iterable.class.isInstance(object)) {
                 udtValues.add(getUdtValue(userType, Iterable.class.cast(Iterable.class.cast(object))));
@@ -115,9 +115,9 @@ private static void insertSingleField(Column column, Insert insert) {
         Object value = column.get();
         try {
             CodecRegistry.DEFAULT_INSTANCE.codecFor(value);
-            insert.value(column.getName(), value);
+            insert.value(getName(column), value);
         } catch (CodecNotFoundException exp) {
-            insert.value(column.getName(), ValueUtil.convert(column.getValue()));
+            insert.value(getName(column), ValueUtil.convert(column.getValue()));
         }
 
 
@@ -165,25 +165,25 @@ private static void createClause(Optional<ColumnCondition> columnConditionOption
         Object value = column.getValue().get();
         switch (condition) {
             case EQUALS:
-                clauses.add(QueryBuilder.eq(column.getName(), value));
+                clauses.add(QueryBuilder.eq(getName(column), value));
                 return;
             case GREATER_THAN:
-                clauses.add(QueryBuilder.gt(column.getName(), value));
+                clauses.add(QueryBuilder.gt(getName(column), value));
                 return;
             case GREATER_EQUALS_THAN:
-                clauses.add(QueryBuilder.gte(column.getName(), value));
+                clauses.add(QueryBuilder.gte(getName(column), value));
                 return;
             case LESSER_THAN:
-                clauses.add(QueryBuilder.lt(column.getName(), value));
+                clauses.add(QueryBuilder.lt(getName(column), value));
                 return;
             case LESSER_EQUALS_THAN:
-                clauses.add(QueryBuilder.lte(column.getName(), value));
+                clauses.add(QueryBuilder.lte(getName(column), value));
                 return;
             case IN:
-                clauses.add(QueryBuilder.in(column.getName(), getIinValue(value)));
+                clauses.add(QueryBuilder.in(getName(column), getIinValue(value)));
                 return;
             case LIKE:
-                clauses.add(QueryBuilder.like(column.getName(), value));
+                clauses.add(QueryBuilder.like(getName(column), value));
                 return;
             case AND:
                 for (ColumnCondition cc : column.get(new TypeReference<List<ColumnCondition>>() {
@@ -198,6 +198,15 @@ private static void createClause(Optional<ColumnCondition> columnConditionOption
         }
     }
 
+    private static String getName(Column column) {
+
+        String name = column.getName();
+        if (name.charAt(0) == '_') {
+            return "\"" + name + "\"";
+        }
+        return name;
+    }
+
     private static Object[] getIinValue(Object value) {
         if (Iterable.class.isInstance(value)) {
             Iterable values = Iterable.class.cast(value);