Телеграмм чат группы scala

2021 September 15

VK

Vladyslav Kopaniev in Scala User Group

Да? Я слыхал некоторые даж на 2.11 сидят до сих пор

источник

09:56пожаловаться #1

ΛВ

Λнтон Войцишевский... in Scala User Group

ну тикет закрыли с апдейтом самого спарка

источник

09:56пожаловаться #2

LB

Let Eat Bee in Scala User Group

Как в doobie скомпозить ConnectionIO[Unit] и Stream[ConnectionIO, K] ? хочу повоторить запрос при TRANSACTION_ROLLBACK, а но не могу понять как типы выровнять

https://scastie.scala-lang.org/i7DN8cRtQb2AGJDksUCrZA

scastie.scala-lang.org

Scastie - An interactive playground for Scala.

import doobie._
import doobie.implicits._
import cats.implicits._
import doobie.postgres.sqlstate.class40

// Works for simple ConnectionIO
def insertManyWithRetry[P: Write](
q: doobie.Update[P],
elems: List[P]
): ConnectionIO[Int] = {
q.updateMany(elems)
.exceptSomeSqlState({
case class40.TRANSACTION_ROLLBACK |
class40.TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION |
class40.SERIALIZATION_FAILURE |
class40.STATEMENT_COMPLETION_UNKNOWN | class40.DEADLOCK_DETECTED => {
HC.rollback *> insertManyWithRetry(q, elems)
}
})
}

// Doesn't compile :(
def insertManyReturningWithRetry[K: Read, P: Write](q: Update[P], elems: List[P], columns: Seq[String]): fs2.Stream[ConnectionIO, K] = {
q.updateManyWithGeneratedKeys(columns: _*)(elems).exceptSomeSqlState({
case class40.TRANSACTION_ROLLBACK |
class40.TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION |
class40.SERIALIZATION_FAILURE |
class40.STATEMENT_COMPLETION_UNKNOWN |
…

источник

11:42пожаловаться #3

ЮБ

Юрий Бадальянц... in Scala User Group

https://scastie.scala-lang.org/YDpCLe2oQE6LyBD0YCStGQ

scastie.scala-lang.org

Scastie - An interactive playground for Scala.

import doobie._
import doobie.implicits._
import cats.implicits._
import doobie.postgres.sqlstate.class40

// Works for simple ConnectionIO
def insertManyWithRetry[P: Write](
q: doobie.Update[P],
elems: List[P]
): ConnectionIO[Int] = {
q.updateMany(elems)
.exceptSomeSqlState({
case class40.TRANSACTION_ROLLBACK |
class40.TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION |
class40.SERIALIZATION_FAILURE |
class40.STATEMENT_COMPLETION_UNKNOWN | class40.DEADLOCK_DETECTED => {
HC.rollback *> insertManyWithRetry(q, elems)
}
})
}

// Doesn't compile :(
def insertManyReturningWithRetry[K: Read, P: Write](q: Update[P], elems: List[P], columns: Seq[String]): fs2.Stream[ConnectionIO, K] = {
q.updateManyWithGeneratedKeys(columns: _*)(elems).exceptSomeSqlState({
case class40.TRANSACTION_ROLLBACK |
class40.TRANSACTION_INTEGRITY_CONSTRAINT_VIOLATION |
class40.SERIALIZATION_FAILURE |
class40.STATEMENT_COMPLETION_UNKNOWN |
…

источник

11:45пожаловаться #4

LB

Let Eat Bee in Scala User Group

Спасибо. Я правильно понимаю, что это работает так:

Stream.eval(x: ConnectionIO[Unit]) создает Stream с одним элементом типа Unit

Затем >> это как flatMap, но который игнорирует этот елемент и возвращает Stream который передали аргументом в >>

источник

11:55пожаловаться #5

NV

Nikita Vilunov in Scala User Group

Есть проекты кроме спарка на 2.12

источник

11:56пожаловаться #6

VK

Vladyslav Kopaniev in Scala User Group

тру

источник

11:57пожаловаться #7

ЮБ

Юрий Бадальянц... in Scala User Group

Всё так

источник

11:59пожаловаться #8

ΛВ

Λнтон Войцишевский... in Scala User Group

Есть Вообще такОе, да

источник

12:00пожаловаться #9

LB

Let Eat Bee in Scala User Group

Как это работает? откуда Stream.eval знает, что делать с ConnectionIO? Тип eval:

  def eval[F[_], O](fo: F[O]): Stream[F, O]

т.е. любой тип с аргументом . Как он не зная конкретного типа сумел из ConnectionIO[T] достать T?

источник

12:40пожаловаться #10

ЮБ

Юрий Бадальянц... in Scala User Group

Это работает не так. Он ничего ниоткуда не достёт

источник

13:00пожаловаться #11

ЮБ

Юрий Бадальянц... in Scala User Group

Стрим — это описание такой штуки, которая при запуске может выплюнуть 0,1 или более элементов указанного типа. Причём "запуск" — это и есть тип F

источник

13:01пожаловаться #12

ЮБ

Юрий Бадальянц... in Scala User Group

То есть элементы достаются не в момент Stream.eval, а в момент запуска ConnectionIO, который в итоге получился

источник

13:02пожаловаться #13

ЮБ

Юрий Бадальянц... in Scala User Group

Если быть точнее, даже не ConnectionIO, а эффекта, который фактически запускается

источник

13:02пожаловаться #14

ЮБ

Юрий Бадальянц... in Scala User Group

Там короче несколько слоёв интерпретации происходит. В двух словах не расскажешь

источник

13:02пожаловаться #15

ЮБ

Юрий Бадальянц... in Scala User Group

Рекомендую почитать статьи про то, как работает IO монада

источник

13:03пожаловаться #16

ЮБ

Юрий Бадальянц... in Scala User Group

может понятнее станет

источник

13:03пожаловаться #17

Oℕ

Oleg ℕizhnik in Scala User Group

можно просто посмотреть, как определена фримонада

источник

13:13пожаловаться #18

AD

Apache DOG™ in Scala User Group

sttp под 11 жавой работать будет?

источник

13:59пожаловаться #19

ΛВ

Λнтон Войцишевский... in Scala User Group

sticker.webp

(51.47 Кб)

источник

14:06пожаловаться #20