OrientDB Java連接操作

與RDBMS類似，OrientDB支持JDBC。 為此，首先我們需要配置JDBC編程環境。 以下是在應用程式和數據庫之間創建連接的過程。

首先，我們需要下載JDBC驅動程式。 請訪問以下鏈接
https://code.google.com/archive/p/orient/downloads 下載OrientDB-JDBC。

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

• 加載JDBC驅動程式
• 創建連接
• 創建語句
• 執行語句
• 關閉連接

示例

嘗試以下示例來瞭解OrientDB-JDBC連接。假設有一個雇員表，其中包含以下字段及其類型。

可以通過執行以下命令來創建一個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表，其中包含以下字段:id，name，salary和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