📌  相关文章
📜  OrientDB-Java接口

📅  最后修改于: 2020-11-26 05:44:46             🧑  作者: Mango

与RDBMS相似，OrientDB支持JDBC。为此，首先我们需要配置用于JDBC编程的环境。以下是在应用程序和数据库之间创建连接的过程。

首先，我们需要下载JDBC驱动程序。访问以下链接https://code.google.com/archive/p/orient/downloads下载OrientDB-JDBC。

以下是实现OrientDB-jdbc连接的五个基本步骤。

  • 加载JDBC驱动程序
  • 建立连接
  • 建立陈述
  • 执行语句
  • 紧密连接

例

请尝试以下示例以了解OrientDB-JDBC连接。让我们考虑一下，我们有一个雇员表，其中包含以下字段及其类型。

Sr.No. Field Name Type
1 Id Integer
2 Name String
3 Salary Integer
4 Join date Date

您可以通过执行以下命令来创建模式(表)。

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

执行完所有命令后，您将获得带有以下字段的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

如果上面的命令成功执行，您将获得以下输出。

Records Successfully Inserted