Untitled

CREATE TABLE `NOTICIA` (
  `cdNoticia` bigint(20) NOT NULL AUTO_INCREMENT,
  `cdVeiculo` bigint(20) NOT NULL,
  `nmAutor` varchar(255) DEFAULT NULL,
  `cdColunista` smallint(5) DEFAULT NULL,
  `cdSecao` smallint(5) unsigned NOT NULL,
  `dsTitulo` varchar(255) DEFAULT NULL,
  `dsTexto` longtext,
  `dsURL` char(255) NOT NULL COMMENT 'URL da notÃcia',
  `cdHash` char(32) DEFAULT NULL,
  `dtNoticia` date NOT NULL COMMENT 'Data da notÃcia',
  `hrNoticia` time NOT NULL COMMENT 'Hora da notÃcia',
  `dhCadastro` datetime DEFAULT NULL,
  `idTipo` enum('0','1','2') NOT NULL COMMENT 'Tipo: 0 = NotÃcia, 1 = Coluna, 2 = Blog;',
  `idDigitalizada` enum('0','1') NOT NULL DEFAULT '0',
  PRIMARY KEY (`cdNoticia`) USING BTREE,
  UNIQUE KEY `icdHash` (`cdVeiculo`,`cdSecao`,`cdHash`),
  KEY `iidTipo` (`idTipo`),
  KEY `idhCadastro` (`dhCadastro`),
  KEY `icdVeiculo` (`cdVeiculo`),
  KEY `icdColunista` (`cdColunista`),
  KEY `inmAutor` (`nmAutor`),
  KEY `idsURL` (`dsURL`),
  KEY `idsTitulo` (`dsTitulo`),
  KEY `idtNoticia` (`dtNoticia`),
  KEY `ihrNoticia` (`hrNoticia`)
) ENGINE=InnoDB AUTO_INCREMENT=3215226820 DEFAULT CHARSET=latin1 PACK_KEYS=0;

CREATE TABLE `NOTICIAIMAGEM` (
  `cdNoticia` bigint(20) NOT NULL,
  `nmImagem` varchar(255) NOT NULL,
  `nmExtensao` varchar(10) DEFAULT NULL,
  `nrTamanho` float DEFAULT NULL,
  `nrAltura` smallint(5) unsigned DEFAULT NULL,
  `nrLargura` smallint(5) unsigned DEFAULT NULL,
  `nrOrdem` tinyint(3) unsigned DEFAULT NULL,
  `cdTipoNoticiaImagem` mediumint(8) unsigned DEFAULT NULL,
  KEY `fk_NOTICIAIMAGEM_TIPONOTICIAIMAGEM_idx` (`cdTipoNoticiaImagem`),
  KEY `idx_cdNoticia` (`cdNoticia`),
  CONSTRAINT `fk_NOTICIAIMAGEM_TIPONOTICIAIMAGEM` FOREIGN KEY (`cdTipoNoticiaImagem`) REFERENCES `TIPONOTICIAIMAGEM` (`cdTipoNoticiaImagem`) ON DELETE NO ACTION ON UPDATE NO ACTION
) ENGINE=InnoDB DEFAULT CHARSET=latin1;

<?xml version="1.0" encoding="UTF-8"?>
<persistence version="2.1" xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_1.xsd">
    <persistence-unit name="Transicao" transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <properties>
            <property name="javax.persistence.jdbc.url" value="jdbc:mysql://ip/schema?useTimezone=true&serverTimezone=GMT-3&useSSL=false"/>
            <property name="javax.persistence.jdbc.user" value="user"/>
            <property name="javax.persistence.jdbc.driver" value="com.mysql.cj.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.password" value="password"/>
            <property name="hibernate.cache.provider_class" value="org.hibernate.cache.NoCacheProvider"/>
            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect"/>
        </properties>
    </persistence-unit>
    <persistence-unit name="Producao" transaction-type="RESOURCE_LOCAL">
        <provider>org.hibernate.ejb.HibernatePersistence</provider>
        <properties>
            <property name="javax.persistence.jdbc.url" value="jdbc:mysql://ip:3306/schema?useTimezone=true&serverTimezone=GMT-3&useSSL=false"/>
            <property name="javax.persistence.jdbc.user" value="user"/>
            <property name="javax.persistence.jdbc.driver" value="com.mysql.cj.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.password" value="password"/>
            <property name="hibernate.cache.provider_class" value="org.hibernate.cache.NoCacheProvider"/>
            <property name="hibernate.dialect" value="org.hibernate.dialect.MySQL5Dialect"/>
        </properties>
    </persistence-unit>
