BAEL-150 Introduction to DeltaSpike
This commit is contained in:
@@ -0,0 +1,84 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.controller;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import javax.enterprise.inject.Model;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.faces.application.FacesMessage;
|
||||
import javax.faces.context.FacesContext;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
|
||||
import baeldung.model.Member;
|
||||
import baeldung.service.MemberRegistration;
|
||||
|
||||
// The @Model stereotype is a convenience mechanism to make this a request-scoped bean that has an
|
||||
// EL name
|
||||
// Read more about the @Model stereotype in this FAQ:
|
||||
// http://www.cdi-spec.org/faq/#accordion6
|
||||
@Model
|
||||
public class MemberController {
|
||||
|
||||
@Inject
|
||||
private FacesContext facesContext;
|
||||
|
||||
@Inject
|
||||
private MemberRegistration memberRegistration;
|
||||
|
||||
@Produces
|
||||
@Named
|
||||
private Member newMember;
|
||||
|
||||
@PostConstruct
|
||||
public void initNewMember() {
|
||||
newMember = new Member();
|
||||
}
|
||||
|
||||
public void register() throws Exception {
|
||||
try {
|
||||
memberRegistration.register(newMember);
|
||||
FacesMessage m = new FacesMessage(FacesMessage.SEVERITY_INFO, "Registered!", "Registration successful");
|
||||
facesContext.addMessage(null, m);
|
||||
initNewMember();
|
||||
} catch (Exception e) {
|
||||
String errorMessage = getRootErrorMessage(e);
|
||||
FacesMessage m = new FacesMessage(FacesMessage.SEVERITY_ERROR, errorMessage, "Registration unsuccessful");
|
||||
facesContext.addMessage(null, m);
|
||||
}
|
||||
}
|
||||
|
||||
private String getRootErrorMessage(Exception e) {
|
||||
// Default to general error message that registration failed.
|
||||
String errorMessage = "Registration failed. See server log for more information";
|
||||
if (e == null) {
|
||||
// This shouldn't happen, but return the default messages
|
||||
return errorMessage;
|
||||
}
|
||||
|
||||
// Start with the exception and recurse to find the root cause
|
||||
Throwable t = e;
|
||||
while (t != null) {
|
||||
// Get the message from the Throwable class instance
|
||||
errorMessage = t.getLocalizedMessage();
|
||||
t = t.getCause();
|
||||
}
|
||||
// This is the root cause message
|
||||
return errorMessage;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
package baeldung.data;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.enterprise.inject.Default;
|
||||
import javax.enterprise.inject.Disposes;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.EntityManagerFactory;
|
||||
import javax.persistence.PersistenceUnit;
|
||||
|
||||
@ApplicationScoped
|
||||
public class EntityManagerProducer
|
||||
{
|
||||
@PersistenceUnit(unitName = "primary")
|
||||
private EntityManagerFactory entityManagerFactory;
|
||||
|
||||
@Produces
|
||||
@Default
|
||||
@RequestScoped
|
||||
public EntityManager create()
|
||||
{
|
||||
return this.entityManagerFactory.createEntityManager();
|
||||
}
|
||||
|
||||
public void dispose(@Disposes @Default EntityManager entityManager)
|
||||
{
|
||||
if (entityManager.isOpen())
|
||||
{
|
||||
entityManager.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,54 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.data;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.enterprise.event.Observes;
|
||||
import javax.enterprise.event.Reception;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.inject.Inject;
|
||||
import javax.inject.Named;
|
||||
import java.util.List;
|
||||
|
||||
import baeldung.model.Member;
|
||||
|
||||
@RequestScoped
|
||||
public class MemberListProducer {
|
||||
|
||||
@Inject
|
||||
private MemberRepository memberRepository;
|
||||
|
||||
private List<Member> members;
|
||||
|
||||
// @Named provides access the return value via the EL variable name "members" in the UI (e.g.
|
||||
// Facelets or JSP view)
|
||||
@Produces
|
||||
@Named
|
||||
public List<Member> getMembers() {
|
||||
return members;
|
||||
}
|
||||
|
||||
public void onMemberListChanged(@Observes(notifyObserver = Reception.IF_EXISTS) final Member member) {
|
||||
retrieveAllMembersOrderedByName();
|
||||
}
|
||||
|
||||
@PostConstruct
|
||||
public void retrieveAllMembersOrderedByName() {
|
||||
members = memberRepository.findAllOrderedByNameWithQueryDSL();
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,43 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.data;
|
||||
|
||||
import baeldung.model.Member;
|
||||
import baeldung.model.QMember;
|
||||
import org.apache.deltaspike.data.api.*;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
@Repository
|
||||
@EntityManagerConfig(entityManagerResolver = SecondaryEntityManagerResolver.class)
|
||||
public abstract class MemberRepository extends AbstractEntityRepository<Member, Long> implements QueryDslSupport {
|
||||
|
||||
public abstract Member findById(Long id);
|
||||
|
||||
public abstract Member findByEmail(String email);
|
||||
|
||||
@Query("from Member m order by m.name")
|
||||
public abstract List<Member> findAllOrderedByName();
|
||||
|
||||
public List<Member> findAllOrderedByNameWithQueryDSL() {
|
||||
final QMember member = QMember.member;
|
||||
return jpaQuery()
|
||||
.from(member)
|
||||
.orderBy(member.email.asc())
|
||||
.list(member);
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,18 @@
|
||||
package baeldung.data;
|
||||
|
||||
import com.mysema.query.jpa.impl.JPAQuery;
|
||||
import org.apache.deltaspike.data.spi.DelegateQueryHandler;
|
||||
import org.apache.deltaspike.data.spi.QueryInvocationContext;
|
||||
|
||||
import javax.inject.Inject;
|
||||
|
||||
public class QueryDslRepositoryExtension<E> implements QueryDslSupport, DelegateQueryHandler {
|
||||
|
||||
@Inject
|
||||
private QueryInvocationContext context;
|
||||
|
||||
@Override
|
||||
public JPAQuery jpaQuery() {
|
||||
return new JPAQuery(context.getEntityManager());
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,7 @@
|
||||
package baeldung.data;
|
||||
|
||||
import com.mysema.query.jpa.impl.JPAQuery;
|
||||
|
||||
public interface QueryDslSupport {
|
||||
JPAQuery jpaQuery();
|
||||
}
|
||||
@@ -0,0 +1,34 @@
|
||||
package baeldung.data;
|
||||
|
||||
import javax.enterprise.context.ApplicationScoped;
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.enterprise.inject.Default;
|
||||
import javax.enterprise.inject.Disposes;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.EntityManagerFactory;
|
||||
import javax.persistence.PersistenceUnit;
|
||||
|
||||
@ApplicationScoped
|
||||
public class SecondaryEntityManagerProducer
|
||||
{
|
||||
@PersistenceUnit(unitName = "secondary")
|
||||
private EntityManagerFactory entityManagerFactory;
|
||||
|
||||
@Produces
|
||||
@Default
|
||||
@RequestScoped
|
||||
@SecondaryPersistenceUnit
|
||||
public EntityManager create()
|
||||
{
|
||||
return this.entityManagerFactory.createEntityManager();
|
||||
}
|
||||
|
||||
public void dispose(@Disposes @Default EntityManager entityManager)
|
||||
{
|
||||
if (entityManager.isOpen())
|
||||
{
|
||||
entityManager.close();
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,18 @@
|
||||
package baeldung.data;
|
||||
|
||||
import org.apache.deltaspike.data.api.EntityManagerResolver;
|
||||
|
||||
import javax.inject.Inject;
|
||||
import javax.persistence.EntityManager;
|
||||
|
||||
public class SecondaryEntityManagerResolver implements EntityManagerResolver {
|
||||
|
||||
@Inject
|
||||
@SecondaryPersistenceUnit
|
||||
private EntityManager entityManager;
|
||||
|
||||
@Override
|
||||
public EntityManager resolveEntityManager() {
|
||||
return entityManager;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,12 @@
|
||||
package baeldung.data;
|
||||
|
||||
import javax.inject.Qualifier;
|
||||
import java.lang.annotation.Documented;
|
||||
import java.lang.annotation.Retention;
|
||||
import java.lang.annotation.RetentionPolicy;
|
||||
|
||||
@Documented
|
||||
@Retention(RetentionPolicy.RUNTIME)
|
||||
@Qualifier
|
||||
public @interface SecondaryPersistenceUnit {
|
||||
}
|
||||
@@ -0,0 +1,93 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.model;
|
||||
|
||||
import java.io.Serializable;
|
||||
|
||||
import javax.persistence.Column;
|
||||
import javax.persistence.Entity;
|
||||
import javax.persistence.GeneratedValue;
|
||||
import javax.persistence.Id;
|
||||
import javax.persistence.Table;
|
||||
import javax.persistence.UniqueConstraint;
|
||||
import javax.validation.constraints.Digits;
|
||||
import javax.validation.constraints.NotNull;
|
||||
import javax.validation.constraints.Pattern;
|
||||
import javax.validation.constraints.Size;
|
||||
import javax.xml.bind.annotation.XmlRootElement;
|
||||
|
||||
import org.hibernate.validator.constraints.Email;
|
||||
import org.hibernate.validator.constraints.NotEmpty;
|
||||
|
||||
@SuppressWarnings("serial")
|
||||
@Entity
|
||||
@XmlRootElement
|
||||
@Table(uniqueConstraints = @UniqueConstraint(columnNames = "email"))
|
||||
public class Member implements Serializable {
|
||||
|
||||
@Id
|
||||
@GeneratedValue
|
||||
private Long id;
|
||||
|
||||
@NotNull
|
||||
@Size(min = 1, max = 25)
|
||||
@Pattern(regexp = "[^0-9]*", message = "Must not contain numbers")
|
||||
private String name;
|
||||
|
||||
@NotNull
|
||||
@NotEmpty
|
||||
@Email
|
||||
private String email;
|
||||
|
||||
@NotNull
|
||||
@Size(min = 10, max = 12)
|
||||
@Digits(fraction = 0, integer = 12)
|
||||
@Column(name = "phone_number")
|
||||
private String phoneNumber;
|
||||
|
||||
public Long getId() {
|
||||
return id;
|
||||
}
|
||||
|
||||
public void setId(Long id) {
|
||||
this.id = id;
|
||||
}
|
||||
|
||||
public String getName() {
|
||||
return name;
|
||||
}
|
||||
|
||||
public void setName(String name) {
|
||||
this.name = name;
|
||||
}
|
||||
|
||||
public String getEmail() {
|
||||
return email;
|
||||
}
|
||||
|
||||
public void setEmail(String email) {
|
||||
this.email = email;
|
||||
}
|
||||
|
||||
public String getPhoneNumber() {
|
||||
return phoneNumber;
|
||||
}
|
||||
|
||||
public void setPhoneNumber(String phoneNumber) {
|
||||
this.phoneNumber = phoneNumber;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,33 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.rest;
|
||||
|
||||
import javax.ws.rs.ApplicationPath;
|
||||
import javax.ws.rs.core.Application;
|
||||
|
||||
/**
|
||||
* A class extending {@link Application} and annotated with @ApplicationPath is the Java EE 7 "no XML" approach to activating
|
||||
* JAX-RS.
|
||||
*
|
||||
* <p>
|
||||
* Resources are served relative to the servlet path specified in the {@link ApplicationPath} annotation.
|
||||
* </p>
|
||||
*/
|
||||
@ApplicationPath("/rest")
|
||||
public class JaxRsActivator extends Application {
|
||||
/* class body intentionally left blank */
|
||||
}
|
||||
@@ -0,0 +1,185 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.rest;
|
||||
|
||||
import java.util.HashMap;
|
||||
import java.util.HashSet;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.Set;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.inject.Inject;
|
||||
import javax.persistence.NoResultException;
|
||||
import javax.validation.ConstraintViolation;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
import javax.validation.ValidationException;
|
||||
import javax.validation.Validator;
|
||||
import javax.ws.rs.Consumes;
|
||||
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.WebApplicationException;
|
||||
import javax.ws.rs.core.MediaType;
|
||||
import javax.ws.rs.core.Response;
|
||||
|
||||
import baeldung.data.MemberRepository;
|
||||
import baeldung.model.Member;
|
||||
import baeldung.service.MemberRegistration;
|
||||
|
||||
/**
|
||||
* JAX-RS Example
|
||||
* <p/>
|
||||
* This class produces a RESTful service to read/write the contents of the members table.
|
||||
*/
|
||||
@Path("/members")
|
||||
@RequestScoped
|
||||
public class MemberResourceRESTService {
|
||||
|
||||
@Inject
|
||||
private Logger log;
|
||||
|
||||
@Inject
|
||||
private Validator validator;
|
||||
|
||||
@Inject
|
||||
private MemberRepository repository;
|
||||
|
||||
@Inject
|
||||
MemberRegistration registration;
|
||||
|
||||
@GET
|
||||
@Produces(MediaType.APPLICATION_JSON)
|
||||
public List<Member> listAllMembers() {
|
||||
return repository.findAllOrderedByName();
|
||||
}
|
||||
|
||||
@GET
|
||||
@Path("/{id:[0-9][0-9]*}")
|
||||
@Produces(MediaType.APPLICATION_JSON)
|
||||
public Member lookupMemberById(@PathParam("id") long id) {
|
||||
Member member = repository.findById(id);
|
||||
if (member == null) {
|
||||
throw new WebApplicationException(Response.Status.NOT_FOUND);
|
||||
}
|
||||
return member;
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates a new member from the values provided. Performs validation, and will return a JAX-RS response with either 200 ok,
|
||||
* or with a map of fields, and related errors.
|
||||
*/
|
||||
@POST
|
||||
@Consumes(MediaType.APPLICATION_JSON)
|
||||
@Produces(MediaType.APPLICATION_JSON)
|
||||
public Response createMember(Member member) {
|
||||
|
||||
Response.ResponseBuilder builder = null;
|
||||
|
||||
try {
|
||||
// Validates member using bean validation
|
||||
validateMember(member);
|
||||
|
||||
registration.register(member);
|
||||
|
||||
// Create an "ok" response
|
||||
builder = Response.ok();
|
||||
} catch (ConstraintViolationException ce) {
|
||||
// Handle bean validation issues
|
||||
builder = createViolationResponse(ce.getConstraintViolations());
|
||||
} catch (ValidationException e) {
|
||||
// Handle the unique constrain violation
|
||||
Map<String, String> responseObj = new HashMap<>();
|
||||
responseObj.put("email", "Email taken");
|
||||
builder = Response.status(Response.Status.CONFLICT).entity(responseObj);
|
||||
} catch (Exception e) {
|
||||
// Handle generic exceptions
|
||||
Map<String, String> responseObj = new HashMap<>();
|
||||
responseObj.put("error", e.getMessage());
|
||||
builder = Response.status(Response.Status.BAD_REQUEST).entity(responseObj);
|
||||
}
|
||||
|
||||
return builder.build();
|
||||
}
|
||||
|
||||
/**
|
||||
* <p>
|
||||
* Validates the given Member variable and throws validation exceptions based on the type of error. If the error is standard
|
||||
* bean validation errors then it will throw a ConstraintValidationException with the set of the constraints violated.
|
||||
* </p>
|
||||
* <p>
|
||||
* If the error is caused because an existing member with the same email is registered it throws a regular validation
|
||||
* exception so that it can be interpreted separately.
|
||||
* </p>
|
||||
*
|
||||
* @param member Member to be validated
|
||||
* @throws ConstraintViolationException If Bean Validation errors exist
|
||||
* @throws ValidationException If member with the same email already exists
|
||||
*/
|
||||
private void validateMember(Member member) throws ConstraintViolationException, ValidationException {
|
||||
// Create a bean validator and check for issues.
|
||||
Set<ConstraintViolation<Member>> violations = validator.validate(member);
|
||||
|
||||
if (!violations.isEmpty()) {
|
||||
throw new ConstraintViolationException(new HashSet<ConstraintViolation<?>>(violations));
|
||||
}
|
||||
|
||||
// Check the uniqueness of the email address
|
||||
if (emailAlreadyExists(member.getEmail())) {
|
||||
throw new ValidationException("Unique Email Violation");
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Creates a JAX-RS "Bad Request" response including a map of all violation fields, and their message. This can then be used
|
||||
* by clients to show violations.
|
||||
*
|
||||
* @param violations A set of violations that needs to be reported
|
||||
* @return JAX-RS response containing all violations
|
||||
*/
|
||||
private Response.ResponseBuilder createViolationResponse(Set<ConstraintViolation<?>> violations) {
|
||||
log.fine("Validation completed. violations found: " + violations.size());
|
||||
|
||||
Map<String, String> responseObj = new HashMap<>();
|
||||
|
||||
for (ConstraintViolation<?> violation : violations) {
|
||||
responseObj.put(violation.getPropertyPath().toString(), violation.getMessage());
|
||||
}
|
||||
|
||||
return Response.status(Response.Status.BAD_REQUEST).entity(responseObj);
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if a member with the same email address is already registered. This is the only way to easily capture the
|
||||
* "@UniqueConstraint(columnNames = "email")" constraint from the Member class.
|
||||
*
|
||||
* @param email The email to check
|
||||
* @return True if the email already exists, and false otherwise
|
||||
*/
|
||||
public boolean emailAlreadyExists(String email) {
|
||||
Member member = null;
|
||||
try {
|
||||
member = repository.findByEmail(email);
|
||||
} catch (NoResultException e) {
|
||||
// ignore
|
||||
}
|
||||
return member != null;
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,85 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.service;
|
||||
|
||||
import baeldung.data.MemberRepository;
|
||||
import baeldung.data.SecondaryPersistenceUnit;
|
||||
import baeldung.model.Member;
|
||||
import baeldung.model.QMember;
|
||||
|
||||
import javax.ejb.Stateless;
|
||||
import javax.enterprise.event.Event;
|
||||
import javax.enterprise.inject.Default;
|
||||
import javax.inject.Inject;
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.NoResultException;
|
||||
import javax.validation.ConstraintViolation;
|
||||
import javax.validation.ConstraintViolationException;
|
||||
import javax.validation.ValidationException;
|
||||
import javax.validation.Validator;
|
||||
import java.util.HashSet;
|
||||
import java.util.Set;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
@Stateless
|
||||
public class MemberRegistration {
|
||||
|
||||
@Inject
|
||||
private Logger log;
|
||||
|
||||
@Inject
|
||||
private MemberRepository repository;
|
||||
|
||||
@Inject
|
||||
private Event<Member> memberEventSrc;
|
||||
|
||||
@Inject
|
||||
private Validator validator;
|
||||
|
||||
private void validateMember(Member member) throws ConstraintViolationException, ValidationException {
|
||||
// Create a bean validator and check for issues.
|
||||
Set<ConstraintViolation<Member>> violations = validator.validate(member);
|
||||
|
||||
if (!violations.isEmpty()) {
|
||||
throw new ConstraintViolationException(new HashSet<ConstraintViolation<?>>(violations));
|
||||
}
|
||||
|
||||
// Check the uniqueness of the email address
|
||||
if (emailAlreadyExists(member.getEmail())) {
|
||||
throw new ValidationException("Unique Email Violation");
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
public void register(Member member) throws Exception {
|
||||
log.info("Registering " + member.getName());
|
||||
validateMember(member);
|
||||
repository.save(member);
|
||||
memberEventSrc.fire(member);
|
||||
}
|
||||
|
||||
public boolean emailAlreadyExists(String email) {
|
||||
Member member = null;
|
||||
try {
|
||||
member = repository.findByEmail(email);
|
||||
} catch (NoResultException e) {
|
||||
// ignore
|
||||
}
|
||||
return member != null;
|
||||
}
|
||||
|
||||
}
|
||||
@@ -0,0 +1,53 @@
|
||||
/*
|
||||
* JBoss, Home of Professional Open Source
|
||||
* Copyright 2013, Red Hat, Inc. and/or its affiliates, and individual
|
||||
* contributors by the @authors tag. See the copyright.txt in the
|
||||
* distribution for a full listing of individual contributors.
|
||||
*
|
||||
* Licensed under the Apache License, Version 2.0 (the "License");
|
||||
* you may not use this file except in compliance with the License.
|
||||
* You may obtain a copy of the License at
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* Unless required by applicable law or agreed to in writing, software
|
||||
* distributed under the License is distributed on an "AS IS" BASIS,
|
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||
* See the License for the specific language governing permissions and
|
||||
* limitations under the License.
|
||||
*/
|
||||
package baeldung.util;
|
||||
|
||||
import java.util.logging.Logger;
|
||||
|
||||
import javax.enterprise.context.RequestScoped;
|
||||
import javax.enterprise.inject.Produces;
|
||||
import javax.enterprise.inject.spi.InjectionPoint;
|
||||
import javax.faces.context.FacesContext;
|
||||
import javax.persistence.EntityManager;
|
||||
import javax.persistence.PersistenceContext;
|
||||
|
||||
/**
|
||||
* This class uses CDI to alias Java EE resources, such as the persistence context, to CDI beans
|
||||
*
|
||||
* <p>
|
||||
* Example injection on a managed bean field:
|
||||
* </p>
|
||||
*
|
||||
* <pre>
|
||||
* @Inject
|
||||
* private EntityManager em;
|
||||
* </pre>
|
||||
*/
|
||||
public class Resources {
|
||||
|
||||
@Produces
|
||||
public Logger produceLog(InjectionPoint injectionPoint) {
|
||||
return Logger.getLogger(injectionPoint.getMember().getDeclaringClass().getName());
|
||||
}
|
||||
|
||||
@Produces
|
||||
@RequestScoped
|
||||
public FacesContext produceFacesContext() {
|
||||
return FacesContext.getCurrentInstance();
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user