• エッジの追加はどうするの？
  • node1.createRelationshipTo(node2, relation) でnode1からnode2へrelationを表すエッジが作成されます

• relationて何？
  • エッジは単なる矢印でなく、それに種類を定義できます。

• で、relationて何？
  • つまりノード間に意味が発生するので、そのつながり方を「関係」として捉えているのです

• どうやって定義するの？
  • DynamicRelationshipType.withName(name)で動的に作ることが出来ます

• nameには何を指定するの？
  • 関係を意味する文字列です。好きな文字列で構いません。ラベルと思ってOKです

scala> import org.neo4j.graphdb.{Node,DynamicRelationshipType} scala> val love = DynamicRelationshipType.withName("Love")

• キャー、Love作っちゃった！岡井ちゃんに向けていい？
  • ご自由にどうぞ

rm -rf /tmp/neo1

import org.neo4j.kernel.EmbeddedGraphDatabase
import org.neo4j.graphdb.{Node,DynamicRelationshipType}

val db = new EmbeddedGraphDatabase("/tmp/neo1")
val tx = db.beginTx

// 舞波
val maiha = db.createNode
maiha.setProperty("name", "舞波")

// 岡井ちゃん
val okai = db.createNode
okai.setProperty("name","岡井")

// Love
val love = DynamicRelationshipType.withName("Love")
maiha.createRelationshipTo(okai, love)

tx.success
tx.finish
db.shutdown

Love 　[舞波] ---> [岡井]

現在のDB内のグラフ（想像）

• 本当にグラフできてるの？
  • node.getRelationships でそのノードが持つ関連(エッジ)のイテレータを取得できます

import org.neo4j.kernel.EmbeddedGraphDatabase
import scala.collection.JavaConversions._
val db = new EmbeddedGraphDatabase("/tmp/neo1")
val n1 = db.getNodeById(1)

scala> n1.getRelationships foreach(println) Relationship[0]

• うほ！中身はどうやってみるの？
  • TABろう

scala> val r = n1.getRelationships head r: org.neo4j.graphdb.Relationship = Relationship[0] scala> r. asInstanceOf compareTo delete getEndNode getGraphDatabase getId getNodes getOtherNode getProperty getPropertyKeys getPropertyValues getStartNode getType hasProperty isInstanceOf isType removeProperty setProperty toString

• これがどういう関連(エッジ)かを見るには？
  • getType

scala> r.getType res8: org.neo4j.graphdb.RelationshipType = Love

• Loveキタ！誰に向いてるかは？
  • getEndNode

scala> r.getEndNode res9: org.neo4j.graphdb.Node = Node[2] scala> r.getEndNode.getProperty("name") res10: java.lang.Object = 岡井

• グラフを全部表示して

import org.neo4j.kernel.EmbeddedGraphDatabase
import scala.collection.JavaConversions._
def inspectNeo(path:String) {
  val db = new EmbeddedGraphDatabase(path)
  for (n1 <- db.getAllNodes) {
    for (r <- n1.getRelationships) {
      val n2 = r.getEndNode
      if (n1 != n2) printf("[%s] --(%s)--> [%s]\n",
        n1.getProperty("name"), r.getType, n2.getProperty("name"))
    }
  }
}

scala> inspectNeo("/tmp/neo1") [舞波] --(Love)--> [岡井]

• グラフの作り方はわかったけど、createほげほげとか面倒だね
  • そんなあなたにneo4j-scala

http://github.com/jawher/neo4j-scala

1. エッジの作成を "-->" でできるようになる
2. node(key) = value でプロパティを扱えるようになる
3. execInNeo4jでトランザクション処理を行う

rm -rf /tmp/neo1

import org.neo4j.kernel.EmbeddedGraphDatabase
import org.neo4j.scala.Neo4jWrapper

object world extends Neo4jWrapper {
  implicit val neo = new EmbeddedGraphDatabase("/tmp/neo1")
  execInNeo4j { neo =>
    val chisa = neo.createNode; chisa("name") = "岡井"
    val mai   = neo.createNode; mai("name")   = "萩原"
    val airi  = neo.createNode; airi("name")  = "鈴木"
    val momo  = neo.createNode; momo("name")  = "嗣永"

    chisa --> "疎遠" --> airi <-- "危機感" <-- momo
    airi  --> "疎遠" --> chisa
    chisa --> "親密" --> mai
  }
  neo.shutdown
}
world

