Pandas sql

From UVOO Tech Wiki
Revision as of 23:47, 7 September 2023 by Busk (talk | contribs) (Created page with "# Prep for sqlite3 ``` import pandas as pd import sqlite3 def write_sql_from_dfs(): for table, df in dfs.items(): # loop through `dict` of dataframes uuids = [] for...")
(diff) ← Older revision | Latest revision (diff) | Newer revision → (diff)
Jump to navigation Jump to search

Prep for sqlite3

import pandas as pd
import sqlite3
def write_sql_from_dfs():
  for table, df in dfs.items():  # loop through `dict` of dataframes
    uuids = []
    for i in range(len(df.index)):
      uuids.append(uuid.uuid4())
    df.insert(0, "uuid", uuids)
    df['timestamp'] = pd.Timestamp("now")
    # df['timestamp'] = [pd.Timestamp("now") for _ in range(len(df.index))]
    for i in df.columns:
      for i in df.columns:  df[i] =  df[i].astype("string")
    df.to_sql(name=table, con=cnx, if_exists='append', index=False)

def main():
  global cnx
  cnx = sqlite3.connect(f"mydb.sqlite3")
  write_sql_from_dfs()

if __name__ == "__main__":
  main()