async def METHOD_NAME(connection, elasticapm_client):
    elasticapm_client.begin_transaction("test")
    await connection.execute(f"SELECT id, name FROM test WHERE name = '{'x' * 10010}';")
    elasticapm_client.end_transaction("test", "OK")
    transactions = elasticapm_client.events[constants.TRANSACTION]
    spans = elasticapm_client.spans_for_transaction(transactions[0])
    statement = spans[0]["context"]["db"]["statement"]
    assert len(statement) == 10000
    assert statement.endswith("...")