scala> inspectNeo("/tmp/neo1") [岡井] --(親密)--> [萩原] [岡井] --(疎遠)--> [鈴木] [鈴木] --(疎遠)--> [岡井] [嗣永] --(危機感)--> [鈴木]

• こ、これがコードなのか！Scalaの表現力はバケモノか！
  • Scalaの演算子定義は上手く使うと楽しいですね

• DBへの接続は？
  • 多分 EmbeddedGraphDatabase クラスを使う

import org.neo4j.kernel.EmbeddedGraphDatabase
val db = new EmbeddedGraphDatabase("/tmp/neo1")                 

• DBで何ができるの？
  • REPLでTABってみる

scala> db. asInstanceOf beginTx createNode enableRemoteShell getAllNodes getConfig getManagementBean getNodeById getReferenceNode getRelationshipById getRelationshipTypes getStoreDir index isInstanceOf isReadOnly registerKernelEventHandler registerTransactionEventHandler shutdown toString unregisterKernelEventHandler unregisterTransactionEventHandler

• グラフにノードを追加するには？
  • createNodeがそれっぽい

scala> db.createNode org.neo4j.graphdb.NotInTransactionException

• なんかでたよ？
  • createNodeはトランザクション内で実行する必要があるっぽい

• トランザクションの開始は？
  • beginTxがそれっぽい

scala> db.beginTx res1: org.neo4j.graphdb.Transaction = org.neo4j.kernel.TopLevelTransaction@329a0466 scala> db.createNode res2: org.neo4j.graphdb.Node = Node[2]

• ノード作成できた！
  • おつかれちゃん
• 一度終了して、REPL立ち上げなおして確認しよう
  • そうしましょう

scala> import org.neo4j.kernel.EmbeddedGraphDatabase scala> val db = new EmbeddedGraphDatabase("/tmp/neo1") org.neo4j.graphdb.TransactionFailureException: Could not create data source [nioneodb], see nested exception for cause of error

• あれ、繋がらなくなった？
  • 正常にシャットダウンしないとこうなるらしい（ぐぐった）
• どうやって修復するの？
  • 接続中のJVMプロセスが残っているのでkillする
• はい、殺して REPL を立ち上げなおしました
  • 乙
• さっき作ったノードはどうやって取るの？
  • getNodeById がそれっぽい

scala> db.getNodeById() :8: error: not enough arguments for method getNodeById: (x$1: Long)org.neo4j.graphdb.Node. Unspecified value parameter x$1. db.getNodeById() ^

• いやいや、IDとか覚えてねーし
  • どうせシーケンシャルだろうから1じゃね？

scala> db.getNodeById(1) org.neo4j.graphdb.NotFoundException: Node[1] at org.neo4j.kernel.impl.core.NodeManager.getNodeById(NodeManager.java:388)

• ちょｗ
  • 2回実行したから2かも

scala> db.getNodeById(2) org.neo4j.graphdb.NotFoundException: Node[2]

• ちょｗｗ
  • じゃあ、3...
• もう騙されないぞ！
  • getAllNodes てのがあるから、そっちやってみよう

scala> db.getAllNodes res9: java.lang.Iterable[org.neo4j.graphdb.Node] = org.neo4j.kernel.EmbeddedGraphDbImpl$2@24174be7

• Nodeクラスだってよ
  • 変数に入れてTABろう

scala> val nodes = db.getAllNodes scala> nodes. asInstanceOf isInstanceOf iterator toString

• iteratableか、面倒だな。全部ガツーンと返せよ！
  • 1億件あったらお前文句言うじゃん
• ですよねー
  • foreachで見てみよう

scala> nodes foreach println :11: error: value foreach is not a member of java.lang.Iterable[org.neo4j.graphdb.Node] nodes foreach println ^

• あぁ、Javaのクラスだから互換ないのか。どうするんだっけ？
  • import scala.collection.JavaConversions._

scala> import scala.collection.JavaConversions._ scala> nodes foreach println Node[0]

• うわぁ、0オリジンかよー！
  • ついてないね
• ノードの情報を見るには？
  • TABろう

