Java Code Examples for javax.persistence.Column

private static JPAMember findByColumn(Attribute<?,?> att,String columnName,Object target){
  JPAMember rt=JPAMember.create(att,target);
  Column c=rt.getAnnotation(Column.class);
  if (c == null)   return null;
  if (columnName.equals(c.name()))   return rt;
  return null;
}
 

protected EdmProperty.Builder toEdmProperty(String modelNamespace,SingularAttribute<?,?> sa){
  String name=sa.getName();
  EdmType type;
  if (sa.getPersistentAttributeType() == PersistentAttributeType.EMBEDDED) {
    String simpleName=sa.getJavaType().getSimpleName();
    type=EdmComplexType.newBuilder().setNamespace(modelNamespace).setName(simpleName).build();
  }
 else   if (sa.getBindableJavaType().isEnum()) {
    type=EdmSimpleType.STRING;
  }
 else {
    type=toEdmType(sa);
  }
  boolean nullable=sa.isOptional();
  Integer maxLength=null;
  if (sa.getJavaMember() instanceof AnnotatedElement) {
    Column col=((AnnotatedElement)sa.getJavaMember()).getAnnotation(Column.class);
    if (col != null && Enumerable.<EdmType>create(EdmSimpleType.BINARY,EdmSimpleType.STRING).contains(type))     maxLength=col.length();
  }
  return EdmProperty.newBuilder(name).setType(type).setNullable(nullable).setMaxLength(maxLength);
}
 

@SuppressWarnings("unchecked") @DefaultCommand(help="Create a JPA @Entity") public void newEntity(@Option(required=true,name="named",description="The @Entity name") final String entityName,@Option(required=false,name="package",type=PromptType.JAVA_PACKAGE,description="The package name") final String packageName,@Option(name="idStrategy",defaultValue="AUTO",description="The GenerationType name for the ID") final GenerationType idStrategy) throws Throwable {
  final PersistenceFacet jpa=project.getFacet(PersistenceFacet.class);
  final JavaSourceFacet java=project.getFacet(JavaSourceFacet.class);
  String entityPackage;
  if ((packageName != null) && !"".equals(packageName)) {
    entityPackage=packageName;
  }
 else   if (getPackagePortionOfCurrentDirectory() != null) {
    entityPackage=getPackagePortionOfCurrentDirectory();
  }
 else {
    entityPackage=shell.promptCommon("In which package you'd like to create this @Entity, or enter for default",PromptType.JAVA_PACKAGE,jpa.getEntityPackage());
  }
  JavaClass javaClass=JavaParser.create(JavaClass.class).setPackage(entityPackage).setName(entityName).setPublic().addAnnotation(Entity.class).getOrigin().addInterface(Serializable.class);
  Field<JavaClass> id=javaClass.addField("private Long id = null;");
  id.addAnnotation(Id.class);
  id.addAnnotation(GeneratedValue.class).setEnumValue("strategy",idStrategy);
  id.addAnnotation(Column.class).setStringValue("name","id").setLiteralValue("updatable","false").setLiteralValue("nullable","false");
  Field<JavaClass> version=javaClass.addField("private int version = 0;");
  version.addAnnotation(Version.class);
  version.addAnnotation(Column.class).setStringValue("name","version");
  Refactory.createGetterAndSetter(javaClass,id);
  Refactory.createGetterAndSetter(javaClass,version);
  Refactory.createToStringFromFields(javaClass,id);
  Refactory.createHashCodeAndEquals(javaClass);
  JavaResource javaFileLocation=java.saveJavaSource(javaClass);
  shell.println("Created @Entity [" + javaClass.getQualifiedName() + "]");
  shell.execute("pick-up " + javaFileLocation.getFullyQualifiedName().replace(" ","\\ "));
}
 

@Command(value="custom",help="Add a custom field to an existing @Entity class") public void newCustomField(@Option(name="named",required=true,description="The field name",type=PromptType.JAVA_VARIABLE_NAME) final String fieldName,@Option(name="type",required=true,type=PromptType.JAVA_CLASS,description="The qualified Class to be used as this field's type") final String type){
  try {
    JavaClass entity=getJavaClass();
    String javaType=(type.toLowerCase().endsWith(".java")) ? type.substring(0,type.length() - 5) : type;
    addFieldTo(entity,javaType,fieldName,Column.class);
  }
 catch (  FileNotFoundException e) {
    shell.println("Could not locate the @Entity requested. No update was made.");
  }
}
 

@Test public void countColumnValueTest(){
  int objective=3;
  int counter=0;
  for (  Field field : Person.class.getDeclaredFields()) {
    if (field.getAnnotation(Column.class) != null) {
      counter++;
    }
  }
  Assert.assertEquals(counter,objective);
}
 

/** 
 * Support method which will be used for construction of criteria-based queries.
 * @param example an example of the given entity
 * @return an instance of {@code CriteriaQuery}
 */
