OrientDB - Java接口

2018-12-24 16:22 更新

與RDBMS類似,OrientDB支持JDBC。 為此,首先我們需要配置JDBC編程的環(huán)境。 以下是在應(yīng)用程序和數(shù)據(jù)庫之間創(chuàng)建連接的過程。
首先,我們需要下載JDBC驅(qū)動程序。 訪問以下鏈接https://code.google.com/archive/p/orient/downloads下載OrientDB-JDBC。
以下是實現(xiàn)OrientDB-jdbc連接的基本五個步驟。
1、加載JDBC驅(qū)動程序
2、創(chuàng)建連接
3、創(chuàng)建語句
4、執(zhí)行語句
5、關(guān)閉連接

嘗試以下示例來了解OrientDB-JDBC連接。 讓我們考慮我們有一個employee表,它包含以下字段及其類型。

編號字段名稱類型
1ID整數(shù)
2Name
3Salary
整數(shù)
4Join date
日期

您可以創(chuàng)建通過執(zhí)行以下命令的架構(gòu)(表)。

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 

執(zhí)行所有命令后,您將獲得具有以下字段的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 

如果成功執(zhí)行上面的命令,你會得到下面的輸出:

Records Successfully Inserted 

以上內(nèi)容是否對您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號