DynamoDB を Node.js で操作する（SDK ver.3 の場合）

### yarn の場合
$ yarn add @aws-sdk/client-dynamodb
$ yarn add @aws-sdk/lib-dynamodb @aws-sdk/util-dynamodb  # Document クライアント

### npm の場合
$ npm install @aws-sdk/client-dynamodb
$ npm install @aws-sdk/lib-dynamodb @aws-sdk/util-dynamodb  # Document クライアント

import { DynamoDBClient } from '@aws-sdk/client-dynamodb'
import { DynamoDBDocumentClient } from '@aws-sdk/lib-dynamodb'

import { CreateTableCommand, DynamoDBClient } from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})

// テーブルを作成する
async function createTable() {
  try {
    const command = new CreateTableCommand({
      TableName: 'Games', // テーブル名
      KeySchema: [
        { AttributeName: 'Hardware', KeyType: 'HASH' }, // パーティションキー
        { AttributeName: 'GameId', KeyType: 'RANGE' }, // ソートキー
      ],
      AttributeDefinitions: [
        { AttributeName: 'Hardware', AttributeType: 'S' }, // 文字列属性
        { AttributeName: 'GameId', AttributeType: 'S' }, // 文字列属性
      ],
      ProvisionedThroughput: {
        ReadCapacityUnits: 1,
        WriteCapacityUnits: 1,
      },
      StreamSpecification: {
        StreamEnabled: false,
      },
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS: Table created:', output)
  } catch (err) {
    console.error('ERROR:', err)
  }
}

createTable()

import {DeleteTableCommand, DynamoDBClient} from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000'
})

// テーブルを削除する
async function deleteTable() {
  try {
    const command = new DeleteTableCommand({
      TableName: 'Games',
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS: Table deleted:', output)
  } catch (err) {
    console.error('ERROR:', err)
  }
}

deleteTable()

import { DynamoDBClient, ListTablesCommand } from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})

// テーブルの一覧を取得する
async function listTables() {
  try {
    const command = new ListTablesCommand({})
    const output = await dbClient.send(command)
    if (output.TableNames) {
      console.log(output.TableNames.join(', '))
    }
    console.log(output)
  } catch (err) {
    console.error('ERROR', err)
  }
}

listTables()

import { DescribeTableCommand, DynamoDBClient } from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})

// テーブルの詳細情報を取得する
async function describeTable() {
  try {
    const command = new DescribeTableCommand({
      TableName: 'Games',
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS (describe table):', JSON.stringify(output, null, 2))
  } catch (err) {
    console.error('ERROR:', err)
  }
}

describeTable()

import {DynamoDBClient, PutItemCommand} from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000'
})

// テーブルにアイテムを追加する
async function putItem() {
  try {
    const command = new PutItemCommand({
      TableName: 'Games',
      Item: {
        Hardware: { S: 'SNES' },
        GameId: { S: '1990-SuperMarioWorld' },
        Title: { S: 'Super Mario World' },
        Players: { N: '2' },
        Genre: { S: 'ACT' },
      },
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS (put item):', output)
  } catch (err) {
    console.log('ERROR:', err)
  }
}

putItem()

async function putItem() {
  try {
    const command = new PutItemCommand({
      TableName: 'Games',
      Item: {
        Hardware: { S: 'SNES' },
        GameId: { S: '1990-SuperMarioWorld' },
        Title: { S: 'XXXXX' }, // 値を適当に変えてみる
        Players: { N: '2' },
        Genre: { S: 'ACT' },
      },
      ReturnValues: 'ALL_OLD',  // もとの属性値を取得
    });
    const output = await dbClient.send(command);
    console.log('SUCCESS (put item):', output.Attributes);
  } catch (err) {
    console.log('ERROR:', err);
  }
}

SUCCESS (put item): {
  Title: { S: 'Super Mario World' },
  Hardware: { S: 'SNES' },
  Genre: { S: 'ACT' },
  GameId: { S: '1990-SuperMarioWorld' },
  Players: { N: '2' }
}

const command = new PutItemCommand({
  TableName: 'Games',
  Item: {
    Hardware: { S: 'SNES' },
    GameId: { S: '1990-SuperMarioWorld' },
    Title: { S: 'XXXXX' }, // 値を適当に変えてみる
    Players: { N: '2' },
    Genre: { S: 'ACT' },
  },
  ConditionExpression: 'attribute_not_exists(Hardware)',
});

import { DynamoDBClient, UpdateItemCommand } from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})

