ckaczor/azuredatastudio
1
0
Fork 0
mirror of https://github.com/ckaczor/azuredatastudio.git synced 2026-02-17 02:51:36 -05:00
Code Issues Packages Projects Releases Wiki Activity

announce query execution events (#20285)

Browse Source
This commit is contained in:
Alan Ren
2022-08-09 20:23:17 -07:00
committed by GitHub
parent 0550d58579
commit 2d14665208
1 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/sql/workbench/contrib/query/browser/gridPanel.ts
View File

@@ -51,6 +51,7 @@ import { IQueryModelService } from 'sql/workbench/services/query/common/queryMod
import { FilterButtonWidth, HeaderFilter } from 'sql/base/browser/ui/table/plugins/headerFilter.plugin'; import { FilterButtonWidth, HeaderFilter } from 'sql/base/browser/ui/table/plugins/headerFilter.plugin';
import { HybridDataProvider } from 'sql/base/browser/ui/table/hybridDataProvider'; import { HybridDataProvider } from 'sql/base/browser/ui/table/hybridDataProvider';
import { INotificationService } from 'vs/platform/notification/common/notification'; import { INotificationService } from 'vs/platform/notification/common/notification';
import { alert, status } from 'vs/base/browser/ui/aria/aria';
const ROW_HEIGHT = 29; const ROW_HEIGHT = 29;
const HEADER_HEIGHT = 26; const HEADER_HEIGHT = 26;
@@ -122,11 +123,20 @@ export class GridPanel extends Disposable {
this.queryRunnerDisposables.add(this.runner.onResultSet(this.onResultSet, this)); this.queryRunnerDisposables.add(this.runner.onResultSet(this.onResultSet, this));
this.queryRunnerDisposables.add(this.runner.onResultSetUpdate(this.updateResultSet, this)); this.queryRunnerDisposables.add(this.runner.onResultSetUpdate(this.updateResultSet, this));
this.queryRunnerDisposables.add(this.runner.onQueryStart(() => { this.queryRunnerDisposables.add(this.runner.onQueryStart(() => {
status(localize('query.QueryExecutionStarted', "Query execution started."));
if (this.state) { if (this.state) {
this.state.tableStates = []; this.state.tableStates = [];
} }
this.reset(); this.reset();
})); }));
this.queryRunnerDisposables.add(this.runner.onQueryEnd(() => {
status(localize('query.QueryExecutionEnded', "Query execution completed."));
}));
this.queryRunnerDisposables.add(this.runner.onMessage((messages) => {
if (messages?.find(m => m.isError)) {
alert(localize('query.QueryErrorOccured', "Error occured while executing the query."));
}
}));
this.addResultSet(this.runner.batchSets.reduce<ResultSetSummary[]>((p, e) => { this.addResultSet(this.runner.batchSets.reduce<ResultSetSummary[]>((p, e) => {
if (this.configurationService.getValue<IQueryEditorConfiguration>('queryEditor').results.streaming) { if (this.configurationService.getValue<IQueryEditorConfiguration>('queryEditor').results.streaming) {
p = p.concat(e.resultSetSummaries ?? []); p = p.concat(e.resultSetSummaries ?? []);