Function InferSchema

pgtypes/pgtypes.go:294–331

(rows *stdsql.Rows)

		return nil, 0, 0, fallback, fmt.Errorf("unsupported type %s", name)
	}
	return
}

func InferSchema(rows *stdsql.Rows) (sql.Schema, error) {
	types, err := rows.ColumnTypes()
	if err != nil {
		return nil, err
	}

	schema := make(sql.Schema, len(types))
	for i, t := range types {
		pgType, precision, scale, fallback, err := GoDuckDBTypeNameToPostgresType(t.DatabaseTypeName())
		if err != nil {
			return nil, err
		}
		nullable, _ := t.Nullable()

		switch pgType.OID {
		case pgtype.NumericOID, pgtype.NumericArrayOID:
			// Currently, ok is always false
			if p, s, ok := t.DecimalSize(); ok {
				precision = int32(p)
				scale = int32(s)
			}
		}

		schema[i] = &sql.Column{
			Name: t.Name(),
			Type: PostgresType{
				PG:        pgType,
				Size:      PostgresTypeSize(pgType.OID),
				Precision: precision,
				Scale:     scale,
				Fallback:  fallback,
			},
			Nullable: nullable,
		}
	}

	return schema, nil
}