Ищете помощь в Nested groupBy с scalikejdbc? - PullRequest
0 голосов
/ 08 марта 2019

Я использую Scala 2.12 и мне нужны библиотеки, загруженные через build.sbt.

У меня есть вывод БД в следующем формате.enter image description here

По сути, это похоже на дату оценки и книгу, может быть несколько валютных данных.

У меня есть группировка по книге (в основном), котораябудет иметь список данных Pnl на основе валюты.

Просто грубое представление:

{ Bookid: 1234,
  BookName: EQUITY,
  PnlBreakdown: [currency: cad, actual_pnl_local: 100, actual_pnl_cde: 100], [currency: usd, actual_pnl_local: 100, actual_pnl_cde: 130]
}

В основном.Ключ будет book, а value - список данных pnl.

У меня есть класс case, определенный следующим образом:

case class PnlData(valuation_date: Option[String], currency: Option[String],pnl_status: Option[String],actual_pnl_local: Option[String] ,actual_pnl_cde: Option[String], actual_pnl_local_me_adj: Option[String] ,actual_pnl_cde_me_adj: Option[String] ) {
  override def toString():String= {
    s"valuation_date=$valuation_date,currency=$currency,pnl_status=$pnl_status,actual_pnl_local=$actual_pnl_local,actual_pnl_cde=$actual_pnl_cde,actual_pnl_local_me_adj=$actual_pnl_local_me_adj,actual_pnl_cde_me_adj=$actual_pnl_cde_me_adj"
  }
}

case class BookLevelDaily(book_id: Option[String], book: Option[String], pnlBreakdown: List[SaPnlData]){
  override def toString():String= {
    s"book_id=$book_id,book=$book,pnl=$pnlBreakdown"
  }
}

По сути, мой последний объект имеет тип BookLevelDaily.

Как преобразовать вывод БД (см. Выше) в мой объект BookLevelDaily?

Я могу преобразовать весь результат в список, но как мне сделать groupBy?

val list: List[BookLevelDaily] =
      sql"""
           |SELECT QUERY TO GET ABOVE RESULTSET
        """.stripMargin.map(rs =>
        BookLevelDaily(
          valuation_date = rs.stringOpt("valuation_date"),
          book_id = rs.stringOpt("book_id"),
          book =  rs.stringOpt("book"),
          currency=  rs.stringOpt("currency"),
          pnl_status=  rs.stringOpt("pnl_status"),
          actual_pnl_local=  rs.stringOpt("actual_pnl_local"),
          actual_pnl_cde=  rs.stringOpt("actual_pnl_cde"),
          actual_pnl_local_me_adj= rs.stringOpt("actual_pnl_local_me_adj"),
          actual_pnl_cde_me_adj= rs.stringOpt("actual_pnl_cde_me_adj")
        )
      ).list().apply()

Во-первых, выше не относится к типу BookLevelDaily.Итак, как выполнить итерацию или группирование, чтобы разделить данные уровня Pnl и отобразить их в ключ (книга).

1 Ответ

0 голосов
/ 09 марта 2019

Если я правильно понимаю, это, кажется, отношение один ко многим (один: book_level_daily, many: pnl_breakdown).Если это так, проверьте следующую документацию.

http://scalikejdbc.org/documentation/one-to-x.html

...