OrientDB Java連線操作


與RDBMS類似,OrientDB支援JDBC。 為此,首先我們需要組態JDBC程式設計環境。 以下是在應用程式和資料庫之間建立連線的過程。

首先,我們需要下載JDBC驅動程式。 請存取以下連結
https://code.google.com/archive/p/orient/downloads 下載OrientDB-JDBC。

以下是實現OrientDB-jdbc連線的基本五個步驟。

  • 載入JDBC驅動程式
  • 建立連線
  • 建立語句
  • 執行語句
  • 關閉連線

範例

嘗試以下範例來了解OrientDB-JDBC連線。假設有一個雇員表,其中包含以下欄位及其型別。

編號 屬性 型別
1 Id Integer
2 Name String
3 Salary Integer
4 Join date Date

可以通過執行以下命令來建立一個Schema(表)。

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表,其中包含以下欄位:idnamesalaryjoin_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