select top 10 distinct вместо select distinct top 10

или это постгрес?

в любом случае подзапрос решит проблему.

а можно полностью текст ошибки?

выполни DBCC OPENTRAN на базе своей. покеж что вернёт.

А версия студии?

17.9.1

большое спасибо за советы сейчас посмотрбю

Мускул)

LIMIT?

Да

А что не так?

Это предполагаемый ответ на твой вопрос

Коллеги, привет!

Подскажите, пользуется ли кто-то RabbitMQ через CLR?
Посмотрел пару видео по рэббиту, воспользовался примером в одном из них - https://github.com/EPilyaev/RabbitMQNetCore/tree/master/PublisherConfirms/PublisherConfirms.
Написал простую CLR https://gist.github.com/ivaninkv/0cae611655e564b6207cdfd912e6b3f3, подключил к серверу и попробовал в курсоре поотоправлять сообщения. В курсоре - потому, что у меня такой кейс - нужно вклинить отправку сообщений в существющий механизм обработки.
По факту получил ~30rps, если этот же код запустить в консольном приложении, то получается ~1000rps.
Может кто подскажет как правильно готовить такую связку?

может такое быть, что консольное не разрывает подключение между отправками

а sql сервер разрывает, потому что отправка работает в рамках одного вызова функции

из-за этого можеть быть такая низкая производительность

Блин, точно!
Я ж его именно так и написал 🤦‍♂
Цикл уже внутри, после установки соединения и создания очереди.
Завтра уже проверю как будет на честном тесте.
Спасибо!

Оке. Если правильно понял - делается left merge join и что с null - то новое и вставляется.  Что not null - то обновление и нужно обновить.
Делать sql command в data flow - это зло. Лучше откидывать изменения во временную таблицу (не temp) и делать merge или delete- insert с ней.

Если уж есть возможность писать во временную таблицу, то проще писать туда все и потом делать merge в целевую таблицу. Но я так понял задача делать merge именно не выходя из ssis. Как вариант (если строк на обновление действительно много и использовать промежуточные таблицы в целевой базе нельзя ) писать их  в recordset, потом из него с помощью c# динамически создавать sql запрос с разбивкой по 1000 строк, вставкой в табличную переменную и merge из неё в целевую таблицу, и в цикле передавать его в execute sql task. Но сам так не пробовал делать, поэтому не уверен что будет лучше работать чем oledb внутри data flow