Method test_aggregate_strings_execute

test/sql/test_functions.py:1541–1602

(
        self,
        connection,
        metadata,
        unicode_value,
        unicode_separator,
        use_order_by,
    )

        ["postgresql", "sqlite", "mysql", "mariadb", "oracle", "mssql"]
    )
    def test_aggregate_strings_execute(
        self,
        connection,
        metadata,
        unicode_value,
        unicode_separator,
        use_order_by,
    ):
        values_t = Table(
            "values",
            metadata,
            Column("value", String(42)),
            Column("unicode_value", Unicode(42)),
        )
        metadata.create_all(connection)
        connection.execute(
            values_t.insert(),
            [
                {"value": "a", "unicode_value": "b 測試"},
                {"value": "b", "unicode_value": "c téble2"},
                {"value": None, "unicode_value": None},  # ignored
                {"value": "c", "unicode_value": "a 🐍 su"},
            ],
        )

        if unicode_separator:
            separator = " 🐍試 "
        else:
            separator = " and "

        if unicode_value:
            col = values_t.c.unicode_value
            if use_order_by:
                expected = separator.join(["c téble2", "b 測試", "a 🐍 su"])
            else:
                expected = separator.join(["b 測試", "c téble2", "a 🐍 su"])
        else:
            col = values_t.c.value
            if use_order_by:
                expected = separator.join(["c", "b", "a"])
            else:
                expected = separator.join(["a", "b", "c"])

            # to join on a unicode separator, source string has to be unicode,
            # so cast().  SQL Server will raise otherwise
            if unicode_separator:
                col = cast(col, Unicode(42))

        if use_order_by:
            value = connection.execute(
                select(
                    func.aggregate_strings(col, separator).aggregate_order_by(
                        col.desc()
                    )
                )
            ).scalar_one()
        else:
            value = connection.execute(