/*
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license
|
* Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template
|
*/
|
package com.megatim.apifdxweb.dao.impl.camel.historique;
|
|
import com.megatim.apifdxweb.model.camel.historique.ConsumedFilesHistory;
|
import javax.ejb.Stateless;
|
import javax.persistence.EntityManager;
|
import javax.persistence.PersistenceContext;
|
import com.megatim.apifdxweb.model.camel.historique.ConsumedFileType;
|
import java.util.List;
|
import java.util.Optional;
|
import com.megatim.apifdxweb.dao.ifaces.camel.historique.ConsumedFilesHistoryDAO;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
@Stateless
|
public class ConsumedFilesHistoryDAOImpl implements ConsumedFilesHistoryDAO {
|
|
@PersistenceContext(name = "fdxPU")
|
EntityManager em;
|
|
@Override
|
public Class<ConsumedFilesHistory> getManagedEntityClass() {
|
return ConsumedFilesHistory.class;
|
}
|
|
@Override
|
public EntityManager getEntityManager() {
|
return em;
|
}
|
|
@Override
|
public ConsumedFilesHistory getById(Long id) {
|
throw new UnsupportedOperationException("Not supported yet."); // Generated from nbfs://nbhost/SystemFileSystem/Templates/Classes/Code/GeneratedMethodBody
|
}
|
|
@Override
|
public List<ConsumedFilesHistory> notDeleted() {
|
return em.createQuery("SELECT cfh FROM ConsumedFilesHistory cfh where cfh.deletedInFolder = :param")
|
.setParameter("param", false)
|
.getResultList();
|
}
|
|
@Override
|
public ConsumedFilesHistory findByTypeFileName(ConsumedFileType consumedFileType, String fileName) {
|
Optional<ConsumedFilesHistory> optDonnee = em.createQuery("SELECT cfh FROM ConsumedFilesHistory cfh WHERE cfh.fileName = :fileName AND cfh.consumedFileType = :consumedFileType")
|
.setParameter("fileName", fileName)
|
.setParameter("consumedFileType", consumedFileType)
|
.getResultList()
|
.stream()
|
.findFirst();
|
|
return optDonnee.isPresent() ? optDonnee.get() : null;
|
}
|
}
|
