Commit 0978be8a authored by Kazuhiko Shiozaki's avatar Kazuhiko Shiozaki Committed by Jérome Perrin

py2/py3: use exception.args[] instead of exception[].

parent 19f8a198
......@@ -383,7 +383,7 @@ class WorkflowTool(BaseTool, OriginalWorkflowTool):
self.Base_zClearWorklistTable()
except ProgrammingError as error_value:
# 1146 = table does not exist
if error_value[0] != 1146:
if error_value.args[0] != 1146:
raise
self.Base_zCreateWorklistTable()
portal_catalog = self.getPortalObject().portal_catalog
......@@ -443,7 +443,7 @@ class WorkflowTool(BaseTool, OriginalWorkflowTool):
Base_zInsertIntoWorklistTable(**value_column_dict)
except (ProgrammingError, OperationalError) as error_value:
# OperationalError 1054 = unknown column
if isinstance(error_value, OperationalError) and error_value[0] != 1054:
if isinstance(error_value, OperationalError) and error_value.args[0] != 1054:
raise
LOG('WorkflowTool', WARNING, 'Insertion in worklist cache table ' \
'failed. Recreating table and retrying.',
......@@ -603,13 +603,13 @@ class WorkflowTool(BaseTool, OriginalWorkflowTool):
continue
except ProgrammingError as error_value:
# 1146 = table does not exist
if not use_cache or error_value[0] != 1146:
if not use_cache or error_value.args[0] != 1146:
raise
try:
self.Base_zCreateWorklistTable()
except ProgrammingError as error_value:
# 1050 = table exists (alarm run just a bit too late)
if error_value[0] != 1050:
if error_value.args[0] != 1050:
raise
if src__:
action_list.append(catalog_brain_result)
......
......@@ -407,14 +407,14 @@ class DB(TM):
try:
self.db.query(query)
except OperationalError as m:
if m[0] in query_syntax_error:
raise OperationalError(m[0], '%s: %s' % (m[1], query))
if m[0] in lock_error:
raise ConflictError('%s: %s: %s' % (m[0], m[1], query))
if m[0] in query_timeout_error:
raise TimeoutReachedError('%s: %s: %s' % (m[0], m[1], query))
if m.args[0] in query_syntax_error:
raise OperationalError(m.args[0], '%s: %s' % (m.args[1], query))
if m.args[0] in lock_error:
raise ConflictError('%s: %s: %s' % (m.args[0], m.args[1], query))
if m.args[0] in query_timeout_error:
raise TimeoutReachedError('%s: %s: %s' % (m.args[0], m.args[1], query))
if (allow_reconnect or not self._use_TM) and \
m[0] in hosed_connection:
m.args[0] in hosed_connection:
self._forceReconnection()
self.db.query(query)
else:
......@@ -422,7 +422,7 @@ class DB(TM):
raise
except ProgrammingError as m:
if (allow_reconnect or not self._use_TM) and \
m[0] in hosed_connection:
m.args[0] in hosed_connection:
self._forceReconnection()
self.db.query(query)
else:
......@@ -431,8 +431,8 @@ class DB(TM):
try:
return self.db.store_result()
except OperationalError as m:
if m[0] in query_timeout_error:
raise TimeoutReachedError('%s: %s: %s' % (m[0], m[1], query))
if m.args[0] in query_timeout_error:
raise TimeoutReachedError('%s: %s: %s' % (m.args[0], m.args[1], query))
else:
raise
......@@ -535,7 +535,7 @@ class DB(TM):
except OperationalError as m:
LOG('ZMySQLDA', ERROR, "exception during _abort",
error=True)
if m[0] not in hosed_connection:
if m.args[0] not in hosed_connection:
raise
def getMaxAllowedPacket(self):
......@@ -587,7 +587,7 @@ class DB(TM):
try:
old_list, old_set, old_default = self._getTableSchema("`%s`" % name)
except ProgrammingError as e:
if e[0] != ER.NO_SUCH_TABLE or not create_if_not_exists:
if e.args[0] != ER.NO_SUCH_TABLE or not create_if_not_exists:
raise
if not src__:
self.query(create_sql)
......
......@@ -137,7 +137,7 @@ class TestDeferredConnection(ERP5TypeTestCase):
try:
self.commit()
except OperationalError as m:
if m[0] not in hosed_connection:
if m.args[0] not in hosed_connection:
raise
else:
self.fail()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment