Druid Dialect

export class DruidDialect extends SQLiteDialect {
  // name === 'druid'; library === 'fetch'
}

$ npm install ts-prorm-orm

$ pnpm add ts-prorm-orm

$ yarn add ts-prorm-orm

$ bun add ts-prorm-orm

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

export const db = new Prorm({
  dialect: 'druid',
  host: 'druid-router.internal', // port defaults to 8888 (the Router)
});

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

export const db = new Prorm({
  dialect: 'druid',
  url: 'druid://druid-router.internal:8888',
});

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';

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

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

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

const orm = new Prorm({ dialect: 'druid', host: 'druid-router.internal', logging: false });
// or directly:
const d = new Prorm({
  dialect: 'druid',
  host: 'druid-router.internal', // port defaults to 8888 (the Router)
  username: 'analyst', // HTTP Basic (basic-security extension)
  password: process.env.DRUID_PASSWORD,
  dialectOptions: {
    protocol: 'https', // default 'http'
    context: { sqlTimeZone: 'UTC' }, // query context on every request
  },
});
await d.connect(); // probes GET /status/health

const src = d.buildInlineExtern(
  [{ ts: '2024-01-01T00:00:00Z', page: 'Main', added: 3 }],
  [
    { name: 'ts', type: 'string' },
    { name: 'page', type: 'string' },
    { name: 'added', type: 'long' },
  ],
);
const stmt = d.buildInsertIngestion({
  table: 'wikipedia',
  select: `SELECT TIME_PARSE("ts") AS __time, "page", "added" FROM ${src}`,
  partitionedBy: 'DAY',
  clusteredBy: ['page'],
});
const { taskId } = await d.submitIngestion(stmt);
await d.waitForTask(taskId); // throws with Druid's errorMsg on FAILED