Skip to content

Instantly share code, notes, and snippets.

@mkhorasani
Last active October 31, 2020 12:23
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save mkhorasani/ccc18865cf3b3631181038f08134d0b4 to your computer and use it in GitHub Desktop.
Save mkhorasani/ccc18865cf3b3631181038f08134d0b4 to your computer and use it in GitHub Desktop.
def write_state(column,value,engine,session_id):
engine.execute("UPDATE %s SET %s='%s'" % (session_id,column,value))
def write_state_df(df,engine,session_id):
df.to_sql('%s' % (session_id),engine,index=False,if_exists='replace',chunksize=1000)
def read_state(column,engine,session_id):
state_var = engine.execute("SELECT %s FROM %s" % (column,session_id))
state_var = state_var.first()[0]
return state_var
def read_state_df(engine,session_id):
try:
df = pd.read_sql_table(session_id,con=engine)
except:
df = pd.DataFrame([])
return df
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment