42 lines
1.5 KiB
Java
42 lines
1.5 KiB
Java
|
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) {
|
||
|
|
orderBy = "ORDER BY name ASC";
|
||
|
|
}
|
||
|
|
return super.search(entityClass, condition, orderBy);
|
||
|
|
}
|
||
|
|
|
||
|
|
@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);
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|