scala数据库访问toolslick

package com.test

import scala.slick.driver.MySQLDriver.simple._
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource
import scala.slick.session.Database
import scala.slick.session.Session

object Supplier extends Table[(String,Int)]("test") {
	def name = column[String]("name")
	def age = column[Int]("age")
	
	def * = name ~ age
	
	def main(args: Array[String]) {
	val session = Sandbox.database
	val query = tableToQuery(Supplier)
	
	//查询
	//query.selectStatement
	
	//query.foreach(println(_))(session)
	
	//更新
//	val uq = Supplier.filter( p => p.name==="ricki").map(_.age)
//	
//	 uq.updateStatement
//	 
//	 uq.update(24)(session)
	//插入
	
//	val in = Supplier.name ~ Supplier.age
//	
//	in.insertStatement
//	
//	in.insert("cherry",1)(session)
	
	//删除
	
	val dq = Supplier.filter(_.name==="cherry")
	
	dq.deleteStatement
	
	dq.delete(session)
	
	session.close
	}
}

object Sandbox {
 
	def database:Session = {
	 val dataSource = new MysqlDataSource()
	 	dataSource.setUser("root")
	 	dataSource.setPassword("root")
	 	dataSource.setDatabaseName("test")
	 
	 val dataBase = Database.forDataSource(dataSource)
	 dataBase.createSession
	}
}