OrientDB - Giao diện Java

Tương tự như RDBMS, OrientDB hỗ trợ JDBC. Đối với điều này, trước tiên chúng ta cần cấu hình môi trường để lập trình JDBC. Sau đây là quy trình để tạo kết nối giữa ứng dụng và cơ sở dữ liệu của bạn.

Đầu tiên, chúng ta cần tải xuống Trình điều khiển JDBC. Truy cập liên kết sauhttps://code.google.com/archive/p/orient/downloads để tải xuống OrientDB-JDBC.

Sau đây là năm bước cơ bản để đạt được kết nối OrientDB-jdbc.

Tải trình điều khiển JDBC
Tạo kết nối
Tạo tuyên bố
Thực thi câu lệnh
Đóng kết nối

Thí dụ

Hãy thử ví dụ sau để hiểu kết nối OrientDB-JDBC. Hãy xem xét chúng ta có một bảng nhân viên chứa các trường sau đây và các loại của nó.

Sr.No.	Tên trường	Kiểu
1	Tôi	Số nguyên
2	Tên	Chuỗi
3	Tiền lương	Số nguyên
4	Ngày tham gia	Ngày

Bạn có thể tạo một Lược đồ (bảng) bằng cách thực hiện các lệnh sau.

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

Sau khi thực hiện tất cả các lệnh, bạn sẽ nhận được bảng Nhân viên với các trường sau, tên nhân viên với các trường id, age và join_date.

Lưu mã sau vào OrientJdbcDemo.java tập tin.

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(); 
   } 
}

Lệnh sau dùng để biên dịch chương trình trên.

$ javac –classpath:.:orientdb-jdbc-1.0-SNAPSHOT.jar OrientJdbcDemo.java  
$ java –classpath:.:orientdb-jdbc-1.0-SNAPSHOT.jar OrientJdbcDemo

Nếu lệnh trên được thực hiện thành công, bạn sẽ nhận được kết quả sau.

Records Successfully Inserted