数据分析从零开始实战，Python、Pandas 与各类数据库

pip install SQLAlchemy

pip install xxxxx.whl

pip install -i https://pypi.douban.com/simple/ SQLAlchemy

import pandas as pdimport sqlalchemy as sa
# 读取的CSV文件路径r_filepath = r"H:\PyCoding\Data_analysis\day01\data01\realEstate_trans.csv"# 数据库鉴权user = "postgres"   # 数据库用户名password = "root"   # 数据库密码db_name = "test513"   # 数据库名称# 连接数据库engine = sa.create_engine('postgresql://{0}:{1}@localhost:5432/{2}'.format(user, password, db_name))print(engine)# 读取数据csv_read = pd.read_csv(r_filepath)# 将 sale_date 转成 datetime 对象csv_read['sale_date'] = pd.to_datetime(csv_read['sale_date'])# 将数据存入数据库csv_read.to_sql('real_estate', engine, if_exists='replace')print("完成")# 可能报错：ModuleNotFoundError: No module named 'psycopg2'# 解决方法：pip install psycopg2

engine = sa.create_engine('postgresql://{0}:{1}@localhost:5432/{2}'.format(user, password, db_name))

csv_read.to_sql('real_estate', engine, if_exists='replace')

query = 'SELECT * FROM real_estate LIMIT 10'top10 = pd.read_sql_query(query, engine)print(top10)

# 使用前先安装 pymysql 模块 ：pip install pymysql# 导入 pymysql 模块import pymysql#连接数据库,参数说明：服务器，用户名，数据库密码，数据库名称db = pymysql.connect("localhost","root","root","db_test")#使用cursor()方法创建一个游标对象cursor = db.cursor()#使用execute()方法执行SQL语句cursor.execute("SELECT * FROM test_table")#使用fetall()获取全部数据data = cursor.fetchall()#关闭游标和数据库的连接cursor.close()db.close()

# 使用前先安装 pymongodb 模块 ：pip install pymongodb # 导入 pymogodb 模块import pymongo# 连接数据库,参数说明：服务器IP，端口号默认为27017my_client = pymongo.MongoClient(host="127.0.0.1",port=27017)# 直接通过数据库名称索引，有点像字典my_db = my_client["db_name"]  # 连接 collection_name 集合，Mongodb里集合就相当于Mysql里的表my_collection = my_client["collection_name"]  datas = my_collection.find() # 查询for x in datas :  print(x)

# 使用前先安装 sqlite3  模块 ：pip install sqlite3'''sqlite数据库和前面两种数据库不一样，它是一个本地数据库也就是说数据直接存在本地，不依赖服务器'''# 导入 sqlite3 模块import sqlite3# 连接数据库，参数说明：这里的参数就是数据文件的地址conn = sqlite3.connect('test.db')#使用cursor()方法创建一个游标对象c = conn.cursor()#使用execute()方法执行SQL语句cursor = c.execute("SELECT * from test_table")for row in cursor:  print(row)#关闭游标和数据库的连接c.close()conn.close()