本文整理了Java中com.psddev.dari.db.Query.using方法的一些代码示例，展示了Query.using的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Query.using方法的具体详情如下：
包路径：com.psddev.dari.db.Query
类名称：Query
方法名：using

Query.using介绍

暂无

代码示例

代码示例来源：origin: perfectsense/dari

/**
 * Creates a new instance that runs in the given {@code executor},
 * and produces items that match the given {@code query} from the
 * given {@code database} into the given {@code output} queue.
 *
 * @param executor If {@code null}, uses the default executor.
 * @param output If {@code null}, creates a new queue.
 * @param database Can't be {@code null}.
 * @param query Can't be {@code null}.
 * @throws IllegalArgumentException If the given {@code database}
 *         or {@code query} is {@code null}.
 */
public AsyncDatabaseReader(
    String executor,
    AsyncQueue<E> output,
    Database database,
    Query<E> query) {
  super(executor, output);
  if (database == null) {
    throw new IllegalArgumentException("Database can't be null!");
  }
  if (query == null) {
    throw new IllegalArgumentException("Query can't be null!");
  }
  this.iterator = query.using(database).iterable(0).iterator();
}

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("_id = ?", keyId)
.using(database)
.noCache()
.master()

代码示例来源：origin: perfectsense/dari

@Override
  public void doTask() {
    Database database = getDatabase();
    Date newGlobalsUpdate = Query
        .from(Object.class)
        .where("_id = ?", GLOBALS_ID)
        .using(database)
        .lastUpdate();
    if (newGlobalsUpdate != null
        && (lastGlobalsUpdate == null
        || newGlobalsUpdate.after(lastGlobalsUpdate))) {
      refreshGlobals();
    }
    Date newTypesUpdate = Query
        .from(ObjectType.class)
        .using(database)
        .lastUpdate();
    if (newTypesUpdate != null
        && (lastTypesUpdate == null
        || newTypesUpdate.after(lastTypesUpdate))) {
      refreshTypes();
    }
  }
};

代码示例来源：origin: perfectsense/dari

@Override
  @SuppressWarnings("unchecked")
  public void ping() {
    Database defaultDatabase = Database.Static.getDefault();
    if (defaultDatabase instanceof Iterable) {
      for (Database delegate : (Iterable<Database>) defaultDatabase) {
        Query.from(Object.class).using(delegate).first();
      }
    } else {
      Query.from(Object.class).first();
    }
  }
}

代码示例来源：origin: perfectsense/dari

private static Map<String, BootstrapPackage> getPackagesMap(Database database) {
  Map<String, BootstrapPackage> packagesByName = new TreeMap<String, BootstrapPackage>();
  // First create the _init package for the whole database
  BootstrapPackage initPkg = new BootstrapPackage();
  initPkg.setName(INIT_NAME);
  initPkg.setIsInit(true);
  packagesByName.put(INIT_NAME, initPkg);
  for (ObjectType type : database.getEnvironment().getTypes()) {
    TypeData bmod = type.as(TypeData.class);
    for (String name : bmod.getPackageNames()) {
      BootstrapPackage pkg = packagesByName.get(name);
      if (pkg == null) {
        pkg = new BootstrapPackage();
        pkg.setName(name);
        packagesByName.put(name, pkg);
      }
      pkg.getTypes().add(type);
    }
  }
  for (BootstrapPackage pkg : Query.from(BootstrapPackage.class).using(database).selectAll()) {
    packagesByName.put(pkg.getName(), pkg);
  }
  for (Map.Entry<String, BootstrapPackage> entry : packagesByName.entrySet()) {
    checkConsistency(database, entry.getValue(), new HashSet<BootstrapPackage>(packagesByName.values()), null);
  }
  return packagesByName;
}

代码示例来源：origin: perfectsense/dari

