共計 3191 個字符，預計需要花費 8 分鐘才能閱讀完成。
本篇內容介紹了“怎么使用 ScalikeJDBC 操作 MySQL 數據庫”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓丸趣 TV 小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！
環境：
IDEA+Maven+ScalikeJDBC+MySQL5.6
1 新建 Maven 的 Scala 工程
2 pom.xml 文件添加依賴：
properties
scala.version 2.11.8 /scala.version
!– 添加 scalikejdbc 和 mysql 的 version 定義 —
scalikejdbc.version 2.5.2 /scalikejdbc.version
mysql.version 5.6.23 /mysql.version
/properties
dependencies
!– 添加 scalikejdbc 的 dependency —
dependency
groupId org.scalikejdbc /groupId
artifactId scalikejdbc_2.11 /artifactId
version ${scalikejdbc.version} /version
/dependency
dependency
groupId org.scalikejdbc /groupId
artifactId scalikejdbc-config_2.11 /artifactId
version ${scalikejdbc.version} /version
/dependency
!– 添加 mysql 的 dependency —
dependency
groupId mysql /groupId
artifactId mysql-connector-java /artifactId
version ${mysql.version} /version
/dependency
dependency
groupId ch.qos.logback /groupId
artifactId logback-classic /artifactId
version 1.2.3 /version
/dependency
/dependencies
3 新增 Scala 對象
package com.ruozedata
import scalikejdbc._
object ScalaLikeJdbc {
def main(args: Array[String]): Unit = {
// 加載驅動
Class.forName(com.mysql.jdbc.Driver)
// 指定數據庫連接 url，userName，password
val url = jdbc:mysql://192.168.1.108:3306/ruozedata?useUnicode=true characterEncoding=UTF8
val userName = root
val password = root
// 設置數據庫連接參數
val settings = ConnectionPoolSettings(
initialSize = 5,
maxSize = 20,
connectionTimeoutMillis = 3000L,
validationQuery = select 1 from test ) // test 表是專門創建的一個測試表
// 構建數據庫連接池
ConnectionPool.singleton(url, userName, password, settings)
// 新增數據
val insertResult: Int = DB autoCommit {implicit session =
SQL(insert into user(id, name,age) values(?,?,?) ).bind(1, Zhangsan ,15).update().apply()
SQL(insert into user(id, name,age) values(?,?,?) ).bind(2, Ruoze ,16).update().apply()
SQL(insert into user(id, name,age) values(?,?,?) ).bind(3, Jepson ,17).update().apply()
}
println(insertResult) // 打印 insertResult 變量的值，如果新增成功，返回 1，否則返回 0
// 定義 User 類
case class User(id: Int, name: String, age: Int)
// 查詢數據操作
val allColumns = (rs: WrappedResultSet) = User(
id = rs.int(id),
name = rs.string(name),
age = rs.int(age))
val users: List[User] = DB readOnly {implicit session =
SQL(select * from user).map(allColumns).list.apply()
}
// 循環遍歷 users 對象 并輸出
for(user – users) {
println(user.id + , + user.name + , + user.age)
}
}
}
4 添加 jdbc 的 MySQL 驅動包
mysql-connector-java-commercial-5.1.25-bin.jar
5 運行結果如下：
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/D:/software/apache-maven-3.3.9/repository/org/slf4j/slf4j-log4j12/1.7.16/slf4j-log4j12-1.7.16.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/D:/software/apache-maven-3.3.9/repository/ch/qos/logback/logback-classic/1.2.3/logback-classic-1.2.3.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
log4j:WARN No appenders could be found for logger (scalikejdbc.ConnectionPool$).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
1
1,Zhangsan,15
2,Ruoze,16
3,Jepson,17
Process finished with exit code 0
“怎么使用 ScalikeJDBC 操作 MySQL 數據庫”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注丸趣 TV 網站，丸趣 TV 小編將為大家輸出更多高質量的實用文章！
