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

Update edit data for result set streaming changes (#3634)

Browse Source
This commit is contained in:
Matt Irvine
2018-12-18 11:07:26 -08:00
committed by GitHub
parent 50e2251e74
commit 7f950ddb80
2 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/parts/grid/views/editData/editData.component.ts
View File

@@ -343,6 +343,9 @@ export class EditDataComponent extends GridParentComponent implements OnInit, On
handleResultSet(self: EditDataComponent, event: any): void { handleResultSet(self: EditDataComponent, event: any): void {
// Clone the data before altering it to avoid impacting other subscribers // Clone the data before altering it to avoid impacting other subscribers
let resultSet = Object.assign({}, event.data); let resultSet = Object.assign({}, event.data);
if (!resultSet.complete) {
return;
}
// Add an extra 'new row' // Add an extra 'new row'
resultSet.rowCount++; resultSet.rowCount++;

8
src/sql/parts/query/execution/queryModelService.ts
View File

@@ -387,8 +387,14 @@ export class QueryModelService implements IQueryModelService {
// We do not have a query runner for this editor, so create a new one // We do not have a query runner for this editor, so create a new one
// and map it to the results uri // and map it to the results uri
queryRunner = this._instantiationService.createInstance(QueryRunner, ownerUri); queryRunner = this._instantiationService.createInstance(QueryRunner, ownerUri);
const resultSetEventType = 'resultSet';
queryRunner.addListener(QREvents.RESULT_SET, resultSet => { queryRunner.addListener(QREvents.RESULT_SET, resultSet => {
this._fireQueryEvent(ownerUri, 'resultSet', resultSet); this._fireQueryEvent(ownerUri, resultSetEventType, resultSet);
});
queryRunner.onResultSetUpdate(resultSetSummaries => {
resultSetSummaries.forEach(resultSet => {
this._fireQueryEvent(ownerUri, resultSetEventType, resultSet);
})
}); });
queryRunner.addListener(QREvents.BATCH_START, batch => { queryRunner.addListener(QREvents.BATCH_START, batch => {
let link = undefined; let link = undefined;