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