欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  科技

scalikejdbc框架进行mysql数据库增删改查及事务创建

程序员文章站 2022-04-01 20:17:43
1.在scala中想要操作mysql数库中的数据,可以使用scalikejdbc。 2.导入依赖。 3.在resource文件中添加application.conf文件。然后配置参数。...

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"
4.案例:
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()
    }
  }

}