Spring Cloud 自定義SQL / DML查詢方法

上面的List<Trade> fetchByActionNamedQuery(String action)示例與Spring Data查詢創(chuàng)建命名約定不匹配，因此我們必須將參數(shù)化的Spanner SQL查詢映射到它。

可以通過以下兩種方式之一將方法的SQL查詢映射到存儲庫方法：

SQL的標(biāo)記名稱與方法參數(shù)的@Param帶注釋的名稱相對應(yīng)。

自定義SQL查詢方法可以接受單個Sort或Pageable參數(shù)，該參數(shù)將應(yīng)用于SQL中的任何排序或分頁：

	@Query("SELECT * FROM trades ORDER BY action DESC")
	List<Trade> sortedTrades(Pageable pageable);

	@Query("SELECT * FROM trades ORDER BY action DESC LIMIT 1")
 	Trade sortedTopTrade(Pageable pageable);

可以使用：

	List<Trade> customSortedTrades = tradeRepository.sortedTrades(PageRequest
  				.of(2, 2, org.springframework.data.domain.Sort.by(Order.asc("id"))));

結(jié)果將按“ id”以升序排序。

您的查詢方法還可以返回非實(shí)體類型：

  	@Query("SELECT COUNT(1) FROM trades WHERE action = @action")
  	int countByActionQuery(String action);

  	@Query("SELECT EXISTS(SELECT COUNT(1) FROM trades WHERE action = @action)")
  	boolean existsByActionQuery(String action);

  	@Query("SELECT action FROM trades WHERE action = @action LIMIT 1")
  	String getFirstString(@Param("action") String action);

  	@Query("SELECT action FROM trades WHERE action = @action")
  	List<String> getFirstStringList(@Param("action") String action);

DML語句也可以通過查詢方法執(zhí)行，但是唯一可能的返回值是long，代表受影響的行數(shù)。必須在@Query上設(shè)置dmlStatement布爾設(shè)置，以指示查詢方法是作為DML語句執(zhí)行的。

  	@Query(value = "DELETE FROM trades WHERE action = @action", dmlStatement = true)
  	long deleteByActionQuery(String action);

Trade.fetchByActionNamedQuery=SELECT * FROM trades WHERE trades.action = @tag0

public interface TradeRepository extends SpannerRepository<Trade, String[]> {
	// This method uses the query from the properties file instead of one generated based on name.
	List<Trade> fetchByActionNamedQuery(@Param("tag0") String action);
}

public interface TradeRepository extends SpannerRepository<Trade, String[]> {
    @Query("SELECT * FROM trades WHERE trades.action = @tag0")
    List<Trade> fetchByActionNamedQuery(@Param("tag0") String action);
}

@Query("SELECT * FROM :com.example.Trade: WHERE trades.action = @tag0")
List<Trade> fetchByActionNamedQuery(String action);

@Query("SELECT * FROM :com.example.Trade: WHERE trades.action = @tag0
  AND price > #{#priceRadius * -1} AND price < #{#priceRadius * 2}")
List<Trade> fetchByActionNamedQuery(String action, Double priceRadius);