query designer

packages/web/src/designer/ColumnLine.svelte

@@ -0,0 +1,57 @@
+<script lang="ts">
+  import { findForeignKeyForColumn } from 'dbgate-tools';
+
+  import ColumnLabel from '../elements/ColumnLabel.svelte';
+
+  import CheckboxField from '../forms/CheckboxField.svelte';
+  import FontIcon from '../icons/FontIcon.svelte';
+  export let column;
+  export let table;
+  export let designer;
+  export let designerId;
+  export let onChangeColumn;
+
+  $: designerColumn = (designer.columns || []).find(
+    x => x.designerId == designerId && x.columnName == column.columnName
+  );
+</script>
+
+<div>
+  <CheckboxField
+    checked={!!(designer.columns || []).find(
+      x => x.designerId == designerId && x.columnName == column.columnName && x.isOutput
+    )}
+    onChange={e => {
+      if (e.target.checked) {
+        onChangeColumn(
+          {
+            ...column,
+            designerId,
+          },
+          col => ({ ...col, isOutput: true })
+        );
+      } else {
+        onChangeColumn(
+          {
+            ...column,
+            designerId,
+          },
+          col => ({ ...col, isOutput: false })
+        );
+      }
+    }}
+  />
+  <ColumnLabel {...column} foreignKey={findForeignKeyForColumn(table, column)} forceIcon />
+  {#if designerColumn?.filter}
+    <FontIcon icon="img filter" />
+  {/if}
+  {#if designerColumn?.sortOrder > 0}
+    <FontIcon icon="img sort-asc" />
+  {/if}
+  {#if designerColumn?.sortOrder < 0}
+    <FontIcon icon="img sort-desc" />
+  {/if}
+  {#if designerColumn?.isGrouped}
+    <FontIcon icon="img group" />
+  {/if}
+</div>

packages/web/src/designer/Designer.svelte

@@ -0,0 +1,261 @@
+<script lang="ts" context="module">
+</script>
+
+<script lang="ts">
+  import DesignerTable from './DesignerTable.svelte';
+  import { isConnectedByReference } from './designerTools';
+  import uuidv1 from 'uuid/v1';
+  import { getTableInfo } from '../utility/metadataLoaders';
+  import cleanupDesignColumns from './cleanupDesignColumns';
+  import _ from 'lodash';
+
+  export let value;
+  export let onChange;
+  export let conid;
+  export let database;
+
+  let domWrapper;
+
+  $: tables = value?.tables as any[];
+  $: references = value?.references as any[];
+
+  function fixPositions(tables) {
+    const minLeft = _.min(tables.map(x => x.left));
+    const minTop = _.min(tables.map(x => x.top));
+    if (minLeft < 0 || minTop < 0) {
+      const dLeft = minLeft < 0 ? -minLeft : 0;
+      const dTop = minTop < 0 ? -minTop : 0;
+      return tables.map(tbl => ({
+        ...tbl,
+        left: tbl.left + dLeft,
+        top: tbl.top + dTop,
+      }));
+    }
+    return tables;
+  }
+
+  const changeTable = table => {
+    onChange(current => ({
+      ...current,
+      tables: fixPositions((current.tables || []).map(x => (x.designerId == table.designerId ? table : x))),
+    }));
+  };
+
+  const bringToFront = table => {
+    onChange(
+      current => ({
+        ...current,
+        tables: [...(current.tables || []).filter(x => x.designerId != table.designerId), table],
+      }),
+      true
+    );
+  };
+
+  const removeTable = table => {
+    onChange(current => ({
+      ...current,
+      tables: (current.tables || []).filter(x => x.designerId != table.designerId),
+      references: (current.references || []).filter(
+        x => x.sourceId != table.designerId && x.targetId != table.designerId
+      ),
+      columns: (current.columns || []).filter(x => x.designerId != table.designerId),
+    }));
+  };
+
+  const changeReference = ref => {
+    onChange(current => ({
+      ...current,
+      references: (current.references || []).map(x => (x.designerId == ref.designerId ? ref : x)),
+    }));
+  };
+
+  const removeReference = ref => {
+    onChange(current => ({
+      ...current,
+      references: (current.references || []).filter(x => x.designerId != ref.designerId),
+    }));
+  };
+
+  const handleCreateReference = (source, target) => {
+    onChange(current => {
+      const existingReference = (current.references || []).find(
+        x =>
+          (x.sourceId == source.designerId && x.targetId == target.designerId) ||
+          (x.sourceId == target.designerId && x.targetId == source.designerId)
+      );
+
+      return {
+        ...current,
+        references: existingReference
+          ? current.references.map(ref =>
+              ref == existingReference
+                ? {
+                    ...existingReference,
+                    columns: [
+                      ...existingReference.columns,
+                      existingReference.sourceId == source.designerId
+                        ? {
+                            source: source.columnName,
+                            target: target.columnName,
+                          }
+                        : {
+                            source: target.columnName,
+                            target: source.columnName,
+                          },
+                    ],
+                  }
+                : ref
+            )
+          : [
+              ...(current.references || []),
+              {
+                designerId: uuidv1(),
+                sourceId: source.designerId,
+                targetId: target.designerId,
+                joinType: isConnectedByReference(current, source, target, null) ? 'CROSS JOIN' : 'INNER JOIN',
+                columns: [
+                  {
+                    source: source.columnName,
+                    target: target.columnName,
+                  },
+                ],
+              },
+            ],
+      };
+    });
+  };
+
+  const handleAddReferenceByColumn = async (designerId, foreignKey) => {
+    const toTable = await getTableInfo({
+      conid,
+      database,
+      pureName: foreignKey.refTableName,
+      schemaName: foreignKey.refSchemaName,
+    });
+    const newTableDesignerId = uuidv1();
+    onChange(current => {
+      const fromTable = (current.tables || []).find(x => x.designerId == designerId);
+      if (!fromTable) return;
+      return {
+        ...current,
+        tables: [
+          ...(current.tables || []),
+          {
+            ...toTable,
+            left: fromTable.left + 300,
+            top: fromTable.top + 50,
+            designerId: newTableDesignerId,
+          },
+        ],
+        references: [
+          ...(current.references || []),
+          {
+            designerId: uuidv1(),
+            sourceId: fromTable.designerId,
+            targetId: newTableDesignerId,
+            joinType: 'INNER JOIN',
+            columns: foreignKey.columns.map(col => ({
+              source: col.columnName,
+              target: col.refColumnName,
+            })),
+          },
+        ],
+      };
+    });
+  };
+
+  const handleSelectColumn = column => {
+    onChange(
+      current => ({
+        ...current,
+        columns: (current.columns || []).find(
+          x => x.designerId == column.designerId && x.columnName == column.columnName
+        )
+          ? current.columns
+          : [...cleanupDesignColumns(current.columns), _.pick(column, ['designerId', 'columnName'])],
+      }),
+      true
+    );
+  };
+
+  const handleChangeColumn = (column, changeFunc) => {
+    onChange(current => {
+      const currentColumns = (current || {}).columns || [];
+      const existing = currentColumns.find(x => x.designerId == column.designerId && x.columnName == column.columnName);
+      if (existing) {
+        return {
+          ...current,
+          columns: currentColumns.map(x => (x == existing ? changeFunc(existing) : x)),
+        };
+      } else {
+        return {
+          ...current,
+          columns: [...cleanupDesignColumns(currentColumns), changeFunc(_.pick(column, ['designerId', 'columnName']))],
+        };
+      }
+    });
+  };
+</script>
+
+<div class="wrapper" bind:this={domWrapper}>
+  {#if !(tables?.length > 0)}
+    <div class="empty">Drag &amp; drop tables or views from left panel here</div>
+  {/if}
+
+  <div class="canvas">
+    <!-- {#each references || [] as ref (ref.designerId)}
+      <DesignerReference
+        {changeToken}
+        {domTablesRef}
+        reference={ref}
+        onChangeReference={changeReference}
+        onRemoveReference={removeReference}
+        designer={value}
+      />
+        {/each} 
+
+                {sourceDragColumn}
+        {setSourceDragColumn}
+        {targetDragColumn}
+        {setTargetDragColumn}
+
+                {setChangeToken}
+        onChangeDomTable={table => {
+          domTablesRef.current[table.designerId] = table;
+        }}
+
+  -->
+
+    {#each tables || [] as table (table.designerId)}
+      <DesignerTable
+        onCreateReference={handleCreateReference}
+        onSelectColumn={handleSelectColumn}
+        onChangeColumn={handleChangeColumn}
+        onAddReferenceByColumn={handleAddReferenceByColumn}
+        {table}
+        onChangeTable={changeTable}
+        onBringToFront={bringToFront}
+        onRemoveTable={removeTable}
+        {domWrapper}
+        designer={value}
+      />
+    {/each}
+  </div>
+</div>
+
+<style>
+  .wrapper {
+    flex: 1;
+    background-color: var(--theme-bg-1);
+    overflow: scroll;
+  }
+  .empty {
+    margin: 50px;
+    font-size: 20px;
+  }
+  .canvas {
+    width: 3000px;
+    height: 3000px;
+    position: relative;
+  }
+</style>

packages/web/src/designer/DesignerComponentCreator.ts

@@ -0,0 +1,91 @@
+import _ from 'lodash';
+import { dumpSqlSelect, Select, JoinType, Condition, Relation, mergeConditions, Source } from 'dbgate-sqltree';
+import { EngineDriver } from 'dbgate-types';
+import { DesignerInfo, DesignerTableInfo, DesignerReferenceInfo, DesignerJoinType } from './types';
+import { findPrimaryTable, findConnectingReference, referenceIsJoin, referenceIsExists } from './designerTools';
+
+export class DesignerComponent {
+  subComponents: DesignerComponent[] = [];
+  parentComponent: DesignerComponent;
+  parentReference: DesignerReferenceInfo;
+
+  tables: DesignerTableInfo[] = [];
+  nonPrimaryReferences: DesignerReferenceInfo[] = [];
+
+  get primaryTable() {
+    return this.tables[0];
+  }
+  get nonPrimaryTables() {
+    return this.tables.slice(1);
+  }
+  get nonPrimaryTablesAndReferences() {
+    return _.zip(this.nonPrimaryTables, this.nonPrimaryReferences);
+  }
+  get myAndParentTables() {
+    return [...this.parentTables, ...this.tables];
+  }
+  get parentTables() {
+    return this.parentComponent ? this.parentComponent.myAndParentTables : [];
+  }
+  get thisAndSubComponentsTables() {
+    return [...this.tables, ..._.flatten(this.subComponents.map(x => x.thisAndSubComponentsTables))];
+  }
+}
+
+export class DesignerComponentCreator {
+  toAdd: DesignerTableInfo[];
+  components: DesignerComponent[] = [];
+
+  constructor(public designer: DesignerInfo) {
+    this.toAdd = [...designer.tables];
+    while (this.toAdd.length > 0) {
+      const component = this.parseComponent(null);
+      this.components.push(component);
+    }
+  }
+
+  parseComponent(root) {
+    if (root == null) {
+      root = findPrimaryTable(this.toAdd);
+    }
+    if (!root) return null;
+    _.remove(this.toAdd, x => x == root);
+    const res = new DesignerComponent();
+    res.tables.push(root);
+
+    for (;;) {
+      let found = false;
+      for (const test of this.toAdd) {
+        const ref = findConnectingReference(this.designer, res.tables, [test], referenceIsJoin);
+        if (ref) {
+          res.tables.push(test);
+          res.nonPrimaryReferences.push(ref);
+          _.remove(this.toAdd, x => x == test);
+          found = true;
+          break;
+        }
+      }
+
+      if (!found) break;
+    }
+
+    for (;;) {
+      let found = false;
+      for (const test of this.toAdd) {
+        const ref = findConnectingReference(this.designer, res.tables, [test], referenceIsExists);
+        if (ref) {
+          const subComponent = this.parseComponent(test);
+          res.subComponents.push(subComponent);
+          subComponent.parentComponent = res;
+          subComponent.parentReference = ref;
+          found = true;
+          break;
+        }
+      }
+
+      if (!found) break;
+    }
+
+    return res;
+  }
+}

packages/web/src/designer/DesignerQueryDumper.ts

@@ -0,0 +1,215 @@
+import _ from 'lodash';
+import {
+  dumpSqlSelect,
+  Select,
+  JoinType,
+  Condition,
+  Relation,
+  mergeConditions,
+  Source,
+  ResultField,
+} from 'dbgate-sqltree';
+import { EngineDriver } from 'dbgate-types';
+import { DesignerInfo, DesignerTableInfo, DesignerReferenceInfo, DesignerJoinType } from './types';
+import { DesignerComponent } from './DesignerComponentCreator';
+import {
+  getReferenceConditions,
+  referenceIsCrossJoin,
+  referenceIsConnecting,
+  mergeSelectsFromDesigner,
+  findQuerySource,
+  findDesignerFilterType,
+} from './designerTools';
+import { parseFilter } from 'dbgate-filterparser';
+
+export class DesignerQueryDumper {
+  constructor(public designer: DesignerInfo, public components: DesignerComponent[]) {}
+
+  get topLevelTables(): DesignerTableInfo[] {
+    return _.flatten(this.components.map(x => x.tables));
+  }
+
+  dumpComponent(component: DesignerComponent) {
+    const select: Select = {
+      commandType: 'select',
+      from: {
+        name: component.primaryTable,
+        alias: component.primaryTable.alias,
+        relations: [],
+      },
+    };
+
+    for (const [table, ref] of component.nonPrimaryTablesAndReferences) {
+      select.from.relations.push({
+        name: table,
+        alias: table.alias,
+        joinType: ref.joinType as JoinType,
+        conditions: getReferenceConditions(ref, this.designer),
+      });
+    }
+
+    for (const subComponent of component.subComponents) {
+      const subQuery = this.dumpComponent(subComponent);
+      subQuery.selectAll = true;
+      select.where = mergeConditions(select.where, {
+        conditionType: subComponent.parentReference.joinType == 'WHERE NOT EXISTS' ? 'notExists' : 'exists',
+        subQuery,
+      });
+    }
+
+    if (component.parentReference) {
+      select.where = mergeConditions(select.where, {
+        conditionType: 'and',
+        conditions: getReferenceConditions(component.parentReference, this.designer),
+      });
+
+      // cross join conditions in subcomponents
+      for (const ref of this.designer.references || []) {
+        if (referenceIsCrossJoin(ref) && referenceIsConnecting(ref, component.tables, component.myAndParentTables)) {
+          select.where = mergeConditions(select.where, {
+            conditionType: 'and',
+            conditions: getReferenceConditions(ref, this.designer),
+          });
+        }
+      }
+      this.addConditions(select, component.tables);
+    }
+
+    return select;
+  }
+
+  addConditions(select: Select, tables: DesignerTableInfo[]) {
+    for (const column of this.designer.columns || []) {
+      if (!column.filter) continue;
+      const table = (this.designer.tables || []).find(x => x.designerId == column.designerId);
+      if (!table) continue;
+      if (!tables.find(x => x.designerId == table.designerId)) continue;
+
+      const condition = parseFilter(column.filter, findDesignerFilterType(column, this.designer));
+      if (condition) {
+        select.where = mergeConditions(
+          select.where,
+          _.cloneDeepWith(condition, expr => {
+            if (expr.exprType == 'placeholder')
+              return {
+                exprType: 'column',
+                columnName: column.columnName,
+                source: findQuerySource(this.designer, column.designerId),
+              };
+          })
+        );
+      }
+    }
+  }
+
+  addGroupConditions(select: Select, tables: DesignerTableInfo[], selectIsGrouped: boolean) {
+    for (const column of this.designer.columns || []) {
+      if (!column.groupFilter) continue;
+      const table = (this.designer.tables || []).find(x => x.designerId == column.designerId);
+      if (!table) continue;
+      if (!tables.find(x => x.designerId == table.designerId)) continue;
+
+      const condition = parseFilter(column.groupFilter, findDesignerFilterType(column, this.designer));
+      if (condition) {
+        select.having = mergeConditions(
+          select.having,
+          _.cloneDeepWith(condition, expr => {
+            if (expr.exprType == 'placeholder') {
+              return this.getColumnOutputExpression(column, selectIsGrouped);
+            }
+          })
+        );
+      }
+    }
+  }
+
+  getColumnOutputExpression(col, selectIsGrouped): ResultField {
+    const source = findQuerySource(this.designer, col.designerId);
+    const { columnName } = col;
+    let { alias } = col;
+    if (selectIsGrouped && !col.isGrouped) {
+      // use aggregate
+      const aggregate = col.aggregate == null || col.aggregate == '---' ? 'MAX' : col.aggregate;
+      if (!alias) alias = `${aggregate}(${columnName})`;
+
+      return {
+        exprType: 'call',
+        func: aggregate == 'COUNT DISTINCT' ? 'COUNT' : aggregate,
+        argsPrefix: aggregate == 'COUNT DISTINCT' ? 'DISTINCT' : null,
+        alias,
+        args: [
+          {
+            exprType: 'column',
+            columnName,
+            source,
+          },
+        ],
+      };
+    } else {
+      return {
+        exprType: 'column',
+        columnName,
+        alias,
+        source,
+      };
+    }
+  }
+
+  run() {
+    let res: Select = null;
+    for (const component of this.components) {
+      const select = this.dumpComponent(component);
+      if (res == null) res = select;
+      else res = mergeSelectsFromDesigner(res, select);
+    }
+
+    // top level cross join conditions
+    const topLevelTables = this.topLevelTables;
+    for (const ref of this.designer.references || []) {
+      if (referenceIsCrossJoin(ref) && referenceIsConnecting(ref, topLevelTables, topLevelTables)) {
+        res.where = mergeConditions(res.where, {
+          conditionType: 'and',
+          conditions: getReferenceConditions(ref, this.designer),
+        });
+      }
+    }
+
+    const topLevelColumns = (this.designer.columns || []).filter(col =>
+      topLevelTables.find(tbl => tbl.designerId == col.designerId)
+    );
+    const selectIsGrouped = !!topLevelColumns.find(x => x.isGrouped || (x.aggregate && x.aggregate != '---'));
+    const outputColumns = topLevelColumns.filter(x => x.isOutput);
+    if (outputColumns.length == 0) {
+      res.selectAll = true;
+    } else {
+      res.columns = outputColumns.map(col => this.getColumnOutputExpression(col, selectIsGrouped));
+    }
+
+    const groupedColumns = topLevelColumns.filter(x => x.isGrouped);
+    if (groupedColumns.length > 0) {
+      res.groupBy = groupedColumns.map(col => ({
+        exprType: 'column',
+        columnName: col.columnName,
+        source: findQuerySource(this.designer, col.designerId),
+      }));
+    }
+
+    const orderColumns = _.sortBy(
+      topLevelColumns.filter(x => x.sortOrder),
+      x => Math.abs(x.sortOrder)
+    );
+    if (orderColumns.length > 0) {
+      res.orderBy = orderColumns.map(col => ({
+        exprType: 'column',
+        direction: col.sortOrder < 0 ? 'DESC' : 'ASC',
+        columnName: col.columnName,
+        source: findQuerySource(this.designer, col.designerId),
+      }));
+    }
+
+    this.addConditions(res, topLevelTables);
+    this.addGroupConditions(res, topLevelTables, selectIsGrouped);
+
+    return res;
+  }
+}

packages/web/src/designer/DesignerTable.svelte

@@ -0,0 +1,86 @@
+<script lang="ts">
+  import FontIcon from '../icons/FontIcon.svelte';
+  import ColumnLine from './ColumnLine.svelte';
+
+  export let table;
+  export let onChangeTable;
+  export let onBringToFront;
+  export let onRemoveTable;
+  export let onCreateReference;
+  export let onAddReferenceByColumn;
+  export let onSelectColumn;
+  export let onChangeColumn;
+  export let sourceDragColumn;
+  export let setSourceDragColumn;
+  export let targetDragColumn;
+  export let setTargetDragColumn;
+  export let onChangeDomTable;
+  export let domWrapper;
+  export let designer;
+
+  let movingPosition = null;
+
+  $: pureName = table?.pureName;
+  $: alias = table?.alias;
+  $: columns = table?.columns;
+  $: designerId = table?.designerId;
+  $: objectTypeField = table?.objectTypeField;
+  $: left = table?.left;
+  $: top = table?.top;
+</script>
+
+<div
+  class="wrapper"
+  style={`left: ${movingPosition ? movingPosition.left : left}px; top:${movingPosition ? movingPosition.top : top}px`}
+>
+  <div class="header" class:isTable={objectTypeField == 'tables'} class:isView={objectTypeField == 'views'}>
+    <div>{alias || pureName}</div>
+    <div class="close" on:click={() => onRemoveTable(table)}>
+      <FontIcon icon="icon close" />
+    </div>
+  </div>
+  <div class="columns">
+    {#each columns || [] as column}
+      <ColumnLine {column} {table} {designer} {designerId} {onChangeColumn} />
+    {/each}
+  </div>
+</div>
+
+<style>
+  .wrapper {
+    position: absolute;
+    background-color: var(--theme-bg-0);
+    border: 1px solid var(--theme-border);
+  }
+
+  .header {
+    font-weight: bold;
+    text-align: center;
+    padding: 2px;
+    border-bottom: 1px solid var(--theme-border);
+    cursor: pointer;
+    display: flex;
+    justify-content: space-between;
+  }
+  .header.isTable {
+    background: var(--theme-bg-blue);
+  }
+  .header.isView {
+    background: var(--theme-bg-magenta);
+  }
+  .close {
+    background: var(--theme-bg-1);
+  }
+  .close:hover {
+    background: var(--theme-bg-2);
+  }
+  .close:active:hover {
+    background: var(--theme-bg-3);
+  }
+  .columns {
+    max-height: 400px;
+    overflow-y: auto;
+    width: calc(100% - 10px);
+    padding: 5px;
+  }
+</style>

packages/web/src/designer/DomTableRef.ts

@@ -0,0 +1,39 @@
+import { DesignerTableInfo } from './types';
+
+export default class DomTableRef {
+  domTable: Element;
+  domWrapper: Element;
+  table: DesignerTableInfo;
+  designerId: string;
+  domRefs: { [column: string]: Element };
+
+  constructor(table: DesignerTableInfo, domRefs, domWrapper: Element) {
+    this.domTable = domRefs[''];
+    this.domWrapper = domWrapper;
+    this.table = table;
+    this.designerId = table.designerId;
+    this.domRefs = domRefs;
+  }
+
+  getRect() {
+    if (!this.domWrapper) return null;
+    if (!this.domTable) return null;
+
+    const wrap = this.domWrapper.getBoundingClientRect();
+    const rect = this.domTable.getBoundingClientRect();
+    return {
+      left: rect.left - wrap.left,
+      top: rect.top - wrap.top,
+      right: rect.right - wrap.left,
+      bottom: rect.bottom - wrap.top,
+    };
+  }
+
+  getColumnY(columnName: string) {
+    let col = this.domRefs[columnName];
+    if (!col) return null;
+    const rect = col.getBoundingClientRect();
+    const wrap = this.domWrapper.getBoundingClientRect();
+    return (rect.top + rect.bottom) / 2 - wrap.top;
+  }
+}

packages/web/src/designer/QueryDesigner.svelte

@@ -0,0 +1,5 @@
+<script lang="ts">
+  import Designer from './Designer.svelte';
+</script>
+
+<Designer {...$$props} />

packages/web/src/designer/cleanupDesignColumns.js

@@ -0,0 +1,5 @@
+export default function cleanupDesignColumns(columns) {
+  return (columns || []).filter(
+    x => x.isOutput || x.isGrouped || x.alias || (x.aggregate && x.aggregate != '---') || x.sortOrder || x.filter
+  );
+}

packages/web/src/designer/designerTools.ts

@@ -0,0 +1,144 @@
+import _ from 'lodash';
+import { dumpSqlSelect, Select, JoinType, Condition, Relation, mergeConditions, Source } from 'dbgate-sqltree';
+import { EngineDriver } from 'dbgate-types';
+import { DesignerInfo, DesignerTableInfo, DesignerReferenceInfo, DesignerJoinType } from './types';
+import { DesignerComponentCreator } from './DesignerComponentCreator';
+import { DesignerQueryDumper } from './DesignerQueryDumper';
+import { getFilterType } from 'dbgate-filterparser';
+
+export function referenceIsConnecting(
+  reference: DesignerReferenceInfo,
+  tables1: DesignerTableInfo[],
+  tables2: DesignerTableInfo[]
+) {
+  return (
+    (tables1.find(x => x.designerId == reference.sourceId) && tables2.find(x => x.designerId == reference.targetId)) ||
+    (tables1.find(x => x.designerId == reference.targetId) && tables2.find(x => x.designerId == reference.sourceId))
+  );
+}
+
+export function referenceIsJoin(reference) {
+  return ['INNER JOIN', 'LEFT JOIN', 'RIGHT JOIN', 'FULL OUTER JOIN'].includes(reference.joinType);
+}
+export function referenceIsExists(reference) {
+  return ['WHERE EXISTS', 'WHERE NOT EXISTS'].includes(reference.joinType);
+}
+export function referenceIsCrossJoin(reference) {
+  return !reference.joinType || reference.joinType == 'CROSS JOIN';
+}
+
+export function findConnectingReference(
+  designer: DesignerInfo,
+  tables1: DesignerTableInfo[],
+  tables2: DesignerTableInfo[],
+  additionalCondition: (ref: DesignerReferenceInfo) => boolean
+) {
+  for (const ref of designer.references || []) {
+    if (additionalCondition(ref) && referenceIsConnecting(ref, tables1, tables2)) {
+      return ref;
+    }
+  }
+  return null;
+}
+
+export function findQuerySource(designer: DesignerInfo, designerId: string): Source {
+  const table = designer.tables.find(x => x.designerId == designerId);
+  if (!table) return null;
+  return {
+    name: table,
+    alias: table.alias,
+  };
+}
+
+export function mergeSelectsFromDesigner(select1: Select, select2: Select): Select {
+  return {
+    commandType: 'select',
+    from: {
+      ...select1.from,
+      relations: [
+        ...select1.from.relations,
+        {
+          joinType: 'CROSS JOIN',
+          name: select2.from.name,
+          alias: select2.from.alias,
+        },
+        ...select2.from.relations,
+      ],
+    },
+    where: mergeConditions(select1.where, select2.where),
+  };
+}
+
+export function findPrimaryTable(tables: DesignerTableInfo[]) {
+  return _.minBy(tables, x => x.top);
+}
+
+export function getReferenceConditions(reference: DesignerReferenceInfo, designer: DesignerInfo): Condition[] {
+  const sourceTable = designer.tables.find(x => x.designerId == reference.sourceId);
+  const targetTable = designer.tables.find(x => x.designerId == reference.targetId);
+
+  return reference.columns.map(col => ({
+    conditionType: 'binary',
+    operator: '=',
+    left: {
+      exprType: 'column',
+      columnName: col.source,
+      source: {
+        name: sourceTable,
+        alias: sourceTable.alias,
+      },
+    },
+    right: {
+      exprType: 'column',
+      columnName: col.target,
+      source: {
+        name: targetTable,
+        alias: targetTable.alias,
+      },
+    },
+  }));
+}
+
+export function generateDesignedQuery(designer: DesignerInfo, engine: EngineDriver) {
+  const { tables, columns, references } = designer;
+  const primaryTable = findPrimaryTable(designer.tables);
+  if (!primaryTable) return '';
+  const componentCreator = new DesignerComponentCreator(designer);
+  const designerDumper = new DesignerQueryDumper(designer, componentCreator.components);
+  const select = designerDumper.run();
+
+  const dmp = engine.createDumper();
+  dumpSqlSelect(dmp, select);
+  return dmp.s;
+}
+
+export function isConnectedByReference(
+  designer: DesignerInfo,
+  table1: { designerId: string },
+  table2: { designerId: string },
+  withoutRef: { designerId: string }
+) {
+  if (!designer.references) return false;
+  const creator = new DesignerComponentCreator({
+    ...designer,
+    references: withoutRef
+      ? designer.references.filter(x => x.designerId != withoutRef.designerId)
+      : designer.references,
+  });
+  const arrays = creator.components.map(x => x.thisAndSubComponentsTables);
+  const array1 = arrays.find(a => a.find(x => x.designerId == table1.designerId));
+  const array2 = arrays.find(a => a.find(x => x.designerId == table2.designerId));
+  return array1 == array2;
+}
+
+export function findDesignerFilterType({ designerId, columnName }, designer) {
+  const table = (designer.tables || []).find(x => x.designerId == designerId);
+  if (table) {
+    const column = (table.columns || []).find(x => x.columnName == columnName);
+    if (column) {
+      const { dataType } = column;
+      return getFilterType(dataType);
+    }
+  }
+  return 'string';
+}

packages/web/src/designer/types.ts

@@ -0,0 +1,44 @@
+import { JoinType } from 'dbgate-sqltree';
+import { TableInfo } from 'dbgate-types';
+
+export type DesignerTableInfo = TableInfo & {
+  designerId: string;
+  alias?: string;
+  left: number;
+  top: number;
+};
+
+export type DesignerJoinType = JoinType | 'WHERE EXISTS' | 'WHERE NOT EXISTS';
+
+export type DesignerReferenceInfo = {
+  designerId: string;
+  joinType: DesignerJoinType;
+  sourceId: string;
+  targetId: string;
+  columns: {
+    source: string;
+    target: string;
+  }[];
+};
+
+export type DesignerColumnInfo = {
+  designerId: string;
+  columnName: string;
+  alias?: string;
+  isGrouped?: boolean;
+  aggregate?: string;
+  isOutput?: boolean;
+  sortOrder?: number;
+  filter?: string;
+  groupFilter?: string;
+};
+
+export type DesignerInfo = {
+  tables: DesignerTableInfo[];
+  columns: DesignerColumnInfo[];
+  references: DesignerReferenceInfo[];
+};
+
+// export type DesignerComponent = {
+//   tables: DesignerTableInfo[];
+// };

packages/web/src/plugins/ThemeDark.svelte

@@ -32,6 +32,8 @@
     --theme-bg-green: #1d3712; /* green-2 */
     --theme-bg-volcano: #441d12; /* volcano-2 */
     --theme-bg-red: #431418; /* red-2 */
+    --theme-bg-blue: #15395b; /* blue-3 */
+    --theme-bg-magenta: #551c3b; /* magenta-3 */
 
     --theme-font-inv-1: #ffffff;
     --theme-font-inv-2: #b3b3b3;

packages/web/src/plugins/ThemeLight.svelte

@@ -25,6 +25,8 @@
     --theme-bg-green: #d9f7be; /* green-2 */
     --theme-bg-volcano: #ffd8bf; /* volcano-2 */
     --theme-bg-red: #ffccc7; /* red-2 */
+    --theme-bg-blue: #91d5ff; /* blue-3 */
+    --theme-bg-magenta: #ffadd2; /* magenta-3 */
 
     --theme-font-inv-1: #ffffff;
     --theme-font-inv-2: #b3b3b3;

packages/web/src/tabs/QueryDesignTab.svelte

@@ -0,0 +1,189 @@
+<script lang="ts" context="module">
+  let lastFocusedEditor = null;
+  const getCurrentEditor = () =>
+    lastFocusedEditor?.getTabId && lastFocusedEditor?.getTabId() == getActiveTabId() ? lastFocusedEditor : null;
+
+  registerFileCommands({
+    idPrefix: 'designer',
+    category: 'Designer',
+    getCurrentEditor,
+    folder: 'query',
+    format: 'json',
+    fileExtension: 'qdesign',
+
+    execute: true,
+  });
+</script>
+
+<script lang="ts">
+  import { get_current_component } from 'svelte/internal';
+  import { getContext } from 'svelte';
+  import sqlFormatter from 'sql-formatter';
+
+  import { writable, derived, get } from 'svelte/store';
+  import registerCommand from '../commands/registerCommand';
+
+  import VerticalSplitter from '../elements/VerticalSplitter.svelte';
+  import SqlEditor from '../query/SqlEditor.svelte';
+  import useEditorData from '../query/useEditorData';
+  import { activeTabId, extensions, getActiveTabId, nullStore } from '../stores';
+  import applySqlTemplate from '../utility/applySqlTemplate';
+  import axiosInstance from '../utility/axiosInstance';
+  import { changeTab } from '../utility/common';
+  import { useConnectionInfo } from '../utility/metadataLoaders';
+  import socket from '../utility/socket';
+  import SocketMessageView from '../query/SocketMessageView.svelte';
+  import memberStore from '../utility/memberStore';
+  import useEffect from '../utility/useEffect';
+  import ResultTabs from '../query/ResultTabs.svelte';
+  import { registerFileCommands } from '../commands/stdCommands';
+  import invalidateCommands from '../commands/invalidateCommands';
+  import QueryDesigner from '../designer/QueryDesigner.svelte';
+  import createReducer from '../utility/createReducer';
+  import createUndoReducer from '../utility/createUndoReducer';
+  import _ from 'lodash';
+
+  export let tabid;
+  export let conid;
+  export let database;
+  export let initialArgs;
+
+  const instance = get_current_component();
+  const tabVisible: any = getContext('tabVisible');
+
+  let busy = false;
+  let executeNumber = 0;
+  let visibleResultTabs = false;
+  let sessionId = null;
+  let sqlPreview = '';
+
+  let domEditor;
+
+  $: connection = useConnectionInfo({ conid });
+
+  $: effect = useEffect(() => {
+    return onSession(sessionId);
+  });
+  function onSession(sid) {
+    if (sid) {
+      socket.on(`session-done-${sid}`, handleSessionDone);
+      return () => {
+        socket.off(`session-done-${sid}`, handleSessionDone);
+      };
+    }
+    return () => {};
+  }
+  $: $effect;
+
+  $: {
+    changeTab(tabid, tab => ({ ...tab, busy }));
+  }
+
+  $: {
+    busy;
+    sessionId;
+    invalidateCommands();
+  }
+
+  export function canKill() {
+    return !!sessionId;
+  }
+
+  export function isBusy() {
+    return busy;
+  }
+
+  export function getTabId() {
+    return tabid;
+  }
+
+  export async function execute() {
+    if (busy) return;
+    executeNumber++;
+    visibleResultTabs = true;
+
+    let sesid = sessionId;
+    if (!sesid) {
+      const resp = await axiosInstance.post('sessions/create', {
+        conid,
+        database,
+      });
+      sesid = resp.data.sesid;
+      sessionId = sesid;
+    }
+    busy = true;
+    // timerLabel.start();
+    await axiosInstance.post('sessions/execute-query', {
+      sesid,
+      sql: sqlPreview,
+    });
+  }
+
+  export async function kill() {
+    await axiosInstance.post('sessions/kill', {
+      sesid: sessionId,
+    });
+    sessionId = null;
+    busy = false;
+    // timerLabel.stop();
+  }
+
+  export function getData() {
+    return $editorState.value || '';
+  }
+
+  const handleSessionDone = () => {
+    busy = false;
+    // timerLabel.stop();
+  };
+
+  const handleChange = (value, skipUndoChain) =>
+    // @ts-ignore
+    dispatchModel({
+      type: 'compute',
+      useMerge: skipUndoChain,
+      compute: v => (_.isFunction(value) ? value(v) : value),
+    });
+
+  const { editorState, editorValue, setEditorData } = useEditorData({
+    tabid,
+    onInitialData: value => {
+      dispatchModel({ type: 'reset', value });
+    },
+  });
+
+  $: setEditorData($modelState.value);
+
+  const [modelState, dispatchModel] = createUndoReducer({
+    tables: [],
+    references: [],
+    columns: [],
+  });
+  // {visibleResultTabs && (
+  //     <TabPage label="Messages" key="messages">
+  //       <SocketMessagesView
+  //         eventName={sessionId ? `session-info-${sessionId}` : null}
+  //         executeNumber={executeNumber}
+  //       />
+  //     </TabPage>
+  //   )}
+</script>
+
+<QueryDesigner
+  value={$modelState.value || {}}
+  {conid}
+  {database}
+  engine={$connection && $connection.engine}
+  onChange={handleChange}
+/>
+<!-- 
+<VerticalSplitter initialValue="70%">
+  <ResultTabs {sessionId} {executeNumber}>
+    <TabPage label="Columns" key="columns">
+      <QueryDesignColumns value={modelState.value || {}} onChange={handleChange} />
+    </TabPage>
+    <TabPage label="SQL" key="sql">
+      <SqlEditor value={sqlPreview} {engine} readOnly />
+    </TabPage>
+  </ResultTabs>
+</VerticalSplitter> -->

packages/web/src/tabs/index.js

@@ -12,7 +12,7 @@ import * as MarkdownEditorTab from './MarkdownEditorTab.svelte';
 // import MarkdownViewTab from './MarkdownViewTab';
 // import MarkdownPreviewTab from './MarkdownPreviewTab';
 // import FavoriteEditorTab from './FavoriteEditorTab';
-// import QueryDesignTab from './QueryDesignTab';
+import * as QueryDesignTab from './QueryDesignTab.svelte';
 
 export default {
   TableDataTab,
@@ -29,5 +29,5 @@ export default {
   //   MarkdownViewTab,
   //   MarkdownPreviewTab,
   //   FavoriteEditorTab,
-  //   QueryDesignTab,
+  QueryDesignTab,
 };