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() } } }
下一篇: Hadoop系列修炼笔记12