OrientDB - อินเตอร์เฟส Java

เช่นเดียวกับ RDBMS OrientDB รองรับ JDBC สำหรับสิ่งนี้อันดับแรกเราต้องกำหนดค่าสภาพแวดล้อมสำหรับการเขียนโปรแกรม JDBC ต่อไปนี้เป็นขั้นตอนในการสร้างการเชื่อมต่อระหว่างแอปพลิเคชันและฐานข้อมูลของคุณ

ก่อนอื่นเราต้องดาวน์โหลด JDBC Driver ไปที่ลิงค์ต่อไปนี้https://code.google.com/archive/p/orient/downloads เพื่อดาวน์โหลด OrientDB-JDBC

ต่อไปนี้เป็นห้าขั้นตอนพื้นฐานเพื่อให้บรรลุการเชื่อมต่อ OrientDB-jdbc

โหลดไดรเวอร์ JDBC
สร้างการเชื่อมต่อ
สร้างคำสั่ง
ดำเนินการคำสั่ง
ปิดการเชื่อมต่อ

ตัวอย่าง

ลองใช้ตัวอย่างต่อไปนี้เพื่อทำความเข้าใจการเชื่อมต่อ OrientDB-JDBC ให้เราพิจารณาว่าเรามีตารางพนักงานซึ่งมีฟิลด์และประเภทต่อไปนี้

ซีเนียร์	ชื่อฟิลด์	ประเภท
1	Id	จำนวนเต็ม
2	ชื่อ	สตริง
3	เงินเดือน	จำนวนเต็ม
4	วันที่เข้าร่วม	วันที่

คุณสามารถสร้าง 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

หลังจากดำเนินการคำสั่งทั้งหมดคุณจะได้รับตารางพนักงานพร้อมฟิลด์ต่อไปนี้ชื่อพนักงานพร้อม ID อายุและฟิลด์ 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