我是 python 新手,不太了解 sql 的東西。目前是團隊樹屋的第六周,所以如果這些是菜鳥問題,請在這里與我交流。目標導入包含 stock_tickers 和其他 5 列數(shù)據(jù)的 CSV將 CSV 轉(zhuǎn)換為 pandas 數(shù)據(jù)框?qū)?shù)據(jù)框?qū)霐?shù)據(jù)庫。如果已經(jīng)有唯一的stock_ticker,則不添加新行,而是接下來檢查其他5列中的數(shù)據(jù)是否不同。如果是的話就更新它。現(xiàn)在我可以執(zhí)行步驟 #1 和 #2 以及步驟 #3 的一半。在此處的幫助下,能夠使循環(huán)工作正常工作。如果 csv 中有新的 stock_ticker 行,它會將其添加到數(shù)據(jù)庫中。如果現(xiàn)有 stock_ticker 的數(shù)據(jù)發(fā)生變化,它不會進行任何更新。for i in range(len(df)): try: df[df.index == i].to_sql(name='stocks', con=conn, if_exists='append', index=False) conn.commit() except sqlite3.IntegrityError: pass當前代碼如下所示import pandas as pdfrom pandas import DataFramefrom pandas import ExcelWriterimport csvimport sqlite3### IMPORT CSV ###stock_csv_file = pd.read_csv (r'C:\Users\home\Desktop\code_projects\FIRE_Dashboard\db\alpha_vantage_active_stocks.csv')### CHANGING INDEX NAMES FROM CSV TO TABLE NAMES ###df = pd.DataFrame(stock_csv_file)df = df.rename(columns = {"symbol":"stock_ticker", "name":"stock_name", "exchange":"stock_exchange", "ipoDate":"stock_ipoDate", "delistingDate":"stock_delistingDate", "status":"stock_status"})### UPDATING DATABSE WITH SQLITE3###conn = sqlite3.connect('stockmarket.db')c = conn.cursor()insert_statement = """INSERT INTO stocks (stock_ticker, stock_name, stock_exchange, stock_ipoDate, stock_delistingDate, stock_status )VALUES (?, ?, ?, ?, ?, ?)ON CONFLICT (stock_ticker) DO UPDATE SET (stock_status)""" for i in range(len(df)): values = tuple(df.iloc[i]) c.execute(insert_statement, values)我收到的錯誤Traceback (most recent call last): File "update_stock_tickers.py", line 71, in <module> c.execute(insert_statement, values)sqlite3.OperationalError: incomplete input
1 回答

茅侃侃
TA貢獻1842條經(jīng)驗 獲得超21個贊
這是ON CONFLICT您的查詢的子句:
ON CONFLICT (stock_ticker) DO UPDATE
SET (stock_status)
這不是有效的 SQLite 語法。stock_status如果您想在另一行已存在且具有相同的行時進行更新stock_ticker,您可以使用偽表,EXCLUDED如下所示:
INSERT INTO stocks (stock_ticker,
stock_name,
stock_exchange,
stock_ipoDate,
stock_delistingDate,
stock_status
)
VALUES (?, ?, ?, ?, ?, ?)
ON CONFLICT (stock_ticker) DO UPDATE
SET stock_status = EXCLUDED.status
添加回答
舉報
0/150
提交
取消