Guest User

Untitled

a guest
Apr 19th, 2021
104
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 1.05 KB | None | 0 0
  1. import sys
  2. import urllib
  3.  
  4. import pandas as pd
  5. import pyodbc
  6. import sqlalchemy as sa
  7.  
  8. print(sys.version)
  9. # 3.7.8 (tags/v3.7.8:4b47a5b6ba, Jun 28 2020, 08:53:46) [MSC v.1916 64 bit (AMD64)]
  10. print(
  11.     f"SQLAlchemy {sa.__version__}, pandas {pd.__version__}, pyodbc {pyodbc.version}"
  12. )
  13. # SQLAlchemy 1.4.9, pandas 1.2.4, pyodbc 4.0.30
  14.  
  15. connection_string = (
  16.     r"DRIVER=MySQL ODBC 8.0 ANSI Driver;"
  17.     r"SERVER=localhost;"
  18.     r"PORT=3307;"
  19.     r"DATABASE=myDb;"
  20.     r"UID=scott;"
  21.     r"PWD=tiger;"
  22.     r"charset=utf8;"
  23. )
  24. connection_uri = "mysql+pyodbc:///?odbc_connect=" + urllib.parse.quote_plus(
  25.     connection_string
  26. )
  27.  
  28. engine = sa.create_engine(
  29.     connection_uri,
  30.     echo=True,
  31. )
  32.  
  33. # --------------------------------------------
  34. # https://stackoverflow.com/q/67159916/2144390
  35. # --------------------------------------------
  36.  
  37. num_rows = 2000
  38. df = pd.DataFrame(
  39.     [(i, f"foo{i:04d}") for i in range(num_rows)],
  40.     columns=["id", "txt"],
  41. )
  42. df.to_sql(
  43.     "so67159916", engine, index=False, if_exists="replace", chunksize=1000
  44. )
  45.  
Advertisement
Add Comment
Please, Sign In to add comment