main class that does whatever flyway tasks you use
object MyFlyway { val flyway = ... } and in sbt set mysubproject / console / intialCommands := "import MyFlyway.flyway"
> console
scala> flyway.migrate()
I want to call the procedure tht has five params:
so i have created the function as
def five[T1, T2, T3,T4,T5, R : TypedType](fname: String, fn: Boolean = false): ((Rep[T1], Rep[T2], Rep[T3],Rep[T4],Rep[T5]) => Rep[R]) = {
val f = SimpleFunction.apply(fname, fn);
{ (t1: Rep[T1], t2: Rep[T2], t3: Rep[T3],t4:Rep[T4],t5:Rep[T5]) => f(Seq(t1, t2, t3,t4,t5)) }
}My sql procedure function returns TABLE(res1 String, res2 String)
case class CaseClass(res1: String,res2: String)Now i am calling my method:
val f = five[String,String,String,String,String,CaseClass]("function")How can i cast the TABLE(res1 String, res2 String) to CaseClass
I have tried:
implicit val caseClass = CaseClass(r.nextString(), r.nextString())It did not work for me.
MyCaseClass(field1, field2) . If you want to do it implicitly then I don't know.
Hello @arkankhan-ak and welcome :wave: The Slick Manual has a section on transactions, and there's Essential Slick which is a tutorial introduction to Slick, which has a section on transactions too.
The basic idea is: combine actions into a single action, and stick .transactionally on the end :+1:
Option[String] = Some("slick") then in table "slick"
externalId: Option[String] = None
//this is error below:
value PrimaryKey is not a member of Int
//from this line below:
def id = column[Int]("id",0.PrimaryKey,0.AutoInc)
//and this is build file below:
lazy val root = (project in file(".")).enablePlugins(PlayScala)
scalaVersion := "2.13.0"
libraryDependencies += guice
libraryDependencies += "org.scalatestplus.play" %% "scalatestplus-play" % "5.0.0" % Test
libraryDependencies ++= Seq(
"mysql" % "mysql-connector-java" % "8.0.19"
)
libraryDependencies ++= Seq(
"com.typesafe.play" %% "play-slick" % "5.0.0",
"com.typesafe.play" %% "play-slick-evolutions" % "5.0.0"
)
//and this is code below:
package models
import javax.inject.{Inject,Singleton}
import play.api.db.slick.DatabaseConfigProvider
import slick.jdbc.JdbcProfile
import scala.concurrent.{Future,ExecutionContext}
@Singleton
class PersonRepository @Inject()(dbConfigProvider: DatabaseConfigProvider)(implicit ec: ExecutionContext){
private val dbConfig = dbConfigProvider.get[JdbcProfile]
import dbConfig._
import profile.api._
private class PeopleTable(tag:Tag) extends Table[Person](tag,"people"){
def id = column[Int]("id",0.PrimaryKey,0.AutoInc)
def name = column[String]("name")
def mail = column[String]("mail")
def tel = column[String]("tel")
def * = (id,name,mail,tel)<>((Person.apply _).tupled,Person.unapply)
}
private val people = TableQuery[PeopleTable]
def list(): Future[Seq[Person]] = db.run{
people.result
}
}
//this is error below:
1) No implementation for play.api.db.slick.DatabaseConfigProvider was bound.
while locating play.api.db.slick.DatabaseConfigProvider
for the 1st parameter of models.PersonRepository.<init>(PersonRepository.scala:34)
while locating models.PersonRepository
for the 1st parameter of controllers.HomeController.<init>(HomeController.scala:18)
while locating controllers.HomeController
for the 2nd parameter of router.Routes.<init>(Routes.scala:29)
at play.api.inject.RoutesProvider$.bindingsFromConfiguration(BuiltinModule.scala:137):
Binding(class router.Routes to self) (via modules: com.google.inject.util.Modules$OverrideModule -> play.api.inject.guice.GuiceableModuleConversions$$anon$4)
1 error
No source available, here is the exception stack trace:
->com.google.inject.CreationException: Unable to create injector, see the following errors:
com.google.inject.internal.Errors.throwCreationExceptionIfErrorsExist(Errors.java:543)
com.google.inject.internal.InternalInjectorCreator.initializeStatically(InternalInjectorCreator.java:159)
com.google.inject.internal.InternalInjectorCreator.build(InternalInjectorCreator.java:106)
com.google.inject.Guice.createInjector(Guice.java:87)
com.google.inject.Guice.createInjector(Guice.java:78)
play.api.inject.guice.GuiceBuilder.injector(GuiceInjectorBuilder.scala:200)
play.api.inject.guice.GuiceApplicationBuilder.build(GuiceApplicationBuilder.scala:155)
play.api.inject.guice.GuiceApplicationLoader.load(GuiceApplicationLoader.scala:21)
play.core.server.DevServerStart$$anon$1.$anonfun$reload$3(DevServerStart.scala:189)
play.utils.Threads$.withContextClassLoader(Threads.scala:21)
play.core.server.DevServerStart$$anon$1.reload(DevServerStart.scala:181)
play.core.server.DevServerStart$$anon$1.get(DevServerStart.scala:141)
play.core.server.AkkaHttpServer.handleRequest(AkkaHttpServer.scala:296)
play.core.server.AkkaHttpServer.$anonfun$createServerBinding$1(AkkaHttpServer.scala:186)
akka.stream.impl.fusing.MapAsync$$anon$30.onPush(Ops.scala:1261)
akka.stream.impl.fusing.GraphInterpreter.processPush(GraphInterpreter.scala:541)
akka.stream.impl.fusing.GraphInterpreter.execute(GraphInterpreter.scala:423)
akka.stream.impl.fusing.GraphInterpreterShell.runBatch(ActorGraphInterpreter.scala:624)
akka.stream.impl.fusing.GraphInterpreterShell$AsyncInput.execute(ActorGraphInterpreter.scala:501)
akka.stream.impl.fusing.GraphInterpreterShell.processEvent(ActorGraphInterpreter.scala:599)
akka.stream.impl.fusing.ActorGraphInterpreter.akka$stream$impl$fusing$ActorGraphInterpreter$$processEvent(ActorGraphInterpreter.scala:768)
akka.stream.impl.fusing.ActorGraphInterpreter$$anonfun$receive$1.applyOrElse(ActorGraphInterpreter.scala:783)
akka.actor.Actor.aroundReceive(Actor.scala:533)
akka.actor.Actor.aroundReceive$(Actor.scala:531)
akka.stream.impl.fusing.ActorGraphInterpreter.aroundReceive(ActorGraphInterpreter.scala:690)
akka.actor.ActorCell.receiveMessage(ActorCell.scala:573)
akka.actor.ActorCell.invoke(ActorCell.scala:543)
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:269)
akka.dispatch.Mailbox.run(Mailbox.scala:23// this is PersonRepository.scala file below:
package models
import javax.inject.{Inject,Singleton}
import play.api.db.slick.DatabaseConfigProvider
import slick.jdbc.JdbcProfile
import scala.concurrent.{Future,ExecutionContext}
@Singleton
class PersonRepository @Inject()(dbConfigProvider: DatabaseConfigProvider)(implicit ec: ExecutionContext){
private val dbConfig = dbConfigProvider.get[JdbcProfile]
import dbConfig._
import profile.api._
import Person._
private class PeopleTable(tag:Tag) extends Table[Person](tag,"people"){
def id = column[Int]("id",O.PrimaryKey,O.AutoInc)
def name = column[String]("name")
def mail = column[String]("mail")
def tel = column[String]("tel")
def * = (id,name,mail,tel)<>((Person.apply _).tupled,Person.unapply)
}
private val people = TableQuery[PeopleTable]
def list(): Future[Seq[Person]] = db.run{
people.result
}
}//this is HomeController.scala file:
package controllers
import models._
import javax.inject._
import play.api.data.Form
import play.api.data.Forms._
import play.api.data.validation.Constraints._
import play.api.i18n._
import play.api.libs.json.Json
import play.api.mvc._
import scala.concurrent.{ExecutionContext,Future}
@Singleton
class HomeController @Inject()(repository:PersonRepository,cc:MessagesControllerComponents)(implicit ec: ExecutionContext)extends MessagesAbstractController(cc){
def index() = Action.async{ implicit request =>
repository.list().map{ people =>
Ok(views.html.index("People Data.",people))
}
}
}Hi everyone
While i am insertingOption[String]in slick table it is inserting data withdouble quotes
Hi @amitprasad01_twitter - I'd check you have the right profile imported for the database you're using. E.g., import slick.jdbc.OracleProfile.api._ for ORACLE, or import slick.jdbc.H2Profile.api._ for H2 etc. That would possibly impact the SQL that's being generated. If that's not it, give us an example of a query to see if we can see anything troubling there.
ccom.mysql.jdbc.Driverr -> this looks suspicious (it should probably be com.mysql.jdbc.Driver). Alos, for usage with play, unless you changed something, you want your db object configuration in slick.dbs.default, like so:
slick.dbs.default {
db = {
url = "jdbc:mysql://localhost:3306/lib"
user = "root"
password = "12345678"
driver = "com.mysql.jdbc.Driver"
}
profile = "slick.jdbc.SQLServerProfile$"
numThreads = 10 # or whatever
}(not 100% certain about the profile, never used mysql, but within your ide you can type slick.jdbc.[...] and you should see the complete list of possible profiles).
Note that the "default" in the conf is just a convention, you could have several databases with different names. There are used for migration (name of migration folder should match that) and for DI within the controllers, for example
@kovalyovGA what you have there will evaluate into SQL along the lines of where xOpt = the-value-of-right-hand-side (if it's a Some) and where xOpt = NULL (if it's None). The second case is false, which may be what you want to happen.
If you need to be explicit about NULL handling, you'll be using isEmpty (IS NULL) or isDefined (IS NOT NULL)
Hi, I'm working with slick for the first time, and seeing some sub-optimal behavior that doesn’t seem to match the docs.
This code
dbConfig.db.run(table.filter(_.id === id).filter(_.active === true).result.headOption)should generate sql along the lines of
select * from TRAVEL_BOOKING_AGENT_INFO where id = $id and active = $active"But what I’m seeing in the logs is this:
2020-06-01 13:22:40 DEBUG slick.jdbc.JdbcBackend.statement Preparing statement: select `id`, `travel_booking_id`, `assigned_agent_id`, `assigned_agent_name`, `active`, `create_date` from `TRAVEL_BOOKING_AGENT_INFO`Instead of using a WHERE clause, it is pulling the entire table and post filtering.
@scruffycatherder I've not seen anything like that before. Looks to me like it should be OK. I've checked a project I have, and the generated SQL from something like that query is as we expect it.
Always worth checking you have the right profiles imported for each environment (H2 and MySQL), but I doubt that's it.
Perhaps as a sanity check re-work what you have as something equivalent to this...
val action = messages.filter(_.id === id).filter(_.active === true).result.headOption
println(query.statements.mkString)
dbConfig.db.run(action)...which would at least tell you that action is what you expect. In case there's some confusion in the logging or the way the action is being run.
1 reply
