【注释】 read_sql_query的两个参数: (sql语句, 数据库连接)
dataset = pd.read_sql_query(sql, connection) #生成转换得到数据框
首先,需要确保已经安装好了pymysql模块。可以通过在命令行中输入"pip install pymysql"来进行安装。接下来请按照以下步骤来连接SQL数据库:
1.导入pymysql模块:使用import pymysql语句导入pymysql模块。
2.连接SQL数据库:使用pymysql.connect()方法连接SQL数据库,需要提供数据库地址、端口号、用户名和密码等必要信息。
3.创建游标:使用conn.cursor()方法创建游标对象。
4.执行sql语句:使用cur.execute(sql)方法来执行sql语句,其中sql是一个字符串类型的变量,保存执行的sql语句。
5.获取查询结果:获取查询结果,可以使用cur.fetchone()方法获取一个查询结果,使用cur.fetchall()方法获取所有的查询结果。
6.提交事务:针对数据库操作的语句,必须提交事务。事务提交方法为conn.commit()。
7.关闭游标和数据库连接:当使用完数据库连接之后,必须将游标关闭,可以使用cur.close()方法关闭游标;将数据库连接关闭,可以使用conn.close()方法关闭连接。
接下来提供一个完整的连接数据库的示例代码:
import pymysql
# 连接到数据库
conn = pymysql.connect(host="localhost", port=3306, user="root",
password="password", database="test", charset="utf8")
# 创建一个游标对象
cur = conn.cursor()
# 执行sql语句
sql = "select * from users"
cur.execute(sql)
# 获取查询集中的所有数据
datas = cur.fetchall()
print(datas)
# 提交事务
conn.commit()
# 关闭游标和数据库连接
cur.close()
conn.close()
请注意更改连接信息(数据库地址、端口号、用户名和密码等)以及sql语句的内容,以适应你的实际情况。
TAF_MT 换成IP试试