org.h2.command.dml.Query.query()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(6.0k)|赞(0)|评价(0)|浏览(154)

本文整理了Java中org.h2.command.dml.Query.query方法的一些代码示例,展示了Query.query的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.query方法的具体详情如下:
包路径:org.h2.command.dml.Query
类名称:Query
方法名: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);
}

相关文章