import sys, json
|
sys.stdout.reconfigure(encoding='utf-8')
|
from pathlib import Path
|
sys.path.insert(0, str(Path(__file__).resolve().parents[1] / 'iqc-import-20261012/deps'))
|
import pymysql
|
password = sys.stdin.readline().strip()
|
with pymysql.connect(host='36.213.150.237', port=10000, user='root', password=password,
|
database='mom-hm', charset='utf8mb4', connect_timeout=15,
|
cursorclass=pymysql.cursors.DictCursor) as connection:
|
with connection.cursor() as cursor:
|
for sql in [
|
'SELECT DATABASE() AS db',
|
'SHOW COLUMNS FROM crm_contact',
|
'SHOW COLUMNS FROM crm_customer',
|
"SELECT post, master, COUNT(*) AS count FROM crm_contact WHERE deleted=0 GROUP BY post, master ORDER BY count DESC",
|
'SELECT COUNT(*) AS count FROM crm_customer WHERE deleted=0',
|
'SELECT COUNT(*) AS count FROM crm_contact WHERE deleted=0',
|
'SELECT COUNT(*) AS multiple_customers FROM (SELECT customer_id FROM crm_contact WHERE deleted=0 GROUP BY customer_id HAVING COUNT(*)>1) t',
|
]:
|
cursor.execute(sql)
|
print(json.dumps({'sql': sql, 'rows': cursor.fetchall()}, ensure_ascii=False, default=str))
|
