Add logs for NativeSerializer
Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/163624a9 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/163624a9 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/163624a9 Branch: refs/heads/master Commit: 163624a9596298bf80bb41360fcd246a886a0688 Parents: 2fe2c2b Author: madhawa <[email protected]> Authored: Sat Jul 8 11:06:45 2017 +0530 Committer: madhawa <[email protected]> Committed: Sat Jul 8 11:13:40 2017 +0530 ---------------------------------------------------------------------- .../cassandra/serializers/AvroSerializer.java | 4 ++-- .../cassandra/serializers/NativeSerializer.java | 22 +++++++++++++++++--- .../gora/cassandra/store/CassandraStore.java | 2 +- 3 files changed, 22 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/163624a9/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializer.java ---------------------------------------------------------------------- diff --git a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializer.java b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializer.java index 8061a80..83676dc 100644 --- a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializer.java +++ b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/AvroSerializer.java @@ -37,7 +37,7 @@ import java.util.Map; /** * This class contains the operations relates to Avro Serialization */ -public class AvroSerializer<K, T extends PersistentBase> extends CassandraSerializer { +class AvroSerializer<K, T extends PersistentBase> extends CassandraSerializer { /** @@ -45,7 +45,7 @@ public class AvroSerializer<K, T extends PersistentBase> extends CassandraSerial */ public static final int DEFAULT_UNION_SCHEMA = 0; - public AvroSerializer(CassandraClient cassandraClient, Class<K> keyClass, Class<T> persistentClass, CassandraMapping mapping) { + AvroSerializer(CassandraClient cassandraClient, Class<K> keyClass, Class<T> persistentClass, CassandraMapping mapping) { super(cassandraClient, keyClass, persistentClass, mapping); } http://git-wip-us.apache.org/repos/asf/gora/blob/163624a9/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/NativeSerializer.java ---------------------------------------------------------------------- diff --git a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/NativeSerializer.java b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/NativeSerializer.java index d551d33..2bac3dd 100644 --- a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/NativeSerializer.java +++ b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/serializers/NativeSerializer.java @@ -29,6 +29,8 @@ import org.apache.gora.cassandra.store.CassandraMapping; import org.apache.gora.persistency.Persistent; import org.apache.gora.query.Query; import org.apache.gora.store.DataStore; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import java.lang.reflect.Method; import java.util.ArrayList; @@ -38,22 +40,32 @@ import java.util.List; /** * This Class contains the operation relates to Native Serialization. */ -public class NativeSerializer<K, T extends CassandraNativePersistent> extends CassandraSerializer { +class NativeSerializer<K, T extends CassandraNativePersistent> extends CassandraSerializer { + + private static final Logger LOG = LoggerFactory.getLogger(CassandraNativePersistent.class); private Mapper<T> mapper; @Override public void put(Object key, Persistent value) { + LOG.debug("Object is saved with key : {} and value : {}",key,value); mapper.save((T) value); } @Override public T get(Object key) { - return mapper.get(key); + T object = mapper.get(key); + if(object != null) { + LOG.debug("Object is found for key : {}", key); + } else { + LOG.debug("Object is not found for key : {}", key); + } + return object; } @Override public boolean delete(Object key) { + LOG.debug("Object is deleted for key : {}", key); mapper.delete(key); return true; } @@ -66,8 +78,10 @@ public class NativeSerializer<K, T extends CassandraNativePersistent> extends Ca Result<T> objects = mapper.map(results); List<T> objectList = objects.all(); if (objectList != null) { + LOG.debug("Object is found for key : {}", key); return objectList.get(0); } + LOG.debug("Object is not found for key : {}" , key); return null; } @@ -81,6 +95,8 @@ public class NativeSerializer<K, T extends CassandraNativePersistent> extends Ca } else { results = client.getSession().execute(cqlQuery, objectArrayList.toArray()); } + LOG.debug("Delete by Query was applied : " + results.wasApplied()); + LOG.info("Delete By Query method doesn't return the deleted element count."); return 0; } @@ -105,7 +121,7 @@ public class NativeSerializer<K, T extends CassandraNativePersistent> extends Ca return cassandraResult; } - public NativeSerializer(CassandraClient cassandraClient, Class<K> keyClass, Class<T> persistentClass, CassandraMapping mapping) { + NativeSerializer(CassandraClient cassandraClient, Class<K> keyClass, Class<T> persistentClass, CassandraMapping mapping) { super(cassandraClient, keyClass, persistentClass, mapping); this.createSchema(); MappingManager mappingManager = new MappingManager(cassandraClient.getSession()); http://git-wip-us.apache.org/repos/asf/gora/blob/163624a9/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java ---------------------------------------------------------------------- diff --git a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java index 3fb1507..e6cf373 100644 --- a/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java +++ b/gora-cassandra-cql/src/main/java/org/apache/gora/cassandra/store/CassandraStore.java @@ -44,7 +44,7 @@ public class CassandraStore<K, T extends Persistent> implements DataStore<K, T> private static final String DEFAULT_MAPPING_FILE = "gora-cassandra-mapping.xml"; - public static final Logger LOG = LoggerFactory.getLogger(CassandraStore.class); + private static final Logger LOG = LoggerFactory.getLogger(CassandraStore.class); private BeanFactory<K, T> beanFactory;
