Skip to content

Commit f0cc1fb

Browse files
committed
fix naming
1 parent b336f88 commit f0cc1fb

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

src/statement/async.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ export class AsyncStatement extends BaseStatement {
3636
monitorSql
3737
};
3838
}
39-
get async_query_token(): string {
39+
get asyncQueryToken(): string {
4040
return this.asyncToken;
4141
}
4242

test/integration/v2/serverSideAsync.test.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@ describe("server side async integration test", () => {
3636
`INSERT INTO ${testTableName} VALUES (1)`
3737
);
3838
await expect(statement.fetchResult()).rejects.toThrow();
39-
expect(statement.async_query_token).toBeDefined();
40-
expect(statement.async_query_token).not.toBe("");
39+
expect(statement.asyncQueryToken).toBeDefined();
40+
expect(statement.asyncQueryToken).not.toBe("");
4141
});
4242

4343
it("can check long-running query status", async () => {
@@ -52,7 +52,7 @@ describe("server side async integration test", () => {
5252
const statement = await connection.executeAsync(
5353
`INSERT INTO ${testTableName} ${longSelect}`
5454
);
55-
const token = statement.async_query_token;
55+
const token = statement.asyncQueryToken;
5656
expect(token).toBeDefined();
5757
expect(token).not.toBe("");
5858
const isRunning = await connection.isAsyncQueryRunning(token);
@@ -83,7 +83,7 @@ describe("server side async integration test", () => {
8383
const statement = await connection.executeAsync(
8484
`INSERT INTO ${testTableName} ${longSelect}`
8585
);
86-
const token = statement.async_query_token;
86+
const token = statement.asyncQueryToken;
8787
expect(token).toBeDefined();
8888
expect(token).not.toBe("");
8989
await connection.cancelAsyncQuery(token);
@@ -105,7 +105,7 @@ describe("server side async integration test", () => {
105105
const statement = await connection.executeAsync(
106106
`INSERT INTO ${testTableName} ${longSelect}`
107107
);
108-
const token = statement.async_query_token;
108+
const token = statement.asyncQueryToken;
109109
expect(token).toBeDefined();
110110
expect(token).not.toBe("");
111111
const connection2 = await firebolt.connect(connectionParams);

test/unit/v2/connection.test.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -299,7 +299,7 @@ describe("Connection V2", () => {
299299
const connection = await firebolt.connect(connectionParams);
300300
const asyncStatement = await connection.executeAsync("INSERT 1");
301301
expect(asyncStatement).toBeDefined();
302-
expect(asyncStatement.async_query_token).toBe("async_query_token");
302+
expect(asyncStatement.asyncQueryToken).toBe("async_query_token");
303303
});
304304

305305
it("throws error for async SET statement", async () => {
@@ -370,11 +370,11 @@ describe("Connection V2", () => {
370370
const connection = await firebolt.connect(connectionParams);
371371
const asyncStatement = await connection.executeAsync("INSERT 1");
372372
const isRunning = await connection.isAsyncQueryRunning(
373-
asyncStatement.async_query_token
373+
asyncStatement.asyncQueryToken
374374
);
375375
expect(isRunning).toBe(expectedRunning);
376376
const isSuccessful = await connection.isAsyncQuerySuccessful(
377-
asyncStatement.async_query_token
377+
asyncStatement.asyncQueryToken
378378
);
379379
expect(isSuccessful).toBe(expectedSuccessful);
380380
};
@@ -440,8 +440,8 @@ describe("Connection V2", () => {
440440

441441
const connection = await firebolt.connect(connectionParams);
442442
const asyncStatement = await connection.executeAsync("INSERT 1");
443-
expect(asyncStatement.async_query_token).not.toBe("");
444-
await connection.cancelAsyncQuery(asyncStatement.async_query_token);
443+
expect(asyncStatement.asyncQueryToken).not.toBe("");
444+
await connection.cancelAsyncQuery(asyncStatement.asyncQueryToken);
445445
await new Promise(resolve => setTimeout(resolve, 100)); // somehow we need it to wait for the flag switch
446446
expect(cancelQueryExecuted).toBe(true);
447447
});

0 commit comments

Comments
 (0)