I'm trying to build simple REST for purchases I need 2 methods. Firstone should show all purchases sorted by date Secondone removes all purchases for specified date I made a method to add and to get all pu,java,hibernate,jpa"/>

时间戳

首页 > 解决方案 > 如何查找列表 sorted by Date

I'm trying to build simple REST for purchases I need 2 methods. Firstone should show all purchases sorted by date Secondone removes all purchases for specified date I made a method to add and to get all pu

java - 如何查找列表 sorted by Date

I'm trying to build simple REST for purchases I need 2 methods. Firstone should show all purchases sorted by date Secondone removes all purchases for specified date I made a method to add and to get all pu

问题描述

I'm trying to build simple REST for purchases I need 2 methods. Firstone should show all purchases sorted by date Secondone removes all purchases for specified date I made a method to add and to get all purchases. Now i'm stucked.

@Entity
@Table (name="purchase")
public class Purchase {

@Id
@Column(name = "id")
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Long id;

 @Column(name = "name")
 private String name;

 @CreationTimestamp
 @Temporal(TemporalType.DATE)
 @Column(name="createat")
    private Date created;

 @Column(name="price")
 private BigDecimal price;


@Column(name="currency")
private String currency;
@Repository
public interface PurchaseRepository extends JpaRepository<Purchase, Long> {
}

@Service
public class PurchaseService {

    @Autowired
    private PurchaseRepository purchaseRepository;

    public void addPurchase(Purchase purchase) {
        purchaseRepository.save(purchase);
    }

    public List<Purchase> getAllPurchase() {

        List<Purchase> purchase = new ArrayList<>();
        purchaseRepository.findAll().forEach(purchase::add);
        return purchase;
    }
}

@RestController
public class PurchaseController {

    @Autowired
    private PurchaseService purchaseService;

    @PostMapping("/purchase")
    public void addPurchase(@RequestBody Purchase purchase) {
        purchaseService.addPurchase(purchase);
    }

    @RequestMapping("/purchase")
    public List<Purchase> getAllTopics() {
        return purchaseService.getAllPurchase();
    }
}

Can't find the solution and implementation for: I expect 1 method to sort my List sorted by date 2 method that removes all purchases for specified date

Arwin solution works well, but only in an environment where one request is send at the time.

In order to get this to work save the refreshToken method into an Observable with the pipe share. This will allow multiple subscribers but a single result.

Wrap the next.handle(request) method in another Subject<any> and return the subject. If the request fires an error call that isn't a 401 error call subject.error.

After refreshing the token call this.updateTokenAndRetry(request, next, currentUser, token).subscribe(result => subject.next(result); to make sure that the request is returned to the initial subscriber.

Below code is pseudo code and should work in your case.

refreshTokenObservable: Observable<any>;

intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {

    let subject = new Subject<any>();

    next.handle(request).pipe(
        catchError(err => {
            if (err.status === 401) {
                let user = localStorage.getItem('currentUser');
                if (!user) {
                    this.logout(false);
                    subject.error(err.error);
                    return;
                }
                let currentUser = JSON.parse(user);
                if (!currentUser || !currentUser.stsTokenManager || !currentUser.stsTokenManager.accessToken) {
                    this.logout(false);
                    subject.error(err.error);
                    return;
                }
                // Return a newly created function here
                this.refreshToken(currentUser).subscribe(token => {

                    this.updateTokenAndRetry(request, next, currentUser, token).subscribe(result => subject.next(result);
                    this.refreshTokenObservable = null; // clear observable for next failed login attempt
                });
            }
            this.alertService.showAlert({
                text: 'Fout tijdens het verzenden van het verzoek',
            });
            subject.error(err.error);
        })
    ).subscribe(result => subject.next(result));

    return subject.asObservable();
}

refreshToken(currentUser: any) {

    if(this.refreshTokenObservable == null)
    {
        // By making use of the from operator of RxJS convert the promise to an observable
        this.refreshTokenObservable = from(this.authService.getToken(currentUser, true)).pipe(share());
    }

    return this.refreshTokenObservable;
}

updateTokenAndRetry(request: HttpRequest<any>, next: HttpHandler, currentUser: any, token: string): Observable<HttpEvent<any>> {
    // Update local stored user
    currentUser.stsTokenManager.accessToken = token;
    localStorage.setItem('currentUser', JSON.stringify(currentUser));

    // Add the new token to the request
    request = request.clone({
        setHeaders: {
            Authorization: token,
        },
    });

    return next.handle(request);
}

标签： javahibernatejpa

解决方案

假设您使用 Spring 作为注释显示，还假设您使用 SpringData 作为数据库通信的抽象层。您不应该扩展 JPARepository，而是应该扩展 CrudRepository。在那里，您可以通过特殊的命名约定或 HQL 来定义查询。

例如：

@Repository
public interface PurchaseRepository extends CrudRepository<Purchase, Long> {
    List<Purchase> findAllOrderByDate();

    long deleteByDate(Date date);
}

deleteByDate 函数将返回已删除行的计数。

如您所见，您可以按名称定义查询。有关这方面的更多信息：https ://docs.spring.io/spring-data/data-commons/docs/2.1.8.RELEASE/reference/html/

更新：实现只是一个例子，你不能复制和粘贴它并按原样使用它。正如在提到的文档中解释的那样，您可以通过特殊的命名约定定义查询，该约定允许您使用实体中的属性名称以语义方式定义查询。在您的情况下，这将findAllOrderByCreatedAsc或findAllOrderByCreatedDesc同样适用于删除。

推荐阅读