2017-08-15 228 views
4

我正尝试使用dataframe.to_sql函数将pandas dataframe df插入到SQL Server数据库中。但我得到以下错误:使用python中的to_sql函数将数据框插入到Sql-server数据库时出错

源代码:

import pyodbc 
import sqlalchemy 
import urllib 

df #sample dataframe 
params = urllib.parse.quote_plus("DRIVER={SQL Server};SERVER=GIRSQL.GIRCAPITAL.com;DATABASE=Tableau;UID=SQL_User;PWD=pass") 
engine = sqlalchemy.create_engine("mssql+pyodbc:///?odbc_connect=%s" % params) 
engine.connect() 
df.to_sql(name='[Tableau].[dbo].[Test table]',con=engine, index=False, 
if_exists='append') 

错误:

File "C:\Users\Arvinth\sqlalchemy\engine\default.py", line 470, in do_execute cursor.execute(statement, parameters)

sqlalchemy.exc.ProgrammingError: (pyodbc.ProgrammingError) ('42000', "[42000] [Microsoft][ODBC SQL Server Driver][SQL Server]Incorrect syntax near 'INTEGER'. (102) (SQLExecDirectW)") [SQL: '\nCREATE TABLE [[Tableau].[dbo].[Test table]] (\n\t[A] INTEGER NULL, \n\t[B] INTEGER NULL, \n\t[C] INTEGER NULL\n)\n\n']

样品数据框:

A B C 
0 0 0 0 
1 1 1 1 
2 2 2 2 
3 3 3 3 
4 4 4 4 
5 5 5 5 
6 6 6 6 
7 7 7 7 

谁能请帮助解决问题。

+1

这不是必需的* [Tableau]。[dbo]。*当您连接到* Tableau *并且默认架构是* dbo *。只需传递表名:'df.to_sql(name ='Test table',con = engine,index = False, if_exists ='append')' – Parfait

+0

它的工作正常。非常感谢! –

回答

3

至于评论,你所引用的数据库名称和dbo架构在大熊猫表 ARG to_sql呼吁‘[的Tableau] [DBO]。[测试表]’和括号的名字,渲染sqlAlchemy引擎的CREATE TABLE SQL调用中出现错误。由于当前连接引用的数据库和默认模式为dbo,因此不需要名称中的两个限定符:`[Tableau]。[dbo]。

因此,在df.to_sql,简单地引用该表的名称,而无需支架转义:

CREATE TABLE [Test table] (
    [A] INTEGER NULL, 
    [B] INTEGER NULL, 
    [C] INTEGER NULL 
); 

df.to_sql(name='Test table', con=engine, index=False, if_exists='append') 

将在连接Tableau数据库的默认dbo模式中创建所需要的表

-2

也许你可以参考to_sql()中的表格:

df.to_sql('test_table',con=engine, index=False, if_exists='append') 
+1

这也是在接受的答案中提到的。如果您有针对同一问题的其他解决方案,请仅添加新答案。 – rene

相关问题