擅长:python、mysql、java
<p>你可以试试</p>
<pre><code>connection_string = r'mssql+pyodbc:///?odbc_connect={}'.format(dbString).strip()
engine = sqlalchemy.create_engine(connection_string, echo=False, pool_recycle=3600)
with engine.connect() as connection:
df.to_sql(name=tablename, con=connection, if_exists='append', index=False)
</code></pre>
<p>这种方法使用<code>ContextManager</code>。引擎的<code>ContextManager</code>返回一个连接,并自动调用该连接上的<code>connection.close()</code>,<a href="https://docs.sqlalchemy.org/en/14/core/connections.html" rel="nofollow noreferrer">see</a>。阅读有关<code>ContextManager</code>{a2}的更多信息。要知道的另一件有用的事情是,连接也是一个<code>ContextManager</code>,为您处理事务。这意味着它开始和结束一个事务,如果出现错误,它会自动调用回滚</p>