Method getTable

lib/metadata/schema-parser.js:130–191

* @param {String} keyspaceName * @param {String} name * @param {Object} cache * @param {Boolean} virtual * @returns {Promise }

(keyspaceName, name, cache, virtual)

   * @returns {Promise<TableMetadata|null>}
   */
  async getTable(keyspaceName, name, cache, virtual) {
    let tableInfo = cache && cache[name];
    if (!tableInfo) {
      tableInfo = new TableMetadata(name);
      if (cache) {
        cache[name] = tableInfo;
      }
    }
    if (tableInfo.loaded) {
      return tableInfo;
    }
    if (tableInfo.loading) {
      // Wait for it to emit
      return promiseUtils.fromEvent(tableInfo, 'load');
    }
    try {
      // its not cached and not being retrieved
      tableInfo.loading = true;
      let indexRows;
      let virtualTable = virtual;
      const selectTable = virtualTable ? _selectVirtualTable : this.selectTable;
      const query = util.format(selectTable, keyspaceName, name);
      let tableRow = await this._getFirstRow(query);
      // if we weren't sure if table was virtual or not, query virtual schema.
      if (!tableRow && this.supportsVirtual && virtualTable === undefined) {
        const query = util.format(_selectVirtualTable, keyspaceName, name);
        try {
          tableRow = await this._getFirstRow(query);
        }
        catch (err) {
          // we can't error here as we can't be sure if the node
          // supports virtual tables, in this case it is adequate
          // to act as if there was no matching table.
        }
        if (tableRow) {
          // We are fetching a virtual table
          virtualTable = true;
        }
      }
      if (!tableRow) {
        tableInfo.loading = false;
        tableInfo.emit('load', null, null);
        return null;
      }
      const selectColumns = virtualTable ? _selectVirtualColumns : this.selectColumns;
      const columnRows = await this._getRows(util.format(selectColumns, keyspaceName, name));
      if (this.selectIndexes && !virtualTable) {
        indexRows = await this._getRows(util.format(this.selectIndexes, keyspaceName, name));
      }
      await this._parseTableOrView(tableInfo, tableRow, columnRows, indexRows, virtualTable);
      tableInfo.loaded = true;
      tableInfo.emit('load', null, tableInfo);
      return tableInfo;
    }
    catch (err) {
      tableInfo.emit('load', err, null);
      throw err;
    }