stop db connections for error count exceeding limit

Author: zaihuaji

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "rda_python_common"
-version = "2.0.10"
+version = "2.0.11"
 authors = [
   { name="Zaihua Ji", email="zji@ucar.edu" },
 ]

src/rda_python_common/PgDBI.py

@@ -468,6 +468,8 @@ def check_dberror(pgerr, pgcnt, sqlstr, ary, logact = PGDBI['ERRLOG']):
 
    if logact&PgLOG.DOLOCK and pgcode and re.match(r'^55\w\w\w$', pgcode):
       logact &= ~PgLOG.EXITLG   # no exit for lock error
+   elif pgcnt > PgLOG.PGLOG['DBRETRY']:
+      logact |= PgLOG.EXITLG   # exit for error count exceeds limit
    return qelog(dberror, 0, sqlstr, ary, pgcnt, logact)
 
 #

src/rda_python_common/pg_dbi.py

@@ -366,6 +366,8 @@ def check_dberror(self, pgerr, pgcnt, sqlstr, ary, logact = None):
             return self.SUCCESS
       if logact&self.DOLOCK and pgcode and re.match(r'^55\w\w\w$', pgcode):
          logact &= ~self.EXITLG   # no exit for lock error
+      elif pgcnt > self.PGLOG['DBRETRY']:
+         logact |= self.EXITLG   # exit for error count exceeds limit
       return self.qelog(dberror, 0, sqlstr, ary, pgcnt, logact)
 
    # return hash reference to postgresql batch mode command and output file name