Update Slick.scala

pjfanning · Aug 14, 2023 · fc62669 · fc62669
1 parent b2ddda9
commit fc62669
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala b/slick/src/main/scala/org/apache/pekko/stream/connectors/slick/javadsl/Slick.scala
@@ -52,8 +52,8 @@ object Slick {
       session: SlickSession,
       query: String,
       mapper: JFunction[SlickRow, T]): Source[T, NotUsed] = {
-
-    val streamingAction = SQLActionBuilder(Seq(query), Seq(unitType)).as[T](toSlick(mapper))
+    val chars: Seq[Char] = query.toSeq
+    val streamingAction = SQLActionBuilder(chars.map(_.toString), Seq(unitType)).as[T](toSlick(mapper))
 
     ScalaSlick
       .source[T](streamingAction)(session)
@@ -362,7 +362,8 @@ object Slick {
     GetResult(pr => mapper(new SlickRow(pr)))
 
   private def toDBIO[T](javaDml: JFunction[T, String]): T => DBIO[Int] = { t =>
-    SQLActionBuilder(Seq(javaDml.asScala(t)), Seq(unitType)).asUpdate
+    val chars: Seq[Char] = javaDml.asScala(t).toSeq
+    SQLActionBuilder(chars.map(_.toString), Seq(unitType)).asUpdate
   }
 
   private def toDBIO[T](javaDml: Function2[T, Connection, PreparedStatement]): T => DBIO[Int] = { t =>