既存のMySQL・PostgreSQLデータベースをアプリに接続する

npx ampx sandbox secret set SQL_CONNECTION_STRING

npx ampx generate schema-from-database --connection-uri-secret SQL_CONNECTION_STRING --out amplify/data/schema.sql.ts

import { type ClientSchema, a, defineData } from '@aws-amplify/backend';
Copy highlighted code example
import { schema as generatedSqlSchema } from './schema.sql';

// グローバル認可ルールを追加する
const sqlSchema = generatedSqlSchema.authorization(allow => allow.guest())

// リレーショナルデータベースソースはAmplifyで管理されるDynamoDBテーブルと共存できます。
const schema = a.schema({
  Todo: a.model({
    content: a.string(),
  }).authorization(allow => [allow.guest()])
});

// a.combine()演算子を使用して、DynamoDBでサポートされているモデルと
// PostgresまたはMySQLデータベースでサポートされているモデルを統合します。
Copy highlighted code example
const combinedSchema = a.combine([schema, sqlSchema]);

// 両方のスキーマからのタイプを考慮してクライアント型を更新することを忘れないでください。
Copy highlighted code example
export type Schema = ClientSchema<typeof combinedSchema>;

export const data = defineData({
  // データ定義を更新して、DynamoDBでサポートされているスキーマだけでなく
  // 統合スキーマを使用するようにします
Copy highlighted code example
  schema: combinedSchema
});

// スキーマに認可ルールを追加する
Copy highlighted code example
const sqlSchema = generatedSqlSchema.setAuthorization((models) => [
  // モデルレベルの認可ルール
  models.event.authorization((allow) => [allow.publicApiKey()]),
  // フィールドレベルの認可ルール
  models.event.fields.id.authorization(allow => [allow.publicApiKey(), allow.guest()]),
  models.event.fields.created_at.authorization(allow => [allow.publicApiKey(), allow.guest()])
]);

npx ampx sandbox

const { data: events } = await client.models.event.list()

// フロントエンドコードをより使いやすくするためにモデルまたはフィールドを名前変更する
const sqlSchema = generatedSqlSchema.authorization(allow => allow.guest())
Copy highlighted code example
  .renameModels(() => [
    //⌄⌄⌄⌄⌄ テーブル名に基づく既存のモデル名
    ['event', 'Event']
    //        ^^^^^^ 名前変更されたデータモデル名
  ])

const sqlSchema = generatedSqlSchema
  .authorization(allow => allow.guest())
Copy highlighted code example
  .setRelationships((models) => [
    models.Note.relationships({
      comments: a.hasMany("Comment", "note_id"),
    }),
    models.Comment.relationships({
      note: a.belongsTo("Note", "note_id")
    })
  ]);

// カスタムミューテーションまたはクエリを追加してSQLステートメントを実行する
const sqlSchema = generatedSqlSchema.authorization(allow => allow.guest())
Copy highlighted code example
  .addToSchema({
    listEventsWithDecodedLatLong: a.query()
      // スキーマに追加されたカスタムタイプを参照する
      .returns(a.ref("EventWithDecodedCoord").array())
      .handler(a.handler.inlineSql(
          `SELECT
            id,
            name,
            address,
            ST_X(geom) AS longitude,
            ST_Y(geom) AS latitude
          FROM locations;`
      ))
      .authorization(allow => [allow.guest()]),

      // カスタムクエリ・ミューテーションの終了型のある結果を提供するための
      // カスタムタイプを定義する
      EventWithDecodedCoord: a.customType({
        id: a.integer(),
        name: a.string(),
        address: a.string(),
        longitude: a.float(),
        latitude: a.float(),
      })
  })

const sqlSchema = generatedSqlSchema.authorization(allow => allow.guest())
  .addToSchema({
    createNewLocationWithLongLat: a.mutation()
      .arguments({
        lat: a.float().required(),
        long: a.float().required(),
        name: a.string().required(),
        address: a.string().required()
      })
      .returns(a.json().array())
      .authorization(allow => allow.authenticated())
Copy highlighted code example
      .handler(a.handler.sqlReference('./createNewLocationWithLongLat.sql'))
  })