1 
engine = sqlalchemy.create_engine('mssql+pyodbc://<Username>:<password>@<DBServername>/<DBName>', pool_pre_ping=True)

我有数据要加载到 DataFrame 中，当我循环遍历 DF 中的每一行时，我可以使用连接字符串将数据插入表中（使用 INSERT INTO .. 语句一次插入 1 行），但我想使用<DataFrame>.to_sql("<Table_name>", engine, if_exists='append')

请帮助我了解我是否遗漏了什么？

但我不断收到此错误

/Library/Python/2.7/site-packages/sqlalchemy/connectors/pyodbc.py:79: SAWarning: No driver name specified; this is expected by PyODBC when using DSN-less connections
  "No driver name specified; "
Traceback (most recent call last):
  File "/Users/snaidu/renuka/python-projects/staging/test.py", line 131, in <module>
    print(loaddmvcsvfile())
  File "/Users/snaidu/renuka/python-projects/staging/test.py", line 115, in loaddmvcsvfile
    result.to_sql("table1", engine, if_exists='append')
  File "/Library/Python/2.7/site-packages/pandas/core/generic.py", line 1534, in to_sql
    chunksize=chunksize, dtype=dtype)
4

1 回答 1

0

您需要指定要使用的 SQL 驱动程序，对于 MS-SQL，这将是本机驱动程序SQL Server Native Client 11.0

因此，例如，您可以使用以下内容：

cxn_string = 'mssql+pyodbc://<Username>:<password>@<DBServername>/<DBName>?driver=SQL+Server+Native+Client+11.0'
engine = sqlalchemy.create_engine(cxn_string, pool_pre_ping=True)

但这有点长，而且难以阅读，所以我通常会做一个辅助函数，像这样

import sqlalchemy
import urllib

def sql_connect(server, username, password, database, **kwargs):
'''Connect to SQL server'''
parameters = {'driver': 'SQL Server Native Client 11.0'}

string = r'mssql+pyodbc://{username}:{password}@{server}/{database}?{parameters}'
cxn_string = string.format(server=server,
                           username=username,
                           password=password,
                           database=database,
                           parameters=urllib.parse.urlencode(parameters))
return sqlalchemy.create_engine(cxn_string, **kwargs)
于 2018-05-05T08:42:42.173 回答