SQLite 및 fp ts를 사용하여 React Native에서 마이그레이션 처리

최근에 제 보조 프로젝트에서 저는 expo-sqlite을 사용하여 React 원본 응용 프로그램에서 소형 클라이언트 데이터베이스를 관리하고 경외심을 불러일으키는 fp-ts을 사용해야 했습니다.나는 내가 그 프로그램을 발표할 수 있을지 모르겠지만, 적어도 나는 내가 얻은 경험을 좋은 방식으로 사용할 것이다🙂.

현지와 엑스포에 호응하다
React Native은 모바일 응용 프로그램 프레임워크로 React을 엔진으로 사용하여 이 프로그램의 보기로 컴파일합니다.즉, JavaScript를 사용하여 네이티브 모바일 애플리케이션을 작성할 수 있습니다(🤢) 그리고 반응하기(❤️). 이것은 이미 훌륭하지만, Expo은 이 모든 것을 다른 수준으로 끌어올릴 것이다.Expo는 React Native를 기반으로 작성된 도구로 플랫폼 간 모바일 어플리케이션 개발을 단순화하고 네이티브 요소에 대한 범용 API(푸시 알림, 카메라, 가속계 등)를 제공합니다.공중 갱신, 구름 내 인프라 구축 등등!

멋진 fpts
작년에 저는 일상적인 업무에서 순수한 기능적인 방식으로 Scala를 사용해야 했습니다. 그래서 저는 드디어 약간의 경멸과 경멸의 태도를 가지고 TypeScript를 바라보기 시작했습니다.나는 많은 다른 것들(예를 들어 Reason,ScalaJS,PureScript)을 시도했지만, 나는 항상 그것들 중에서 내가 싫어하는 것들을 발견한다(예를 들어PureScript는 여전히 나의 평가 목록에 있지만, 나는 아직 완성하지 못했기 때문이다).그러나 진정한 게임 규칙 변경자는 fpts이다. 이것은 내가 기능성이 강한 유형으로 TypeScript를 사용할 수 있도록 허용하고 TypeScript일 뿐이기 때문에 나는 모든 JavaScript API를 사용할 수 있어 귀속할 필요가 없다(이것은 정말 대단하다!)유감스럽게도 TypeScript도 단점이 있습니다. 이것은 FP를 대상으로 하는 것이 아닙니다. 많은 기능들이 약간 거칠거나 괴이하지만 (예:) 시간을 주어야 합니다. 그것은 여전히 매우 재미있습니다.

왜 이민
내 응용 프로그램은 100% 클라이언트이고 상대적으로 작은 데이터베이스(약 4개의 테이블과 2개의 관계)가 있어 실행할 때 관리해야 한다.왜?이것은 완전히 클라이언트이기 때문에 데이터베이스 수정 기능을 추가해야 할 때마다 우리는 응용 프로그램 자체에서 SQL 조회를 직접 실행해야 한다.
올바른 방법™ 마이그레이션을 수행하는 것입니다. React Native에서도 마이그레이션을 지원하는 라이브러리가 다릅니다(TypeORM 참조).마이그레이션은 대상 데이터베이스에서 한 번만 수행하는 추적된 SQL 쿼리입니다.추적을 하는 이유는 조회가 실행되었는지 알아야 하기 때문이다. 이를 위해서는 데이터베이스의 현재 버전이나 실행된 이전을 저장할 위치가 필요하다.
이전을 이해하는 작은 예부터 시작하겠습니다. 빈 관계 데이터베이스, Gigi라는 작은 로봇이 이전과 일련의 SQL 조회를 처리한다고 가정해 봅시다. 예를 들어 다음과 같습니다.

V1__create_users_table.sql

V2__create_posts_table.sql

V3__create_comments_table.sql

Gigi에게 전화를 걸었을 때, 그는 수첩에서 데이터베이스에서 실행된 마지막 이전을 검사해서 이 이전들을 처리하기 시작할 것이다.첫 번째 경우, 그는 그의 노트가 비어 있다는 것을 알아차리기 때문에, 그는 하나하나 모든 이전을 시작하고, 마지막으로 그가 마지막으로 실행한 이전은 V3__create_comments_table.sql이라고 쓴다.
다음날, 우리는 목록에 V4__delete_comments_table.sql 조회를 추가했다. 우리는 Gigi에게 전화를 걸었다. 그는 일반적인 과정을 시작할 것이다. 그러나 이번에는 그가 모든 이전을 다시 실행할 필요가 없다는 것을 알았다. V3__create_comments_table.sql 이후의 이전만 실행할 수 있다는 것을 알고, 그는 남은 SQL 조회를 실행하기 시작했고, 마지막에 그는 노트의 최신 조회를 교체할 것이다.
이 간단한 과정은 우리가 버전화된 데이터베이스를 가지도록 허용한다. 설령 우리가 직접 접근 권한이 없는 상황에서도 (이것이 우리의 상황이다!) 업데이트와 관리가 매우 쉽다.우리가 여기서 해야 할 일은 fp 실현과 경량급 코드 라이브러리의 장점을 이용하여 fpts를 사용하여 처음부터 이 특성을 실현하는 것이다(때로는 TypeORM과 같은 라이브러리가 상당히 크다)😕).

