在Python中读取SQL数据通常有以下几种方法:
使用内置的`sqlite3`模块
```python
import sqlite3
连接数据库,如果不存在则创建
conn = sqlite3.connect('example.db')
打开 SQL 文件
with open('example.sql', 'r') as f:
sql = f.read()
执行 SQL 文件中的语句
conn.executescript(sql)
关闭数据库连接
conn.close()
使用第三方库`pymysql`连接MySQL服务器
```python
import pymysql
import pandas as pd
连接数据库
con = pymysql.connect(host='机器', user='用户名', password='密码', db='数据库名', charset='utf8')
读取 SQL 文件
sql_path = 'sql文件夹路径'
sql_file = 'sql文件名.sql'
sql = open(sql_path + sql_file, 'r', encoding='utf8').read()
使用 pandas 读取 SQL 查询结果
df = pd.read_sql(sql, con)
关闭数据库连接
con.close()
使用第三方库`psycopg2`连接PostgreSQL数据库
```python
import psycopg2
连接数据库
conn = psycopg2.connect(host='机器', dbname='数据库名', user='用户名', password='密码')
读取 SQL 文件
sql_path = 'sql文件夹路径'
sql_file = 'sql文件名.sql'
sql = open(sql_path + sql_file, 'r', encoding='utf8').read()
使用 pandas 读取 SQL 查询结果
df = pd.read_sql(sql, conn)
关闭数据库连接
conn.close()
使用第三方库`pymssql`连接SQL Server数据库
```python
import pymssql
连接数据库
conn = pymssql.connect(server='机器', user='用户名', password='密码', database='数据库名')
读取 SQL 文件
sql_path = 'sql文件夹路径'
sql_file = 'sql文件名.sql'
sql = open(sql_path + sql_file, 'r', encoding='utf8').read()
使用 pandas 读取 SQL 查询结果
df = pd.read_sql(sql, conn)
关闭数据库连接
conn.close()
请根据你的数据库类型选择合适的方法,并确保在使用第三方库前已经安装好相应的库。