使用 PYMSSQL 将值放入 SQL 服务器数据库 Table

Question

我正在尝试将值放入 SQL 服务器上数据库的 Table。

我的程序将订阅一个 MQTT 服务器，每当它收到一条消息时，它会将消息放入数据库的 table。

以下是我的代码：

import paho.mqtt.client as mqtt
import signal
import sys
import pymssql
from os import getenv
from time import gmtime, strftime

#Signal Handler
def signal_handler(signal, frame):
    print("\nProgram has been interrupted!")
    sys.exit(0)

#MQTT Subscribe ON_CONNECT
def on_connect(client, userdata, flags, rc):
    if str(rc) == '0':
        print ("Connected Successfully")
    else:
        print ("Connection has a problem")

    #CLIENT SUBSCRIPTION
    client.subscribe("topic1")

#MQTT Subscribe ON_MESSAGE
def on_message(client, userdata, msg):
    print("[" + msg.topic + "] " + str(msg.payload) )
    deviceID = msg.payload
    time = strftime("%Y%m%d%H%M%S", gmtime())
    #Puts the data into the SQL Server DB Table "Topic"
    cursor.execute("""
    IF OBJECT_ID('Topic', 'U') IS NOT NULL
        DROP TABLE Topic
    CREATE TABLE Topic(
        id INT NOT NULL,
        deviceID INT NOT NULL,
        dateTime INT NOT NULL,
        PRIMARY KEY(id)
    )
    """)
    cursor.execute(
        "INSERT INTO Topic VALUES (%d)",
        [(id, deviceID, time)]

    conn.commit()

#Signal Handler
signal.signal(signal.SIGINT, signal_handler)

#Connect to the SQL Server
server = 'mqtt.server.address.com'
user = 'sa'
password = 'pwd'
database = 'topics'

#SQL Server Connection Established
conn = pymssql.connect(server, user, password, database)
cursor = conn.cursor()

#Establishing MQTT Subscribe Connection
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("mqtt.server.address.com", 1883, 60)
client.loop_forever()

而且我一直收到以下错误：

提前感谢您的帮助。

Answer 1

你应该post你的错误直接在你的问题中作为文本。
错误清楚地表明 query_params 参数应该是
元组或字典，而不是列表。
```
cursor.execute("INSERT INTO Topic VALUES (%d)",
               [(id, deviceID, time)])
```
您正在尝试将包含一个元组的列表插入到单个列中。

另请注意，您在此行中缺少结尾 )。

相反，您应该单独插入每一列，并为您的参数使用一个元组：
```
cursor.execute("INSERT INTO Topic VALUES (%d, %d, %d)",
               (id, deviceID, time))
```

使用 PYMSSQL 将值放入 SQL 服务器数据库 Table

Putting values into SQL Server Database Table using PYMSSQL

python

pymssql

mqtt