Как вставить данные из базы данных с помощью веб-службы в java с помощью JAX-RS

Ответ 1

Ниже приведен пример службы JAX-RS, реализованной в виде сессионного компонента с использованием JPA для сохранения и JAXB для обмена сообщениями.

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();
    }

}

Customer

клиентовНиже приведен пример одного из объектов. Он содержит аннотации JPA и 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;

}

Для получения дополнительной информации

• Часть 1. Модель данных
• Часть 2 - JPA
• Часть 3 - JAXB (с использованием MOXy)
• Часть 4. Служба RESTful (с использованием сессионного компонента EJB)
• Часть 5. Клиент

UPDATE

какие банки нужны

Вы можете развернуть приложение JAX-RS/EJB/JPA/JAXB на любом совместимом с Java EE 6 сервере приложений, не требуя дополнительной настройки сервера. Программируя клиента, вы можете получить API-интерфейсы JAX-RS из Джерси (http://jersey.java.net/), а API-интерфейсы JPA и JAXB - из EclipseLink (http://www.eclipse.org/eclipselink/).

и где написано соединение с базой данных

JDBC Resource & Пул подключений

Вам необходимо настроить пул соединений на вашем сервере приложений. Ниже приведены шаги, чтобы сделать это на GlassFish. Действия могут отличаться в зависимости от сервера приложений, который вы используете.

1. Скопируйте драйвер JDBC (ojdbc14.jar) в /glashfish/lib
2. Запустите консоль администрирования
3. Создайте пул соединений:
   1. Имя = CustomerService
   2. Тип ресурса = 'javax.sql.ConnectionPoolDataSource'
   3. Поставщик базы данных = Oracle (или любой другой поставщик базы данных, подходящий для вашей базы данных)
   4. Нажмите Далее и заполните следующие "Дополнительные свойства":
   5. Пользователь (например, CustomerService)
   6. Пароль (например, пароль)
   7. URL (например, jdbc: oracle: thin: @localhost: 1521: XE)
   8. Используйте кнопку "Пинг", чтобы проверить соединение с базой данных
4. Создайте ресурс JDBC с именем "CustomerService"
   1. Имя JNDI = CustomerService
   2. Имя пула = CustomerService (имя пула соединений, созданного на предыдущем шаге)

Конфигурация JPA

Затем мы ссылаемся на соединение с базой данных, которое мы создали выше, в файле persistence.xml для наших объектов JPA следующим образом:

<?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>

Ответ 2

Посмотрите на ссылку , есть видеоурок, который объясняет, как это можно сделать.

Таким образом, видео объясняет, как веб-служба получает некоторое значение, чтобы сообщить клиенту, что данные учетные данные совпадают с некоторыми данными в базе данных.

Вот как выглядит метод, который обрабатывает клиентский запрос:

@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();
    }

Этот веб-сервис передает учетные данные бизнес-уровню, где EJB будет выполнять операцию выбора в базе данных:

@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 полагается в классе службы, который будет выполнять задачу взаимодействия с базой данных

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;
    }
}

Наконец, чтобы иметь возможность взаимодействовать с БД, данные должны быть представлены как сущность JPA. Также, чтобы иметь возможность маршалировать выбранную строку обратно клиенту, как любой желаемый тип MediaType, сущность должна содержать некоторые аннотации 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;
    }
}

Вот пример клиентского кода, чтобы вы могли увидеть один из способов вызова веб-сервиса:

<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>

Надеюсь, это поможет вам дать представление.

Чтобы вставить данные, процесс почти такой же, просто используйте метод persist() вместо find() из диспетчера сущностей.

Ответ 3

В этом руководстве объясняется, как создавать веб-службы RESTful на Java с помощью JAX-RS эталонной реализации Jersey.

Вы также можете найти серию учебных руководств JAX-RS от "Hello World" до более сложных примеров здесь.