在Python中读取数据库通常涉及以下步骤:
安装必要的库
对于MySQL,可以使用`pymysql`或`mysql-connector-python`。
对于MS-SQL,可以使用`pymssql`。
对于其他数据库,可能使用`psycopg2`(PostgreSQL)、`sqlite3`(SQLite)等。
连接数据库
使用库提供的连接函数,如`pymysql.connect`或`pymssql.connect`,提供必要的参数,如服务器地址、用户名、密码和数据库名。
执行SQL查询
使用数据库连接对象的`cursor`对象执行SQL命令,如`cursor.execute`。
处理查询结果
使用`fetchone`、`fetchmany`或`fetchall`方法获取查询结果。
关闭连接
完成操作后,关闭数据库连接和游标。
import pandas as pd
import pymysql
数据库连接参数
sql_path = "sql文件夹路径" SQL文件的路径
sql_file = "sql文件名.sql" SQL文件名
读取SQL文件内容
with open(sql_path + sql_file, "r", encoding="utf8") as sql:
sql_text = sql.read()
连接到MySQL数据库
con = pymysql.connect(
host="数据库地址",
user="用户名",
password="密码",
db="数据库名",
charset="utf8"
)
使用pandas读取SQL查询结果
df = pd.read_sql(sql_text, con)
关闭数据库连接
con.close()
请根据你的具体需求调整代码中的参数和库。如果你需要读取MS-SQL数据库,可以使用`pymssql`库,但请注意`pymssql`已经不是Python的维护库,你可能需要寻找其他替代方案,如`pyodbc`或`mssql-connector-python`。