87 lines
3.8 KiB
Python
87 lines
3.8 KiB
Python
# -*- coding: utf-8 -*-
|
||
"""只读勘察第二轮：确定目标库 + 校验引用完整性。绝不写入。"""
|
||
import io, sys, pymysql
|
||
sys.stdout = io.TextIOWrapper(sys.stdout.buffer, encoding='utf-8')
|
||
|
||
SRC = dict(host='192.168.3.200', user='root', password='PX4fTAAsJ#T!1',
|
||
database='zentao_dev', charset='utf8mb4', connect_timeout=15)
|
||
DST = dict(host='192.168.1.161', user='devgps', password='dev@2021GPS',
|
||
charset='utf8mb4', connect_timeout=15)
|
||
SID = 9197
|
||
|
||
src = pymysql.connect(**SRC); scur = src.cursor()
|
||
dst = pymysql.connect(**DST); dcur = dst.cursor()
|
||
|
||
# 1) 161 上哪个库是活跃测试库：比较最近活动
|
||
print('===== 161 各库活跃度 =====')
|
||
for db in ['zentao_dev', 'zentao_dev_2026']:
|
||
dcur.execute(f'USE `{db}`')
|
||
dcur.execute("SELECT COUNT(*), MAX(id) FROM zt_story")
|
||
c1, m1 = dcur.fetchone()
|
||
try:
|
||
dcur.execute("SELECT COUNT(*), MAX(date) FROM zt_action")
|
||
c2, m2 = dcur.fetchone()
|
||
except Exception as e:
|
||
c2, m2 = 'err', str(e)
|
||
dcur.execute("SELECT MAX(lastEditedDate) FROM zt_story")
|
||
m3 = dcur.fetchone()[0]
|
||
print(f'{db}: story数={c1} max_story_id={m1} action数={c2} max_action_date={m2} story最近编辑={m3}')
|
||
|
||
# 2) 200 上 9197 相关行明细
|
||
print('\n===== 200 上 9197 相关明细 =====')
|
||
scur.execute("SELECT * FROM zt_storyspec WHERE story=%s", (SID,))
|
||
cols = [d[0] for d in scur.description]
|
||
for r in scur.fetchall():
|
||
print('storyspec:', dict(zip(cols, r)))
|
||
|
||
scur.execute("SELECT project, story, version, `order` FROM zt_projectstory WHERE story=%s", (SID,))
|
||
proj_links = scur.fetchall()
|
||
print('projectstory:', proj_links)
|
||
|
||
scur.execute("""SELECT id, project, execution, name, status, type, assignedTo, deleted
|
||
FROM zt_task WHERE story=%s""", (SID,))
|
||
tasks = scur.fetchall()
|
||
print('tasks:', tasks)
|
||
|
||
scur.execute("""SELECT id, action, date, actor, LEFT(comment,40) FROM zt_action
|
||
WHERE objectType='story' AND objectID=%s ORDER BY id""", (SID,))
|
||
for r in scur.fetchall():
|
||
print('action:', r)
|
||
|
||
# 3) zentao_dev_2026 里已有的 9197 action/file 是什么
|
||
print('\n===== zentao_dev_2026 已有 9197 action/file =====')
|
||
dcur.execute('USE zentao_dev_2026')
|
||
dcur.execute("""SELECT id, action, date, actor, LEFT(comment,40) FROM zt_action
|
||
WHERE objectType='story' AND objectID=%s ORDER BY id""", (SID,))
|
||
for r in dcur.fetchall():
|
||
print('action:', r)
|
||
dcur.execute("SELECT id, title, pathname, addedBy, addedDate FROM zt_file WHERE objectType='story' AND objectID=%s", (SID,))
|
||
for r in dcur.fetchall():
|
||
print('file:', r)
|
||
|
||
# 4) 引用完整性：目标库中 product/项目/task id 冲突检查
|
||
print('\n===== 目标库引用完整性 =====')
|
||
dcur.execute("SELECT id, LEFT(name,30), deleted FROM zt_product WHERE id=150")
|
||
print('目标 product 150:', dcur.fetchone())
|
||
scur.execute("SELECT id, LEFT(name,30), deleted FROM zt_product WHERE id=150")
|
||
print('源 product 150:', scur.fetchone())
|
||
for pid in {r[0] for r in proj_links}:
|
||
dcur.execute("SELECT id, LEFT(name,40), deleted FROM zt_project WHERE id=%s", (pid,))
|
||
print(f'目标 project {pid}:', dcur.fetchone())
|
||
for tid in [t[0] for t in tasks]:
|
||
dcur.execute("SELECT id, LEFT(name,40), story, deleted FROM zt_task WHERE id=%s", (tid,))
|
||
print(f'目标 task {tid} 冲突检查:', dcur.fetchone())
|
||
|
||
# 5) zt_story 9197 行全列比对（200 vs zentao_dev_2026）
|
||
scur.execute("SELECT * FROM zt_story WHERE id=%s", (SID,))
|
||
story_cols = [d[0] for d in scur.description]
|
||
srow = scur.fetchone()
|
||
dcur.execute("SELECT * FROM zt_story WHERE id=%s", (SID,))
|
||
drow = dcur.fetchone()
|
||
diff = [(c, s, d) for c, s, d in zip(story_cols, srow, drow) if s != d]
|
||
print('\n===== zt_story 9197 差异列 =====' if diff else '\n===== zt_story 9197 两库完全一致 =====')
|
||
for c, s, d in diff:
|
||
print(f' {c}: 200={s!r} vs 161_2026={d!r}')
|
||
|
||
src.close(); dst.close()
|