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))