@@ -2867,12 +2867,14 @@ def to_sql(
2867
2867
>>> with engine.begin() as connection:
2868
2868
... df1 = pd.DataFrame({'name' : ['User 4', 'User 5']})
2869
2869
... df1.to_sql('users', con=connection, if_exists='append')
2870
+ 2
2870
2871
2871
2872
This is allowed to support operations that require that the same
2872
2873
DBAPI connection is used for the entire operation.
2873
2874
2874
2875
>>> df2 = pd.DataFrame({'name' : ['User 6', 'User 7']})
2875
2876
>>> df2.to_sql('users', con=engine, if_exists='append')
2877
+ 2
2876
2878
>>> engine.execute("SELECT * FROM users").fetchall()
2877
2879
[(0, 'User 1'), (1, 'User 2'), (2, 'User 3'),
2878
2880
(0, 'User 4'), (1, 'User 5'), (0, 'User 6'),
@@ -2882,6 +2884,7 @@ def to_sql(
2882
2884
2883
2885
>>> df2.to_sql('users', con=engine, if_exists='replace',
2884
2886
... index_label='id')
2887
+ >>> with engine.begin() as connection:
2885
2888
>>> engine.execute("SELECT * FROM users").fetchall()
2886
2889
[(0, 'User 6'), (1, 'User 7')]
2887
2890
@@ -2900,6 +2903,7 @@ def to_sql(
2900
2903
>>> from sqlalchemy.types import Integer
2901
2904
>>> df.to_sql('integers', con=engine, index=False,
2902
2905
... dtype={"A": Integer()})
2906
+ 2
2903
2907
2904
2908
>>> engine.execute("SELECT * FROM integers").fetchall()
2905
2909
[(1,), (None,), (2,)]
0 commit comments