private CriteriaQuery<T> createCriteriaByExample(final T example){
  final CriteriaBuilder builder=getCriteriaBuilder();
  final CriteriaQuery<T> query=builder.createQuery(getBeanClass());
  final Root<T> entity=query.from(getBeanClass());
  final List<Predicate> predicates=new ArrayList<Predicate>();
  final Field[] fields=example.getClass().getDeclaredFields();
  for (  Field field : fields) {
    if (!field.isAnnotationPresent(Column.class) && !field.isAnnotationPresent(Basic.class) && !field.isAnnotationPresent(Enumerated.class)) {
      continue;
    }
    Object value=null;
    try {
      field.setAccessible(true);
      value=field.get(example);
    }
 catch (    IllegalArgumentException e) {
      continue;
    }
catch (    IllegalAccessException e) {
      continue;
    }
    if (value == null) {
      continue;
    }
    final Predicate pred=builder.equal(entity.get(field.getName()),value);
    predicates.add(pred);
  }
  return query.where(predicates.toArray(new Predicate[0])).select(entity);
}
 

@Override public Column createMappedForm(PersistentProperty mpp){
  Field field;
  try {
    field=mpp.getOwner().getJavaClass().getDeclaredField(mpp.getName());
    return field.getAnnotation(Column.class);
  }
 catch (  SecurityException e) {
    return null;
  }
catch (  NoSuchFieldException e) {
    return null;
  }
}
 

/** 
 * @return technology adaption of the domain
 */
@Column(length=40,nullable=false) public String getAdaption(){
  if (this.adaption == null) {
    this.adaption="";
  }
  return this.adaption;
}
 

/** 
 * @return technology switch of the domain
 */
@Column(nullable=false,length=40) public String getSwitch(){
  if (this.switchd == null) {
    this.switchd="";
  }
  return this.switchd;
}
 

@Column(name="credit_limit") public BigDecimal getCreditLimit(){
  if (creditLimit == null) {
    return BigDecimal.ZERO;
  }
  return creditLimit;
}
 

@Column(name="dynamic_balance") public BigDecimal getDynamicBalance(){
  if (dynamicBalance == null) {
    return BigDecimal.ZERO;
  }
  return dynamicBalance;
}
 

@Column(name="userValidated",nullable=false) public void setUserValidated(char userValidated){
  if (userValidated == 'y' || userValidated == 'Y') {
    this.userValidated='Y';
  }
 else {
    this.userValidated='N';
  }
}
 

/** 
 * @return the idTokenString
 */
@Basic @Column(name="id_token_string") public String getIdTokenString(){
  if (idToken != null) {
    return idToken.toString();
  }
 else {
    return null;
  }
}
 

@Lob @Column(name="detailsExt") public byte[] getDetailsExt(){
  if (_details.detailsExt != null && _details.detailsExt.size() > 0) {
    try {
      ByteArrayOutputStream bos=new ByteArrayOutputStream();
      ObjectOutputStream os=new ObjectOutputStream(bos);
      os.writeObject(_details.detailsExt);
      os.close();
      return bos.toByteArray();
    }
 catch (    Exception e) {
      __log.error("Error in getDetailsExt ",e);
    }
  }
  return null;
}
 

@Column(name="pos") public long getPosition(){
  if (position == 0) {
    position=System.currentTimeMillis();
  }
  return position;
}
 

@Lob @Column(name="SESSION_IN_BYTE") public byte[] getByteSession(){
  if (this.session != null) {
    ByteArrayOutputStream bos=new ByteArrayOutputStream();
    ObjectOutputStream os=null;
    try {
      os=new ObjectOutputStream(bos);
      os.writeObject(this.session);
      return bos.toByteArray();
    }
 catch (    Exception e) {
      logger.log(Level.SEVERE,"Error in getting session in byte.");
    }
 finally {
      try {
        if (os != null) {
          os.close();
        }
      }
 catch (      IOException e) {
        logger.log(Level.SEVERE,"Error in closing ObjectOutputStream.");
      }
    }
  }
  return null;
}
 

@Column(name="credit_limit") public BigDecimal getCreditLimit(){
  if (creditLimit == null) {
    return BigDecimal.ZERO;
  }
  return creditLimit;
}
 

@Column(name="dynamic_balance") public BigDecimal getDynamicBalance(){
  if (dynamicBalance == null) {
    return BigDecimal.ZERO;
  }
  return dynamicBalance;
}
 

/** 
 * Returns the most recent IP used to log into this account as string. This should be used in persistence and lobby protocol specific parts only.
 * @see #getLastIp()
 */
@Column(name="last_ip",unique=false,nullable=false,insertable=true,updatable=true,length=15) public String getLastIpAsString(){
  if (lastIp == null) {
    return NO_ACCOUNT_LAST_IP_STR;
  }
 else {
    return lastIp.getHostAddress();
  }
}
 

@Override @NotEmpty @Type(type="text") @AccessType("field") @CollectionOfElements(fetch=FetchType.EAGER) @JoinTable(name="HTextFlowContent",joinColumns=@JoinColumn(name="text_flow_id")) @IndexColumn(name="pos",nullable=false) @Column(name="content",nullable=false) public List<String> getContents(){
  copyLazyLoadedRelationsToHistory();
  if (contents == null) {
    contents=new ArrayList<String>();
  }
  return contents;
}
 

@OneToMany(cascade=CascadeType.ALL,mappedBy="textFlow") @org.hibernate.annotations.MapKey(columns={@Column(name="locale")}) @BatchSize(size=10) @Cache(usage=CacheConcurrencyStrategy.READ_WRITE) public Map<Long,HTextFlowTarget> getTargets(){
  if (targets == null) {
    targets=new HashMap<Long,HTextFlowTarget>();
  }
  return targets;
}