package com.trendmicro.grid.acl.ds.jpa.entities;
   
   import com.trendmicro.grid.acl.Limits;
   import com.trendmicro.grid.acl.ds.datatypes.SharedSource;
   import com.trendmicro.grid.acl.metadata.Metadata;
   import org.hibernate.annotations.Type;
   
   import javax.persistence.*;
   import java.net.URI;
  
  import static com.trendmicro.grid.acl.Limits.SOURCE_MAX_INTERNAL_URI_LENGTH;
  import static com.trendmicro.grid.acl.Limits.SOURCE_MAX_REMOTE_URI_LENGTH;
  import static com.trendmicro.grid.acl.ds.jpa.QueryHints.*;
  import static com.trendmicro.grid.acl.ds.jpa.QueryHints.CACHE_STORE_MODE;
  import static com.trendmicro.grid.acl.ds.jpa.QueryHints.V_USE;
  
  /**
   * Binds Source to the table "SOURCE".
   *
   * @author juergen_kellerer, 2010-06-01
   * @version 1.0
   */
  @NamedQueries({
  		@NamedQuery(name = "Source.SelectSourcesOfDomainInRange", query = "" +
  				"SELECT s.sourceInformation.publicGUID FROM SOURCE s " +
  				"WHERE 	s.sourceDomain.name = :name AND " +
  				"		s.sourceInformation.lastModified BETWEEN :fromDate AND :toDate"),
  		@NamedQuery(name = "Source.SelectSourcesOfDomain", query = "" +
  				"SELECT s.sourceInformation.publicGUID FROM SOURCE s " +
  				"WHERE 	s.sourceDomain.name = :name"),
  
  		@NamedQuery(name = "Source.SelectSourceInformationById", query = "" +
  				"SELECT s.sourceInformation FROM SOURCE s " +
  				"WHERE 	s.sourceInformation.publicGUID = :publicGUID",
  				hints = {@QueryHint(name = CACHEABLE, value = V_YES),
  						@QueryHint(name = CACHE_RETRIEVE_MODE, value = V_USE), @QueryHint(name = CACHE_STORE_MODE, value = V_USE)}),
  
  		@NamedQuery(name = "Source.SelectSourceById", query = "" +
  				"SELECT s FROM SOURCE s " +
  				"WHERE 	s.sourceInformation.publicGUID = :publicGUID",
  				hints = {@QueryHint(name = CACHEABLE, value = V_YES),
  						@QueryHint(name = CACHE_RETRIEVE_MODE, value = V_USE), @QueryHint(name = CACHE_STORE_MODE, value = V_USE)}),
  
  		@NamedQuery(name = "Source.SelectSourcePrimaryKeyById", query = "" +
  				"SELECT s.id FROM SOURCE s " +
  				"WHERE 	s.sourceInformation.publicGUID = :publicGUID",
  				hints = {@QueryHint(name = CACHEABLE, value = V_YES),
  						@QueryHint(name = CACHE_RETRIEVE_MODE, value = V_USE), @QueryHint(name = CACHE_STORE_MODE, value = V_USE)}),
  
  		@NamedQuery(name = "Source.SelectSourceExistsById", query = "" +
  				"SELECT COUNT(*) FROM SOURCE s " +
  				"WHERE 	s.sourceInformation.publicGUID = :publicGUID"),
  
  		@NamedQuery(name = "Source.UpdateInternalURIById", query = "" +
  				"UPDATE SOURCE s SET s.internalURIString = :internalURI " +
  				"WHERE 	s.sourceInformation.publicGUID = :publicGUID AND s.remoteURIString IS NOT NULL")
  })
  @Cacheable
  @Entity(name = "SOURCE")
  public class JpaSource extends SharedSource {
  
  	private static final long serialVersionUID = 891571981945509368L;
  
  	int primaryKey;
  
  	public JpaSource() {
  	}
  
  	public JpaSource(URI remoteURI, URI internalURI, JpaSourceInformation sourceInformation,
  					 JpaSourceDomain sourceDomain, Metadata metadata) {
  		super(remoteURI, internalURI, sourceInformation, sourceDomain,
  				metadata == null ? null : metadata.clone());
  	}
  
  	@Id
  	@GeneratedValue
  	@Column(name = "SOURCE_ID")
  	public int getPrimaryKey() {
  		return primaryKey;
  	}
  
  	public void setPrimaryKey(int primaryKey) {
  		this.primaryKey = primaryKey;
  	}
  
  	@Column(name = "PUBLIC_URI", length = SOURCE_MAX_REMOTE_URI_LENGTH, nullable = true)
  	public String getRemoteURIString() {
  		return remoteURI == null ? null : remoteURI.toString();
  	}
  
  	public void setRemoteURIString(String remoteURI) {
  		this.remoteURI = remoteURI == null ? null : URI.create(remoteURI);
  	}
  
  	@Column(name = "INTERNAL_URI", length = SOURCE_MAX_INTERNAL_URI_LENGTH, nullable = true)
  	public String getInternalURIString() {
  		return internalURI == null ? null : internalURI.toString();
  	}
  
 	public void setInternalURIString(String internalURI) {
 		this.internalURI = internalURI == null ? null : URI.create(internalURI);
 	}
 
 	@Embedded
 	public JpaSourceInformation getSourceInformation() {
 		return (JpaSourceInformation) sourceInformation;
 	}
 
 	public void setSourceInformation(JpaSourceInformation sourceInformation) {
 		this.sourceInformation = sourceInformation;
 	}
 
 	@ManyToOne(fetch = FetchType.LAZY, cascade = CascadeType.PERSIST)
 	@JoinColumn(name = "SOURCE_DOMAIN_ID", nullable = false, updatable = false)
 	public JpaSourceDomain getSourceDomain() {
 		return (JpaSourceDomain) sourceDomain;
 	}
 
 	public void setSourceDomain(JpaSourceDomain sourceDomain) {
 		this.sourceDomain = sourceDomain;
 	}
 
 	@Override
 	@Type(type = "metadata")
 	@Basic(fetch = FetchType.EAGER)
 	@Column(name = "META_DATA", length = Limits.MAX_SERIALIZED_METADATA_LENGTH)
 	public Metadata getMetadata() {
 		return super.getMetadata();
 	}
 
 	@Override
 	public void setMetadata(Metadata metadata) { //NOSONAR - Override is required as hook for JPA.
 		super.setMetadata(metadata == null ? null : metadata.clone());
 	}
 
 	/**
 	 * {@inheritDoc}
 	 */
 	@Override
 	public String toString() {
 		return "JpaSource{" +
 				"primaryKey=" + primaryKey +
 				", remoteURL=" + remoteURI +
 				", internalURL=" + internalURI +
 				", sourceDomain=" + sourceDomain +
 				", metadata=" + metadata +
 				'}';
 	}
 }