@@ -176,7 +176,7 @@ class DatabaseTransactionBase<TABLES extends TablesBase> {
176
176
fmtString,
177
177
values: values,
178
178
timeoutInSeconds: timeoutInSeconds,
179
- queryMode: useExtendedQuery ? QueryMode .extended : null ,
179
+ queryMode: useExtendedQuery ? QueryMode .extended : QueryMode .simple ,
180
180
);
181
181
result = sqlResult.affectedRows;
182
182
if (expectedResultCount != null && result != expectedResultCount) {
@@ -195,19 +195,23 @@ class DatabaseTransactionBase<TABLES extends TablesBase> {
195
195
Future <Result > query (
196
196
String fmtString, {
197
197
Map <String , Object ?>? values,
198
- bool allowReuse = true ,
199
198
int ? timeoutInSeconds,
200
199
QueryMode ? queryMode,
201
200
}) async {
202
201
assert (_assertCorrectValues (values));
202
+ queryMode ?? = values == null || values.isEmpty
203
+ ? QueryMode .simple
204
+ : QueryMode .extended;
203
205
try {
204
206
// _logger.finest('QUERY: $fmtString');
205
- return _conn.execute (Sql .named (fmtString),
206
- parameters: values,
207
- queryMode: queryMode,
208
- timeout: timeoutInSeconds == null
209
- ? null
210
- : Duration (seconds: timeoutInSeconds));
207
+ return _conn.execute (
208
+ Sql .named (fmtString),
209
+ parameters: values,
210
+ queryMode: queryMode,
211
+ timeout: timeoutInSeconds == null
212
+ ? null
213
+ : Duration (seconds: timeoutInSeconds),
214
+ );
211
215
} catch (e, stackTrace) {
212
216
_logger.warning (
213
217
'Error while running statement $fmtString ' , e, stackTrace);
0 commit comments