2 @message |
assert
checked_mode: table, STDLOG: Records affected: 5
checked_mode: table, STDLOG: ID X
checked_mode: table, STDLOG:
checked_mode: table, STDLOG: -3 -3
checked_mode: table, STDLOG: -2 -2
checked_mode: table, STDLOG: -1 -1
checked_mode: table, STDLOG: 12 12
checked_mode: table, STDLOG: 13 13
checked_mode: table, STDLOG: Records affected: 5
checked_mode: table, STDLOG: OLD_ID OP SNAP_NO_RANK
checked_mode: table, STDLOG:
- checked_mode: table, STDLOG: 1 UPD 1
+ checked_mode: table, STDLOG: 1UPD 1
- checked_mode: table, STDLOG: 2 UPD 1
+ checked_mode: table, STDLOG: 2UPD 1
- checked_mode: table, STDLOG: -13 UPD 2
+ checked_mode: table, STDLOG: -13UPD 2
- checked_mode: table, STDLOG: -12 UPD 2
+ checked_mode: table, STDLOG: -12UPD 2
- checked_mode: table, STDLOG: 1 UPD 2
+ checked_mode: table, STDLOG: 1UPD 2
- checked_mode: table, STDLOG: 2 UPD 2
+ checked_mode: table, STDLOG: 2UPD 2
- checked_mode: table, STDLOG: 3 UPD 2
+ checked_mode: table, STDLOG: 3UPD 2
checked_mode: table, STDLOG: Records affected: 7
LOG DETAILS:
2025-07-02 06:07:44.905
2025-07-02 06:07:44.917 act = <firebird.qa.plugin.Action object at [hex]>
2025-07-02 06:07:44.927 fn_worker_sql = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.sql')
2025-07-02 06:07:44.935 fn_worker_log = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.log')
2025-07-02 06:07:44.942 fn_worker_err = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.err')
2025-07-02 06:07:44.949 capsys = <_pytest.capture.CaptureFixture object at [hex]>
2025-07-02 06:07:44.956
2025-07-02 06:07:44.962 @pytest.mark.trace
2025-07-02 06:07:44.972 @pytest.mark.version('>=4.0.2')
2025-07-02 06:07:44.983 def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err: Path, capsys):
2025-07-02 06:07:44.993 sql_init = (act.files_dir / 'read-consist-sttm-restart-DDL.sql').read_text()
2025-07-02 06:07:45.003
2025-07-02 06:07:45.013 for checked_mode in('table', 'view'):
2025-07-02 06:07:45.023 target_obj = 'test' if checked_mode == 'table' else 'v_test'
2025-07-02 06:07:45.033
2025-07-02 06:07:45.041 SQL_TO_BE_RESTARTED = f"""
2025-07-02 06:07:45.048 merge /* {SQL_TAG_THAT_WE_WAITING_FOR} */ into {target_obj} t
2025-07-02 06:07:45.054 using (select * from {target_obj} order by id ROWS 10) s on s.id=t.id
2025-07-02 06:07:45.065 when matched then
2025-07-02 06:07:45.075 update set t.id = -t.id, t.x = -s.x
2025-07-02 06:07:45.082 when not matched then
2025-07-02 06:07:45.090 insert(id,x) values(s.id, -s.x - 500)
2025-07-02 06:07:45.095 """
2025-07-02 06:07:45.101
2025-07-02 06:07:45.106 # add rows with ID = 1, 2, 3:
2025-07-02 06:07:45.111 sql_addi = f'''
2025-07-02 06:07:45.117 set term ^;
2025-07-02 06:07:45.122 execute block as
2025-07-02 06:07:45.131 begin
2025-07-02 06:07:45.139 rdb$set_context('USER_SESSION', 'WHO', 'INIT_DATA');
2025-07-02 06:07:45.145 end
2025-07-02 06:07:45.151 ^
2025-07-02 06:07:45.157 set term ;^
2025-07-02 06:07:45.169 insert into {target_obj}(id, x)
2025-07-02 06:07:45.179 select row_number()over(),row_number()over()
2025-07-02 06:07:45.188 from rdb$types rows 3;
2025-07-02 06:07:45.200 commit;
2025-07-02 06:07:45.210 '''
2025-07-02 06:07:45.218
2025-07-02 06:07:45.227 act.isql(switches=['-q'], input = ''.join( (sql_init, sql_addi) ) )
2025-07-02 06:07:45.236 # ::: NOTE ::: We have to immediately quit if any error raised in prepare phase.
2025-07-02 06:07:45.244 # See also letter from dimitr, 01-feb-2022 14:46
2025-07-02 06:07:45.250 assert act.stderr == ''
2025-07-02 06:07:45.261 act.reset()
2025-07-02 06:07:45.270
2025-07-02 06:07:45.277 trace_cfg_items = [
2025-07-02 06:07:45.287 'time_threshold = 0',
2025-07-02 06:07:45.294 'log_errors = true',
2025-07-02 06:07:45.302 'log_statement_start = true',
2025-07-02 06:07:45.309 'log_statement_finish = true',
2025-07-02 06:07:45.315 ]
2025-07-02 06:07:45.322
2025-07-02 06:07:45.331 with act.trace(db_events = trace_cfg_items, encoding=locale.getpreferredencoding()):
2025-07-02 06:07:45.342
2025-07-02 06:07:45.351 with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2, act.db.connect() as con_monitoring:
2025-07-02 06:07:45.358
2025-07-02 06:07:45.365 tpb_monitoring = tpb(isolation=Isolation.READ_COMMITTED_RECORD_VERSION, lock_timeout=0)
2025-07-02 06:07:45.371 tx_monitoring = con_monitoring.transaction_manager(tpb_monitoring)
2025-07-02 06:07:45.375 cur_monitoring = tx_monitoring.cursor()
2025-07-02 06:07:45.380
2025-07-02 06:07:45.385 for i,c in enumerate((con_lock_1,con_lock_2)):
2025-07-02 06:07:45.389 sttm = f"execute block as begin rdb$set_context('USER_SESSION', 'WHO', 'LOCKER #{i+1}'); end"
2025-07-02 06:07:45.395 c.execute_immediate(sttm)
2025-07-02 06:07:45.400
2025-07-02 06:07:45.406 #########################
2025-07-02 06:07:45.410 ### L O C K E R - 1 ###
2025-07-02 06:07:45.415 #########################
2025-07-02 06:07:45.420
2025-07-02 06:07:45.425 con_lock_1.execute_immediate( f'update {target_obj} set id=id where id = 3' )
2025-07-02 06:07:45.430
2025-07-02 06:07:45.441 worker_sql = f'''
2025-07-02 06:07:45.450 set list on;
2025-07-02 06:07:45.457 set autoddl off;
2025-07-02 06:07:45.463 set term ^;
2025-07-02 06:07:45.475 execute block returns (whoami varchar(30)) as
2025-07-02 06:07:45.486 begin
2025-07-02 06:07:45.499 whoami = 'WORKER'; -- , ATT#' || current_connection;
2025-07-02 06:07:45.510 rdb$set_context('USER_SESSION','WHO', whoami);
2025-07-02 06:07:45.517 -- suspend;
2025-07-02 06:07:45.529 end
2025-07-02 06:07:45.543 ^
2025-07-02 06:07:45.552 set term ;^
2025-07-02 06:07:45.559 commit;
2025-07-02 06:07:45.565 SET KEEP_TRAN_PARAMS ON;
2025-07-02 06:07:45.571 set transaction read committed read consistency;
2025-07-02 06:07:45.577
2025-07-02 06:07:45.587 set list off;
2025-07-02 06:07:45.599 set wng off;
2025-07-02 06:07:45.608 set count on;
2025-07-02 06:07:45.615
2025-07-02 06:07:45.623 -- THIS MUST HANG:
2025-07-02 06:07:45.637 {SQL_TO_BE_RESTARTED};
2025-07-02 06:07:45.646
2025-07-02 06:07:45.658 -- check results:
2025-07-02 06:07:45.667 -- ###############
2025-07-02 06:07:45.676 select id,x from {target_obj} order by id; -- this will produce output only after all lockers do their commit/rollback
2025-07-02 06:07:45.683
2025-07-02 06:07:45.693 select v.old_id, v.op, v.snap_no_rank
2025-07-02 06:07:45.705 from v_worker_log v
2025-07-02 06:07:45.717 where v.op = 'upd';
2025-07-02 06:07:45.730
2025-07-02 06:07:45.743 set width who 10;
2025-07-02 06:07:45.753 -- DO NOT check this! Values can differ here from one run to another!
2025-07-02 06:07:45.766 -- select id, trn, who, old_id, new_id, op, rec_vers, global_cn, snap_no from tlog_done order by id;
2025-07-02 06:07:45.775
2025-07-02 06:07:45.784 rollback;
2025-07-02 06:07:45.792
2025-07-02 06:07:45.800 '''
2025-07-02 06:07:45.807
2025-07-02 06:07:45.815 fn_worker_sql.write_text(worker_sql)
2025-07-02 06:07:45.824
2025-07-02 06:07:45.832 with fn_worker_log.open(mode='w') as hang_out, fn_worker_err.open(mode='w') as hang_err:
2025-07-02 06:07:45.839
2025-07-02 06:07:45.849 ############################################################################
2025-07-02 06:07:45.857 ### L A U N C H W O R K E R U S I N G I S Q L, A S Y N C. ###
2025-07-02 06:07:45.865 ############################################################################
2025-07-02 06:07:45.877 p_worker = subprocess.Popen([act.vars['isql'], '-i', str(fn_worker_sql),
2025-07-02 06:07:45.886 '-user', act.db.user,
2025-07-02 06:07:45.895 '-password', act.db.password,
2025-07-02 06:07:45.906 '-pag', '9999999',
2025-07-02 06:07:45.920 act.db.dsn
2025-07-02 06:07:45.932 ],
2025-07-02 06:07:45.944 stdout = hang_out,
2025-07-02 06:07:45.957 stderr = hang_err
2025-07-02 06:07:45.970 )
2025-07-02 06:07:45.985 # NB: when ISQL will establish attach, first record that it must lock is ID = 1 -- see above SQL_TO_BE_RESTARTED
2025-07-02 06:07:45.996 # We must to ensure that this (worker) attachment has been really created and LOCKS this record:
2025-07-02 06:07:46.006 #
2025-07-02 06:07:46.017 wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=1', SQL_TAG_THAT_WE_WAITING_FOR)
2025-07-02 06:07:46.030
2025-07-02 06:07:46.043 #########################
2025-07-02 06:07:46.058 ### L O C K E R - 2 ###
2025-07-02 06:07:46.071 #########################
2025-07-02 06:07:46.080 con_lock_2.execute_immediate( f'insert into {target_obj}(id,x) values(-13,-13)')
2025-07-02 06:07:46.089 con_lock_2.commit()
2025-07-02 06:07:46.100 con_lock_2.execute_immediate( f'update {target_obj} set id=id where id = -13')
2025-07-02 06:07:46.110
2025-07-02 06:07:46.117 #########################
2025-07-02 06:07:46.123 ### L O C K E R - 1 ###
2025-07-02 06:07:46.128 #########################
2025-07-02 06:07:46.135 con_lock_1.commit() # releases record with ID = 3 ==> now it can be locked by worker.
2025-07-02 06:07:46.143
2025-07-02 06:07:46.155 # We have to WAIT HERE until worker will actually 'catch' just released record with ID = 3.
2025-07-02 06:07:46.164 #
2025-07-02 06:07:46.171 wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=3', SQL_TAG_THAT_WE_WAITING_FOR)
2025-07-02 06:07:46.178 # If we come here then it means that record with ID = 3 for sure is locked by WORKER.
2025-07-02 06:07:46.188
2025-07-02 06:07:46.197 con_lock_1.execute_immediate( f'insert into {target_obj}(id,x) values(-12,-12)' )
2025-07-02 06:07:46.207 con_lock_1.commit()
2025-07-02 06:07:46.219 con_lock_1.execute_immediate( f'update {target_obj} set id=id where id = -12' )
2025-07-02 06:07:46.231
2025-07-02 06:07:46.243 #########################
2025-07-02 06:07:46.252 ### L O C K E R - 2 ###
2025-07-02 06:07:46.259 #########################
2025-07-02 06:07:46.274 con_lock_2.commit() # releases record with ID = -13 ==> now it can be locked by worker.
2025-07-02 06:07:46.285
2025-07-02 06:07:46.292 # We have to WAIT HERE until worker will actually 'catch' just released record with ID = -13.
2025-07-02 06:07:46.299 #
2025-07-02 06:07:46.304 wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=-13', SQL_TAG_THAT_WE_WAITING_FOR)
2025-07-02 06:07:46.309 # If we come here then it means that record with ID = -13 for sure is locked by WORKER.
2025-07-02 06:07:46.314
2025-07-02 06:07:46.319 #########################
2025-07-02 06:07:46.324 ### L O C K E R - 1 ###
2025-07-02 06:07:46.329 #########################
2025-07-02 06:07:46.335 con_lock_1.commit() # WORKER will complete his job after this
2025-07-02 06:07:46.341
2025-07-02 06:07:46.356 # Here we wait for ISQL complete its mission:
2025-07-02 06:07:46.364 p_worker.wait()
2025-07-02 06:07:46.375
2025-07-02 06:07:46.382 #< with act.db.connect()
2025-07-02 06:07:46.389
2025-07-02 06:07:46.395 for g in (fn_worker_log, fn_worker_err):
2025-07-02 06:07:46.401 with g.open() as f:
2025-07-02 06:07:46.407 for line in f:
2025-07-02 06:07:46.413 if line.split():
2025-07-02 06:07:46.420 if g == fn_worker_log:
2025-07-02 06:07:46.431 print(f'checked_mode: {checked_mode}, STDLOG: {line}')
2025-07-02 06:07:46.445 else:
2025-07-02 06:07:46.455 print(f'UNEXPECTED STDERR {line}')
2025-07-02 06:07:46.465
2025-07-02 06:07:46.473 expected_stdout_worker = f"""
2025-07-02 06:07:46.482 checked_mode: {checked_mode}, STDLOG: Records affected: 5
2025-07-02 06:07:46.494
2025-07-02 06:07:46.503 checked_mode: {checked_mode}, STDLOG: ID X
2025-07-02 06:07:46.510 checked_mode: {checked_mode}, STDLOG: ======= =======
2025-07-02 06:07:46.519 checked_mode: {checked_mode}, STDLOG: -3 -3
2025-07-02 06:07:46.527 checked_mode: {checked_mode}, STDLOG: -2 -2
2025-07-02 06:07:46.535 checked_mode: {checked_mode}, STDLOG: -1 -1
2025-07-02 06:07:46.543 checked_mode: {checked_mode}, STDLOG: 12 12
2025-07-02 06:07:46.551 checked_mode: {checked_mode}, STDLOG: 13 13
2025-07-02 06:07:46.559 checked_mode: {checked_mode}, STDLOG: Records affected: 5
2025-07-02 06:07:46.566
2025-07-02 06:07:46.576 checked_mode: {checked_mode}, STDLOG: OLD_ID OP SNAP_NO_RANK
2025-07-02 06:07:46.590 checked_mode: {checked_mode}, STDLOG: ======= ====== =====================
2025-07-02 06:07:46.597 checked_mode: {checked_mode}, STDLOG: 1 UPD 1
2025-07-02 06:07:46.608 checked_mode: {checked_mode}, STDLOG: 2 UPD 1
2025-07-02 06:07:46.616 checked_mode: {checked_mode}, STDLOG: -13 UPD 2
2025-07-02 06:07:46.624 checked_mode: {checked_mode}, STDLOG: -12 UPD 2
2025-07-02 06:07:46.631 checked_mode: {checked_mode}, STDLOG: 1 UPD 2
2025-07-02 06:07:46.639 checked_mode: {checked_mode}, STDLOG: 2 UPD 2
2025-07-02 06:07:46.646 checked_mode: {checked_mode}, STDLOG: 3 UPD 2
2025-07-02 06:07:46.652
2025-07-02 06:07:46.658 checked_mode: {checked_mode}, STDLOG: Records affected: 7
2025-07-02 06:07:46.663 """
2025-07-02 06:07:46.668
2025-07-02 06:07:46.674 act.expected_stdout = expected_stdout_worker
2025-07-02 06:07:46.683 act.stdout = capsys.readouterr().out
2025-07-02 06:07:46.696 > assert act.clean_stdout == act.clean_expected_stdout
2025-07-02 06:07:46.708 E assert
2025-07-02 06:07:46.719 E checked_mode: table, STDLOG: Records affected: 5
2025-07-02 06:07:46.728 E checked_mode: table, STDLOG: ID X
2025-07-02 06:07:46.736 E checked_mode: table, STDLOG:
2025-07-02 06:07:46.743 E checked_mode: table, STDLOG: -3 -3
2025-07-02 06:07:46.751 E checked_mode: table, STDLOG: -2 -2
2025-07-02 06:07:46.761 E checked_mode: table, STDLOG: -1 -1
2025-07-02 06:07:46.769 E checked_mode: table, STDLOG: 12 12
2025-07-02 06:07:46.776 E checked_mode: table, STDLOG: 13 13
2025-07-02 06:07:46.783 E checked_mode: table, STDLOG: Records affected: 5
2025-07-02 06:07:46.792 E checked_mode: table, STDLOG: OLD_ID OP SNAP_NO_RANK
2025-07-02 06:07:46.800 E checked_mode: table, STDLOG:
2025-07-02 06:07:46.807 E - checked_mode: table, STDLOG: 1 UPD 1
2025-07-02 06:07:46.823 E + checked_mode: table, STDLOG: 1UPD 1
2025-07-02 06:07:46.835 E - checked_mode: table, STDLOG: 2 UPD 1
2025-07-02 06:07:46.851 E + checked_mode: table, STDLOG: 2UPD 1
2025-07-02 06:07:46.856 E - checked_mode: table, STDLOG: -13 UPD 2
2025-07-02 06:07:46.867 E + checked_mode: table, STDLOG: -13UPD 2
2025-07-02 06:07:46.872 E - checked_mode: table, STDLOG: -12 UPD 2
2025-07-02 06:07:46.883 E + checked_mode: table, STDLOG: -12UPD 2
2025-07-02 06:07:46.888 E - checked_mode: table, STDLOG: 1 UPD 2
2025-07-02 06:07:46.901 E + checked_mode: table, STDLOG: 1UPD 2
2025-07-02 06:07:46.908 E - checked_mode: table, STDLOG: 2 UPD 2
2025-07-02 06:07:46.923 E + checked_mode: table, STDLOG: 2UPD 2
2025-07-02 06:07:46.930 E - checked_mode: table, STDLOG: 3 UPD 2
2025-07-02 06:07:46.951 E + checked_mode: table, STDLOG: 3UPD 2
2025-07-02 06:07:46.959 E checked_mode: table, STDLOG: Records affected: 7
2025-07-02 06:07:46.966
2025-07-02 06:07:46.972 tests/functional/transactions/test_read_consist_sttm_restart_on_merge_01.py:429: AssertionError
2025-07-02 06:07:46.979 ---------------------------- Captured stdout setup -----------------------------
2025-07-02 06:07:46.989 Creating db: localhost:/var/tmp/qa_2024/test_12481/test.fdb [page_size=None, sql_dialect=None, charset='NONE', user=SYSDBA, password=masterkey]
|
3 #text |
act = <firebird.qa.plugin.Action pytest object at [hex]>
fn_worker_sql = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.sql')
fn_worker_log = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.log')
fn_worker_err = PosixPath('/var/tmp/qa_2024/test_12481/tmp_worker.err')
capsys = <_pytest.capture.CaptureFixture pytest object at [hex]>
@pytest.mark.trace
@pytest.mark.version('>=4.0.2')
def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err: Path, capsys):
sql_init = (act.files_dir / 'read-consist-sttm-restart-DDL.sql').read_text()
for checked_mode in('table', 'view'):
target_obj = 'test' if checked_mode == 'table' else 'v_test'
SQL_TO_BE_RESTARTED = f"""
merge /* {SQL_TAG_THAT_WE_WAITING_FOR} */ into {target_obj} t
using (select * from {target_obj} order by id ROWS 10) s on s.id=t.id
when matched then
update set t.id = -t.id, t.x = -s.x
when not matched then
insert(id,x) values(s.id, -s.x - 500)
"""
# add rows with ID = 1, 2, 3:
sql_addi = f'''
set term ^;
execute block as
begin
rdb$set_context('USER_SESSION', 'WHO', 'INIT_DATA');
end
^
set term ;^
insert into {target_obj}(id, x)
select row_number()over(),row_number()over()
from rdb$types rows 3;
commit;
'''
act.isql(switches=['-q'], input = ''.join( (sql_init, sql_addi) ) )
# ::: NOTE ::: We have to immediately quit if any error raised in prepare phase.
# See also letter from dimitr, 01-feb-2022 14:46
assert act.stderr == ''
act.reset()
trace_cfg_items = [
'time_threshold = 0',
'log_errors = true',
'log_statement_start = true',
'log_statement_finish = true',
]
with act.trace(db_events = trace_cfg_items, encoding=locale.getpreferredencoding()):
with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2, act.db.connect() as con_monitoring:
tpb_monitoring = tpb(isolation=Isolation.READ_COMMITTED_RECORD_VERSION, lock_timeout=0)
tx_monitoring = con_monitoring.transaction_manager(tpb_monitoring)
cur_monitoring = tx_monitoring.cursor()
for i,c in enumerate((con_lock_1,con_lock_2)):
sttm = f"execute block as begin rdb$set_context('USER_SESSION', 'WHO', 'LOCKER #{i+1}'); end"
c.execute_immediate(sttm)
#########################
### L O C K E R - 1 ###
#########################
con_lock_1.execute_immediate( f'update {target_obj} set id=id where id = 3' )
worker_sql = f'''
set list on;
set autoddl off;
set term ^;
execute block returns (whoami varchar(30)) as
begin
whoami = 'WORKER'; -- , ATT#' || current_connection;
rdb$set_context('USER_SESSION','WHO', whoami);
-- suspend;
end
^
set term ;^
commit;
SET KEEP_TRAN_PARAMS ON;
set transaction read committed read consistency;
set list off;
set wng off;
set count on;
-- THIS MUST HANG:
{SQL_TO_BE_RESTARTED};
-- check results:
-- ###############
select id,x from {target_obj} order by id; -- this will produce output only after all lockers do their commit/rollback
select v.old_id, v.op, v.snap_no_rank
from v_worker_log v
where v.op = 'upd';
set width who 10;
-- DO NOT check this! Values can differ here from one run to another!
-- select id, trn, who, old_id, new_id, op, rec_vers, global_cn, snap_no from tlog_done order by id;
rollback;
'''
fn_worker_sql.write_text(worker_sql)
with fn_worker_log.open(mode='w') as hang_out, fn_worker_err.open(mode='w') as hang_err:
############################################################################
### L A U N C H W O R K E R U S I N G I S Q L, A S Y N C. ###
############################################################################
p_worker = subprocess.Popen([act.vars['isql'], '-i', str(fn_worker_sql),
'-user', act.db.user,
'-password', act.db.password,
'-pag', '9999999',
act.db.dsn
],
stdout = hang_out,
stderr = hang_err
)
# NB: when ISQL will establish attach, first record that it must lock is ID = 1 -- see above SQL_TO_BE_RESTARTED
# We must to ensure that this (worker) attachment has been really created and LOCKS this record:
#
wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=1', SQL_TAG_THAT_WE_WAITING_FOR)
#########################
### L O C K E R - 2 ###
#########################
con_lock_2.execute_immediate( f'insert into {target_obj}(id,x) values(-13,-13)')
con_lock_2.commit()
con_lock_2.execute_immediate( f'update {target_obj} set id=id where id = -13')
#########################
### L O C K E R - 1 ###
#########################
con_lock_1.commit() # releases record with ID = 3 ==> now it can be locked by worker.
# We have to WAIT HERE until worker will actually 'catch' just released record with ID = 3.
#
wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=3', SQL_TAG_THAT_WE_WAITING_FOR)
# If we come here then it means that record with ID = 3 for sure is locked by WORKER.
con_lock_1.execute_immediate( f'insert into {target_obj}(id,x) values(-12,-12)' )
con_lock_1.commit()
con_lock_1.execute_immediate( f'update {target_obj} set id=id where id = -12' )
#########################
### L O C K E R - 2 ###
#########################
con_lock_2.commit() # releases record with ID = -13 ==> now it can be locked by worker.
# We have to WAIT HERE until worker will actually 'catch' just released record with ID = -13.
#
wait_for_record_become_locked(tx_monitoring, cur_monitoring, f'update {target_obj} set id=id where id=-13', SQL_TAG_THAT_WE_WAITING_FOR)
# If we come here then it means that record with ID = -13 for sure is locked by WORKER.
#########################
### L O C K E R - 1 ###
#########################
con_lock_1.commit() # WORKER will complete his job after this
# Here we wait for ISQL complete its mission:
p_worker.wait()
#< with act.db.connect()
for g in (fn_worker_log, fn_worker_err):
with g.open() as f:
for line in f:
if line.split():
if g == fn_worker_log:
print(f'checked_mode: {checked_mode}, STDLOG: {line}')
else:
print(f'UNEXPECTED STDERR {line}')
expected_stdout_worker = f"""
checked_mode: {checked_mode}, STDLOG: Records affected: 5
checked_mode: {checked_mode}, STDLOG: ID X
checked_mode: {checked_mode}, STDLOG: ======= =======
checked_mode: {checked_mode}, STDLOG: -3 -3
checked_mode: {checked_mode}, STDLOG: -2 -2
checked_mode: {checked_mode}, STDLOG: -1 -1
checked_mode: {checked_mode}, STDLOG: 12 12
checked_mode: {checked_mode}, STDLOG: 13 13
checked_mode: {checked_mode}, STDLOG: Records affected: 5
checked_mode: {checked_mode}, STDLOG: OLD_ID OP SNAP_NO_RANK
checked_mode: {checked_mode}, STDLOG: ======= ====== =====================
checked_mode: {checked_mode}, STDLOG: 1 UPD 1
checked_mode: {checked_mode}, STDLOG: 2 UPD 1
checked_mode: {checked_mode}, STDLOG: -13 UPD 2
checked_mode: {checked_mode}, STDLOG: -12 UPD 2
checked_mode: {checked_mode}, STDLOG: 1 UPD 2
checked_mode: {checked_mode}, STDLOG: 2 UPD 2
checked_mode: {checked_mode}, STDLOG: 3 UPD 2
checked_mode: {checked_mode}, STDLOG: Records affected: 7
"""
act.expected_stdout = expected_stdout_worker
act.stdout = capsys.readouterr().out
> assert act.clean_stdout == act.clean_expected_stdout
E assert
E checked_mode: table, STDLOG: Records affected: 5
E checked_mode: table, STDLOG: ID X
E checked_mode: table, STDLOG:
E checked_mode: table, STDLOG: -3 -3
E checked_mode: table, STDLOG: -2 -2
E checked_mode: table, STDLOG: -1 -1
E checked_mode: table, STDLOG: 12 12
E checked_mode: table, STDLOG: 13 13
E checked_mode: table, STDLOG: Records affected: 5
E checked_mode: table, STDLOG: OLD_ID OP SNAP_NO_RANK
E checked_mode: table, STDLOG:
E - checked_mode: table, STDLOG: 1 UPD 1
E + checked_mode: table, STDLOG: 1UPD 1
E - checked_mode: table, STDLOG: 2 UPD 1
E + checked_mode: table, STDLOG: 2UPD 1
E - checked_mode: table, STDLOG: -13 UPD 2
E + checked_mode: table, STDLOG: -13UPD 2
E - checked_mode: table, STDLOG: -12 UPD 2
E + checked_mode: table, STDLOG: -12UPD 2
E - checked_mode: table, STDLOG: 1 UPD 2
E + checked_mode: table, STDLOG: 1UPD 2
E - checked_mode: table, STDLOG: 2 UPD 2
E + checked_mode: table, STDLOG: 2UPD 2
E - checked_mode: table, STDLOG: 3 UPD 2
E + checked_mode: table, STDLOG: 3UPD 2
E checked_mode: table, STDLOG: Records affected: 7
tests/functional/transactions/test_read_consist_sttm_restart_on_merge_01.py:429: AssertionError
|