SQLite 박람회와 저장 대수
이동의 실현을 작성하기 전에 우리는 배경 지식이 필요하다!Expo가 제공하는 수많은 모듈 중 하나는 expo-sqlite이며 SQLite 데이터베이스의 이동 실현이다.사용법은 매우 간단하다. (비록 데이터베이스 파일이 실제로 시뮬레이터에서 만들어진 것은 이해하기 어렵지만)😾) 하지만 나는 이런 API를 그리 좋아하지 않는다.그래서 나는 간단한 Algebra (함수와 값의 추상적인 집합이다. 대상을 대상으로 프로그래밍을 하면 인터페이스로 볼 수 있다) 을 만들어서 그것들을 포장했다.

interface IStorageAlgebra {
  /**
   * Execute a query to retrieve some value from
   * the db
   */
  retrieveQuery: <T>(
    decoder: Decoder<T>,
  ) => (
    query: string,
    args: Array<QueryArgument>,
  ) => TaskEither<DatabaseError, Array<T>>

  /**
   * Execute a query which does not obtain values
   */
  executeQuery: (
    query: string,
    args: Array<QueryArgument>,
  ) => TaskEither<DatabaseError, number>

  /**
   * Execute multiple queries in a single transaction
   */
  executeQueriesInTransaction: (
    queries: Array<string>,
    argsList: Array<Array<QueryArgument>>,
  ) => TaskEither<DatabaseError, void>

  /**
   * Setup the database
   */
  setup: () => TaskEither<DatabaseError, void>
}

저희가 설명을 해야 돼요!우선, 모든 함수가 TaskEither으로 되돌아오는 것을 알 수 있습니다.fpts에서 TaskEither<E, A>은 비동기 계산을 처리하는 데 사용되는 목록으로 성공 결과는 A이고 오류 결과는 E이다.두 번째는 Decoder입니다. fpts에는 없지만, io-ts이라는 라이브러리에는 check을 입력하고 정상적인 (알 수 없는) 자바스크립트 대상을 우리가 실제로 알고 있는 것으로 디코딩할 수 있는 모듈입니다. (만약 우리가 const myDecoder = Decoder<IMyObject>이 있다면, 우리는 myDecoder.decode(unknownObj)을 실행하여 효과적인 IMyObject이나 오류를 얻을 수 있습니다.)
우리가 지금 해야 할 일은 setup 함수를 실현하는 것이다. 이 함수는 프로그램이 시작될 때마다 실행되고 데이터베이스와/또는 응용 프로그램의 최종 업데이트(이동!)를 안내할 것이다.

마이그레이션 관리자setup 함수는 이전에 말했던 마이그레이션 관리자입니다.이 기능은 세 가지 주요 부분으로 나뉘는데 그것이 바로 안내, 검사와 집행이다.깊이 연구하기 전에 우리는 이전 목록이 어떻게 이 프로젝트에서 실현되었는지 지적해야 한다.

const sqliteMigrations: ISQLiteMigrations = {
  0: `CREATE TABLE IF NOT EXISTS articles (
        id INTEGER PRIMARY KEY,
        title TEXT NOT NULL,
        body TEXT NOT NULL
      );`,
}

간단하지 않습니까?이것은 단지 JavaScript 객체이며 버전 번호는 키로 하고 실행할 조회는 값으로 한다.
이제 이동의 구조를 알았으니 setup 함수를 분석해 봅시다!

인도하다
Bootstrap에서 __migration표 (우리가 그 안에 저장할 이전) 가 존재하지 않는다면, 우리는 그것을 만들고 마지막으로 실행한 이전을 검색하기만 하면 됩니다.이 부분의 코드는 매우 간단하다.

this.executeQuery(`
  CREATE TABLE IF NOT EXISTS __migrations (
    id INTEGER PRIMARY KEY NOT NULL,
    version INTEGER NOT NULL,
    executed_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
  )
`),

이것은 __migrations표를 만들 것입니다. 그 중에는 id열 하나, version열 하나 (단지 이동을 표시하는 숫자일 뿐) 와 executed_at열이 포함되어 있으며, 후자는 이동의 실행 시간 스탬프입니다.이제 마지막으로 수행한 마이그레이션을 검색해야 하는 테이블이 존재합니다.

