Method runQuery

src/database-engines/sqlite-engine.ts:547–587

(sql: string, params: any[] = [])

  }

  async runQuery(sql: string, params: any[] = []): Promise<any> {
    try {
      const db = this.getConnection();
      if (!db) {
        return Promise.reject('Cannot connect to database')
      }

      return new Promise<any>((resolve, reject) => {
        // Determine if the query is a SELECT or PRAGMA statement
        const isSelect = /^\s*(SELECT|PRAGMA)\s+/i.test(sql);

        if (isSelect) {
          db.all(sql, params, (err, rows) => {
            if (err) {
              reportError(`SQLite run query error: ${err}`);
              reject(err);
              return;
            }
            resolve(rows);
          });
        } else {
          db.run(sql, params, function (err) {
            if (err) {
              reportError(`SQLite run query error: ${err}`);
              reject(err);
              return;
            }

            // For non-SELECT queries, return information about the operation
            resolve({
              changes: this.changes,
              lastID: this.lastID
            });
          });
        }
      });
    } catch (err) {
      reportError(`SQLite run query error: ${err}`);
      throw err;
    }
  }

  async close(): Promise<void> {
    return this.disconnect();