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