// Decoder that represents a single migration
migrationsDecoder = Decoder.type({
  id: Decoder.number,
  version: Decoder.number,
  executed_at: Decoder.string,
})

// ...

this.retrieveQuery(this.migrationsDecoder)(`
  SELECT * FROM __migrations ORDER BY id DESC LIMIT 1;
`),

검열
이 때, 우리는 지난번에 검색한 이전을 사용하여 실행할 이전을 검사해야 한다. (만약 있다면.)이 작업의 경우 모든 마이그레이션과 선택적 마지막 마이그레이션을 수락하고 마이그레이션이 수행되지 않은 목록을 반환하는 getUnexecutedMigrations이라는 특정 도움말 함수를 만듭니다.

private getUnexecutedMigrations = (migrations: ISQLiteMigrations) => (
  maybeLastMigration: Option.Option<number>,
): Array<number> =>
  pipe(
    Array.map(Number)(Object.keys(migrations)),
    Array.sort(ordNumber),
    (migrationsVersions) =>
      pipe(
        maybeLastMigration,
        Option.fold(
          () => migrationsVersions,
          (lastMigration) =>
            Array.dropLeft(migrationsVersions.indexOf(lastMigration) + 1)(
              migrationsVersions,
            ),
        ),
      ),
  )

주의해야 할 것은 Array, Option과 pipe은 모두 fp-ts에 포함된 모듈/함수이다. Array은 본 컴퓨터의 자바스크립트 그룹을 처리하는 편리한 fp방식일 뿐이고, Option은 선택할 수 있는 영향을 처리하는 단자(Haskell의 Maybe)이며, pipe은 왼쪽에서 오른쪽으로 연결하는 함수의 조수일 뿐이다.

실행
마지막 부분은 분석을 집행하는 것이다.여기서, 이름이 암시할 수 있는 것처럼, 우리는 모든 나머지 이동을 실행할 것이다.각 마이그레이션에 대해 __migrations 테이블에 행을 추가해야 하므로 한 트랜잭션에서 두 개의 쿼리를 수행하여 데이터베이스의 일관성을 유지하는 것이 중요합니다.

// Here we are managing the array of non-executed
// migrations inside a `pipe`, so the fist parameter
// of this `Array.map` is an `Array<number>`
Array.map((version) =>
  this.executeQueriesInTransaction(
    [
      this.migrations[version],
      `INSERT INTO __migrations (version, executed_at) VALUES (?, CURRENT_TIMESTAMP)`,
    ],
    [[], [version]],
  ),
),

IStorageAlgebra을 보면 executeQueriesInTransaction이 TaskEither<DatabaseError, void>으로 돌아오는 것을 볼 수 있다. 그래서 여기서 우리는 Array<number>을 Array<TaskEither<DatabaseError, void>>으로 비추기만 한다.

전체 함수
마지막 setup 함수입니다.

public setup = (): TaskEither.TaskEither<IDatabaseError, number> =>
  pipe(
    this.executeQuery(`
      CREATE TABLE IF NOT EXISTS __migrations (
        id INTEGER PRIMARY KEY NOT NULL,
        version INTEGER NOT NULL,
        executed_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP
      )
    `),

    TaskEither.chain(() =>
      this.retrieveQuery(this.migrationsDecoder)(`
        SELECT * FROM ${this.migrationsTable} ORDER BY id DESC LIMIT 1;
      `),
    ),

    TaskEither.chain((executedMigrations) =>
      pipe(
        executedMigrations,
        Array.map((m) => m.version),
        Array.head,
        this.getUnexecutedMigrations(this.migrations),
        Array.map((version) =>
          this.executeQueriesInTransaction(
            [
              this.migrations[version],
              `INSERT INTO ${this.migrationsTable} (version, executed_at) VALUES (?, CURRENT_TIMESTAMP)`,
            ],
            [[], [version]],
          ),
        ),
        Array.array.sequence(TaskEither.taskEither),
        TaskEither.map(() => undefined),
      ),
    ),
  )

모든 해석 부분은 pipe을 통해 연결되고 TaskEither.chain은'링크'로 되어 있다.TaskEither은 하나의 단자이기 때문에, 우리는 그것의 flatmap 함수를 사용할 수 있다. (여기에서 방금 chain으로 이름을 바꾸었다.)마지막 두 함수는 약간 모호하다. Array.array.sequence(TaskEither.taskEither)은 Array<TaskEither<E, A>>을 받아들이고 TaskEither<E, Array<A>>으로 돌아간다.우리는 이것으로 각종 비동기적인 계산의 모든 성공 결과를 TaskEither으로 통합하고, map을 undefined으로 통합한다. 왜냐하면 우리는 실제적으로 어떠한 결과도 필요하지 않기 때문이다.
이게 다야!🙋‍♂️