Guest User

Untitled

a guest
May 14th, 2018
103
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.18 KB | None | 0 0
  1. package zentrope.testsql {
  2.  
  3. import zentrope.sql._
  4.  
  5. object Main {
  6.  
  7. def getSettings(): Settings = {
  8. new Settings(
  9. user="root",
  10. pass="",
  11. url="jdbc:mysql://localhost:3306",
  12. driver="com.mysql.jdbc.Driver")
  13. }
  14.  
  15. def main(args: Array[String]) = {
  16. println("hello.sql")
  17.  
  18. // Only once per application.
  19. Sql.init(getSettings())
  20.  
  21. Sql.withConnection { sql =>
  22. sql.execute("drop database if exists scala")
  23. sql.execute("create database if not exists scala")
  24.  
  25. sql.execute("""
  26. create table if not exists scala.data (
  27. id bigint auto_increment primary key,
  28. name varchar(50),
  29. value int
  30. )
  31. """)
  32.  
  33. 1.to(100) foreach { i =>
  34. val query = "insert into scala.data (name, value) values (?, ?)"
  35. val params = List("name." + i, i)
  36. sql.execute(query, params)
  37. }
  38.  
  39. sql.foreach("select * from scala.data") { row =>
  40. println(row)
  41. }
  42.  
  43. val data = sql.collect("select * from scala.data") { row =>
  44. row.getLong("id")
  45. }
  46. println(data)
  47.  
  48. }
  49. }
  50. }
  51.  
  52. }
Add Comment
Please, Sign In to add comment