slick db.runはアクションを挿入しません。

Question

Slickを使用してMySqlテーブルに簡単な挿入をしようとしています。以下のデバッグ出力でわかるように、コードは実行されますが、値はデータベースに挿入されません。

これはDatabase.scalaコードである：

//import slick.jdbc.JdbcBackend._ 
import slick.dbio.DBIOAction 
import slick.driver.MySQLDriver.api._ 
import slick.lifted.TableQuery 

import java.sql.Timestamp 

class Database { 
    val url = "jdbc:mysql://username=root:password=xxx@localhost/playdb" 
    val db = Database.forURL(url, driver = "com.mysql.jdbc.Driver") 
    val emrepo = TableQuery[EmailMessageTable] 

    override def finalize() { 
    db.close() 
    super.finalize() 
    } 


protected class EmailMessageTable(tag: Tag) extends Table[EmailMessage](tag, "email_message") { 

    def id  = column[Option[Long]]("id", O.AutoInc, O.PrimaryKey) 
    def email = column[String]("email") 
    def subject = column[String]("subject") 
    def body = column[String]("body") 
    def datain = column[Timestamp]("datain") 
    def email_id= column[Long]("email_id") 

    def * = (id, email, subject, body, datain, email_id) <> ((EmailMessage.apply _).tupled, EmailMessage.unapply) 
    def ? = (id.get.?, email.?, subject.?, body.?, datain.?, email_id.?).shaped.<>({ r => import r._; _1.map(_ => 
    EmailMessage.tupled((_1, _2.get, _3.get, _4.get, _5.get, _6.get))) }, (_: Any) => 
    throw new Exception("Inserting into ? projection not supported.")) 
} 

    def insert(m: EmailMessage) { 
    db.run(
     (emrepo += m) 
    ) 
    } 
} 

呼び出しコード：

def toDatabase(m: EmailMessage): EmailMessage = { 
    val db = new Database() 
    println("HIT") 
    db.insert(m) 
    println("HIT 2") 
    println(m) 
    m 
    } 

データベースに挿入されcase classオブジェクト：

import java.sql.Timestamp 

case class EmailMessage(
    id: Option[Long], 
    email: String, 
    subject:String, 
    body:String, 
    datain: Timestamp, 
    email_id: Long 
) 

DEBUG出力示しますSlickにコールが送信され、Slickがデバッグされます。出力：

