Difference between revisions of "Pandas sql"
Jump to navigation
Jump to search
(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...") |
(No difference)
|
Latest revision as of 23:47, 7 September 2023
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()