run method

Future<void> run({
  1. required String sourceId,
  2. bool fromRefresh = false,
})

Implementation

Future<void> run({required String sourceId, bool fromRefresh = false}) async {
  final sql = queryText.trim();
  if (sql.isEmpty) {
    queryError = 'Query cannot be empty.';
    notifyListeners();
    return;
  }

  if (!_repository.supportsRawSql(sourceId)) {
    queryError = 'Raw SQL is not supported for this source.';
    notifyListeners();
    return;
  }

  if (DbLensSqlUtils.isSelectQuery(sql)) {
    await _runSelect(sourceId, sql, fromRefresh: fromRefresh);
    return;
  }

  await _runStatement(sourceId, sql, fromRefresh: fromRefresh);
}