擅长:python、mysql、java
<p>这在python 3.8.5下运行
它将第二个查询包含在try中,除非case没有年份列,然后使用outyear刷新查询</p>
<p>您应该考虑调用不同的CSV,如果有多个CSV也是不同的</p>
<pre><code>import pandas as pd
import pymysql
conn=pymysql.connect(host="localhost",user="root",password="testpawwd",db="bulkb1")
cursor=conn.cursor()
cursor.execute("SELECT TABLE_NAME FROM INFORMATION_SCHEMA.TABLES WHERE table_schema = 'bulk'")
myresult=cursor.fetchall()
for i in myresult:
print(i)
query=('select text, imdburl, `year` from %s '%(i))
query2=('select text, imdburl from %s '%(i))
try:
cursor.execute(query)
result=cursor.fetchall()
print(result)
my=pd.read_sql_query(query,conn)
my.to_csv("new%s.csv"%(i),index=False)
break
except:
try:
cursor.execute(query2)
result=cursor.fetchall()
print(result)
my=pd.read_sql_query(query2,conn)
my.to_csv("new%s.csv"%(i),index=False)
break
except:
print("An error occured")
</code></pre>