scala> val node = nodes head node: org.neo4j.graphdb.Node = Node[0] scala> node. asInstanceOf compareTo createRelationshipTo delete getGraphDatabase getId getProperty getPropertyKeys getPropertyValues getRelationships getSingleRelationship hasProperty hasRelationship isInstanceOf removeProperty setProperty toString traverse

• お、getIdがある
  • もちろん0なんだろうな

scala> node.getId res5: Long = 0

• おういえ！
  • getProperty てのもあるよ

scala> node.getProperty :15: error: ambiguous reference to overloaded definition, both method getProperty in trait PropertyContainer of type (x$1: java.lang.String,x$2: Any)java.lang.Object and method getProperty in trait PropertyContainer of type (x$1: java.lang.String)java.lang.Object match expected type ? node.getProperty ^

• 引数が必要だって
  • まぁ、そうだろうね
• 有効なプロパティ名は？
  • nameぐらいはあるだろJK

scala> node.getProperty("name") org.neo4j.graphdb.NotFoundException: name property not found for NodeImpl#0.

• お前、意外と適当だな
  • getPropertyKeys があるよ（無視しながら）

scala> node.getPropertyKeys res8: java.lang.Iterable[java.lang.String] = []

• 何も入ってねーぞ！
  • 何も設定してないからね
• 名前入れるぞー！
  • よっしゃ、いったれー

scala> node.setProperty("name", "maiha") org.neo4j.graphdb.NotInTransactionException at org.neo4j.kernel.impl.core.LockReleaser.getAndSetupPrimitiveEleme

• 俺達・・・
  • 学習しないよね

scala> db.beginTx scala> node.setProperty("name", "maiha")

• お、エラーでない！
  • 中身の確認を早く！

scala> node.getPropertyKeys res12: java.lang.Iterable[java.lang.String] = [name] scala> node.getProperty("name") res13: java.lang.Object = maiha

• キター！
  • キテルー！！
• 一旦終了して、再REPLで保存されてるか確認しよう
  • 参照だからTXは不要で、ノードIDは0と

import org.neo4j.kernel.EmbeddedGraphDatabase
val db = new EmbeddedGraphDatabase("/tmp/neo1")   
val node = db.getNodeById(0)
println(node.getProperty("name"))

org.neo4j.graphdb.NotFoundException: name property not found for NodeImpl#0.

• んな、バカな！
  • nodeのkeysはどうなってる？

scala> node.getPropertyKeys res1: java.lang.Iterable[java.lang.String] = []

• 空じゃねーか！
  • そもそも保存されてないってことか
• さっきは見えてたじゃん？
  • transactionだからcommitする必要があったのかも
• あぁ、そのままREPL閉じたからabort扱い？
  • 恐らく
• てことは、このID=0のノードはどうやって保存したの？
  • 多分、初期ノード？
• ふーん。新規に保存してみるか。コミットはどうするの？
  • dbオブジェクトにはメソッドないね
• ちょｗ
  • TXオブジェクトにあるみたい（ぐぐった）
• てことは、変数に入れて
  • TAB!

scala> val tx = db.beginTx tx: org.neo4j.graphdb.Transaction = org.neo4j.kernel.TopLevelTransaction@106f29c8 scala> tx. asInstanceOf failure finish isInstanceOf success toString

• failureがabortとして、finishとsuccessってどっちだ？
  • finishはcloseぽい（ぐぐった）

• もっかいREPL再起動
  • よっしゃいくぞー

import org.neo4j.kernel.EmbeddedGraphDatabase
val db = new EmbeddedGraphDatabase("/tmp/neo1")
val tx = db.beginTx
val n1 = db.createNode
n1.setProperty("name", "maiha")
tx.success
tx.finish
db.shutdown

• 保存できたー！（多分）
  • 再REPLで内容確認だー！

import org.neo4j.kernel.EmbeddedGraphDatabase
import scala.collection.JavaConversions._
val db = new EmbeddedGraphDatabase("/tmp/neo1")
db.getAllNodes foreach println

Node[0] Node[1]

• おぉ！Node[1]キター！
  • 名前！名前！

scala> db.getNodeById(1).getProperty("name") res8: java.lang.Object = maiha

• キター！
  • キテター！

[(root node?)] [name:maiha]

現在のDB内のグラフ（想像）