</persistence>

@Entity
@Table(name = "NOTICIA")
@NamedQueries({
    @NamedQuery(name = "Noticia.findAll", query = "SELECT n FROM Noticia n"),
    @NamedQuery(name = "Noticia.findAllByDate", query = "SELECT n FROM Noticia n WHERE n.dhCadastro BETWEEN :startDate AND :endDate")
})
public class Noticia implements Serializable {

    private static final long serialVersionUID = 1L;
    @Id
    //@GeneratedValue(strategy = GenerationType.IDENTITY)
    @Basic(optional = false)
    @Column(name = "cdNoticia")
    private Long cdNoticia;

    @Basic(optional = false)
    @Column(name = "cdVeiculo")
    private long cdVeiculo;
    @Column(name = "nmAutor")
    private String nmAutor;
    @Column(name = "cdColunista")
    private Short cdColunista;
    @Basic(optional = false)
    @Column(name = "cdSecao")
    private short cdSecao;
    @Column(name = "dsTitulo")
    private String dsTitulo;
    @Lob
    @Column(name = "dsTexto")
    private String dsTexto;
    @Basic(optional = false)
    @Column(name = "dsURL")
    private String dsURL;
    @Column(name = "cdHash")
    private String cdHash;
    @Basic(optional = false)
    @Column(name = "dtNoticia")
    @Temporal(TemporalType.DATE)
    private Date dtNoticia;
    @Basic(optional = false)
    @Column(name = "hrNoticia")
    @Temporal(TemporalType.TIME)
    private Date hrNoticia;
    @Column(name = "dhCadastro")
    @Temporal(TemporalType.TIMESTAMP)
    private Date dhCadastro;
    @Basic(optional = false)
    @Column(name = "idTipo")
    private String idTipo;
    @Basic(optional = false)
    @Column(name = "idDigitalizada")
    private String idDigitalizada;

    @Column(name = "isTransicao")
    private Integer isTransicao;

    @Column(name = "isElasticSearch")
    private Integer isElasticSearch;

    @OneToMany(cascade = CascadeType.ALL, mappedBy = "noticia", orphanRemoval = true)
    private List<Noticiaimagem> noticiaimagemCollection = new ArrayList<Noticiaimagem>();


    public Noticia() {
    }

    public Long getCdNoticia() {
        return cdNoticia;
    }

    public void setCdNoticia(Long cdNoticia) {
        this.cdNoticia = cdNoticia;
    }

    public long getCdVeiculo() {
        return cdVeiculo;
    }

    public void setCdVeiculo(long cdVeiculo) {
        this.cdVeiculo = cdVeiculo;
    }

    public String getNmAutor() {
        return nmAutor;
    }

    public void setNmAutor(String nmAutor) {
        this.nmAutor = nmAutor;
    }

    public Short getCdColunista() {
        return cdColunista;
    }

    public void setCdColunista(Short cdColunista) {
        this.cdColunista = cdColunista;
    }

    public short getCdSecao() {
        return cdSecao;
    }

    public void setCdSecao(short cdSecao) {
        this.cdSecao = cdSecao;
    }

    public String getDsTitulo() {
        return dsTitulo;
    }

    public void setDsTitulo(String dsTitulo) {
        this.dsTitulo = dsTitulo;
    }

    public String getDsTexto() {
        return dsTexto;
    }

    public void setDsTexto(String dsTexto) {
        this.dsTexto = dsTexto;
    }

    public String getDsURL() {
        return dsURL;
    }

    public void setDsURL(String dsURL) {
        this.dsURL = dsURL;
    }

    public String getCdHash() {
        return cdHash;
    }

    public void setCdHash(String cdHash) {
        this.cdHash = cdHash;
    }

    public Date getDtNoticia() {
        return dtNoticia;
    }

    public void setDtNoticia(Date dtNoticia) {
        this.dtNoticia = dtNoticia;
    }

    public Date getHrNoticia() {
        return hrNoticia;
    }

    public void setHrNoticia(Date hrNoticia) {
        this.hrNoticia = hrNoticia;
    }

    public Date getDhCadastro() {
        return dhCadastro;
    }

    public void setDhCadastro(Date dhCadastro) {
        this.dhCadastro = dhCadastro;
    }

    public String getIdTipo() {
        return idTipo;
    }

    public void setIdTipo(String idTipo) {
        this.idTipo = idTipo;
    }

    public String getIdDigitalizada() {
        return idDigitalizada;
    }

    public void setIdDigitalizada(String idDigitalizada) {
        this.idDigitalizada = idDigitalizada;
    }

