0

更新：关于 Projection 与 ColumnBase 的错误已得到解决，但是我仍然遇到重载插入方法的问题。代码已更新以反映这一点。

我正在尝试编写我的第一个中等复杂的 Scala 程序。我希望它从我的 Twitter 时间轴中读取值并将它们写入 postgres 表。

我使用 twitter4j 进行 Twitter 连接，并使用 Slick 将数据写入 postgres，但是我遇到了两个编译错误：

错误：

[error] /Users/trenthauck/Dropbox/Code/twitter-api/src/main/scala/org/trenthauck/TwitterApi.scala:45: overloaded method value insert with alternatives:
[error]   [TT](query: scala.slick.lifted.Query[TT,org.trenthauck.Timeline])(implicit session: scala.slick.session.Session)Int <and>
[error]   (value: org.trenthauck.Timeline)(implicit session: scala.slick.session.Session)Int
[error]  cannot be applied to (java.util.Date, Int, String)
[error]       Timeline.insert(date, id, text)
[error]                ^
[error] one error found
[error] (compile:compile) Compilation failed

我在文件中的 Slick 定义DatabaseApi.scala：

package org.trenthauck

import slick._
import scala.slick.driver.PostgresDriver.simple._
import Database.threadLocalSession

import java.sql.Date

case class Timeline (date: Date, id: Long, text: String)

object Timeline extends Table[Timeline]("timeline") {
  def date = column[Date]("date")
  def id = column[Long]("id")
  def text = column[String]("text")
  def * = date ~ id ~ text <> (Timeline.apply _, Timeline.unapply _)
}

我在文件中的 Twitter 定义TwitterApi.scala：

package org.trenthauck

import twitter4j._

import slick._
import scala.slick.driver.PostgresDriver.simple._
import Database.threadLocalSession

trait TwitterInstance {
  val consumerKey = ""
  val consumerSecret = ""
  val accessToken = ""
  val accessSecret = ""

  val cb = new conf.ConfigurationBuilder()

  cb.setOAuthConsumerKey(consumerKey)
    .setOAuthConsumerSecret(consumerSecret)
    .setOAuthAccessToken(accessToken)
    .setOAuthAccessTokenSecret(accessSecret)

  val twitter = new TwitterFactory(cb.build()).getInstance

}

class Twitter extends TwitterInstance {
  //get timeline
  def getUserTimeline() = twitter.getUserTimeline()

  //insert tweets
  def insertTweets() = {
    val tweets = this.getUserTimeline.iterator
    implicit val session = Database.forURL("jdbc:postgres//localhost/twitter",
                                            driver="org.postgresql.Driver",
                                            user="trenthauck")
    session withTransaction {

      Timeline.ddl.create

      while(tweets.hasNext) {
        var tweet = tweets.next
        Timeline.insert(tweet.getCreatedAt, tweet.getId, tweet.getText)
      }
    }
  }
}

与 twitter 的连接似乎工作得很好，它将数据插入到导致问题的时间线表中。

谢谢

4

3 回答 3

1

您需要定义Timeline类的映射。尝试这个..

def * = date ~ id ~ text <> (Timeline.apply _, Timeline.unapply _)
于 2013-10-19T17:12:57.550 回答
0

从以下位置更改映射器对象：object Timeline

至：object Timelines

然后做Timelines.insert(...)

的内置伴生对象会case class Timeline干扰 Slick 功能。

查看 Slick 文档中的所有示例代码，伴生对象总是复数形式，或者完全删除，而是使用普通的类/实例化。

于 2013-10-20T10:52:36.957 回答
0

vidit 发布的内容意味着您将默认投影映射到 Timeline 案例类，因此您的插入应该使用案例类而不是原始元组。

但是，由于您的代码示例将案例类和表定义为具有相同的名称，因此它可能仍然会出错。我建议你至少重命名你的表，然后你的插入看起来像TimelineTable.insert(Timeline(tweet.getCreatedAt, tweet.getId, tweet.getText))

于 2013-10-20T06:55:08.707 回答