91HdeyDs

1package 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}