import sqlite3
import pandas as pd
conn = sqlite3.connect('tv_shows.db')
三个表格分别导入数据库中
df_hot = pd.read_excel('hot.xlsx')
df_hot.to_sql('hot', conn, index=False, if_exists='replace')
df_release = pd.read_excel('release.xlsx')
df_release.to_sql('release', conn, index=False, if_exists='replace')
df_ratings = pd.read_excel('ratings.xlsx')
df_ratings.to_sql('ratings', conn, index=False, if_exists='replace')
# 使用 SQL 查询进行表格合并并去除重复列
query = """
SELECT DISTINCT hot.*, release.发行时间, ratings.收视率
FROM hot
JOIN release ON hot.电视剧名称 = release.电视剧名称
JOIN ratings ON hot.电视剧名称 = ratings.电视剧名称
"""
执行查询并获取结果
df_merged = pd.read_sql_query(query, conn)
打印合并后的表格
print(df_merged)
conn.close()