本文整理了Java中org.h2.command.dml.Query.query
方法的一些代码示例,展示了Query.query
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.query
方法的具体详情如下:
包路径:org.h2.command.dml.Query
类名称:Query
方法名:query
[英]Execute the query, writing the result to the target result.
[中]执行查询,将结果写入目标结果。
代码示例来源:origin: com.h2database/h2
/**
* Get the current result of the expression. The rows may not be of the same
* type, therefore the rows may not be unique.
*
* @return the result
*/
public ResultInterface getCurrentResult() {
return expressionQuery.query(0);
}
代码示例来源:origin: com.h2database/h2
@Override
public final ResultInterface query(int maxrows) {
return query(maxrows, null);
}
代码示例来源:origin: com.h2database/h2
private Cursor find(Session session, SearchRow first, SearchRow last,
SearchRow intersection) {
if (recursive) {
return findRecursive(first, last);
}
setupQueryParameters(session, first, last, intersection);
ResultInterface result = query.query(0);
return new ViewCursor(this, result, first, last);
}
代码示例来源:origin: com.h2database/h2
@Override
public Value getValue(Session session) {
query.setSession(session);
ResultInterface result = query.query(1);
session.addTemporaryResult(result);
boolean r = result.hasNext();
return ValueBoolean.get(r);
}
代码示例来源:origin: com.h2database/h2
@Override
protected Value[] fetchNextRow() {
if (rightDone) {
return null;
}
if (!leftDone) {
if (l == null) {
l = left.query(0);
l.reset();
}
if (l.next()) {
return l.currentRow();
}
leftDone = true;
}
if (r == null) {
r = right.query(0);
r.reset();
}
if (r.next()) {
return r.currentRow();
}
rightDone = true;
return null;
}
代码示例来源:origin: com.h2database/h2
@Override
protected Cursor run() throws Exception {
viewIndex.setupQueryParameters(viewIndex.getSession(), first, last, null);
ArrayList<JoinBatch> joinBatches = batchUnion.joinBatches;
for (int i = 0, size = joinBatches.size(); i < size; i++) {
assert topFutureCursors[i] != null;
joinBatches.get(i).viewTopFutureCursor = topFutureCursors[i];
}
ResultInterface localResult;
boolean lazy = false;
try {
localResult = viewIndex.getQuery().query(0);
lazy = localResult.isLazy();
} finally {
if (!lazy) {
resetViewTopFutureCursorAfterQuery();
}
}
return newCursor(localResult);
}
代码示例来源:origin: com.h2database/h2
@Override
protected Cursor run() throws Exception {
if (topFutureCursor == null) {
// if the top cursor is empty then the whole query will produce
// empty result
return EMPTY_CURSOR;
}
viewIndex.setupQueryParameters(viewIndex.getSession(), first, last, null);
JoinBatch.this.viewTopFutureCursor = topFutureCursor;
ResultInterface localResult;
boolean lazy = false;
try {
localResult = viewIndex.getQuery().query(0);
lazy = localResult.isLazy();
} finally {
if (!lazy) {
resetViewTopFutureCursorAfterQuery();
}
}
return newCursor(localResult);
}
代码示例来源:origin: com.h2database/h2
@Override
public Value getValue(Session session) {
query.setSession(session);
try (ResultInterface result = query.query(2)) {
Value v;
if (!result.next()) {
v = ValueNull.INSTANCE;
} else {
Value[] values = result.currentRow();
if (result.getVisibleColumnCount() == 1) {
v = values[0];
} else {
v = ValueArray.get(values);
}
if (result.hasNext()) {
throw DbException.get(ErrorCode.SCALAR_SUBQUERY_CONTAINS_MORE_THAN_ONE_ROW);
}
}
return v;
}
}
代码示例来源:origin: com.h2database/h2
@Override
public int update() {
// clear list of source table keys & rowids we have processed already
targetRowidsRemembered.clear();
if (targetTableFilter != null) {
targetTableFilter.startQuery(session);
targetTableFilter.reset();
}
if (sourceTableFilter != null) {
sourceTableFilter.startQuery(session);
sourceTableFilter.reset();
}
sourceQueryRowNumber = 0;
checkRights();
setCurrentRowNumber(0);
// process source select query data for row creation
ResultInterface rows = query.query(0);
targetTable.fire(session, evaluateTriggerMasks(), true);
targetTable.lock(session, true, false);
while (rows.next()) {
sourceQueryRowNumber++;
Value[] sourceRowValues = rows.currentRow();
Row sourceRow = new RowImpl(sourceRowValues, 0);
setCurrentRowNumber(sourceQueryRowNumber);
merge(sourceRow);
}
rows.close();
targetTable.fire(session, evaluateTriggerMasks(), false);
return countUpdatedRows;
}
代码示例来源:origin: com.h2database/h2
ResultInterface rows = query.query(0);
count = 0;
table.fire(session, Trigger.UPDATE | Trigger.INSERT, true);
代码示例来源:origin: com.h2database/h2
query.setDistinct(true);
ResultInterface rows = query.query(0);
Value l = left.getValue(session);
if (!rows.hasNext()) {
代码示例来源:origin: com.h2database/h2
table.lock(session, true, false);
if (insertFromSelect) {
query.query(0, this);
} else {
ResultInterface rows = query.query(0);
while (rows.next()) {
generatedKeys.nextRow();
代码示例来源:origin: com.h2database/h2
ResultInterface rows = query.query(0);
count = 0;
targetTable.fire(session, Trigger.UPDATE | Trigger.INSERT, true);
代码示例来源:origin: com.h2database/h2
ResultInterface resultInterface = left.query(0);
LocalResult localResult = union.getEmptyResult();
resultInterface = right.query(0);
if (!resultInterface.hasNext()) {
break;
代码示例来源:origin: com.h2database/h2
if (sort == null && !distinct && maxRows == 0 &&
offsetExpr == null && limitExpr == null) {
left.query(0, target);
right.query(0, target);
return null;
DbException.throwInternalError("type=" + unionType);
ResultInterface l = left.query(0);
ResultInterface r = right.query(0);
l.reset();
r.reset();
代码示例来源:origin: com.eventsourcing/h2
/**
* Get the current result of the expression. The rows may not be of the same
* type, therefore the rows may not be unique.
*
* @return the result
*/
public ResultInterface getCurrentResult() {
return expressionQuery.query(0);
}
代码示例来源:origin: org.wowtools/h2
@Override
public LocalResult query(int maxrows) {
return query(maxrows, null);
}
代码示例来源:origin: org.wowtools/h2
private Cursor find(Session session, SearchRow first, SearchRow last,
SearchRow intersection) {
if (recursive) {
return findRecursive(first, last);
}
setupQueryParameters(session, first, last, intersection);
LocalResult result = query.query(0);
return new ViewCursor(this, result, first, last);
}
代码示例来源:origin: com.h2database/com.springsource.org.h2
public Value getValue(Session session) throws SQLException {
query.setSession(session);
LocalResult result = query.query(1);
session.addTemporaryResult(result);
boolean r = result.getRowCount() > 0;
return ValueBoolean.get(r);
}
代码示例来源:origin: com.eventsourcing/h2
@Override
public Value getValue(Session session) {
query.setSession(session);
LocalResult result = query.query(1);
session.addTemporaryResult(result);
boolean r = result.getRowCount() > 0;
return ValueBoolean.get(r);
}
内容来源于网络,如有侵权,请联系作者删除!