Skip to content

Commit a937a80

Browse files
quweifanquweifan
andauthored
fix: 修复执行sql时未正确传递参数的问题 (#10)
Co-authored-by: quweifan <quweifan1@h-partners.com>
1 parent 7116cd7 commit a937a80

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

platforms/harmony/sqlite_storage.har

20 Bytes
Binary file not shown.

platforms/harmony/sqlite_storage/src/main/ets/SQLitePluginTurboModule.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,7 @@ export class SQLitePluginTurboModule extends TurboModule implements TM.SQLitePlu
227227
const sqlmap = new Map(Object.entries(JSON.parse(json.stringify(txArgs[i]))));
228228
const queryId = sqlmap.get('qid');
229229
let querySql = sqlmap.get('sql');
230-
const queryParams = sqlmap.get('params');
230+
const queryParams: [] = sqlmap.get('params');
231231
let queryResultcall;
232232
let errorMessage: string = 'unknown';
233233

@@ -236,7 +236,7 @@ export class SQLitePluginTurboModule extends TurboModule implements TM.SQLitePlu
236236
let queryTypeMatch = firstWordRegex.exec(querySql);
237237
let queryType = queryTypeMatch[1];
238238

239-
if (queryType == 'CREATE') {
239+
if (queryType == 'CREATE' || queryType == 'DROP') {
240240
needRawQuery = false;
241241

242242
try {
@@ -252,7 +252,7 @@ export class SQLitePluginTurboModule extends TurboModule implements TM.SQLitePlu
252252
needRawQuery = false;
253253

254254
try {
255-
let rowId = await rdbStore.execute(querySql)
255+
let rowId = await rdbStore.execute(querySql, queryParams)
256256

257257
queryResultcall = { 'insertId': rowId, 'rowsAffected': 1 }
258258
} catch (e) {
@@ -265,7 +265,7 @@ export class SQLitePluginTurboModule extends TurboModule implements TM.SQLitePlu
265265
let rowsAffected: relationalStore.ValueType = -1
266266

267267
try {
268-
rowsAffected = await rdbStore.execute(querySql);
268+
rowsAffected = await rdbStore.execute(querySql, queryParams);
269269

270270
queryResultcall = { 'rowsAffected': rowsAffected }
271271
} catch (e) {
@@ -310,7 +310,7 @@ export class SQLitePluginTurboModule extends TurboModule implements TM.SQLitePlu
310310

311311
if (needRawQuery) {
312312
try {
313-
let resultSet = await rdbStore.querySql(querySql)
313+
let resultSet = await rdbStore.querySql(querySql, queryParams)
314314
const count = resultSet.columnCount;
315315
Logger.debug(CommonConstants.TAG, 'test--SQLitePlugin=backgroundExecuteSqlBatch>>>>>>查询数据个数====' + count);
316316
let results: Array<relationalStore.ValuesBucket> = new Array<relationalStore.ValuesBucket>();

0 commit comments

Comments
 (0)