Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import sys
- import urllib
- import pandas as pd
- import pyodbc
- import sqlalchemy as sa
- print(sys.version)
- # 3.7.8 (tags/v3.7.8:4b47a5b6ba, Jun 28 2020, 08:53:46) [MSC v.1916 64 bit (AMD64)]
- print(
- f"SQLAlchemy {sa.__version__}, pandas {pd.__version__}, pyodbc {pyodbc.version}"
- )
- # SQLAlchemy 1.4.9, pandas 1.2.4, pyodbc 4.0.30
- connection_string = (
- r"DRIVER=MySQL ODBC 8.0 ANSI Driver;"
- r"SERVER=localhost;"
- r"PORT=3307;"
- r"DATABASE=myDb;"
- r"UID=scott;"
- r"PWD=tiger;"
- r"charset=utf8;"
- )
- connection_uri = "mysql+pyodbc:///?odbc_connect=" + urllib.parse.quote_plus(
- connection_string
- )
- engine = sa.create_engine(
- connection_uri,
- echo=True,
- )
- # --------------------------------------------
- # https://stackoverflow.com/q/67159916/2144390
- # --------------------------------------------
- num_rows = 2000
- df = pd.DataFrame(
- [(i, f"foo{i:04d}") for i in range(num_rows)],
- columns=["id", "txt"],
- )
- df.to_sql(
- "so67159916", engine, index=False, if_exists="replace", chunksize=1000
- )
Advertisement
Add Comment
Please, Sign In to add comment