diff --git a/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java b/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java index 069d1ce..c78d451 100644 --- a/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java +++ b/src/main/java/org/gcube/portal/databook/server/DBCassandraAstyanaxImpl.java @@ -1036,31 +1036,6 @@ public final class DBCassandraAstyanaxImpl implements DatabookStore { } return toReturn; } - /** - * - * @param userid user identifier - * @return simply return a list of user messages notifications UUID in chronological order from the oldest to the more recent - */ - private ArrayList getUserMessagesNotificationsIds(String userid) { - OperationResult> result = null; - try { - result = conn.getKeyspace().prepareQuery(cf_UserMessageNotifications) - .getKeySlice(userid) - .execute(); - } catch (ConnectionException e) { - e.printStackTrace(); - } - - ArrayList toReturn = new ArrayList(); - - // Iterate rows and their columns - for (Row row : result.getResult()) { - for (Column column : row.getColumns()) { - toReturn.add(column.getStringValue()); - } - } - return toReturn; - } /** * Returns UUIDS of not read user notification messages * @param userid user identifier diff --git a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java index 7d658f2..b061158 100644 --- a/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java +++ b/src/main/java/org/gcube/portal/databook/server/DatabookCassandraTest.java @@ -18,7 +18,10 @@ import org.junit.AfterClass; import org.junit.BeforeClass; import org.junit.Test; +import com.google.gwt.thirdparty.guava.common.collect.ImmutableMap; import com.netflix.astyanax.connectionpool.exceptions.ConnectionException; +import com.netflix.astyanax.model.ColumnFamily; +import com.netflix.astyanax.serializers.StringSerializer; public class DatabookCassandraTest { private static DBCassandraAstyanaxImpl store; @@ -190,39 +193,30 @@ public class DatabookCassandraTest { // } - // /** - // * use exclusively to add a new (Dynamic) CF to a keyspace - // */ - // @Test - // public void addInvitesDynamicColumnFamilies() { - // System.out.println("addInvitesColumnFamilies"); - // ColumnFamily cf_HashtagsCounter = new ColumnFamily( - // DBCassandraAstyanaxImpl.VRE_INVITES, // Column Family Name - // StringSerializer.get(), // Key Serializer - // StringSerializer.get()); // Column Serializer - // ColumnFamily cf_HashtagTimeline = new ColumnFamily( - // DBCassandraAstyanaxImpl.EMAIL_INVITES, // Column Family Name - // StringSerializer.get(), // Key Serializer - // StringSerializer.get()); // Column Serializer - // - // try { - // new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_HashtagsCounter, ImmutableMap.builder() - // .put("default_validation_class", "UTF8Type") - // .put("key_validation_class", "UTF8Type") - // .put("comparator_type", "UTF8Type") - // .build()); - // - // new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_HashtagTimeline, ImmutableMap.builder() - // .put("default_validation_class", "UTF8Type") - // .put("key_validation_class", "UTF8Type") - // .put("comparator_type", "UTF8Type") - // .build()); - // - // } catch (ConnectionException e) { - // e.printStackTrace(); - // } - // System.out.println("addInvitesColumnFamilies END"); - // } +// /** +// * use exclusively to add a new (Dynamic) CF to a keyspace +// */ +// @Test +// public void addInvitesDynamicColumnFamilies() { +// System.out.println("UserNotificationsUnread"); +// ColumnFamily cf_UserNotificationsUnreadTimeline = new ColumnFamily( +// DBCassandraAstyanaxImpl.USER_NOTIFICATIONS_UNREAD, // Column Family Name +// StringSerializer.get(), // Key Serializer +// StringSerializer.get()); // Column Serializer +// +// try { +// +// new CassandraClusterConnection(false).getKeyspace().createColumnFamily(cf_UserNotificationsUnreadTimeline, ImmutableMap.builder() +// .put("default_validation_class", "UTF8Type") +// .put("key_validation_class", "UTF8Type") +// .put("comparator_type", "UTF8Type") +// .build()); +// +// } catch (ConnectionException e) { +// e.printStackTrace(); +// } +// System.out.println("UserNotificationsUnread END"); +// } // private List getKeys() {