import sys
sys.path.insert(0,'/www/server/xingyu-im/ops')
from baota_publish_test_users import database,env_values,query
conn,_=database(env_values())
try:
 rows=query(conn,"""SELECT user.id,user.public_id,profile.nickname,security.token_version FROM users user JOIN user_profiles profile ON profile.user_id=user.id JOIN user_security_controls security ON security.user_id=user.id WHERE user.is_test=1 AND user.test_batch=%s AND user.status=1 AND user.deleted_at IS NULL ORDER BY user.id""",('cn-adults-20260831-v1',))
 print('rows',len(rows))
finally: conn.close()