// アイテムの属性値を部分的に更新する
async function updateItem() {
  try {
    const command = new UpdateItemCommand({
      TableName: 'Games',
      Key: {
        Hardware: { S: 'SNES' },
        GameId: { S: '1990-SuperMarioWorld' },
      },
      UpdateExpression: 'set Title = :x, #a = :y',
      ExpressionAttributeNames: {
        '#a': 'Maker',
      },
      ExpressionAttributeValues: {
        ':x': { S: 'Mario 4' },
        ':y': { S: 'Nintendo' },
      },
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS (update item):', output)
  } catch (err) {
    console.log('ERROR:', err)
  }
}

updateItem()

import { DynamoDBClient } from '@aws-sdk/client-dynamodb'
import {
  DynamoDBDocumentClient,
  UpdateCommand,
  UpdateCommandInput,
} from '@aws-sdk/lib-dynamodb'
const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})
const documentClient = DynamoDBDocumentClient.from(dbClient)

// アイテムの属性値を部分的に更新する
async function updateItem() {
  try {
    const command = new UpdateCommand({
      TableName: 'Games',
      Key: {
        Hardware: 'SNES', // Partition key
        GameId: '1990-SuperMarioWorld', // Sort key
      },
      UpdateExpression: 'set Title = :x, #a = :y',
      ExpressionAttributeNames: {
        '#a': 'Maker',
      },
      ExpressionAttributeValues: {
        ':x': 'Mario 4',
        ':y': 'Nintendo',
      },
    } as UpdateCommandInput)
    const output = await documentClient.send(command)
    console.log('SUCCESS (update item):', output)
  } catch (err) {
    console.log('ERROR:', err)
  }
}

updateItem()

import { DynamoDBClient, GetItemCommand } from '@aws-sdk/client-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000'
})

// アイテムを取得する
async function getItem() {
  try {
    const command = new GetItemCommand({
      TableName: 'Games',
      Key: {
        Hardware: {S: 'SNES'},
        GameId: {S: '1990-SuperMarioWorld'},
      }
    })
    const output = await dbClient.send(command)
    console.log('SUCCESS (get item):', output)
  } catch (err) {
    console.log('ERROR:', err)
  }
}

getItem();

import { DynamoDBClient } from '@aws-sdk/client-dynamodb'
import { DynamoDBDocumentClient, GetCommand } from '@aws-sdk/lib-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000'
})
const documentClient = DynamoDBDocumentClient.from(dbClient)

async function getItem() {
  try {
    const command = new GetCommand({
      TableName: 'Games',
      Key: {
        Hardware: 'SNES',
        GameId: '1990-SuperMarioWorld',
      }
    })
    const output = await documentClient.send(command)
    console.log('SUCCESS (get item):', output)
  } catch (err) {
    console.log('ERROR:', err)
  }
}

import {DeleteItemCommand, DynamoDBClient} from '@aws-sdk/client-dynamodb';

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000'
});

// アイテムを削除する
async function deleteItem() {
  try {
    const command = new DeleteItemCommand({
      TableName: 'Games',
      Key: {
        Hardware: {S: 'SNES'},
        GameId: {S: '1990-SuperMarioWorld'},
      }
    });
    const output = await dbClient.send(command);
    console.log('SUCCESS (delete item):', output);
  } catch (err) {
    console.log('ERROR:', err);
  }
}

deleteItem();

import { DynamoDBClient, ScanCommand } from '@aws-sdk/client-dynamodb'
const dbClient = new DynamoDBClient({...})

// 全てのアイテムをスキャンする
async function scan() {
  try {
    const command = new ScanCommand({
      TableName: 'Games',
      // Limit: 10,
    })
    const output = await dbClient.send(command)
    console.log(JSON.stringify(output, null, 2))
  } catch (err) {
    console.log('ERROR:', err)
  }
}

scan()

import { DynamoDBClient } from '@aws-sdk/client-dynamodb'
import {
  DynamoDBDocumentClient,
  ScanCommand,
  ScanCommandInput,
  ScanCommandOutput,
} from '@aws-sdk/lib-dynamodb'

const dbClient = new DynamoDBClient({
  endpoint: 'http://localhost:8000',
})
const documentClient = DynamoDBDocumentClient.from(dbClient)

async function scan() {
  try {
    const command = new ScanCommand({
      TableName: 'Games',
    } as ScanCommandInput)
    const output: ScanCommandOutput = await documentClient.send(command)
    console.log(JSON.stringify(output, null, 2))
  } catch (err) {
    console.log('ERROR:', err)
  }
}

scan()

const games = output.Items as Game[]

export async function getGames(): Promise<Game[]> {
  const command = new ScanCommand({
    TableName: 'Games',
  } as ScanCommandInput)
  const output: ScanCommandOutput = await documentClient.send(command)
  return output.Items as Game[]
}