openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/dao/impl/CassandraDaoUtils.java

   1 package org.openecomp.core.zusammen.plugin.dao.impl;
   2
   3 import com.datastax.driver.core.Session;
   4 import com.amdocs.zusammen.commons.db.api.cassandra.CassandraConnectorFactory;
   5 import com.amdocs.zusammen.commons.db.api.cassandra.types.CassandraContext;
   6 import com.amdocs.zusammen.datatypes.SessionContext;
   7
   8 class CassandraDaoUtils {
   9
  10   static <T> T getAccessor(SessionContext context, Class<T> classOfT) {
  11     return CassandraConnectorFactory.getInstance().createInterface(getCassandraContext(context))
  12         .getMappingManager()
  13         .createAccessor(classOfT);
  14   }
  15
  16   static Session getSession(SessionContext context) {
  17     return CassandraConnectorFactory.getInstance().createInterface(getCassandraContext(context))
  18         .getMappingManager()
  19         .getSession();
  20   }
  21
  22   private static CassandraContext getCassandraContext(SessionContext context) {
  23     CassandraContext cassandraContext = new CassandraContext();
  24     cassandraContext.setTenant(context.getTenant());
  25     return cassandraContext;
  26   }
  27 }