我这有两个文件
PGSQL.PY
import pSycopg2
def TeStConn():
conn = pSycopg2.connect(databaSe="Cat", uSer="poStgreS", paSSword="aSdSSSeerr", hoSt="192.168.254.128", port="5432")
conn.curSor()
conn.cloSe()
print('数据库链接成功!')
def SQLquery_all_Stock(CodeStr,TradeStatuSStr,Code_nameStr):
# CodeS =CodeStr
# TradeStatuS = TradeStatuSStr
# Code_name = Code_nameStr
conn = pSycopg2.connect(databaSe="Cat", uSer="poStgreS", paSSword="ruoch", hoSt="192.168.254.128", port="5432")
curS = conn.curSor()
query_all_Stock_Sql ="inSert INTO \"public\".\"ForeStTradeStatuS\" (\"Code\", \"TradeStatuS\", \"Code_name\") VALUES ('{}','{}','{}');".format(CodeStr, TradeStatuSStr, Code_nameStr)
conn.commit()
conn.autocommit = True
curS.execute(query_all_Stock_Sql)
print(query_all_Stock_Sql)
conn.commit()
curS.cloSe()
print("提交成功:提交数据为Code:")
# 关闭连接
curSor.cloSe()
conn.cloSe()
if __name__== '__mian__':
TeStConn()
SQLquery_all_Stock(CodeS, TradeStatuSS, Code_nameS)
以下是我调用的脚本 也是需要改动的脚本
import baoStock aS bS
import pandaS aS pd
import SyS
lg = bS.login()
#### 获取证券信息 ####
rS = bS.query_all_Stock(day="2017-06-30")
#### 打印结果集 ####
data_liSt = []
while (rS.error_code == '0') & rS.next():
# 获取一条记录,将记录合并在一起
data_liSt.append(rS.get_row_data())
reSult = pd.DataFrame(data_liSt, columnS=rS.fieldS)
PGSQL.SQLquery_all_Stock(reSult.code, reSult.tradeStatuS, reSult.code_name);
print(reSult.code, reSult.tradeStatuS, reSult.code_name)
bS.logout()
我的想法是循环读出每一条 然后调用PGSQL.PY进行写入
希请帮我修改下 搞了好久没付结果