public List<TenantDataStore> getTenantList() {
	List<TenantDataStore> list = new ArrayList<TenantDataStore>();
	PersistenceManager pm = PMF.get().getPersistenceManager();
	Extent<TenantDataStore> extent = pm.getExtent(TenantDataStore.class, false);
	Iterator<TenantDataStore> ir = extent.iterator();

	while (ir.hasNext()) {
		TenantDataStore tenants = (TenantDataStore) ir.next();
		list.add(tenants);

	}
	extent.closeAll();
	pm.close();

	return list;
}
 

public boolean isTenantExist(String tenantId) {
	boolean Exist = false;
	PersistenceManager pm = PMF.get().getPersistenceManager();
	Extent<TenantDataStore> extent = pm.getExtent(TenantDataStore.class, false);
	Iterator<TenantDataStore> ir = extent.iterator();

	while (ir.hasNext()) {
		TenantDataStore tenants = (TenantDataStore) ir.next();
		if (tenants.getTenantId().equalsIgnoreCase(tenantId))
			Exist = true;

	}
	extent.closeAll();
	pm.close();
	return Exist;
}
 

@Override
public Collection<Object> query() {
    List<Object> rslt = new ArrayList<>();
    pm.currentTransaction().setNontransactionalRead(true);
    Extent<Persistent> objs = pm.getExtent(Persistent.class);
    if (objs != null) {
        for (Persistent i : objs) {
            i.zooActivateRead();
            rslt.add(i);
        }
    }
    pm.currentTransaction().setNontransactionalRead(false);
    return rslt;
}
 

public Collection<UserAttribute> getAll() {
    Extent<UserAttribute> extent = persistenceManager.getExtent(UserAttribute.class);
    Query query = persistenceManager.newQuery(extent);
    query.setOrdering("attributeId ascending");

    @SuppressWarnings({"unchecked", "UnnecessaryLocalVariable"})
    Collection<UserAttribute> attributes = (Collection<UserAttribute>) query.execute();
    return attributes;
}
 

public UserAttribute findUserAttributeByName(String name) {
    Extent<UserAttribute> extent = persistenceManager.getExtent(UserAttribute.class);
    Query query = persistenceManager.newQuery(extent);
    query.setFilter("name == attrName");
    query.declareParameters("String attrName");

    @SuppressWarnings({"unchecked", "UnnecessaryLocalVariable"})
    Collection<UserAttribute> attributes = (Collection<UserAttribute>) query.execute(name);
    Iterator<UserAttribute> iterator = attributes.iterator();
    return iterator.hasNext() ? iterator.next() : null;
}
 

public UserAttribute findByNameAndType(String name, Integer type) {
    Extent<UserAttribute> extent = persistenceManager.getExtent(UserAttribute.class);
    Query query = persistenceManager.newQuery(extent);
    query.setFilter("name == attrName && type == type");
    query.declareParameters("String attrName, Integer type");

    @SuppressWarnings("unchecked")
    Collection<UserAttribute> attributes = (Collection<UserAttribute>) query.execute(name, type);
    Iterator<UserAttribute> iterator = attributes.iterator();
    return iterator.hasNext() ? iterator.next() : null;
}
 

public void testJdoQueriesAdditionalMethodSig(String input) {
    PersistenceManager pm = getPM();

    pm.newQuery(UserEntity.class,new ArrayList(),"id == "+ input); //Injection?

    pm.newQuery(UserEntity.class,new ArrayList(),"id == 1");

    pm.newQuery(UserEntity.class,"id == "+ input); //Injection?

    pm.newQuery(UserEntity.class,"id == 1");

    pm.newQuery((Extent) null,"id == "+input); //Injection?

    pm.newQuery((Extent) null,"id == 1");

}