RCustomer i ROrder z pomocą kreatora w Eclipse

PC35-RestSerwer/src/main/java/sklep/model/Customer.java

@@ -2,6 +2,9 @@ package sklep.model;
 
 import java.util.Objects;
 
+import javax.xml.bind.annotation.XmlRootElement;
+
+@XmlRootElement
 public class Customer {
 	private String email;
 	private String name;

PC35-RestSerwer/src/main/java/sklep/model/Order.java

@@ -10,8 +10,10 @@ import java.util.Objects;
 import javax.xml.bind.annotation.XmlAttribute;
 import javax.xml.bind.annotation.XmlElement;
 import javax.xml.bind.annotation.XmlElementWrapper;
+import javax.xml.bind.annotation.XmlRootElement;
 import javax.xml.bind.annotation.adapters.XmlJavaTypeAdapter;
 
+@XmlRootElement
 public class Order {
 	@XmlAttribute(name="id")
 	private Integer orderId;

PC35-RestSerwer/src/main/java/sklep/rest/RCustomer.java

+package sklep.rest;
+
+import java.util.List;
+
+import javax.enterprise.context.RequestScoped;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.PUT;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.core.UriBuilder;
+
+import sklep.db.CustomerDAO;
+import sklep.db.DBConnection;
+import sklep.db.DBException;
+import sklep.db.RecordNotFound;
+import sklep.model.Customer;
+
+@RequestScoped
+@Path("/customers")
+@Produces({ "application/xml", "application/json" })
+@Consumes({ "application/xml", "application/json" })
+public class RCustomer {
+
+	@POST
+	public Response save(final Customer customer) throws DBException {
+		try(DBConnection db = DBConnection.open()) {
+			CustomerDAO customerDAO = db.customerDAO();
+			customerDAO.save(customer);
+			db.commit();
+			return Response.created(UriBuilder.fromResource(RCustomer.class).path(String.valueOf(customer.getEmail())).build()).build();
+		}
+	}
+
+	@GET
+	@Path("/{id}")
+	public Customer findById(@PathParam("id") final String email) throws DBException, RecordNotFound {
+		try(DBConnection db = DBConnection.open()) {
+			CustomerDAO customerDAO = db.customerDAO();
+			return customerDAO.findByEmail(email);
+		}
+	}
+
+	@GET
+	public List<Customer> listAll() throws DBException {
+		try(DBConnection db = DBConnection.open()) {
+			CustomerDAO customerDAO = db.customerDAO();
+			return customerDAO.readAll();
+		}
+	}
+
+	@PUT
+	@Path("/{id}")
+	public Response update(@PathParam("id") String email, final Customer customer) throws DBException {
+		try(DBConnection db = DBConnection.open()) {
+			CustomerDAO customerDAO = db.customerDAO();
+			customer.setEmail(email);
+			customerDAO.save(customer);
+			db.commit();
+		}
+		return Response.noContent().build();
+	}
+
+	@DELETE
+	@Path("/{id}")
+	public Response deleteById(@PathParam("id") String email) throws DBException {
+		try(DBConnection db = DBConnection.open()) {
+			CustomerDAO customerDAO = db.customerDAO();
+			customerDAO.delete(email);
+			db.commit();
+		}
+		return Response.noContent().build();
+	}
+
+}

PC35-RestSerwer/src/main/java/sklep/rest/ROrder.java

+package sklep.rest;
+
+import java.util.List;
+
+import javax.enterprise.context.RequestScoped;
+import javax.ws.rs.Consumes;
+import javax.ws.rs.GET;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.core.Response.Status;
+
+import sklep.db.DBConnection;
+import sklep.db.DBException;
+import sklep.db.OrderDAO;
+import sklep.db.RecordNotFound;
+import sklep.model.Order;
+
+@RequestScoped
+@Path("/orders")
+@Produces({ "application/xml", "application/json" })
+@Consumes({ "application/xml", "application/json" })
+public class ROrder {
+
+	@GET
+	@Path("/{id:[0-9][0-9]*}")
+	public Response findById(@PathParam("id") final Integer id) {
+		// Klasa Response pozwala nam z pełną precyzją przygotować odpowiedź, która ma zostać odesłana klientowi.
+		// W przypadku pozytywnym (ok) zostanie odesłany obiekt przetłumaczony na XML lub JSON, a kod wynikowy to będzie 200.
+		// Ale w przypadku błędów możemy sami zdecydować co odsyłami (tutaj odpowiednie kody HTTP).		
+		try(DBConnection db = DBConnection.open()) {
+			OrderDAO orderDAO = db.orderDAO();
+			Order order = orderDAO.findById(id);
+			return Response.ok(order).build();
+		} catch (DBException e) {
+			e.printStackTrace();
+			return Response.status(Status.INTERNAL_SERVER_ERROR).build();
+		} catch (RecordNotFound e) {
+			return Response.status(Status.NOT_FOUND).build();
+		}
+	}
+
+	@GET
+	public List<Order> listAll() throws DBException {
+		try(DBConnection db = DBConnection.open()) {
+			OrderDAO orderDAO = db.orderDAO();
+			return orderDAO.readAll();
+		}
+	}
+
+}