Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package zentrope.testsql {
- import zentrope.sql._
- object Main {
- def getSettings(): Settings = {
- new Settings(
- user="root",
- pass="",
- url="jdbc:mysql://localhost:3306",
- driver="com.mysql.jdbc.Driver")
- }
- def main(args: Array[String]) = {
- println("hello.sql")
- // Only once per application.
- Sql.init(getSettings())
- Sql.withConnection { sql =>
- sql.execute("drop database if exists scala")
- sql.execute("create database if not exists scala")
- sql.execute("""
- create table if not exists scala.data (
- id bigint auto_increment primary key,
- name varchar(50),
- value int
- )
- """)
- 1.to(100) foreach { i =>
- val query = "insert into scala.data (name, value) values (?, ?)"
- val params = List("name." + i, i)
- sql.execute(query, params)
- }
- sql.foreach("select * from scala.data") { row =>
- println(row)
- }
- val data = sql.collect("select * from scala.data") { row =>
- row.getLong("id")
- }
- println(data)
- }
- }
- }
- }
Add Comment
Please, Sign In to add comment