1.方式一(推荐)
import pymysql
from sqlalchemy import create_engine
pymysql.install_as_MySQLdb()
engine = create_engine(“mysql+pymysql://root:*****@localhost:3306/test?charset=gbk”)
sql = “select * from student”
df = pd.read_sql_query (sql,con=engine)
2.方式二
步骤:连接数据库,生成游标,对象执行SQL语句,关闭游标,关闭连接
conn = pymysql.connect(host=’127.0.0.1’ #连接名称,默认127.0.0.1
user=’root’, #用户名
passwd=’******’, #密码
port=3306, #端口,默认3306
db=’test’, #数据库名称
charset=’utf8’ # 字符编码)
cur = conn.cursor() #生成游标对象
sql = ‘select * from student’ # SQL语句
cur.execute(sql) #执行sql语句
data = cur.fetchall() #通过fetchall方法获得数据
cur.close() #关闭游标
conn.close() # 关闭连接
这种方法读取的数据是元组形式,需要去遍历,不是很实用
网友评论