Amazon Redshift Data API Dialect

$ npm install ts-prorm-orm @aws-sdk/client-redshift-data

$ pnpm add ts-prorm-orm @aws-sdk/client-redshift-data

$ yarn add ts-prorm-orm @aws-sdk/client-redshift-data

$ bun add ts-prorm-orm @aws-sdk/client-redshift-data

import { Prorm } from 'ts-prorm-orm';

export const db = new Prorm({
  dialect: 'redshiftdata',
  database: 'dev',
  dialectOptions: {
    workgroupName: 'analytics', // or clusterIdentifier
    region: 'us-east-1',
  },
});

import { DataTypes } from 'ts-prorm-orm';

const User = db.define('User', {
  id: { type: DataTypes.INTEGER(), primaryKey: true, autoIncrement: true },
  email: { type: DataTypes.STRING(255), allowNull: false, unique: true },
  name: { type: DataTypes.STRING(100) },
});

await db.sync(); // CREATE TABLE — see Generated SQL below

import { Op } from 'ts-prorm-orm';

await User.create({ email: 'ada@example.com', name: 'Ada' });

const page = await User.findAll({
  where: { name: { [Op.like]: 'A%' } },
  order: [['id', 'ASC']],
  limit: 20,
  offset: 40,
});

await User.create({ email: 'ada@example.com', name: 'Ada' });
await User.update({ name: 'Grace' }, { where: { email: 'ada@example.com' } });
await User.destroy({ where: { id: 1 } });

await User.upsert({ id: 1, email: 'ada@example.com', name: 'Ada Lovelace' });

await User.findAll({
  where: { name: { [Op.like]: 'A%' } },
  order: [['id', 'ASC']],
  limit: 20,
  offset: 40,
});

await db.transaction(async (t) => {
  await User.create({ email: 'grace@example.com', name: 'Grace' }, { transaction: t });
  await User.update({ name: 'Grace Hopper' }, { where: { email: 'grace@example.com' }, transaction: t });
});

const db = new Prorm({
  dialect: 'redshiftdata',
  database: 'dev',
  dialectOptions: {
    workgroupName: 'analytics', // or clusterIdentifier: 'my-cluster'
    secretArn: 'arn:aws:secretsmanager:…', // optional, see below
    region: 'us-east-1',
  },
});

await db.dialect.query('SELECT * FROM sales WHERE region = :region', {
  parameters: { region: 'EMEA' },
});

const results = await dialect.batch([
  dialect.buildInsertQuery('orders', { id: 1, total: 10 }),
  dialect.buildUpdateQuery('stock', { qty: 4 }, { sku: 'A' }),
  { sql: 'SELECT count(*) AS n FROM orders' },
]);