本文整理了Java中com.psddev.dari.db.Query.using
方法的一些代码示例,展示了Query.using
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.using
方法的具体详情如下:
包路径:com.psddev.dari.db.Query
类名称: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)
内容来源于网络,如有侵权,请联系作者删除!