Set<UUID> objectIds = ID_CACHE.getIfPresent(url);
if (objectIds != null) {
  Query.from(Object.class).using(caching).where("id = ?", objectIds).selectAll();

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("_id = ?", unresolvedIds)
.using(database)
.option(State.REFERENCE_RESOLVING_QUERY_OPTION, parent)
.option(State.REFERENCE_FIELD_QUERY_OPTION, field)

代码示例来源：origin: perfectsense/dari

private Query<?> createQuery(Database database, WebPageContext context) {
  String queryString = context.param(String.class, WebDatabase.QUERY_PARAMETER);
  Object queryObject = ObjectUtils.fromJson(queryString);
  if (!(queryObject instanceof Map)) {
    throw new DatabaseException(database, String.format(
        "Invalid query string! (%s)", queryString));
  }
  @SuppressWarnings("unchecked")
  Map<String, Object> queryMap = (Map<String, Object>) queryObject;
  convertTypeNameToId(database.getEnvironment(), queryMap);
  Query<?> query = Query.fromAll();
  query.getState().putAll(queryMap);
  query.using(database);
  return query;
}

代码示例来源：origin: perfectsense/dari

LastResummarization last = Query.from(LastResummarization.class).using(database).where("key = ?", key).first();
if (last == null) {
  last = new LastResummarization();

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("_id = ?", id)
.using(this)
.option(CONNECTION_QUERY_OPTION, connection)
.option(RETURN_ORIGINAL_DATA_QUERY_OPTION, Boolean.TRUE)

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("id != ?", state.getId())
.using(state.getDatabase())
.referenceOnly()
.noCache()

代码示例来源：origin: perfectsense/dari

.using(database)
    .selectAll();
int typesSize = types.size();

代码示例来源：origin: perfectsense/dari

Query<?> query = Query.fromAll().using(db).noCache().resolveToReferenceOnly().option(SqlDatabase.USE_JDBC_FETCH_SIZE_QUERY_OPTION, false);
if (!isGlobal) {
  Set<ObjectType> concreteTypes = new HashSet<>();

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("_id = ?", keyId)
.using(database)
.noCache()
.master()

代码示例来源：origin: perfectsense/dari

query.using(caching);
query.resolveInvisible();

代码示例来源：origin: perfectsense/dari

/** Immediately refreshes all globals using the backing database. */
public synchronized void refreshGlobals() {
  bootstrapOnce.ensure();
  Database database = getDatabase();
  LOGGER.info("Loading globals from [{}]", database.getName());
  Query<Object> globalsQuery = Query
      .from(Object.class)
      .where("_id = ?", GLOBALS_ID)
      .using(database)
      .noCache();
  State newGlobals = State.getInstance(globalsQuery.first());
  if (newGlobals == null) {
    newGlobals = State.getInstance(globalsQuery.master().first());
  }
  if (newGlobals == null) {
    newGlobals = new State();
    newGlobals.setDatabase(database);
    newGlobals.setId(GLOBALS_ID);
    newGlobals.save();
  }
  globals = newGlobals;
  lastGlobalsUpdate = new Date();
  fieldsCache.reset();
  metricFieldsCache.reset();
  indexesCache.reset();
}

代码示例来源：origin: perfectsense/dari

State state = State.getInstance(Query.fromAll()
    .where("_id = ?", page.param(UUID.class, "id"))
    .using(database)
    .resolveInvisible()
    .first());

代码示例来源：origin: perfectsense/dari

/**
 * Validates the given {@code state} against the constraints defined
 * in this index.
 *
 * @return {@code true} if there aren't any errors.
 */
public boolean validate(State state) {
  if (isUnique()) {
    Object value = getValue(state);
    if (!ObjectUtils.isBlank(value)) {
      Object duplicate = Query
          .from(Object.class)
          .where("id != ?", state.getId())
          .and(getUniqueName() + " = ?", value)
          .using(state.getDatabase())
          .referenceOnly()
          .first();
      if (duplicate != null) {
        state.addError(state.getField(getField()), "Must be unique!");
        return false;
      }
    }
  }
  return true;
}

代码示例来源：origin: perfectsense/dari

Query<T> query = Query.from(applicationClass).where("_type = ?", type.getId()).using(database);
T app = query.first();

代码示例来源：origin: perfectsense/dari

.from(Object.class)
.where("_id = ?", id)
.using(this)
.option(CONNECTION_QUERY_OPTION, connection)
.option(RETURN_ORIGINAL_DATA_QUERY_OPTION, Boolean.TRUE)