mysql操作

# mysql数据库操作
import pymysql
import pandas as pd
# 连接数据库
bridge = pymysql.connect(host='10.16.101.177',user='apps',password='lnmN4tA8n', port=3306, database='femsuat')

# mysql查询语句
sql = '''SELECT m.meter_code,r.meter_id,m.meter_name,o.org_name,
m.org_id,r.record_time,r.electricity
from meter_value_record_11 r,org o,meter m  
WHERE (r.RECORD_TIME >= '2020-9-25 00:00:00' and r.RECORD_TIME <= '2020-9-25 23:55:00' 
AND  m.IS_DELETE=0 AND m.ENERGY_TYPE=1) 
AND m.id =r.METER_ID AND m.ORG_ID=o.id
'''
# 读取数据
sql_data = pd.read_sql(sql, con= bridge)   
bridge.close()  # 关闭数据库连接
sql_data.head()