    public Integer getIsTransicao() {
        return isTransicao;
    }

    public void setIsTransicao(Integer isTransicao) {
        this.isTransicao = isTransicao;
    }

    public Integer getIsElasticSearch() {
        return isElasticSearch;
    }

    public void setIsElasticSearch(Integer isElasticSearch) {
        this.isElasticSearch = isElasticSearch;
    }

    public List<Noticiaimagem> getNoticiaimagemCollection() {
        return noticiaimagemCollection;
    }

    public void setNoticiaimagemCollection(List<Noticiaimagem> noticiaimagemCollection) {
        this.noticiaimagemCollection = noticiaimagemCollection;
    }
}

@Entity
@Table(name = "NOTICIAIMAGEM")
public class Noticiaimagem implements Serializable {

    private static final long serialVersionUID = 1L;

    @Id
    @ManyToOne
    @JoinColumn(name = "cdNoticia", nullable = false)
    @MapsId
    private Noticia noticia;

    @Column
    private String nmImagem;

    @Column(nullable = false)
    private String nmExtensao;

    @Column
    private Float nrTamanho;
    @Column(columnDefinition = "UNSIGNED SMALLINT(5)")
    private Integer nrAltura;
    @Column(columnDefinition = "UNSIGNED SMALLINT(5)")
    private Integer nrLargura;
    @Column(columnDefinition = "UNSIGNED TINYINT(3)")
    private Integer nrOrdem;
    @Column(columnDefinition = "UNSIGNED MEDIUMINT(8)")
    private Integer cdTipoNoticiaImagem;

    public Noticiaimagem() {
    }

    public Noticia getNoticia() {
        return noticia;
    }

    public void setNoticia(Noticia noticia) {
        this.noticia = noticia;
    }

    public String getNmImagem() {
        return nmImagem;
    }

    public void setNmImagem(String nmImagem) {
        this.nmImagem = nmImagem;
    }

    public String getNmExtensao() {
        return nmExtensao;
    }

    public void setNmExtensao(String nmExtensao) {
        this.nmExtensao = nmExtensao;
    }

    public Float getNrTamanho() {
        return nrTamanho;
    }

    public void setNrTamanho(Float nrTamanho) {
        this.nrTamanho = nrTamanho;
    }

    public Integer getNrAltura() {
        return nrAltura;
    }

    public void setNrAltura(Integer nrAltura) {
        this.nrAltura = nrAltura;
    }

    public Integer getNrLargura() {
        return nrLargura;
    }

    public void setNrLargura(Integer nrLargura) {
        this.nrLargura = nrLargura;
    }

    public Integer getNrOrdem() {
        return nrOrdem;
    }

    public void setNrOrdem(Integer nrOrdem) {
        this.nrOrdem = nrOrdem;
    }

    public Integer getCdTipoNoticiaImagem() {
        return cdTipoNoticiaImagem;
    }

    public void setCdTipoNoticiaImagem(Integer cdTipoNoticiaImagem) {
        this.cdTipoNoticiaImagem = cdTipoNoticiaImagem;
    }
}

public static List<Noticia> getNoticias() throws Exception {
        List<Noticia> noticia = null;
        DateTimeFormatter format = DateTimeFormat.forPattern("yyyy-MM-dd HH:mm:ss");
        DateTime startDate = format.parseDateTime(Job.config.getTransferencia().getStartDate());
        DateTime endDate = format.parseDateTime(Job.config.getTransferencia().getEndDate());
        noticia = managerTransicao.createNamedQuery("Noticia.findAllByDate", Noticia.class)
                .setParameter("startDate", startDate.toDate())
                .setParameter("endDate", endDate.toDate())
                .setFirstResult((page - 1) * Job.config.getTransferencia().getLimitNoticia())
                .setMaxResults(Job.config.getTransferencia().getLimitNoticia())
                .getResultList();
        return noticia;
    }

private static void inserirNoticia(List<Noticia> noticias) {
        for (Iterator<Noticia> it = noticias.iterator(); it.hasNext();) {
            Noticia noticia = it.next();

        try {
            managerProducao.getTransaction().begin();
            managerProducao.merge(noticia);
            managerProducao.flush();
            managerProducao.clear();
            managerProducao.getTransaction().commit();
        } catch (Exception e) {
            managerProducao.getTransaction().rollback();
            e.printStackTrace();
            log.error("Problemas para inserir a Noticia e suas dependencias. cdNoticia: " + noticia.getCdNoticia() + " Error:" + e.toString());
            continue;
        }
        managerProducao.clear();
    }