Я работаю над проектом на Scala и doobie . Я пытаюсь реализовать трейт транзактора, который может быть введен MacWire и использован с другой задачей / будущим монады (например, для тестов). import doobie.imports import doobie.imports._ import...

У меня есть ConnectionIO[Option[Int]] и сопоставление с Option для создания ConnectionIO[Option[String]] с запросом Some[Int] , в противном случае сохраните Nones. I was able to do this with a for comprehension and a match`: def...

Для улья есть драйвер jdbc, но, похоже, он не работает полностью. Я использовал doobie Transactor по умолчанию, чтобы подключиться к нему, как val xa = Transactor.fromDriverManager[IO]( "org.apache.hive.jdbc.HiveDriver", url, username, pass )...

Я пытаюсь неявно добавить Async и Sync в свой код для репозитория doobie. Sync и Async[F] отлично работают с вводом-выводом. Я хочу преобразовать их в будущее и столкнуться с проблемой Я попытался создать свой собственный Aync из IO def...

У меня вопрос: val sql = """select id, clientName from partnerClients where partnerName = ? """ Я читаю имя партнера из файла Excel...

Я пытаюсь настроить трассировку XRAY для базы данных postgres. Я продолжаю получать сообщение об ошибке "Сегмент не найден". Я следую инструкциям в этой ссылке https://docs.aws.amazon.com/xray/latest/devguide/scorekeep-workerthreads.html def...

Я хотел бы запустить два эффекта f1 и f2, обновляя две разные таблицы базы данных t1 и t2, оставаясь в общем контексте F. def update(model:Details): Update0 = sql"""Update details_compta set TRANSID=${model.transid}, ACCOUNT=${model.account},...

Я попытался создать нижеприведенное неявное, чтобы я мог ПОЛУЧАТЬ / читать данные из базы данных postgreSQL. Я пробовал добавить рекомендуемые имплициты, но они стали серыми и кажутся неиспользованными. implicit val get: Get[JobPostDetails] =...

Я использую Doobie в приложении ZIO, и иногда возникают взаимоблокировки (полное зависание приложения). Это может произойти, если я запускаю свое приложение только на одном ядре или достигаю максимального количества параллельных подключений к базе...

Допустим, у меня есть два класса case C1 и C2 , каждый из которых наследуется от признака T . У меня есть два Query0 объекта, параметризованных этими классами случаев Query0[C1] и Query0[C2] . Цель состоит в том, что при выполнении этих...