Method getKeyspaces

lib/metadata/schema-parser.js:884–911

(waitReconnect)

  }

  async getKeyspaces(waitReconnect) {
    const keyspaces = {};
    const queries = [
      { query: _selectAllKeyspacesV2, virtual: false },
      { query: _selectAllVirtualKeyspaces, virtual: true }
    ];

    await Promise.all(queries.map(async (q) => {
      let result = null;
      try {
        result = await this.cc.query(q.query, waitReconnect);
      }
      catch (err) {
        if (q.virtual) {
          // Only throw error for non-virtual query as
          // server reporting C* 4.0 may not actually implement
          // virtual tables.
          return;
        }
        throw err;
      }
      for (let i = 0; i < result.rows.length; i++) {
        const ksInfo = this._parseKeyspace(result.rows[i], q.virtual);
        keyspaces[ksInfo.name] = ksInfo;
      }
    }));
    return keyspaces;
  }

  async getKeyspace(name) {
    const ks = await this._getKeyspace(_selectSingleKeyspaceV2, name, false);