Python MySQL连接器未插入

sczxawaw 于 2023-05-30 发布在 Python

关注(0)|答案(1)|浏览(95)

这是我的代码。我不知道为什么插入不工作。select语句起作用。它也没有使try catch失败，这让我相信查询正在执行。另外，在MySQL Workbench中手动输入插入查询似乎也可以正常工作。

def runQuery(query):
    try:
        conn = mysql.connector.connect(host='localhost',
                                       database='optionsdata',
                                       user='python',
                                       passwd='python')
        cursor = conn.cursor()
        cursor.execute(query)
        conn.close()
        cursor.close()
        print(query)
    except Error as e:
        print("Error", e)

def convertDate(date_str):
    date_object = datetime.datetime.strptime(date_str, '%m/%d/%Y').date()
    return date_object

ticker = "MSFT"
html = urlopen("https://api.nasdaq.com/api/quote/" + ticker + "/option-chain?assetclass=stocks&todate=2020-05-08&fromdate=2020-04-07&limit=0").read().decode('utf-8')
optionsData = json.loads(html)
rows = optionsData["data"]["optionChainList"]["rows"]

for row in rows:
    call = row["call"]
    expiryDate = convertDate(call["expiryDate"])
    query = "INSERT INTO `optionsdata`.`call` (`ticker`, `symbol`, `last`, `change`, `bid`, `ask`, `volume`, `openinterest`, `strike`, `expiryDate`, `grabTime`) VALUES ('{0}', '{1}', '{2}', '{3}', '{4}', '{5}', '{6}', '{7}', '{8}', '{9}', '{10}');".format(ticker, call["symbol"], call["last"], call["change"], call["bid"], call["ask"], call["volume"], call["openinterest"], call["strike"], expiryDate, datetime.datetime.now())
    runQuery(query)

插入查询的示例

INSERT INTO `optionsdata`.`call` (`ticker`, `symbol`, `last`, `change`, `bid`, `ask`, `volume`, `openinterest`, `strike`, `expiryDate`, `grabTime`) VALUES ('MSFT', '@MSFT  200508C00175000', '3.21', '-0.29', '2.80', '4.25', '54', '228', '175.00', '2020-05-08', '2020-04-09 19:39:22.554538');

python-3.x

来源：https://stackoverflow.com/questions/61131958/python-mysql-connector-not-inserting

1条答案

按热度按时间

qvk1mo1f1#

这是一个伟大的问题！几周前我花了几个小时试图弄清楚这一点。这很棘手，因为在执行查询之后，必须调用

conn.commit()

实际上是“更新”数据。所以像这样修改你的runQuery函数：

def runQuery(query):
    try:
        conn = mysql.connector.connect(host='localhost',
                                       database='optionsdata',
                                       user='python',
                                       passwd='python')
        cursor = conn.cursor()
        cursor.execute(query)
        conn.commit()  # Added commit line
        conn.close()
        cursor.close()
        print(query)
    except Error as e:
        print(f"Error: {e}")

请参阅this doc page了解更多信息。

赞(0）回复(0）举报 2023-05-30

我来回答

Python MySQL连接器未插入

1条答案

相关问题

热门标签

最新问答