OrientDB - Java Arayüzü

RDBMS'ye benzer şekilde OrientDB, JDBC'yi destekler. Bunun için önce JDBC programlama için ortamı yapılandırmamız gerekiyor. Aşağıda, uygulamanız ve veritabanı arasında bir bağlantı oluşturma prosedürü açıklanmaktadır.

Öncelikle, JDBC Sürücüsünü indirmemiz gerekiyor. Aşağıdaki bağlantıyı ziyaret edinhttps://code.google.com/archive/p/orient/downloads OrientDB-JDBC'yi indirmek için.

Aşağıda, OrientDB-jdbc bağlantısını elde etmek için temel beş adım verilmiştir.

  • JDBC sürücüsünü yükle
  • Bağlantı Oluştur
  • İfade oluştur
  • İfadeyi yürüt
  • Yakın bağlantı

Misal

OrientDB-JDBC bağlantısını anlamak için aşağıdaki örneği deneyin. Aşağıdaki alanları ve türlerini içeren bir çalışan tablomuz olduğunu düşünelim.

Sr.No. Alan adı Tür
1 İD Tamsayı
2 İsim Dize
3 Maaş Tamsayı
4 Katılma tarihi Tarih

Aşağıdaki komutları uygulayarak bir Şema (tablo) oluşturabilirsiniz.

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

Tüm komutları yürüttükten sonra, aşağıdaki alanların bulunduğu Çalışan tablosunu, id ile çalışan adı, yaş ve join_date alanlarını alacaksınız.

Aşağıdaki kodu içine kaydedin OrientJdbcDemo.java dosya.

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

Aşağıdaki komut, yukarıdaki programı derlemek için kullanılır.

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

Yukarıdaki komut başarıyla yürütülürse, aşağıdaki çıktıyı alacaksınız.

Records Successfully Inserted