OrientDB-Javaインターフェース
RDBMSと同様に、OrientDBはJDBCをサポートします。このために、最初にJDBCプログラミング用の環境を構成する必要があります。以下は、アプリケーションとデータベース間の接続を作成する手順です。
まず、JDBCドライバーをダウンロードする必要があります。次のリンクにアクセスしてくださいhttps://code.google.com/archive/p/orient/downloads OrientDB-JDBCをダウンロードします。
以下は、OrientDB-jdbc接続を実現するための基本的な5つのステップです。
- JDBCドライバーをロードします
- 接続を作成する
- ステートメントを作成する
- ステートメントを実行する
- 接続を閉じる
例
次の例を試して、OrientDB-JDBC接続を理解してください。次のフィールドとそのタイプを含むemployeeテーブルがあるとします。
シニア番号 | フィールド名 | タイプ |
---|---|---|
1 | Id | 整数 |
2 | 名前 | ストリング |
3 | 給料 | 整数 |
4 | 参加日 | 日付 |
次のコマンドを実行して、スキーマ(テーブル)を作成できます。
CREATE DATABASE PLOCAL:/opt/orientdb/databases/testdb
CREATE CLASS Employee
CREATE PROPERTY Customer.id integer
CREATE PROPERTY Customer.name String
CREATE PROPERTY Customer.salary integer
CREATE PROPERTY Customer.join_date date
すべてのコマンドを実行すると、次のフィールドを持つEmployeeテーブル、idを持つ従業員名、age、およびjoin_dateフィールドが取得されます。
次のコードをに保存します OrientJdbcDemo.java ファイル。
import com.orientechnologies.common.log.OLogManager;
import com.orientechnologies.orient.core.db.document.ODatabaseDocumentTx;
import org.junit.After;
import org.junit.Before;
import org.junit.BeforeClass;
import java.io.File;
import java.sql.DriverManager;
import java.util.Properties;
import static com.orientechnologies.orient.jdbc.OrientDbCreationHelper.createSchemaDB;
import static com.orientechnologies.orient.jdbc.OrientDbCreationHelper.loadDB;
import static java.lang.Class.forName;
public abstract class OrientJdbcDemo {
protected OrientJdbcConnection conn;
public static void main(String ar[]){
//load Driver
forName(OrientJdbcDriver.class.getName());
String dbUrl = "memory:testdb";
ODatabaseDocumentTx db = new ODatabaseDocumentTx(dbUrl);
String username = "admin";
String password = "admin";
createSchemaDB(db);
loadDB(db, 20);
dbtx.create();
//Create Connection
Properties info = new Properties();
info.put("user", username);
info.put("password", password);
conn = (OrientJdbcConnection) DriverManager.getConnection("jdbc:orient:" + dbUrl, info);
//create and execute statement
Statement stmt = conn.createStatement();
int updated = stmt.executeUpdate("INSERT into emplyoee
(intKey, text, salary, date) values ('001','satish','25000','"
+ date.toString() + "')");
int updated = stmt.executeUpdate("INSERT into emplyoee
(intKey, text, salary, date) values ('002','krishna','25000','"
+ date.toString() + "')");
System.out.println("Records successfully inserted");
//Close Connection
if (conn != null && !conn.isClosed())
conn.close();
}
}
上記のプログラムをコンパイルするには、次のコマンドを使用します。
$ javac –classpath:.:orientdb-jdbc-1.0-SNAPSHOT.jar OrientJdbcDemo.java
$ java –classpath:.:orientdb-jdbc-1.0-SNAPSHOT.jar OrientJdbcDemo
上記のコマンドが正常に実行されると、次の出力が得られます。
Records Successfully Inserted