Method createTableViaSchema

packages/core/data-space/table.ts:349–368

(
    id: string,
    name: string,
    tableSchema: string,
    parent_id?: string
  )

  }

  public async createTableViaSchema(
    id: string,
    name: string,
    tableSchema: string,
    parent_id?: string
  ) {
    // FIXME: should use db transaction to execute multiple sql

    try {
      await this.db.prepare("BEGIN TRANSACTION;").run()
      await this.tree.addNode({ id, name, type: TreeNodeType.Table, parent_id })
      await this.db.exec(tableSchema)
      // create view for table
      await this.view.createDefaultView(getRawTableNameById(id))
      await this.db.prepare("COMMIT;").run()
    } catch (error) {
      await this.db.prepare("ROLLBACK;").run()
      throw error
    }
  }

  public async fixTable(tableId: string) {
    const tableManager = this._table(tableId)