iframe-proxy | Sunbelt Computer Software

62 lines (53 loc) · 1.66 KB

 * Copyright OpenSearch Contributors
 * SPDX-License-Identifier: Apache-2.0
import org.junit.jupiter.api.Test;
import org.opentest4j.AssertionFailedError;
public class GatewayTest {
  Gateway getGateway() {
    Gateway gateway = new Gateway();
    boolean connectionInitialized =
        gateway.initializeConnection("localhost", 9200, "http", null, null, false);
    if (!connectionInitialized) {
      throw new AssertionError("failed to initialize connection");
    return gateway;
  void assertSuccessfulPPL(Gateway gateway, String ppl) {
    String result = gateway.queryExecution(ppl, true, false, "table");
    System.out.println("Result is: " + result);
    if (result.contains("Exception")) {
      throw new AssertionFailedError(
          String.format("expected successful response string but got Exception:\n> %s", result));
  void pplSelectAll() {
    Gateway gateway = getGateway();
    assertSuccessfulPPL(gateway, "source = accounts;");
  void pplSelectHead() {
    Gateway gateway = getGateway();
    assertSuccessfulPPL(gateway, "source = accounts | head 10;");
  void pplSelectOffsetHead() {
    Gateway gateway = getGateway();
    assertSuccessfulPPL(gateway, "source = accounts | head 200 from 9900;");
  void pplNumericStats() {
    Gateway gateway = getGateway();
    assertSuccessfulPPL(
        gateway,
        "source = accounts | stats max(balance) as max_balance, avg(balance) as avg_balance by"
            + " city");
  void pplValuesStats() {
    Gateway gateway = getGateway();
    assertSuccessfulPPL(gateway, "source = accounts | stats values(email) as emails");

Sunbelt Computer Software

PL/B Language Development and Support

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Sunbelt Computer Software

PL/B Language Development and Support

Uh oh!

FilesExpand file tree

GatewayTest.java

Latest commit

History

GatewayTest.java

File metadata and controls