Hi, if I have two value types which have the same underlying type (String), is there any way to perform "column update" (assign the value from one of the columns to the other)?
case class Email(email: String) extends AnyVal
case class EmailVerified(emailVerified: String) extends AnyVal
...
... .update(table => table.emailVerified -> table.email, ...beside infix
liftQuery that vector would fail with "Can't tokenize a non-scalar lifting"
I'm trying to use a model that has a java.time.Instant field. I've put this in my context class:
implicit val encodeInstant = MappedEncoding[Instant, LocalDateTime](i => LocalDateTime.ofInstant(i, ZoneOffset.UTC))
implicit val decodeInstant = MappedEncoding[LocalDateTime, Instant](_.toInstant(ZoneOffset.UTC))but I'm still getting the "Can't find implicit Decoder[java.time.Instant]" error
import ctx._
[error] scala.reflect.macros.TypecheckException: Can't find implicit `Decoder[Foo]`. Please, do one of the following things:
[error] 1. ensure that implicit `Decoder[Foo]` is provided and there are no other conflicting implicits;
[error] 2. make `Foo` `Embedded` case class or `AnyVal`.
[error]
[error] at scala.reflect.macros.contexts.Typers.$anonfun$typecheck$3(Typers.scala:44)
[error] at scala.reflect.macros.contexts.Typers.$anonfun$typecheck$2(Typers.scala:38)
[error] at scala.reflect.macros.contexts.Typers.doTypecheck$1(Typers.scala:37)
[error] at scala.reflect.macros.contexts.Typers.$anonfun$typecheck$7(Typers.scala:50)
[error] at scala.reflect.internal.Trees.wrappingIntoTerm(Trees.scala:1891)
[error] at scala.reflect.internal.Trees.wrappingIntoTerm$(Trees.scala:1888)
[error] at scala.reflect.internal.SymbolTable.wrappingIntoTerm(SymbolTable.scala:28)
[error] at scala.reflect.macros.contexts.Typers.typecheck(Typers.scala:50)
[error] at scala.reflect.macros.contexts.Typers.typecheck$(Typers.scala:32)
[error] at scala.reflect.macros.contexts.Context.typecheck(Context.scala:18)
[error] at scala.reflect.macros.contexts.Context.typecheck(Context.scala:18)
[error] at io.getquill.context.QueryMacro.expandQueryWithMeta(QueryMacro.scala:125)
[error] at io.getquill.context.QueryMacro.expandQuery(QueryMacro.scala:51)
[error] at io.getquill.context.QueryMacro.runQuery(QueryMacro.scala:34)T in EntityQuery[T] has nested case classes.
How can i use dynamic query with implicit joins?
// Implicit Joins:
quote {
for {
a <- query[A]
b <- query[B] if (a.id == b.fk)
} yield (a, b)
}if i use dynamic query, this code return DynamicQuery[Quoted[Schema1], Quoted[Schema2]]:
// Implicit Joins:
val dynamicQ = quote {
for {
a <- query[A].dynamic
b <- query[B].dynamic if (a.id == b.fk)
} yield (a, b)
}and if i then use groupBy, im getting error The query definition must happen within aquoteblock.
[error] b.groupBy(_._1)
dynamicQ.groupBy(_._1)
Hi, can I somehow force quill to execute exactly the same sql I specified via infix?
When I execute this code
case class NamedEntity(name: String)
val rawQuery = s"SHOW DATABASES STARTS WITH '$dbName'"
run(quote(infix"#$rawQuery".as[Query[NamedEntity]])).exists(_.name == dbName)I see query
SELECT "x"."name" FROM (SHOW DATABASES STARTS WITH 'ACC_***_DB') AS "x"and get an error
SQL compilation error:
syntax error line 1 at position 24 unexpected 'SHOW'.
2 replies
Hi everyone. I am trying to make join of count, but i getting stuck with Tuple(Quoted, Quoted). Is there any way to make it Quoted(Tuple(...))?
stream(
for {
item <- items.dynamic
.filter(_.id == lift(id))
.filter(_.parent.isEmpty)
childsCount = items.dynamic
.filter(_.parent == lift(Some(item.id)))
.size
} yield (item, childsCount)
).transact(transactor)The output type is Stream[F, (Quoted[Item], Quoted[Long])], but it should be Stream[F, (Item, Long)]
Hello
I'm trying to write a generic code with Quill to perform some operation on multiple datatype, as described in https://stackoverflow.com/questions/44784310/how-to-write-generic-function-with-scala-quill-io-library/44797199#44797199
I've created my macro
class FindMacro(val c: MacroContext) {
import c.universe._
def find[T](filter: Tree)(implicit t: WeakTypeTag[T]): Tree =
q"""
import ${c.prefix}._
run(${c.prefix}.query[$t].filter($filter))
"""
}That I'm then using in my generic trait:
trait Indexed[I, T] {
def find(key: I, obj: T): Boolean
}
trait Storage[I, T] {
def get(idx: I)(implicit eq: Indexed[I, T]): Task[Option[T]]
}
trait Queries { this: ZioJdbcContext[_, _] =>
def find[T](filter: T => Boolean): T = macro FindMacro.find[T]
}
case class SqliteStorage[I, T](connection: Connection)(implicit schema: SchemaMeta[T]) extends Storage[I, T] {
val ctx = new SqliteZioJdbcContext(SnakeCase) with Queries
override def get(idx: I)(implicit eq: Indexed[I, T]): Task[Option[T]] =
ctx.find[T](p => eq.find(idx, p))
}Unfortunately, the implicit SchemaMeta[T] does not seems to work, I think I must be missing something here, but I don't understand what, could someone help me with that ?
ProtoQuill (i.e. Dotty-Quill) Beta-1 is out!
// build.sbt
lazy val root = project
.in(file("."))
.settings(
scalaVersion := "3.0.0",
libraryDependencies ++= Seq(
"io.getquill" %% "quill-jdbc" %"3.7.1.Beta1.0"
)
)Example:
@main
def simpleQuery = {
inline def q = quote {
query[Person]
}
val ctx = new SqlMirrorContext(PostgresDialect, Literal)
import ctx._
println(run(q))
}Special thanks to Nicolas Stucki!
Tree 'context.querySchema[Entry](cache)' can't be parsed to 'Ast'
groupBy and the filter to work properly. The SQL query itself does give me what I want.SELECT
posts.id, posts.title, COUNT(clicks.id)
FROM
posts LEFT OUTER JOIN clicks ON posts.id = clicks.post_id
WHERE
posts.author_id = '269286af-3be5-4dad-8b17-96704742b9a5'
AND posts.timestamp > current_timestamp - '2 week'::interval
GROUP BY
posts.idThis was my best attempt:
for {
post <- Posts
.leftJoin(Clicks).on((p, c) => p.id == c.postId)
.map { case (post, _) => post }
.filter(p => p.authorId == lift(userId) && p.isDeleted == lift(false))
clickCount <- Clicks
.groupBy(_.postId)
.map { case (_, clicks) => clicks.size }
} yield ClickCount(post.id, post.title, clickCount)but that gives me this compile-time error:
exception during macro expansion:
java.lang.IllegalStateException: The monad composition can't be expressed using applicative joins. Faulty expression: 'p.id'. Free variables: 'List(p)'., Faulty expression: 'p.title'. Free variables: 'List(p)'.