我有一些数据,我想插入到netezza的表中:
import pyodbc
data=[['GZ', datetime.date(2017, 2, 8), 19.7, 10.7, 0, '1级'],
['GZ', datetime.date(2017, 2, 9), 16.3, 9.7, -1, '微风'],
['GZ', datetime.date(2017, 2, 10), 16.0, 10.0, -1, '微风']]
conn = pyodbc.connect("DRIVER={NetezzaSQL}; SERVER=**;DATABASE=weather; UID=**; PASSWORD=**;")
cur = conn.cursor()
for i in data:
cur.execute("""
insert into WEATHER_INFO(location,weather_date,high_tempature,low_tempature,weather,wind)
values('%s',%s,%s,%s,%s,'%s')
""" % (i[0], i[1], i[2], i[3], i[4], i[5]))
conn.commit()
cur.execute('select * from WEATHER_INFO')
print(cur.fetchall())
cur.close()
conn.close()
我收到一些错误:
pyodbc.Error: ('HY000', "[HY000] ERROR: Attribute 'WEATHER_DATE' is of type 'DATE'
but expression is of type 'INT4'ntYou will need to rewrite or cast the expression (46)
(SQLExecDirectW)")
这是表结构:
create table weather(
location varchar(20),
weather_date date,
high_tempature float(4,1),
low_temputare float(4,1),
weather int(11),
wind varchar(20)
);
我知道python datime.date应该与SQL日期匹配。我没有通过搜索堆栈溢出得到我想要的答案。那么我应该如何看待这个问题呢?
您的问题是您使用字符串格式化运算符%
来创建动态 SQL,并且这些 SQL 语句格式不正确。如果我们打印出您尝试执行的实际语句,它们看起来像
insert into WEATHER_INFO(location,weather_date,high_tempature,low_tempature,weather,wind)
values('GZ',2017-02-08,19.7,10.7,0,'1级')
请注意,日期值作为不带分隔符的2017-02-08
插入,因此它被解释为整数表达式。
您需要做的是使用正确的参数化查询:
sql = """
insert into WEATHER_INFO(location,weather_date,high_tempature,low_tempature,weather,wind)
values(?,?,?,?,?,?)
"""
for i in data:
cur.execute(sql, i)
conn.commit()
或者也许只是
sql = """
insert into WEATHER_INFO(location,weather_date,high_tempature,low_tempature,weather,wind)
values(?,?,?,?,?,?)
"""
cur.executemany(sql, data)
conn.commit()