Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #Load using SlickSession.forConfig("slick-h2")
- slick-h2 {
- profile = "slick.jdbc.H2Profile$"
- db {
- connectionPool = disabled
- dataSourceClass = "slick.jdbc.DriverDataSource"
- properties = {
- driver = "org.h2.Driver"
- url = "jdbc:h2:/tmp/alpakka-slick-h2-test"
- }
- }
- }
- import scala.concurrent.Future
- import akka.Done
- import akka.actor.ActorSystem
- import akka.stream.ActorMaterializer
- import akka.stream.scaladsl._
- import akka.stream.alpakka.slick.scaladsl._
- import slick.jdbc.GetResult
- object SlickSourceWithPlainSQLQueryExample extends App {
- implicit val system = ActorSystem()
- implicit val mat = ActorMaterializer()
- implicit val ec = system.dispatcher
- implicit val session = SlickSession.forConfig("slick-h2")
- // The example domain
- case class User(id: Int, name: String)
- // We need this to automatically transform result rows
- // into instances of the User class.
- // Please import slick.jdbc.GetResult
- // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#result-sets"
- implicit val getUserResult = GetResult(r => User(r.nextInt, r.nextString))
- // This import enables the use of the Slick sql"...",
- // sqlu"...", and sqlt"..." String interpolators.
- // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#string-interpolation"
- import session.profile.api._
- // Stream the results of a query
- val done: Future[Done] =
- Slick
- .source(sql"SELECT ID, NAME FROM ALPAKKA_SLICK_SCALADSL_TEST_USERS".as[User])
- .log("user")
- .runWith(Sink.ignore)
- done.onComplete {
- case _ =>
- session.close()
- system.terminate()
- }
- }
- object Main extends App {
- implicit val system = ActorSystem()
- implicit val mat = ActorMaterializer()
- implicit val ec = system.dispatcher
- implicit val session = SlickSession.forConfig("pp")
- }
- pp = {
- url = "jdbc:oracle:thin:@52.4.90.244:1521:pp"
- driver = oracle.jdbc.OracleDriver
- keepAliveConnection = true
- connectionPool = disabled
- user = "pharmapendium4"
- password = "pharmapendium4"
- }
- Exception in thread "main" slick.SlickException: Configured profile oracle.jdbc.OracleDriver does not conform to requested profile slick.jdbc.JdbcProfile
- at slick.basic.DatabaseConfig$.forConfig(DatabaseConfig.scala:99)
- at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:47)
- at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:44)
- object Main extends App {
- val db = Database.forConfig("pp")
- .....}
Add Comment
Please, Sign In to add comment