HIT 
2016-09-06 16:08:41:563 -0300 [run-main-0] DEBUG slick.compiler.QueryCompiler - Source: 
| TableExpansion 
| table s2: Table email_message 
| columns: TypeMapping 
|  0: ProductNode 
|  1: Path s2.id : Option[Long'] 
|  2: Path s2.email : String' 
|  3: Path s2.subject : String' 
|  4: Path s2.body : String' 
|  5: Path s2.datain : java.sql.Timestamp' 
|  6: Path s2.email_id : Long' 

2016-09-06 16:08:41:587 -0300 [run-main-0] DEBUG slick.compiler.AssignUniqueSymbols - Detected features: UsedFeatures(false,true,false,false) 
2016-09-06 16:08:41:597 -0300 [run-main-0] DEBUG slick.compiler.QueryCompiler - After phase assignUniqueSymbols: 
| TableExpansion 
| table s3: Table email_message 
| columns: TypeMapping 
|  0: ProductNode 
|  1: Path s3.id : Option[Long'] 
|  2: Path s3.email : String' 
|  3: Path s3.subject : String' 
|  4: Path s3.body : String' 
|  5: Path s3.datain : java.sql.Timestamp' 
|  6: Path s3.email_id : Long' 

2016-09-06 16:08:41:605 -0300 [run-main-0] DEBUG slick.compiler.QueryCompiler - After phase inferTypes: (no change) 
2016-09-06 16:08:41:624 -0300 [run-main-0] DEBUG slick.compiler.QueryCompiler - After phase insertCompiler: 
| ResultSetMapping : Vector[(String', String', String', java.sql.Timestamp', Long')] 
| from s5: Insert allFields=[id, email, subject, body, datain, email_id] : (String', String', String', java.sql.Timestamp', Long') 
|  table s6: Table email_message : Vector[@t4<UnassignedType>] 
|  linear: ProductNode : (String', String', String', java.sql.Timestamp', Long') 
|  1: Path s6.email : String' 
|  2: Path s6.subject : String' 
|  3: Path s6.body : String' 
|  4: Path s6.datain : java.sql.Timestamp' 
|  5: Path s6.email_id : Long' 
| map: TypeMapping : Mapped[(Option[Long'], String', String', String', java.sql.Timestamp', Long')] 
|  0: ProductNode : (Option[Long'], String', String', String', java.sql.Timestamp', Long') 
|  1: InsertColumn id : Option[Long'] 
|  2: InsertColumn email : String' 
|   0: Path s5._1 : String' 
|  3: InsertColumn subject : String' 
|   0: Path s5._2 : String' 
|  4: InsertColumn body : String' 
|   0: Path s5._3 : String' 
|  5: InsertColumn datain : java.sql.Timestamp' 
|   0: Path s5._4 : java.sql.Timestamp' 
|  6: InsertColumn email_id : Long' 
|   0: Path s5._5 : Long' 

2016-09-06 16:08:41:638 -0300 [run-main-0] DEBUG slick.compiler.CodeGen - Compiling server-side and mapping with server-side: 
| Insert allFields=[id, email, subject, body, datain, email_id] : (String', String', String', java.sql.Timestamp', Long') 
| table s6: Table email_message : Vector[@t4<UnassignedType>] 
| linear: ProductNode : (String', String', String', java.sql.Timestamp', Long') 
|  1: Path s6.email : String' 
|  2: Path s6.subject : String' 
|  3: Path s6.body : String' 
|  4: Path s6.datain : java.sql.Timestamp' 
|  5: Path s6.email_id : Long' 

2016-09-06 16:08:41:673 -0300 [run-main-0] DEBUG slick.relational.ResultConverterCompiler - Compiled ResultConverter 
| TypeMappingResultConverter 
| child: ProductResultConverter 
|  1: CompoundResultConverter 
|  2: SpecializedJdbcResultConverter$$anon$1 idx=1, name=email : String' 
|  3: SpecializedJdbcResultConverter$$anon$1 idx=2, name=subject : String' 
|  4: SpecializedJdbcResultConverter$$anon$1 idx=3, name=body : String' 
|  5: SpecializedJdbcResultConverter$$anon$1 idx=4, name=datain : java.sql.Timestamp' 
|  6: BaseResultConverter$mcJ$sp idx=5, name=email_id : Long' 

2016-09-06 16:08:41:675 -0300 [run-main-0] DEBUG slick.compiler.CodeGen - Compiled server-side to: 
| CompiledStatement "insert into `email_message` (`email`,`subject`,`body`,`datain`,`email_id`) values (?,?,?,?,?)" : (String', String', String', java.sql.Timestamp', Long') 

2016-09-06 16:08:41:681 -0300 [run-main-0] DEBUG slick.compiler.QueryCompiler - After phase codeGen: 
| ResultSetMapping : Vector[(String', String', String', java.sql.Timestamp', Long')] 
| from s5: CompiledStatement "insert into `email_message` (`email`,`subject`,`body`,`datain`,`email_id`) values (?,?,?,?,?)" : (String', String', String', java.sql.Timestamp', Long') 
| map: CompiledMapping : Mapped[(Option[Long'], String', String', String', java.sql.Timestamp', Long')] 
|  converter: TypeMappingResultConverter 
|  child: ProductResultConverter 
|   1: CompoundResultConverter 
|   2: SpecializedJdbcResultConverter$$anon$1 idx=1, name=email : String' 
|   3: SpecializedJdbcResultConverter$$anon$1 idx=2, name=subject : String' 
|   4: SpecializedJdbcResultConverter$$anon$1 idx=3, name=body : String' 
|   5: SpecializedJdbcResultConverter$$anon$1 idx=4, name=datain : java.sql.Timestamp' 
|   6: BaseResultConverter$mcJ$sp idx=5, name=email_id : Long' 

2016-09-06 16:08:41:682 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark - ------------------- Phase: Time --------- 
2016-09-06 16:08:41:702 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark -  assignUniqueSymbols: 32,729098 ms 
2016-09-06 16:08:41:703 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark -    inferTypes: 7,924984 ms 
2016-09-06 16:08:41:703 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark -   insertCompiler: 18,786989 ms 
2016-09-06 16:08:41:703 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark -     codeGen: 57,406605 ms 
2016-09-06 16:08:41:704 -0300 [run-main-0] DEBUG slick.compiler.QueryCompilerBenchmark -      TOTAL: 116,847676 ms 
2016-09-06 16:08:41:709 -0300 [run-main-0] DEBUG slick.backend.DatabaseComponent.action - #1: SingleInsertAction [insert into `email_message` (`email`,`subject`,`body`,`datain`,`email_id`) values (?,?,?,?,?)] 
HIT 2 
EmailMessage(None,fernando@localhost,Me,teste daqui para ali rapido.,2016-09-06 16:08:41.099,1) 
2016-09-06 16:08:41:746 -0300 [AsyncExecutor.default-1] DEBUG slick.jdbc.JdbcBackend.statement - Preparing statement: insert into `email_message` (`email`,`subject`,`body`,`datain`,`email_id`) values (?,?,?,?,?) 
[success] Total time: 18 s, completed 06/09/2016 16:08:41 

値はデータベースに挿入されません。どうして？

Answer 1

最も可能性の高いことは、 'db.insert（m）'という文が非同期（Futureを返します）であり、未来が終了する前にプログラムが終了していることです。終了する。

あなたはこのような何か試すことができます。

val result = db.insert(m) 
Await.result(result, Duration.Inf) 
... 

を私はあなたがここに見ることができる前に、同様の問題があった：How to configure Slick 3.1.1 for PostgreSQL? It seems to ignore my config parameters while running plain sql queries