#OrientDB tutorial in Japanese intro: http://tinyurl.com/354hklo api: http://tinyurl.com/37v5ya5 #nosql #graphdb
Luca Garulli
lgarulli
package orientdbsample;
import com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx;
public class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// 接続の解除
database.close();
}
}以降は上記のソースを基本に処理のコードを追加していきますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// Rebellion クラスのレコードを作成
// ※指定したクラスがデータベースに存在しない場合、自動的に作成してくれます
ODocument document = new ODocument(database, "Rebellion");
document.field("name", "Luke");
document.field("surname", "Skywalker");
document.save();
// メソッドチェーンを利用して、 Rebellion クラスのレコードを作成
new ODocument(database, "Rebellion").field("name", "Han").field("surname", "Solo").save();
// 接続の解除
database.close();
}
}ORientDB ではドキュメントは ODocument クラスを使用して表しますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// INSERT 文を作成する
String insertQuery = "insert into Rebellion (name) values ('Chewbacca')";
// クエリを実行します
database.command(new OCommandSQL(insertQuery)).execute();
// 接続の解除
database.close();
}
}次に browseClass メソッドを使用して、先ほど登録した Rebellion クラスの全レコードを表示しますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// Rebellion クラスのレコードのリストを取得
Iterable<ODocument> documents = database.browseClass("Rebellion");
// レコードのリストから各レコードを取得します
for (ODocument person : documents) {
// レコードの各フィールドを取得
// レコード ID を取得
System.out.println("Rec ID : " + person.getIdentity());
System.out.println("Name : " + person.field("name"));
System.out.println("Surname: " + person.field("surname"));
}
// 接続の解除
database.close();
}
}public class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// Rebellion クラスのレコード件数を取得します
long count = database.countClass("Rebellion");
System.out.println("Count: " + count);
// 接続の解除
database.close();
}
}また、個別のレコードを抽出するにはクエリを使用しますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// クエリ文字列を作成する
// name フィールドのフィールド値が "L" で始まるもののみ抽出する
String query = "select from Rebellion where name like 'L%' ";
// クエリを実行し、結果のリストを取得します
List<ODocument> documents = database.query(new OSQLSynchQuery<ODocument>(query));
// レコードのリストから各レコードを取得します
for (ODocument person : documents) {
// レコードの各フィールドを取得
// レコード ID を取得
System.out.println("Rec ID : " + person.getIdentity());
System.out.println("Name : " + person.field("name"));
System.out.println("Surname: " + person.field("surname"));
}
// 接続の解除
database.close();
}
}実行後、以下のように出力されるかと思いますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
ODocument person = null;
// SELECT 文を作成する
String selectQuery = "select from Rebellion where @rid = 19:0";
// クエリを実行し、その結果のリストを取得します
person = ((List<ODocument>) database.query(new OSQLSynchQuery<ODocument>(selectQuery))).get(0);
// レコードの各フィールドを取得
System.out.println("Rec ID : " + person.getIdentity());
System.out.println("Name : " + person.field("name"));
System.out.println("Surname: " + person.field("surname"));
System.out.println("----------");
// "name" フィールドのフィールド値を "" 更新する
person.field("name", "Ben");
person.save();
// クエリを実行し、その結果のリストを取得します
person = ((List<ODocument>) database.query(new OSQLSynchQuery<ODocument>(selectQuery))).get(0);
// レコードの各フィールドを取得
System.out.println("Rec ID : " + person.getIdentity());
System.out.println("Name : " + person.field("name"));
System.out.println("Surname: " + person.field("surname"));
System.out.println("----------");
// UPDATE 文を作成する
String updateQuery = "update Rebellion set name = 'Anakin' where @rid = 19:0";
// クエリを実行します
database.command(new OCommandSQL(updateQuery)).execute();
// クエリを実行し、その結果のリストを取得します
person = ((List<ODocument>) database.query(new OSQLSynchQuery<ODocument>(selectQuery))).get(0);
// レコードの各フィールドを取得
System.out.println("Rec ID : " + person.getIdentity());
System.out.println("Name : " + person.field("name"));
System.out.println("Surname: " + person.field("surname"));
System.out.println("----------");
// 接続の解除
database.close();
}
}実行後、以下のように出力されるかと思いますpublic class Main {
public static void main(String[] args) {
// admin ユーザでサーバーの demo データベースに接続します
ODatabaseDocumentTx database = new ODatabaseDocumentTx("remote:localhost/demo").open("admin", "admin");
// SELECT 文を作成する
String selectQuery = "select from Rebellion where @rid = 19:0 ";
// レコードのリストから各レコードを取得します
for (ODocument document : database.browseClass("Rebellion")) {
// レコードの各フィールドを取得
System.out.println("Rec ID : " + document.getIdentity());
System.out.println("Name : " + document.field("name"));
System.out.println("Surname: " + document.field("surname"));
}
System.out.println("----------");
// クエリを実行し、その結果を取得します
ODocument person = ((List<ODocument>) database.query(new OSQLSynchQuery<ODocument>(selectQuery))).get(0);
// 取得したレコードの delete() メソッドを実行し、レコードを削除
person.delete();
// DELETE 文を作成する(全件削除)
String deleteQuery = "delete from Rebellion";
// クエリを実行します
database.command(new OCommandSQL(deleteQuery)).execute();
// Rebellion クラスの件数取得(レコード有無判定)
if(database.countClass("Rebellion") > 0) {
// レコードのリストから各レコードを取得します
for (ODocument document : database.browseClass("Rebellion")) {
// レコードの各フィールドを取得
System.out.println("Rec ID : " + document.getIdentity());
System.out.println("Name : " + document.field("name"));
System.out.println("Surname: " + document.field("surname"));
}
} else {
System.out.println("Rebellion クラスにはレコードは存在しません");
}
// 接続の解除
database.close();
}
}実行後、以下のように出力されるかと思います<?xml version="1.0" encoding="UTF-8" standalone="yes"?> <orient-server> <network> <protocols> <protocol implementation="com.orientechnologies.orient.server.network.protocol.binary.ONetworkProtocolBinary" name="binary"/> <protocol implementation="com.orientechnologies.orient.server.network.protocol.http.ONetworkProtocolHttpDb" name="http"/> </protocols> <listeners> <listener protocol="binary" port-range="2424-2430" ip-address="127.0.0.1"/> <listener protocol="http" port-range="2480-2490" ip-address="127.0.0.1"> <!-- 〜中略〜 --> </orient-server>