Function run

packages/sql-sqlite-react-native/src/SqliteClient.ts:109–127

(
        sql: string,
        params: ReadonlyArray<unknown> = []
      )

      yield* Effect.addFinalizer(() => Effect.sync(() => db.close()))

      const run = (
        sql: string,
        params: ReadonlyArray<unknown> = []
      ) =>
        Effect.withFiberRuntime<Array<any>, SqlError>((fiber) => {
          if (fiber.getFiberRef(asyncQuery)) {
            return Effect.map(
              Effect.tryPromise({
                try: () => db.executeAsync(sql, params as Array<any>),
                catch: (cause) => new SqlError({ cause, message: "Failed to execute statement (async)" })
              }),
              (result) => result.rows?._array ?? []
            )
          }
          return Effect.try({
            try: () => db.execute(sql, params as Array<any>).rows?._array ?? [],
            catch: (cause) => new SqlError({ cause, message: "Failed to execute statement" })
          })
        })

      return identity<SqliteConnection>({
        execute(sql, params, transformRows) {