1.在scala中想要操作mysql數庫中的資料，可以使用scalikejdbc。

2.匯入依賴。

3.在resource檔案中新增application.conf檔案。然後配置引數。

db.default.driver="com.mysql.jdbc.Driver"
db.default.url="jdbc:mysql://localhost:3306/bbs?characterEncoding=utf-8"
db.default.user="root"
db.default.password="123456"

import scalikejdbc.{DB, SQL}
import scalikejdbc.config.DBs

//scala中連線mysql，使用scalalikejdbc框架進行資料的增刪改查。
case class people(name: String, age: Int)

object ScalalikeJdbc {

  def main(args: Array[String]): Unit = {

    //解析application.conf的檔案。
    DBs.setup()
    //DBs.setupAll()
    DB.autoCommit { implicit session =>
      SQL("insert into people(name,age,fv) values(?,?,?)").bind("lisi", 20, 99).update().apply()
    }

    println(insertBatch)
  }

  def delete() = {
    DB.autoCommit { implicit session =>
      SQL("delete from people where name = ?").bind("張三").update().apply()
    }
  }


  def update() {
    DB.autoCommit { implicit session =>
      SQL("update people set age = ? where name = ?").bind(23, "lisi").update().apply()
    }
  }

  //select查詢到資料之後會產生一個rs的物件集，然後可以得到這個物件集裡面的資料。
  def select() = {
    DB.readOnly { implicit session =>
      //val sql = SQL("select * from people ").map(rs => (rs.string("name"), rs.int("age"))).toList().apply()
      SQL("select * from people").map(rs => people(rs.string("name"), rs.int("age"))).list().apply()
    }
  }

  //在資料插入的時候建立一個事務。
  def insertBatch() = {

    DB.localTx { implicit session =>
      SQL("insert into people(name,age,fv) values(?,?,?)").bind("王五", 26, 101).update().apply()
      val r = 1 / 0
      SQL("insert into people(name,age) values(?,?)").bind("劉璐", 30).update().apply()
    }
  }

}