方法一:
import psycopg2
import pandas as pd
from sqlalchemy import create_engine
#初始化数据库连接,使用pymysql模块
#postgresql的用户:root,
#password:你的密码,
#端口:5432,
#数据库:trust
engine = create_engine(“postgresql+psycopg2://**root**:**password**@**localhost**:**3306/trust**”,encoding=‘utf-8’)
#查询语句,选出testexcel表中的所有数据
sql = “”“select * from testexcel”""
#read_sql_query的两个参数: sql语句, 数据库连接
df = pd.read_sql_query(sql,con=engine)
方法二:
import psycopg2
import pandas as pd
# postgres config
postgres_host = "" # 数据库地址
postgres_port = "5432" # 数据库端口
postgres_user = "" # 数据库用户名
postgres_password = "" # 数据库密码
postgres_datebase = "" # 数据库名字
postgres_table1 = "" #数据库中的表的名字
# connection string
conn_string = "host=" + postgres_host + " port=" + postgres_port + " dbname=" + postgres_datebase +
" user=" + postgres_user + " password=" + postgres_password
conn = psycopg2.connect(conn_string)
sql_command1 = "select * from test"
try:
data1 = pd.read_sql(sql_command1, conn)
except:
print("load data from postgres failure !")
exit()
方法一:
import psycopg2
import pandas as pd
from sql