code: @Override
      public <T> T execute(final String query, Object connection) {
  
          Session session = factory.getConnection();
          try {
              Statement queryStmt = new SimpleStatement(query);
              KunderaCoreUtils.printQuery(query, showQuery);
              queryStmt.setConsistencyLevel(ConsistencyLevel.valueOf(this.consistencyLevel.name()));
              return (T) session.execute(queryStmt);
          } catch (Exception e) {
              log.error("Error while executing query {}.", query);
              throw new KunderaException(e);
          } finally {
              // factory.releaseConnection(session);
          }
      }
docs: /*
  (non-Javadoc)
  
  @see com.impetus.client.cassandra.CassandraClientBase#execute(java.lang.String , java.lang.Object)