z/os cics db2 cobol программа для обработки записей базы данных одновременно

Question

У меня есть таблица DB2, содержащая большое количество записей для отправки внешней системе через MQ. В таблице есть столбец, содержащий статус записи (отправленный или ожидающий отправки).

Я пишу программу планировщика, чтобы постоянно проверять, есть ли записи в таблице, которые «отправляются на отправку». Если да, программа отправит ожидающие записи и обновит статус соответственно

Это расписание будет запущено в нескольких транзакциях. Поэтому я ожидаю, что несколько экземпляров одной и той же программы будут выполняться одновременно

Мои вопросы - как предотвратить одновременное получение и отправку одних и тех же записей несколькими планировщиками?

Мне сказали использовать курсор с замками на уровне строк? но я не уверен, как это работает

замечания: Я работаю над CICS COBOL в г/зева среде

Answer 1

Один из способов сделать это следующим образом 1) Определить индекс кластеризации для таблицы больших DB2 2) Затем имеют разные экземпляры программы, которые просматривают только разные части этого индекса кластеризации. EG, если индекс кластеризации находился в поле числового идентификатора, которое является уникальным, например идентификатор учетной записи и размер идентификатора, является целым числом 9, чем один экземпляр, который показывает, что идентификаторы учетных записей варьируются от 0 до 099999999, а экземпляр 2 - с идентификаторами ID от 100000000 до 1999999999 и .....

Таким образом вы можете написать свой cusror с удержанием, выполнить обновления и совершить по необходимости.

Answer 2

У меня возникли проблемы с дизайном. Мы выполняем нечто подобное, что вы пытаетесь сделать, имея триггер в таблице DB2, который отправляет сообщение MQ в очередь, которая определена для запуска транзакции CICS.

В вашем случае вы можете вообще отказаться от CICS и просто делать то, что предлагает @BillWoodger и отправлять сообщение, когда вы устанавливаете флаг ожидания.

Answer 3

CICS будет координировать транзакции SQL с DB2 для вас. Каждая из выполненных вами транзакций CICS будет иметь возможность выбирать и блокировать строки обновлений, и DB2 может координировать их между всеми и предотвращать выбор нескольких записей, если вы делаете две вещи.

Когда вы читаете строки, которые соответствуют критериям, используйте операцию типа SELECT FOR UPDATE, это блокирует каждую полученную строку и предотвращает доступ других параллельных транзакций к одному и тому же (также для вас требуется BIND с блокировками уровня строки, если вы не хотите, чтобы полные страницы заблокированы, обратитесь к администратору базы данных об опциях на основе размера строки).

Прежде чем вы отпустите записи или завершите транзакцию CICS, вы должны сделать что-то, чтобы пометить указанные записи как «отправленные», чтобы другие, ожидающие, параллельные транзакции не захватывали их и не отправляли их снова. Это может быть так же просто, как добавление отправленного столбца Y/N в таблицу и добавление «И отправлено <>« Y »в ваше предложение where where. После того, как вы отправили записи, сделайте ОБНОВЛЕНИЕ на этих записях и установите send = 'Y'. В зависимости от ваших данных строки вы могли бы использовать что-то еще, например, время отправлено или что-то еще, это просто должно быть чем-то, что исключало бы эту строку из повторного выбора.