package com.redhat.training.rest;
|
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.List;
|
|
import javax.annotation.Resource;
|
import javax.ejb.EJBException;
|
import javax.ejb.Stateless;
|
import javax.ejb.TransactionManagement;
|
import javax.ejb.TransactionManagementType;
|
import javax.inject.Inject;
|
import javax.persistence.EntityManager;
|
import javax.persistence.PersistenceContext;
|
import javax.persistence.TypedQuery;
|
import javax.transaction.UserTransaction;
|
import javax.ws.rs.Consumes;
|
import javax.ws.rs.DELETE;
|
import javax.ws.rs.GET;
|
import javax.ws.rs.POST;
|
import javax.ws.rs.Path;
|
import javax.ws.rs.PathParam;
|
import javax.ws.rs.Produces;
|
import javax.ws.rs.core.MediaType;
|
import javax.ws.rs.core.Response;
|
import javax.ws.rs.core.Response.ResponseBuilder;
|
|
import com.redhat.training.messaging.JMSUtil;
|
import com.redhat.training.model.Person;
|
|
//TODO Add the stateless annotation
|
|
//TODO Add a Path for persons
|
|
//TODO Add a Consumes annotation for JSON
|
|
//TODO Add a Produces annotation for JSON
|
|
@TransactionManagement(TransactionManagementType.BEAN)
|
public class PersonService {
|
|
@PersistenceContext
|
private EntityManager entityManager;
|
|
@Resource
|
UserTransaction tx;
|
|
@Inject
|
JMSUtil jmsUtil;
|
|
// Simple non-RESTy method for JSF bean invocation
|
public String hello(String name) {
|
try {
|
try {
|
// start a new transaction
|
tx.begin();
|
|
// let's grab the current date and time on the server
|
LocalDateTime today = LocalDateTime.now();
|
|
// format it nicely for on-screen display
|
DateTimeFormatter format = DateTimeFormatter.ofPattern("MMM dd yyyy hh:mm:ss a");
|
String fdate = today.format(format);
|
|
// Create a new Person object and persist to database
|
Person p = new Person();
|
p.setName(name);
|
entityManager.persist(p);
|
|
// Send a JMS message to the 'helloWorldQueue'
|
jmsUtil.sendMessage("Said Hello to " + name.toUpperCase() + " at " + fdate);
|
|
// respond back with Hello and convert the name to UPPERCASE. Also, send the
|
// current time on the server.
|
return "Hello " + name.toUpperCase() + "!. " + "Time on the server is: " + fdate;
|
} finally {
|
// commit the transaction
|
tx.commit();
|
}
|
} catch (Exception e) {
|
throw new EJBException(e);
|
}
|
}
|
|
// CRUD RESTful methods below
|
|
// fetch result by Person id
|
//TODO add GET annotation
|
|
//TODO add path for ID
|
|
public Person getPerson(Long id) {
|
return entityManager.find(Person.class, id);
|
}
|
|
// Dump all Person objects in the Database
|
//TODO add GET annotation
|
|
public List<Person> getAllPersons() {
|
TypedQuery<Person> query = entityManager.createQuery("SELECT p FROM Person p", Person.class);
|
List<Person> persons = query.getResultList();
|
|
return persons;
|
}
|
|
// delete an object by Person id
|
//TODO add DELETE annotation
|
|
//TODO add Path for ID
|
|
public void deletePerson(Long id) {
|
try {
|
try {
|
tx.begin();
|
entityManager.remove(getPerson(id));
|
} finally {
|
tx.commit();
|
}
|
} catch (Exception e) {
|
throw new EJBException();
|
}
|
}
|
|
// Save a Person object to Database
|
//TODO add POST annotation
|
|
public Response savePerson(Person person) {
|
try {
|
try {
|
ResponseBuilder builder;
|
if (person.getId() == null) {
|
Person newPerson = new Person();
|
newPerson.setName(person.getName());
|
tx.begin();
|
entityManager.persist(newPerson);
|
builder = Response.ok();
|
} else {
|
Person uPerson;
|
Person updatePerson = getPerson(person.getId());
|
updatePerson.setName(person.getName());
|
uPerson = entityManager.merge(updatePerson);
|
builder = Response.ok(uPerson);
|
}
|
|
return builder.build();
|
}finally {
|
tx.commit();
|
}
|
}catch (Exception e) {
|
throw new EJBException(e);
|
}
|
}
|
|
}
|
