1.sbt添加依赖
"com.typesafe.slick" %% "slick" % "3.2.3",
"org.slf4j" % "slf4j-nop" % "1.6.4",
"com.typesafe.slick" %% "slick-hikaricp" % "3.2.3",
"mysql" % "mysql-connector-java" % "5.1.47",
2.数据库配置：src/main/resources/application.conf
indie-db = {
url = "jdbc:mysql://devhdp3:3307/indie?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&noAccessToProcedureBodies=true&useSSL=false"
driver = "com.mysql.jdbc.Driver"
keepAliveConnection = true
user = "root"
password = "123456"
connectionPool = disabled
connectionTestQuery = "SELECT 1"
connectionTimeout = 30 second
}
3.代码
package org.netsharp.persist import slick.jdbc.MySQLProfile.api._ import scala.concurrent.duration._
import scala.concurrent.{Await, Future} object Db2 {
//实体定义
final case class Message(
sender: String,
content: String,
id: Long = 0L) //元数据定义
final class MessageTable(tag: Tag) extends Table[Message](tag, "message") {
def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
def sender = column[String]("sender")
def content = column[String]("content")
def * = (sender, content, id).mapTo[Message]
} def main(args:Array[String]): Unit ={ val messages = TableQuery[MessageTable] //数据库访问对象
val db = Database.forConfig("indie-db") //创建表
val setupFuture = db.run(messages.schema.create)
val result = Await.result(setupFuture, 5.seconds) //插入数据
def freshTestData = Seq(
Message("Dave", "Hello, HAL. Do you read me, HAL?"),
Message("HAL", "Affirmative, Dave. I read you."),
Message("Dave", "Open the pod bay doors, HAL."),
Message("HAL", "I'm sorry, Dave. I'm afraid I can't do that.")
) val insert: DBIO[Option[Int]] = messages ++= freshTestData
val result2: Future[Option[Int]] = db.run(insert)
val rowCount = Await.result(result2, 2.seconds) //查询数据
val halSays = messages.filter(_.sender === "HAL").result
val messagesFuture: Future[Seq[Message]] = db.run(halSays)
val list = Await.result(messagesFuture, 2.seconds)
list.foreach(println)
}
}
4.上面例子是基于mysql的，对于sqlserver需要如下修改
a,sbt添加sqlserver的jdbc包依赖："com.microsoft.sqlserver" % "mssql-jdbc" % "7.0.0.jre8",
b.添加配置
indie-sqlserver = {
url = "jdbc:sqlserver://host_or_ip;database=REMInformation;useUnicode=true&characterEncoding=UTF-8"
driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver"
keepAliveConnection = true
user = "xxxx"
password = "xxxx"
connectionPool = disabled
connectionTestQuery = "SELECT 1"
connectionTimeout = 30 second
}
c.代码中原来的import
import slick.jdbc.MySQLProfile.api._
改成新的import
import slick.jdbc.SQLServerProfile.api._
d.代码中原来的数据库配置读取
val db = Database.forConfig("indie-db")
改为
val db = Database.forConfig("indie-sqlserver")