hs.hsadmin/hsarback/src/de/hsadmin/mods/db/PgSqlDatabaseModuleImpl.java

56 lines
2.0 KiB
Java
Raw Normal View History

2011-03-22 23:02:06 +01:00
package de.hsadmin.mods.db;
import java.util.List;
import javax.persistence.EntityManager;
import de.hsadmin.core.model.AbstractEntity;
import de.hsadmin.core.model.AbstractModuleImpl;
import de.hsadmin.core.model.AuthorisationException;
import de.hsadmin.core.model.HSAdminException;
import de.hsadmin.mods.user.UnixUser;
public class PgSqlDatabaseModuleImpl extends AbstractModuleImpl {
@Override
public List<AbstractEntity> search(Class<? extends AbstractEntity> entityClass, String condition, String orderBy) throws HSAdminException {
if (orderBy == null || orderBy.length() == 0) {
2011-04-01 18:53:37 +02:00
orderBy = "ORDER BY obj.name ASC";
2011-03-22 23:02:06 +01:00
}
return super.search(entityClass, condition, orderBy);
}
2011-05-20 16:25:45 +02:00
@Override
public AbstractEntity add(AbstractEntity newEntity) throws HSAdminException {
PgSqlDatabase database = (PgSqlDatabase) newEntity;
String name = database.getName();
String pacname = database.getPac().getName();
if (!name.startsWith(pacname) || name.length() < 7) {
throw new AuthorisationException(getLoginUser(), "add", newEntity);
}
if (name.charAt(5) != '_') {
throw new AuthorisationException(getLoginUser(), "add", newEntity);
}
return super.add(newEntity);
}
2011-03-22 23:02:06 +01:00
@Override
public AbstractEntity update(AbstractEntity existingEntity) throws HSAdminException {
EntityManager em = getTransaction().getEntityManager();
UnixUser unixUser = getLoginUser();
MySqlDatabase detachtedDB = (MySqlDatabase) existingEntity;
MySqlDatabase attachedDB = em.find(MySqlDatabase.class, detachtedDB.getId());
if (!attachedDB.getName().equals(detachtedDB.getName())) {
throw new AuthorisationException(unixUser, "update", existingEntity, "name");
}
if (!attachedDB.getEncoding().equals(detachtedDB.getEncoding())) {
throw new AuthorisationException(unixUser, "update", existingEntity, "encoding");
}
if (!attachedDB.getInstance().equals(detachtedDB.getInstance())) {
throw new AuthorisationException(unixUser, "update", existingEntity, "instance");
}
return super.update(existingEntity);
}
}