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

XQUtils.getXQException介绍

[英]a utility method to extract XQ exception information from the error stack provided
[中]提供了一种从错误堆栈中提取XQ异常信息的实用方法

代码示例

代码示例来源：origin: dsukhoroslov/bagri

@Override
public XQPreparedExpression prepareExpression(Reader xquery, XQStaticContext context) throws XQException {
  String query = null;
  try {
    query = XMLUtils.textToString(xquery);
  } catch (IOException ex) {
    throw getXQException(ex);
  }
  return prepareExpression(query, context);
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public XQPreparedExpression prepareExpression(Reader xquery) throws XQException {
  String query = null;
  try {
    query = XMLUtils.textToString(xquery);
  } catch (IOException ex) {
    throw getXQException(ex);
  }
  return prepareExpression(query);
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public XQPreparedExpression prepareExpression(InputStream xquery) throws XQException {
  String query = null;
  try {
    query = XMLUtils.textToString(xquery);
  } catch (IOException ex) {
    throw getXQException(ex);
  }
  return prepareExpression(query);
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public XQPreparedExpression prepareExpression(InputStream xquery, XQStaticContext context) throws XQException {
  String query = null;
  try {
    query = XMLUtils.textToString(xquery);
  } catch (IOException ex) {
    throw getXQException(ex);
  }
  return prepareExpression(query, context);
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void cancelExecution() throws XQException {
  try {
    getQueryManagement().cancelExecution();
  } catch (BagriException ex) {
    throw getXQException(ex);
  }
}

代码示例来源：origin: dsukhoroslov/bagri

protected void closeTransaction() throws XQException {
  if (transactional) {
    if (autoCommit) {
      try {
        getTxManager().commitTransaction(txId);
      } catch (BagriException ex) {
        throw getXQException(ex);
      }
      txId = TX_NO;
    } else {
      // ??
    }
  }
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void close() throws XQException {
  if (!isClosed()) {
    super.close();
    try {
      cursor.close();
    } catch (Exception ex) {
      throw getXQException(ex);
    }
  }
}

代码示例来源：origin: dsukhoroslov/bagri

void executeCommand(final String cmd, final Map<QName, Object> bindings, final XQStaticContext ctx) throws XQException {
  
  checkState(ex_connection_closed);
  cancelled = false;
  try {
    final Map<String, Object> params = new HashMap<>(bindings.size());
    for (Map.Entry<QName, Object> e: bindings.entrySet()) {
      params.put(toStringName(e.getKey()), e.getValue());
    }
    if (transactional) {
      try {
        executeInTransaction(new Callable<Void>() {
          @Override
          public Void call() throws XQException {
            getProcessor().executeXCommand(cmd, params, ctx);
            return null;
          }
        });
      } catch (BagriException ex) {
        throw getXQException(ex);
      }
    } else {
      getProcessor().executeXCommand(cmd, params, ctx);
    }
  } finally {
    if (cancelled) {
      throw new XQCancelledException("Command execution has been cancelled", null, null, -1, -1, -1, null, null, null);
    }
  }
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void commit() throws XQException {
  checkState(ex_connection_closed);
  if (autoCommit) {
    throw new XQException("The connection is in AutoCommit state, nothing to commit explicitly.", String.valueOf(ecTransWrongState));
  }
  if (transactional) {
    try {
      getTxManager().commitTransaction(txId);
    } catch (BagriException ex) {
      throw getXQException(ex);
    }
    txId = TX_NO;
  }
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void rollback() throws XQException {
  
  checkState(ex_connection_closed);
  if (autoCommit) {
    throw new XQException("The connection is in AutoCommit state, nothing to rollback explicitly.", String.valueOf(ecTransWrongState));
  }
  if (transactional) {
    try {
      getTxManager().rollbackTransaction(txId);
    } catch (BagriException ex) {
      throw getXQException(ex);
    }
    txId = TX_NO;
  }
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public void setAutoCommit(boolean autoCommit) throws XQException {
  checkState(ex_connection_closed);
  if (this.autoCommit == autoCommit) {
    return;
  }
  if (transactional) {
    if (!this.autoCommit) {
      try {
        getTxManager().commitTransaction(txId);
      } catch (BagriException ex) {
        throw getXQException(ex);
      }
      txId = TX_NO;
    }
  }
  this.autoCommit = autoCommit;
}

代码示例来源：origin: dsukhoroslov/bagri

@Override
public ResultCursor executeXQuery(String query, XQStaticContext ctx) throws XQException {
  Properties props = collectProperties(ctx);
  props = ensureProperty(props, pn_query_command, "false");
  try {
    Map<String, Object> params = getXQItemParams();
    return getQueryManagement().executeQuery(query, params, props);
  } catch (XPathException | BagriException ex) {
    throw getXQException(ex);
  }
}

代码示例来源：origin: dsukhoroslov/bagri

throw getXQException(ex);

代码示例来源：origin: dsukhoroslov/bagri

throw getXQException(ex);