Added assert to check empty STDERR after running ISQL with preparing scripts. See also letter from dimitr, 01-feb-2022 14:46

tests/functional/transactions/test_read_consist_statement_delete_undone_01.py

@@ -173,6 +173,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         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()
 
     with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
         for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_statement_delete_undone_02.py

@@ -155,6 +155,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         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()
 
     with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
         for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_merge_deny_multiple_matches.py

@@ -172,6 +172,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         ''' % locals()
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             cur_lock_1 = con_lock_1.cursor()

tests/functional/transactions/test_read_consist_sttm_restart_max_limit.py

@@ -829,6 +829,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
                 '''
 
                 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()
 
                 with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
                     for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_delete_01.py

@@ -219,6 +219,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_delete_02.py

@@ -204,6 +204,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_delete_03.py

@@ -181,8 +181,11 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         act.isql(switches=['-q'], input = 'recreate table detl(id int);' ) # drop dependencies
-
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_delete_04.py

@@ -208,6 +208,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_merge_01.py

@@ -199,6 +199,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_merge_02.py

@@ -205,7 +205,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_merge_03.py

@@ -184,6 +184,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
 
         act.isql(switches=['-q'], input = 'recreate table detl(id int);' ) # drop dependencies
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_merge_04.py

@@ -225,6 +225,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_update_01.py

@@ -219,6 +219,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_update_02.py

@@ -201,6 +201,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_update_03.py

@@ -227,6 +227,10 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
         '''
 
         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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):

tests/functional/transactions/test_read_consist_sttm_restart_on_update_04.py

@@ -220,7 +220,11 @@ def test_1(act: Action, fn_worker_sql: Path, fn_worker_log: Path, fn_worker_err:
             commit;
         '''
 
-        act.isql(switches=['-q'], input = ''.join( (sql_init, sql_addi) ) )
+        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()
 
         with act.db.connect() as con_lock_1, act.db.connect() as con_lock_2:
             for i,c in enumerate((con_lock_1,con_lock_2)):