Jak wstawić dane z bazy danych za pomocą usługi Web w Javie za pomocą JAX-RS
Jestem nowy w usługach internetowych. Proszę o sugestie jak wstawiać i pobierać dane z bazy danych za pomocą jersey JAX-RS w Javie?
2 answers
Poniżej znajduje się przykład usługi JAX-RS zaimplementowanej jako fasola sesji przy użyciu JPA dla trwałości i JAXB dla wiadomości może wyglądać.
CustomerService
package org.example;
import java.util.List;
import javax.ejb.*;
import javax.persistence.*;
import javax.ws.rs.*;
import javax.ws.rs.core.MediaType;
@Stateless
@LocalBean
@Path("/customers")
public class CustomerService {
@PersistenceContext(unitName="CustomerService",
type=PersistenceContextType.TRANSACTION)
EntityManager entityManager;
@POST
@Consumes(MediaType.APPLICATION_XML)
public void create(Customer customer) {
entityManager.persist(customer);
}
@GET
@Produces(MediaType.APPLICATION_XML)
@Path("{id}")
public Customer read(@PathParam("id") long id) {
return entityManager.find(Customer.class, id);
}
@PUT
@Consumes(MediaType.APPLICATION_XML)
public void update(Customer customer) {
entityManager.merge(customer);
}
@DELETE
@Path("{id}")
public void delete(@PathParam("id") long id) {
Customer customer = read(id);
if(null != customer) {
entityManager.remove(customer);
}
}
@GET
@Produces(MediaType.APPLICATION_XML)
@Path("findCustomersByCity/{city}")
public List<Customer> findCustomersByCity(@PathParam("city") String city) {
Query query = entityManager.createNamedQuery("findCustomersByCity");
query.setParameter("city", city);
return query.getResultList();
}
}
Klient
Poniżej znajduje się przykład jednego z Bytów. Zawiera zarówno adnotacje JPA, jak i JAXB.
package org.example;
import java.io.Serializable;
import javax.persistence.*;
import javax.xml.bind.annotation.XmlRootElement;
import java.util.Set;
@Entity
@NamedQuery(name = "findCustomersByCity",
query = "SELECT c " +
"FROM Customer c " +
"WHERE c.address.city = :city")
@XmlRootElement
public class Customer implements Serializable {
private static final long serialVersionUID = 1L;
@Id
private long id;
@Column(name="FIRST_NAME")
private String firstName;
@Column(name="LAST_NAME")
private String lastName;
@OneToOne(mappedBy="customer", cascade={CascadeType.ALL})
private Address address;
@OneToMany(mappedBy="customer", cascade={CascadeType.ALL})
private Set<PhoneNumber> phoneNumbers;
}
Więcej Informacji
- Część 1-Model Danych
- część 2 - JPA
- Część 3-JAXB (za pomocą MOXy)
- Część 4-usługa RESTful (korzystanie z sesji EJB)
- Część 5-Klient
UPDATE
Jakie są wymagane słoiki
Możesz wdrożyć aplikację JAX-RS / EJB / JPA / JAXB na dowolnym serwerze aplikacji zgodnym z Java EE 6 bez konieczności dodatkowej konfiguracji serwera. Programowanie klienta można uzyskać API JAX-RS z Jersey (http://jersey.java.net w przeciwieństwie do innych modeli, nie jest to możliwe. http://www.eclipse.org/eclipselink/).
I gdzie zapisywane są połączenia z bazą danych
JDBC Resource & Connection Pool
Musisz skonfigurować pulę połączeń na serwerze aplikacji. Poniżej znajdują się kroki, aby to zrobić na GlassFish. Kroki te będą się różnić w zależności od używanego serwera aplikacji.
- skopiuj JDBC kierowca (ojdbc14.jar) to / glashfish / lib
- uruchom konsolę administracyjną
- tworzenie puli połączeń:
- Name = CustomerService
- Resource Type = ' javax.sql.ConnectionPoolDataSource ' Oracle (lub jakikolwiek inny dostawca baz danych jest odpowiedni dla twojej bazy danych)]}
- kliknij Dalej i wypełnij następujące "dodatkowe właściwości":
- Użytkownik (np. CustomerService)
- hasło (np. hasło)
- URL (np. jdbc:oracle:thin:@localhost:1521:XE)
- użyj przycisku "Ping", aby przetestować połączenie z bazą danych
- Utwórz zasób JDBC o nazwie " CustomerService"
- JNDI Name = CustomerService Pool Name = CustomerService (Nazwa puli połączeń utworzonej w poprzednim kroku)
Konfiguracja JPA
Następnie odwołujemy się do połączenia z bazą danych, które stworzyliśmy powyżej w pliku persistence.xml
dla naszych jednostek JPA jako następuje:
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="1.0"
xmlns="http://java.sun.com/xml/ns/persistence"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd">
<persistence-unit name="CustomerService" transaction-type="JTA">
<provider>org.eclipse.persistence.jpa.PersistenceProvider</provider>
<jta-data-source>CustomerService</jta-data-source>
<class>org.example.Customer</class>
<class>org.example.Address</class>
<class>org.example.PhoneNumber</class>
<properties>
<property name="eclipselink.target-database" value="Oracle" />
<property name="eclipselink.logging.level" value="FINEST" />
<property name="eclipselink.logging.level.ejb_or_metadata" value="WARNING" />
<property name="eclipselink.logging.timestamp" value="false"/>
<property name="eclipselink.logging.thread" value="false"/>
<property name="eclipselink.logging.session" value="false"/>
<property name="eclipselink.logging.exceptions" value="false"/>
<property name="eclipselink.target-server" value="SunAS9"/>
</properties>
</persistence-unit>
</persistence>
Warning: date(): Invalid date.timezone value 'Europe/Kyiv', we selected the timezone 'UTC' for now. in /var/www/agent_stack/data/www/doraprojects.net/template/agent.layouts/content.php on line 54
2012-04-09 10:44:23
Spójrz na ten link , jest tutorial wideo, który wyjaśnia jeden sposób, w jaki można to zrobić.
Wideo wyjaśnia, w jaki sposób usługa internetowa pobiera pewną wartość, aby powiedzieć klientowi, że dane poświadczenia pasują do niektórych danych w bazie danych.
Tak wygląda metoda obsługująca żądanie klienta:
@POST
@Produces(MediaType.TEXT_PLAIN)
@Path("/login")
public Response login(@FormParam("email") String email, @FormParam("password") String password) {
Response.ResponseBuilder responseBuilder = null;
boolean result = entityFacade.doLogin(email, password);
if (result) {
responseBuilder = Response.ok("Success");//Login good!
}
else {
responseBuilder = Response.ok("Wrong credentials!");//Login bad!
}
return responseBuilder.build();
}
Ta usługa internetowa przenosi poświadczenia do warstwy biznesowej, w której EJB wykona operację select w bazie danych:
@Stateless
public class EntityFacade implements EntityFacadeLocal {
@Resource
private UserTransaction ut;
private CredentialJpaController controller;
@PostConstruct
public void init() {
controller = new CredentialJpaController(ut, Persistence.createEntityManagerFactory("ROLEProject-ejbPU"));
}
public boolean doLogin(String email, String password){
return controller.loginWithParameters(email,password);
}
}
EJB polega na klasie usług, która wykona zadanie interakcji z bazą danych
public class CredentialJpaController implements Serializable {
public CredentialJpaController(UserTransaction utx, EntityManagerFactory emf) {
this.utx = utx;
this.emf = emf;
}
private UserTransaction utx = null;
private EntityManagerFactory emf = null;
public EntityManager getEntityManager() {
return emf.createEntityManager();
}
public boolean loginWithParameters(String email, String password) {
boolean result = false;
EntityManager em = getEntityManager();
Long l = (Long) em.createNamedQuery("loginquery").setParameter("emailParam", email).setParameter("passwordParam", password).getSingleResult();
if (l == 1) {
result = true;
}
return result;
}
}
Wreszcie, aby móc współdziałać z DB, dane muszą być reprezentowane jako jednostka JPA. Aby również móc przekierować wybrany wiersz z powrotem do Klienta, niezależnie od tego, jaki jest pożądany MediaType, encja musi zawierać pewne adnotacje JaxB:
@XmlRootElement
@Entity
@Table(name = "CREDENTIALS")
@NamedQuery(name="loginquery", query="SELECT COUNT(c) FROM Credential c WHERE c.email = :emailParam AND c.password = :passwordParam")
public class Credential implements Serializable {
@Id
private String email;
@Column(nullable = false)
private String password;
@XmlElement
public String getEmail() {
return email;
}
public void setEmail(String email) {
this.email = email;
}
@XmlElement
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
}
Oto przykładowy kod klienta, abyś mógł zobaczyć jeden ze sposobów, w jaki web-service może być wywołany:
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<title>TODO supply a title</title>
</head>
<body>
<div>TODO write content</div>
<form action="http://localhost:8080/ROLEProject-war/role/login" method="POST">
Email <input name="email"/>
Password <input type="password" name="password"/>
<input type="submit"/>
</form>
</body>
</html>
Mam nadzieję, że to pomoże Ci podpowiedzieć.
Aby wstawić dane Proces jest prawie taki sam, po prostu użyj metody persist() zamiast find() z menedżera encji.
Warning: date(): Invalid date.timezone value 'Europe/Kyiv', we selected the timezone 'UTC' for now. in /var/www/agent_stack/data/www/doraprojects.net/template/agent.layouts/content.php on line 54
2012-04-09 08:56:20