server/checkintegrity.py
branchstable
changeset 3374 d5bd1b659ce8
parent 2596 d02eed70937f
child 3417 fb17a54b358c
child 3689 deb13e88e037
equal deleted inserted replaced
3372:26b89dfe4170 3374:d5bd1b659ce8
   209                 for row in cursor.fetchall():
   209                 for row in cursor.fetchall():
   210                     eid = row[0]
   210                     eid = row[0]
   211                     if not has_eid(cursor, eid, eids):
   211                     if not has_eid(cursor, eid, eids):
   212                         bad_related_msg(rschema, 'object', eid, fix)
   212                         bad_related_msg(rschema, 'object', eid, fix)
   213                         if fix:
   213                         if fix:
   214                             sql = 'UPDATE %s SET %s = NULL WHERE %seid=%s;' % (
   214                             sql = 'UPDATE %s SET %s=NULL WHERE %s=%s;' % (
   215                                 table, column, SQL_PREFIX, eid)
   215                                 table, column, column, eid)
   216                             session.system_sql(sql)
   216                             session.system_sql(sql)
   217             continue
   217             continue
   218         cursor = session.system_sql('SELECT eid_from FROM %s_relation;' % rschema)
   218         cursor = session.system_sql('SELECT eid_from FROM %s_relation;' % rschema)
   219         for row in cursor.fetchall():
   219         for row in cursor.fetchall():
   220             eid = row[0]
   220             eid = row[0]