-
Notifications
You must be signed in to change notification settings - Fork 180
/
alterMaterializedView.ts
64 lines (49 loc) · 1.72 KB
/
alterMaterializedView.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
import type { MigrationOptions } from '../../types';
import { formatLines } from '../../utils';
import type { Name, Nullable } from '../generalTypes';
import type { StorageParameters } from './shared';
import { storageParameterStr } from './shared';
export interface AlterMaterializedViewOptions {
cluster?: null | false | string;
extension?: string;
storageParameters?: Nullable<StorageParameters>;
}
export type AlterMaterializedView = (
viewName: Name,
materializedViewOptions: AlterMaterializedViewOptions
) => string;
export function alterMaterializedView(
mOptions: MigrationOptions
): AlterMaterializedView {
const _alter: AlterMaterializedView = (viewName, options) => {
const { cluster, extension, storageParameters = {} } = options;
const clauses: string[] = [];
if (cluster !== undefined) {
if (cluster) {
clauses.push(`CLUSTER ON ${mOptions.literal(cluster)}`);
} else {
clauses.push('SET WITHOUT CLUSTER');
}
}
if (extension) {
clauses.push(`DEPENDS ON EXTENSION ${mOptions.literal(extension)}`);
}
const withOptions = Object.keys(storageParameters)
.filter((key) => storageParameters[key] !== null)
.map(storageParameterStr(storageParameters))
.join(', ');
if (withOptions) {
clauses.push(`SET (${withOptions})`);
}
const resetOptions = Object.keys(storageParameters)
.filter((key) => storageParameters[key] === null)
.join(', ');
if (resetOptions) {
clauses.push(`RESET (${resetOptions})`);
}
const clausesStr = formatLines(clauses);
const viewNameStr = mOptions.literal(viewName);
return `ALTER MATERIALIZED VIEW ${viewNameStr}\n${clausesStr};`;
};
return _alter;
}