Function assertCompleteInsertValues

src/validation.ts:76–101

(query: Query, tables: TableSchema[])

}

function assertCompleteInsertValues(query: Query, tables: TableSchema[]) {
  // FIXME: Consider SELECT INTO queries as well
  if (query.type !== "INSERT") return
  if (query.referencedColumns.some(isUnresolvableColumnReference)) return

  const schema = assertIntactTableRef(query.referencedTables[0], tables)

  const mandatoryColumns = schema.columnNames
    .map(columnName => ({ ...schema.columnDescriptors[columnName], columnName }))
    .filter(descriptor => !descriptor.hasDefault)

  const queryColumns = [...query.referencedColumns, ...resolveColumnReferences(query, tables)]

  for (const mandatoryColumn of mandatoryColumns) {
    const columnReference = queryColumns.find(
      columnRef => columnRef.columnName === mandatoryColumn.columnName
    )

    if (!columnReference) {
      const error = new Error(
        `Column "${mandatoryColumn.columnName}" is missing from INSERT statement.`
      )
      throw augmentValidationError(error, query.path, query)
    }
  }
}

function resolveColumnRefsToTableSchemaDescriptor(
  returnedColumns: ColumnReference[],