Guest User

Untitled

a guest
Dec 10th, 2018
79
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.74 KB | None | 0 0
  1. import sqlalchemy
  2. import pandas as pd
  3. from functools import partial
  4.  
  5. class dataBase:
  6. def __init__(self, connection_string):
  7. self.engine = sqlalchemy.create_engine(connection_string)
  8. self.read_sql = partial(pd.read_sql, con = self.engine)
  9. self.read_sql_table = partial(pd.read_sql_table, con = self.engine)
  10. self.read_sql_query = partial(pd.read_sql_query, con = self.engine)
  11.  
  12. db = dataBase('blah blah connection string')
  13. df = db.read_sql_table('tablename') # note I don't need to specify con = engine
  14. df.to_sql(con = ?) # could use con = db.engine, but I'd prefer
  15. # to specify that in the dataBase class somewhere
  16.  
  17. pd.DataFrame.to_sql = partial(pd.DataFrame.to_sql, con = my_engine)
Add Comment
Please, Sign In to add comment