Java ODatabaseInternal类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.orientechnologies.orient.core.db.ODatabaseInternal类的典型用法代码示例。如果您正苦于以下问题：Java ODatabaseInternal类的具体用法？Java ODatabaseInternal怎么用？Java ODatabaseInternal使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ODatabaseInternal类属于com.orientechnologies.orient.core.db包，在下文中一共展示了ODatabaseInternal类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: onOpen

import com.orientechnologies.orient.core.db.ODatabaseInternal; //导入依赖的package包/类
@Override
public void onOpen(final ODatabaseInternal iDatabase) {

  if (iDatabase.getName().equalsIgnoreCase("OSystem"))
    return;

  OLogManager.instance().info(this, "loading ES conf for database %s", iDatabase.getName());
  final OElasticSearchDatabaseSync db = new OElasticSearchDatabaseSync(iDatabase.getName(), getESClient(iDatabase.getName()));
  iDatabase.registerHook(db);
}

开发者ID:orientechnologies，项目名称:orientdb-elasticsearch，代码行数:11，代码来源:OElasticSearchPlugin.java

示例2: onOpen

import com.orientechnologies.orient.core.db.ODatabaseInternal; //导入依赖的package包/类
@Override
public void onOpen(final ODatabaseInternal db) {
  if (OSecurityNull.class.equals(db.getProperty(ODatabase.OPTIONS.SECURITY.toString()))) {
    return; // ignore maintenance operations which run without security, such as index repair
  }
  if (!startRecording(db)) {
    pendingDbs.add(db);
  }
}

开发者ID:sonatype，项目名称:nexus-public，代码行数:10，代码来源:EntityHook.java

示例3: onClose

import com.orientechnologies.orient.core.db.ODatabaseInternal; //导入依赖的package包/类
@Override
public void onClose(final ODatabaseInternal db) {
  if (!pendingDbs.remove(db)) {
    stopRecording(db);
    flushEvents(db);
  }
}

开发者ID:sonatype，项目名称:nexus-public，代码行数:8，代码来源:EntityHook.java

示例4: recordEvent

import com.orientechnologies.orient.core.db.ODatabaseInternal; //导入依赖的package包/类
private boolean recordEvent(final ODocument document, final EventKind eventKind) {
  final OClass schemaType = document.getSchemaClass();
  if (schemaType != null) {
    final EntityAdapter adapter = recordingAdapters.get(schemaType);
    if (adapter != null) {
      final ODatabaseInternal db = ODatabaseRecordThreadLocal.INSTANCE.get();
      if (db != null) {
        // workaround OrientDB 2.1 issue where in-TX dictionary updates are not replicated
        if (db.getStorage().isDistributed() && adapter instanceof SingletonEntityAdapter) {
          ((SingletonEntityAdapter) adapter).singleton.replicate(document, eventKind);
        }
        Map<ODocument, EventKind> events = dbEvents.get(db);
        if (events == null) {
          events = new LinkedHashMap<>();
          dbEvents.put(db, events);
        }
        // replace mapping after merge so key always points to the latest document instance
        // (avoids a risk that the original key became disconnected/detached at this point)
        EventKind updatedEventKind = updateEventKind(events.remove(document), eventKind);
        if (updatedEventKind != null) {
          events.put(document, updatedEventKind);
        }
        return true;
      }
    }
  }
  return false;
}

开发者ID:sonatype，项目名称:nexus-public，代码行数:29，代码来源:EntityHook.java