Add data export migration

api/db.ts

@@ -28,7 +28,7 @@ export {Lock} from '../src/db/models/new/lock';
 export {Favorite} from '../src/db/models/new/favorite';
 export {UserSettings} from '../src/db/models/new/user-settings';
 export {Comment, CommentType} from '../src/db/models/new/comment';
-
+export {DataExport} from '../src/db/models/new/data-export';
 export {EmbedModel, EmbedModelColumn} from '../src/db/models/new/embed';
 export {
     EmbeddingSecretModel,

src/db/migrations/20241219092946_data_export.ts

@@ -0,0 +1,42 @@
+import type {Knex} from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+    return knex.raw(`
+        CREATE TABLE data_exports (
+            data_export_id BIGINT NOT NULL PRIMARY KEY DEFAULT get_id(),
+            title TEXT NOT NULL,
+            tenant_id TEXT NOT NULL DEFAULT 'common' REFERENCES tenants (tenant_id) ON UPDATE CASCADE ON DELETE CASCADE,
+            chart_id BIGINT REFERENCES entries (entry_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            chart_rev_id BIGINT REFERENCES revisions (rev_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            dataset_id BIGINT REFERENCES entries (entry_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            dataset_rev_id BIGINT REFERENCES revisions (rev_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            connection_id BIGINT REFERENCES entries (entry_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            connection_rev_id BIGINT REFERENCES revisions (rev_id) ON UPDATE CASCADE ON DELETE SET NULL,
+            params JSONB NOT NULL DEFAULT '{}'::jsonb,
+            created_by TEXT NOT NULL,
+            updated_by TEXT,
+            created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
+            updated_at TIMESTAMPTZ,
+            expired_at TIMESTAMPTZ NOT NULL,
+            job_id TEXT NOT NULL,
+            result_link TEXT,
+            error JSONB
+        );
+
+        CREATE INDEX data_exports_chart_id_idx ON data_exports(chart_id);
+        CREATE INDEX data_exports_dataset_id_idx ON data_exports(dataset_id);
+        CREATE INDEX data_exports_connection_id_idx ON data_exports(connection_id);
+        CREATE INDEX data_exports_expired_at_idx ON data_exports(expired_at);
+    `);
+}
+
+export async function down(knex: Knex): Promise<void> {
+    return knex.raw(`
+        DROP INDEX data_exports_chart_id_idx;
+        DROP INDEX data_exports_dataset_id_idx;
+        DROP INDEX data_exports_connection_id_idx;
+        DROP INDEX data_exports_expired_at_idx;
+
+        DROP TABLE data_exports;
+    `);
+}

src/db/models/new/data-export/index.ts

@@ -0,0 +1,30 @@
+import {Model} from '../../..';
+
+export class DataExport extends Model {
+    static get tableName() {
+        return 'data_exports';
+    }
+
+    static get idColumn() {
+        return 'dataExportId';
+    }
+
+    dataExportId!: string;
+    title!: string;
+    tenantId!: string;
+    chartId!: Nullable<string>;
+    chartRevId!: Nullable<string>;
+    datasetId!: Nullable<string>;
+    datasetRevId!: Nullable<string>;
+    connectionId!: Nullable<string>;
+    connectionRevId!: Nullable<string>;
+    params!: Record<string, unknown>;
+    createdBy!: string;
+    updatedBy!: Nullable<string>;
+    createdAt!: string;
+    updatedAt!: Nullable<string>;
+    expiredAt!: string;
+    jobId!: string;
+    resultLink!: Nullable<string>;
+    error!: Nullable<Record<string, unknown>>;
+}