2

我试图弄清楚如何将我自己的闭包表实现从另一种语言移植到 Scala，同时考虑到并发性。

我有两个模型，一个节点（id | parentID）和一个 NodeTree（id | 祖先 | 后代），其中每个条目都类似于树中的一条边。

对于每个新节点，我必须执行以下操作：查询所有祖先（或为它们过滤 TableQuery），然后为每个祖先添加一个 NodeTree-Entry（一条边）

感谢黑豹，我走到了这一步：

private val nodes = TableQuery[Nodes]

override def create(node: Node): Future[Seq[Int]] =
    {
        val createNodesAction = (
            for
            {
                parent <- nodes
                node <- (nodeTrees returning nodeTrees.map(_.id) into ((ntEntry, ntId) => ntEntry.copy(id = Some(ntId))) += NodeTree(id = None, ancestor = parent.id, descendant = node.id, deleted = None, createdAt = new Timestamp(now.getTime), updatedAt = new Timestamp(now.getTime)))
            } yield (node)
        ).transactionally

        db run createNodesAction
    }

但这会导致类型不匹配；

类型不匹配; 找到：slick.lifted.Rep[Long] 需要：Option[Long]

再一次：我想要做的是：对于每个 parentNode（= 每个父节点的父节点，直到最后一个祖先节点没有父节点！）我想在 nodeTree 中创建一个条目，以便稍后我可以轻松地获取所有后代和祖先只需另一个通过 NodeTree-Table 过滤的方法调用。

（只是一个封闭表，真的）

编辑：这些是我的模型

case class Node(id: Option[Long], parentID: Option[Long], level: Option[Long], deleted: Option[Boolean], createdAt: Timestamp, updatedAt: Timestamp)

class Nodes(tag: Tag) extends Table[Node](tag, "nodes")
{
    implicit val dateColumnType = MappedColumnType.base[Timestamp, Long](d => d.getTime, d => new Timestamp(d))

    def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
    def parentID = column[Long]("parent_id")
    def level = column[Long]("level")
    def deleted = column[Boolean]("deleted")
    def createdAt = column[Timestamp]("created_at")
    def updatedAt = column[Timestamp]("updated_at")

    def * = (id.?, parentID.?, level.?, deleted.?, createdAt, updatedAt) <> (Node.tupled, Node.unapply)
}

case class NodeTree(id: Option[Long], ancestor: Option[Long], descendant: Option[Long], deleted: Option[Boolean], createdAt: Timestamp, updatedAt: Timestamp)

class NodeTrees(tag: Tag) extends Table[NodeTree](tag, "nodetree")
{
    implicit val dateColumnType = MappedColumnType.base[Timestamp, Long](d => d.getTime, d => new Timestamp(d))

    def id = column[Long]("id", O.PrimaryKey, O.AutoInc)
    def ancestor = column[Long]("ancestor")
    def descendant = column[Long]("descendant")
    def deleted = column[Boolean]("deleted")
    def createdAt = column[Timestamp]("created_at")
    def updatedAt = column[Timestamp]("updated_at")

    def * = (id.?, ancestor.?, descendant.?, deleted.?, createdAt, updatedAt) <> (NodeTree.tupled, NodeTree.unapply)
}

我想要做的是一个闭包表（http://technobytz.com/closure_table_store_hierarchical_data.html），当我创建一个节点时它会自动填充它的边缘（nodeTree）。所以我不想手动将所有这些条目添加到数据库中，但是当我在第 5 级创建节点时，我希望自动创建整个路径（= nodetree-table 中的条目）。

我希望这能澄清一些事情:)

4

2 回答 2

1

尝试这个：

override def create(node: Node): Future[Seq[Int]] =
{
    val parents = getAllParents(node)
    val createNodesAction = (
      for {
        parent <- parents
        node <- nodeTrees += NodeTree(id = None, ancestor = parent.id, descendant = node.id)
      } yield (node)
    ).transactionally

   db run createNodesAction
}

您不必分别单独检索父母。它可以在同一个会话中完成。在上面，您可以轻松地将“父母”替换为您想要处理的 TableQuery（带或不带过滤器）。

另请注意，在这里您将返回受插入操作影响的行数序列。要改为返回节点 ID 列表（假设您在 db 中将节点 ID 标记为 AUTO_INC），那么您可以执行以下操作：

override def create(node: Node): Future[Seq[Int]] =
{
    val createNodesAction = (
      for {
        parent <- parents
        node <- (nodeTrees returning nodeTrees.map(_.id) into ((ntEntry, ntId) => ntEntry.copy(id = Some(ntId))) += NodeTree(id = None, ancestor = parent.id, descendant = node.id)
      } yield (node)
    ).transactionally

   db run createNodesAction
}

区别在于：(nodeTrees 返回 nodeTrees.map(_.id) 到 ((ntEntry, ntId) => ntEntry.copy(id = Some(ntId)))而不仅仅是(nodeTrees)检索和映射自动 inc id 到结果。

更新：试试这个：

override def create(node: Node): Future[Seq[Int]] =
{
    def createNodesAction(parentId: Long): DBIOAction[NodeTree, NoStream, Read with Write] = (
      for {
        node <- (nodeTrees returning nodeTrees.map(_.id) into ((ntEntry, ntId) => ntEntry.copy(id = Some(ntId))) += NodeTree(id = None, ancestor = parentId, descendant = node.id)
      } yield (node)
    ).transactionally

   // TODO: Init and pass in 'parents'
   db.run(DBIO.sequence(parents.map(createNodesAction(_.id)))
}
于 2015-05-19T21:34:47.397 回答
0

尝试更改为该行。

  node <- (nodeTrees returning nodeTrees.map(_.id) into ((ntEntry, ntId) => ntEntry.copy(id = ntId)) += NodeTree(id = None, ancestor = parent.id, descendant = node.id, deleted = None, createdAt = new Timestamp(now.getTime), updatedAt = new Timestamp(now.getTime)))

它解决了这个问题吗？很难从您的问题中确切地说出您的模型是什么。

于 2015-06-29T17:43:54.583 回答