Package io.crate.action.sql

Examples of io.crate.action.sql.SQLRequest

51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
                        .put("gateway.type", "none")).build();
        node.start();

        SQLService sqlService = node.injector().getInstance(SQLService.class);
        TransportSQLAction transportSQLAction = node.injector().getInstance(TransportSQLAction.class);
        transportSQLAction.execute(new SQLRequest("select name from sys.cluster")).actionGet();

        sqlService.disable();

        try {
            transportSQLAction.execute(new SQLRequest("select name from sys.cluster")).actionGet();
            fail("no exception thrown");
        } catch (NodeDisconnectedException e) {
            // success!
        }

        sqlService.start();
        transportSQLAction.execute(new SQLRequest("select name from sys.cluster")).actionGet();
    }
View Full Code Here
118
119
120
121
122
123
124
125
126
127
128
        execute("select * from information_schema.tables");
        assertEquals(15L, response.rowCount());

        client().execute(SQLAction.INSTANCE,
            new SQLRequest("create table t4 (col1 integer, col2 string)")).actionGet();

        // create table causes a cluster event that will then cause to rebuild the information schema
        // wait until it's rebuild
        Thread.sleep(10);

View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
158
            .setSource("{}")
            .execute()
            .actionGet();
        ensureGreen();

        SQLRequest request =  new SQLRequest("select \"_id\" from test");
        request.includeTypesOnResponse(true);
        SQLResponse r = client.sql(request).actionGet();

        assertEquals(1, r.rows().length);
        assertEquals("_id", r.cols()[0]);
        assertEquals("1", r.rows()[0][0]);
View Full Code Here
107
108
109
110
111
112
113
            internalClient.addTransportAddress(new InetSocketTransportAddress(host, port));
        }
    }

    public ActionFuture<SQLResponse> sql(String stmt) {
        return sql(new SQLRequest(stmt));
    }
View Full Code Here
115
116
117
118
119
120
121
    public ActionFuture<SQLResponse> sql(SQLRequest request) {
        return internalClient.sql(request);
    }

    public void sql(String stmt, ActionListener<SQLResponse> listener) {
        sql(new SQLRequest(stmt), listener);
    }
View Full Code Here
197
198
199
200
201
202
203
204
205
206
207
        assertResponseWithTypes("drop blob table blablob2");
        assertResponseWithTypes("create ANALYZER \"german_snowball\" extends snowball WITH (language='german')");
    }

    private void assertResponseWithTypes(String stmt) {
        SQLRequest request = new SQLRequest(stmt);
        request.includeTypesOnResponse(true);
        SQLResponse sqlResponse = sqlExecutor.exec(request);
        assertThat(sqlResponse.columnTypes(), is(notNullValue()));
        assertThat(sqlResponse.columnTypes().length, is(sqlResponse.cols().length));
    }
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
        Iterator<Client> iterator = clients().iterator();
        Client client1 = iterator.next();
        Client client2 = iterator.next();

        client1.execute(SQLAction.INSTANCE, new SQLRequest(
            "insert into t1 (id, string_field, " +
                "timestamp_field, byte_field) values (?, ?, ?, ?)", new Object[]{1, "With",
            "1970-01-01T00:00:00", 127})).actionGet();

        client2.execute(SQLAction.INSTANCE, new SQLRequest(
            "insert into t1 (id, string_field, timestamp_field, byte_field) values (?, ?, ?, ?)",
            new Object[]{2, "Without", "1970-01-01T01:00:00", Byte.MIN_VALUE})).actionGet();
        refresh();
        SQLResponse response = execute("select id, string_field, timestamp_field, byte_field from t1 order by id");
View Full Code Here
TOP

Related Classes of io.crate.action.sql.SQLRequest

  • io.crate.client.CrateClient
  • io.crate.client.CrateClientTest
  • io.crate.integrationtests.InformationSchemaTest
  • io.crate.integrationtests.SQLTypeMappingTest
  • io.crate.integrationtests.TransportSQLActionSingleNodeTest
  • io.crate.module.sql.benchmark.BenchmarkBase
  • io.crate.module.sql.benchmark.BulkDeleteBenchmark
  • io.crate.module.sql.benchmark.DeleteBenchmark
  • io.crate.module.sql.benchmark.InsertBenchmark
  • io.crate.module.sql.benchmark.UpdateBenchmark
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.