我正试图让我的代码将DataFrame上传到我已经在SQL数据库中创建的表中。
然而,它没有写入该表,而是创建了另一个具有相同名称但有一些额外文本字符串的表。
该表是[数据库]。[dbo]。[myTable]
代码创建的表是[Database]。[dbo]。[DIR\User.myTable]
这是代码,它在过去一直有效,所以我不确定现在会出现什么问题
params = urllib.parse.quote_plus(r'DRIVER={SQL Server Native Client 11.0}; Trusted_Connection=yes; Server='servername005.azr.com, DATABASE=Database; application intent=readwrite'
conn_str = 'mssql+pyodbc:///?odbc_connect={}'.format(params)
engine = sqlalchemy.create_engine(conn_str, fast_executemany=True)
df.to_sql("myTable", con=engine, if_exists='replace', index=True)
提前感谢!
上面的一个用户解决了它!我不确定我是否可以将他/她的评论标记为已解决,但以下是有效的方法。将schema="dbo"添加到to_sql方法中。
谢谢!
params = urllib.parse.quote_plus(r'DRIVER={SQL Server Native Client 11.0};
Trusted_Connection=yes; Server='servername005.azr.com, DATABASE=Database; application intent=readwrite'
conn_str = 'mssql+pyodbc:///?odbc_connect={}'.format(params)
engine = sqlalchemy.create_engine(conn_str, fast_executemany=True)
df.to_sql("myTable", con=engine, if_exists='replace', schema="dbo" index=True)