Guest User

Untitled

a guest
Aug 23rd, 2018
95
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.51 KB | None | 0 0
  1. #Load using SlickSession.forConfig("slick-h2")
  2. slick-h2 {
  3. profile = "slick.jdbc.H2Profile$"
  4. db {
  5. connectionPool = disabled
  6. dataSourceClass = "slick.jdbc.DriverDataSource"
  7. properties = {
  8. driver = "org.h2.Driver"
  9. url = "jdbc:h2:/tmp/alpakka-slick-h2-test"
  10. }
  11. }
  12. }
  13.  
  14. import scala.concurrent.Future
  15.  
  16. import akka.Done
  17. import akka.actor.ActorSystem
  18. import akka.stream.ActorMaterializer
  19.  
  20. import akka.stream.scaladsl._
  21. import akka.stream.alpakka.slick.scaladsl._
  22.  
  23. import slick.jdbc.GetResult
  24.  
  25. object SlickSourceWithPlainSQLQueryExample extends App {
  26. implicit val system = ActorSystem()
  27. implicit val mat = ActorMaterializer()
  28. implicit val ec = system.dispatcher
  29.  
  30. implicit val session = SlickSession.forConfig("slick-h2")
  31.  
  32. // The example domain
  33. case class User(id: Int, name: String)
  34.  
  35. // We need this to automatically transform result rows
  36. // into instances of the User class.
  37. // Please import slick.jdbc.GetResult
  38. // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#result-sets"
  39. implicit val getUserResult = GetResult(r => User(r.nextInt, r.nextString))
  40.  
  41. // This import enables the use of the Slick sql"...",
  42. // sqlu"...", and sqlt"..." String interpolators.
  43. // See also: "http://slick.lightbend.com/doc/3.2.1/sql.html#string-interpolation"
  44. import session.profile.api._
  45.  
  46. // Stream the results of a query
  47. val done: Future[Done] =
  48. Slick
  49. .source(sql"SELECT ID, NAME FROM ALPAKKA_SLICK_SCALADSL_TEST_USERS".as[User])
  50. .log("user")
  51. .runWith(Sink.ignore)
  52.  
  53. done.onComplete {
  54. case _ =>
  55. session.close()
  56. system.terminate()
  57. }
  58. }
  59.  
  60. object Main extends App {
  61.  
  62. implicit val system = ActorSystem()
  63. implicit val mat = ActorMaterializer()
  64. implicit val ec = system.dispatcher
  65.  
  66. implicit val session = SlickSession.forConfig("pp")
  67. }
  68.  
  69. pp = {
  70.  
  71. url = "jdbc:oracle:thin:@52.4.90.244:1521:pp"
  72. driver = oracle.jdbc.OracleDriver
  73. keepAliveConnection = true
  74. connectionPool = disabled
  75.  
  76.  
  77. user = "pharmapendium4"
  78. password = "pharmapendium4"
  79.  
  80. }
  81.  
  82. Exception in thread "main" slick.SlickException: Configured profile oracle.jdbc.OracleDriver does not conform to requested profile slick.jdbc.JdbcProfile
  83. at slick.basic.DatabaseConfig$.forConfig(DatabaseConfig.scala:99)
  84. at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:47)
  85. at akka.stream.alpakka.slick.javadsl.SlickSession$.forConfig(package.scala:44)
  86.  
  87. object Main extends App {
  88. val db = Database.forConfig("pp")
  89. .....}
Add Comment
Please, Sign In to add comment