Function resolveUnqualifiedColumnRef

src/resolver.ts:26–85

(
  columnRef: UnqualifiedColumnReference,
  tables: TableSchema[]
)

}

export function resolveUnqualifiedColumnRef(
  columnRef: UnqualifiedColumnReference,
  tables: TableSchema[]
): QualifiedColumnReference {
  if (columnRef.any) {
    if (columnRef.tableRefsInScope.length === 1) {
      const tableName = getTableByName(tables, columnRef.tableRefsInScope[0].tableName).tableName
      return {
        ...columnRef,
        tableName
      }
    } else {
      throw new Error(
        `Cannot resolve column reference originating from non-inferrable spread expression.`
      )
    }
  }

  let tablesInScopeSchemas: TableSchema[] = []

  for (const availableTableRef of columnRef.tableRefsInScope) {
    tablesInScopeSchemas = [
      ...tablesInScopeSchemas,
      ...tables.filter(
        schema =>
          schema.tableName === availableTableRef.tableName &&
          !tablesInScopeSchemas.find(
            presentSchema => presentSchema.tableName === availableTableRef.tableName
          )
      )
    ]
  }

  const inScopeSchemasContainingColumn = tablesInScopeSchemas.filter(
    schema => schema.columnNames.indexOf(columnRef.columnName) > -1
  )

  if (inScopeSchemasContainingColumn.length === 0) {
    const tablesInScopeNames = tablesInScopeSchemas.map(schema => `"${schema.tableName}"`)
    throw new Error(
      `No table in the query's scope has a column "${columnRef.columnName}".\n` +
        `Tables in scope: ${
          tablesInScopeNames.length > 0 ? tablesInScopeNames.join(", ") : "(none)"
        }` +
        inScopeSchemasContainingColumn.map(schema => schema.tableName).join(", ")
    )
  } else if (inScopeSchemasContainingColumn.length > 1) {
    throw new Error(
      `Unqualified column reference "${
        columnRef.columnName
      }" matches more than one referenced table: ` +
        inScopeSchemasContainingColumn.map(schema => schema.tableName).join(", ")
    )
  }

  return {
    ...columnRef,
    tableName: inScopeSchemasContainingColumn[0].tableName