Novos recursos - Easy-Cassadra 1.0.9 beta

  JCassandra jCassandra=persistence.createJCassandra("select * from Person");
 List persons=jCassandra.getResultList();

@Entity(name = "autocount")
public class Count implements Serializable {
 
    private static final long serialVersionUID = 3L;
     
    @Id
    @GeneratedValue
    private BigInteger id;
     
   
    @Column(name = "name")
    private String name;
     
    @Version
    private Long timeStampLong;
 
    @Version
    private Date timeStampDate;
     
    @Version
    private Calendar timeStampCalendar;
 
//getter and setter
}

@XmlRootElement
@Entity
public class Album implements Serializable{
    
    @Id
    private Long id;
    
    @Column(name="nameOfAlbum")
    private String name;
    
    @Column  
    private String style;
    
    @Column
    private Calendar release;
    
    @Column
    private Double price;
    
    @Embedded
    private Artist artist;
//getter and setter
    }
@XmlRootElement
public class Artist implements  Serializable{
 
    /**
     * name of the artist
     */
    @Column(name="nameOfArtist")
    private String name;
    
    /**
     * was born
     */
    @Column
    private String country;
    
    @Enumerated
    private Sex sex;
//getter and setter
}

@XmlRootElement
public enum Sex {
    MALE,FAMALE
}

@ApplicationScoped
public class PersistenceManagement {
    
   @Produces 
   private Persistence persistence;
      
  @Inject
    public void init(){
    persistence=EasyCassandraManager.getPersistence("javabahia", 
"localhost", 9160);
    
    EasyCassandraManager.addFamilyObject(Album.class);
    }     
}



@RequestScoped
public class PersistenceService {

@Inject    
 private Persistence persistence;
   
    public List findAllAlbum() {
        Query query=persistence.createJCassandra
           (" select * from Album");
        return query.getResultList();
    }

    public Album findById(Long id) {
        Query query=persistence.createJCassandra
           (" select * from Album where id =:id");
        query.setParameter("id", id);
        return (Album) query.getSingleResult();
        
    }

    public boolean save(Album album) {
      return  persistence.insert(album);
    }

    public void remove(Long id) {
        persistence.deleteByKeyValue(id, Album.class);
    }

    public String update(Long id, String name, 
    String style, Double price,String nameOfArtis,String country) {
       StringBuilder query=new StringBuilder();
     AuxQuery auxQuery=new AuxQuery();
       String conecion="";
       query.append("update Album set ");
       if(!isnull(name)){
           query.append(conecion);
           query.append(" name =:name ");
           auxQuery.updatable=true;
           conecion=" , ";
       }
       if(!isnull(style)){
       query.append(conecion);
           query.append(" style =:style ");
           auxQuery.updatable=true;
           conecion=" , ";
       }
       if(!isnull(price)){
           query.append(conecion);
           query.append(" price =:price ");
           auxQuery.updatable=true;
       }
       
         if(!isnull(country)){
       query.append(conecion);
           query.append(" artist.country =:country ");
           auxQuery.updatable=true;
           conecion=" , ";
       }
       if(!isnull(nameOfArtis)){
           query.append(conecion);
           query.append(" artist.name =:artist ");
           auxQuery.updatable=true;
       }
       
       query.append(" where id =:id ");
     
       if(!auxQuery.updatable){
            return "nothing is update";
       }
       
       Query jCassandra=persistence.createJCassandra(query.toString());
       
          if(!isnull(name)){
          jCassandra.setParameter("name", name);
       }
       if(!isnull(style)){
    
        jCassandra.setParameter("style", style);
       }
       if(!isnull(price)){
         jCassandra.setParameter("price", price);
       }
       if(!isnull(nameOfArtis)){
      
        jCassandra.setParameter("artist", nameOfArtis);
       }
       if(!isnull(country)){
         jCassandra.setParameter("country", country);
       }
      
       jCassandra.setParameter("id", id);
       return jCassandra.executeUpdate()==1?"executed with 
                                                sucess":" error in update ";
     
    }
   
    class AuxQuery{
      boolean updatable=false;
    
    }
    
    private boolean isnull(Object object){
    
        return object==null;
    }
    
}

@Path("/album")
@RequestScoped
public class AlbumResource {
   
     
@Inject    
 private PersistenceService persistenceService; 
 

@GET 
@Produces(MediaType.TEXT_XML)
 public List getProdutos() {
 return persistenceService.findAllAlbum();
 }
 
@Path("{id}")
@GET 
@javax.ws.rs.Produces(MediaType.TEXT_XML)
public Album getAlbum(@PathParam("id") long id) {
    return persistenceService.findById(id);
}

@Path("update/{id}")
@GET 
@javax.ws.rs.Produces(MediaType.TEXT_PLAIN)
public String updateAlbum(@PathParam("id") Long id ,@QueryParam("name") 
String name,@QueryParam("style") String style,@QueryParam("price") 
Double price,@QueryParam("artist") String nameOfArtis,@QueryParam("country") 
String country) {

    return persistenceService.update(id,name,style,price,nameOfArtis,country);
}
    
    
@POST 
@Consumes(MediaType.TEXT_XML)
@Produces(MediaType.TEXT_PLAIN)
public String addAlbum(Album album) {
    boolean sucess=persistenceService.save(album);
    if(sucess){
    return album.getName() + " added!";
    }
   return album.getName() + " not added!";
}



@Path("{id}") 
@DELETE
@Produces(MediaType.TEXT_PLAIN)
public String removeAlbum(@PathParam("id") Long id) {
    persistenceService.remove(id);
    return "Album removed."; 
}
    
 
}